forked from sourcegraph/sourcegraph-public-snapshot
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathresetters.go
More file actions
22 lines (19 loc) · 764 Bytes
/
resetters.go
File metadata and controls
22 lines (19 loc) · 764 Bytes
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
package uploads
import (
"time"
"github.com/sourcegraph/sourcegraph/internal/workerutil/dbworker"
)
// NewUploadResetter returns a background routine that periodically resets upload
// records that are marked as being processed but are no longer being processed
// by a worker.
func (s *Service) NewUploadResetter(interval time.Duration) *dbworker.Resetter {
return dbworker.NewResetter(s.logger, s.workerutilStore, dbworker.ResetterOptions{
Name: "precise_code_intel_upload_worker_resetter",
Interval: interval,
Metrics: dbworker.ResetterMetrics{
RecordResets: s.resetterMetrics.numUploadResets,
RecordResetFailures: s.resetterMetrics.numUploadResetFailures,
Errors: s.resetterMetrics.numUploadResetErrors,
},
})
}