BackendScheduler manages scheduling and execution of backend jobs
| 34 | |
| 35 | // BackendScheduler manages scheduling and execution of backend jobs |
| 36 | type BackendScheduler struct { |
| 37 | services.Service |
| 38 | |
| 39 | mtx sync.Mutex |
| 40 | |
| 41 | cfg Config |
| 42 | store storage.Store |
| 43 | overrides overrides.Interface |
| 44 | |
| 45 | work work.Interface |
| 46 | |
| 47 | reader backend.RawReader |
| 48 | writer backend.RawWriter |
| 49 | |
| 50 | providers []struct { |
| 51 | provider provider.Provider |
| 52 | jobs <-chan *work.Job |
| 53 | } |
| 54 | |
| 55 | mergedJobs chan *work.Job |
| 56 | } |
| 57 | |
| 58 | // ListJobs returns all jobs in the work cache |
| 59 | func (s *BackendScheduler) ListJobs() []*work.Job { |
nothing calls this directly
no outgoing calls
no test coverage detected