Documentation
¶
Overview ¶
Package jobs implements persistence of the job definition. For the time being, only BoltDB persistence is implemented.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type DAO ¶
type DAO interface {
dao.DAO
PutJob(job *jobs.Job) error
GetJob(jobId string, withTasks jobs.TaskStatus) (*jobs.Job, error)
DeleteJob(jobId string) error
ListJobs(owner string, eventsOnly bool, timersOnly bool, withTasks jobs.TaskStatus, jobIDs []string, taskCursor ...int32) (chan *jobs.Job, error)
PutTask(task *jobs.Task) error
PutTasks(task map[string]map[string]*jobs.Task) error
ListTasks(jobId string, taskStatus jobs.TaskStatus, cursor ...int32) (chan *jobs.Task, chan bool, error)
DeleteTasks(jobId string, taskId []string) error
FindOrphans() ([]*jobs.Task, error)
BuildOrphanLogsQuery(time.Duration, []string) string
}
DAO provides method interface to access the store for scheduler job and task definitions.
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package grpc provides a gRPC service to access the store for scheduler job definitions.
|
Package grpc provides a gRPC service to access the store for scheduler job definitions. |
|
Package rest provides a REST gateway to the job definition repository.
|
Package rest provides a REST gateway to the job definition repository. |
Click to show internal directories.
Click to hide internal directories.