golang.org/x/pkgsite/internal/worker.Server.db (field)

26 uses

	golang.org/x/pkgsite/internal/worker (current package)
		pages.go#L50: 		excluded, err = s.db.GetExcludedPrefixes(ctx)
		pages.go#L137: 		next, err = s.db.GetNextModulesToFetch(ctx, pageSize)
		pages.go#L145: 		failures, err = s.db.GetRecentFailedVersions(ctx, pageSize)
		pages.go#L153: 		recents, err = s.db.GetRecentVersions(ctx, pageSize)
		pages.go#L161: 		stats, err = s.db.GetVersionStats(ctx)
		server.go#L49: 	db              *postgres.DB
		server.go#L98: 		db:              scfg.DB,
		server.go#L229: 	n, err := s.db.UpdateSearchDocumentsImportedByCount(r.Context())
		server.go#L255: 	sdargs, err := s.db.GetPackagesForSearchDocumentUpsert(ctx, before, limit)
		server.go#L261: 		if err := postgres.UpsertSearchDocument(ctx, s.db.Underlying(), args); err != nil {
		server.go#L306: 		DB:           s.db,
		server.go#L369: 	since, err := s.db.LatestIndexTimestamp(ctx)
		server.go#L377: 	if err := s.db.InsertIndexVersions(ctx, modules); err != nil {
		server.go#L386: 	ot, err := s.db.StalenessTimestamp(ctx)
		server.go#L411: 	modules, err := s.db.GetNextModulesToFetch(ctx, limit)
		server.go#L474: 	vm, err := s.db.GetVersionMap(r.Context(), stdlib.ModulePath, "master")
		server.go#L483: 	return s.db.DeletePseudoversionsExcept(r.Context(), stdlib.ModulePath, vm.ResolvedVersion)
		server.go#L523: 		if err := s.db.UpdateModuleVersionStatesForReprocessingLatestOnly(r.Context(), appVersion); err != nil {
		server.go#L537: 		if err := s.db.UpdateModuleVersionStatesWithStatus(r.Context(), code, appVersion); err != nil {
		server.go#L547: 		if err := s.db.UpdateModuleVersionStatesForReprocessingReleaseVersionsOnly(r.Context(), appVersion); err != nil {
		server.go#L555: 	if err := s.db.UpdateModuleVersionStatesForReprocessing(r.Context(), appVersion); err != nil {
		server.go#L579: 	if err := s.db.DeleteModule(r.Context(), modulePath, version); err != nil {
		server.go#L612: 		mvs, err := s.db.GetModuleVersionsToClean(ctx, cleanDays, parseLimitParam(r, 1000))
		server.go#L617: 		if err := s.db.CleanModuleVersions(ctx, mvs, "Bulk deleted via /clean endpoint"); err != nil {
		server.go#L625: 		if err := s.db.CleanModule(ctx, module, "Manually deleted via /clean endpoint"); err != nil {
		server.go#L634: 	if err := s.db.Underlying().Ping(); err != nil {