Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // CountRunning is count of running semaphore CountRunning atomic.Int64 // CountWaiting is count of waiting job CountWaiting atomic.Int64 // CountRecovered is count of recovered job per target CountRecovered = sync.Map{} )
View Source
var ( // DeletedJobMap is map for deleted jobs. key: runs_on, value: number of deleted jobs DeletedJobMap = sync.Map{} )
Functions ¶
This section is empty.
Types ¶
type Starter ¶
type Starter struct {
// contains filtered or unexported fields
}
Starter is dispatcher for running job
func New ¶
func New(ds datastore.Datastore, s safety.Safety, runnerVersion string, notifyEnqueueCh <-chan struct{}) *Starter
New create starter instance
Click to show internal directories.
Click to hide internal directories.