jobs

Documentation

Overview

Package jobs implements persistence of the job definition. For the time being, only BoltDB persistence is implemented.

Index

• func Migrate(f, t dao.DAO, dryRun bool, status chan dao.MigratorStatus) (map[string]int, error)
• func NewDAO(ctx context.Context, o dao.DAO) (dao.DAO, error)
• type BoltStore
  • func NewBoltStore(dao boltdb.DAO) (*BoltStore, error)
  • func (s *BoltStore) DeleteJob(jobID string) error
  • func (s *BoltStore) DeleteTasks(jobId string, taskId []string) error
  • func (s *BoltStore) GetJob(jobId string, withTasks jobs.TaskStatus) (*jobs.Job, error)
  • func (s *BoltStore) ListJobs(owner string, eventsOnly bool, timersOnly bool, withTasks jobs.TaskStatus, ...) (chan *jobs.Job, chan bool, error)
  • func (s *BoltStore) ListTasks(jobId string, taskStatus jobs.TaskStatus, cursor ...int32) (chan *jobs.Task, chan bool, error)
  • func (s *BoltStore) PutJob(job *jobs.Job) error
  • func (s *BoltStore) PutTask(task *jobs.Task) error
  • func (s *BoltStore) PutTasks(tasks map[string]map[string]*jobs.Task) error
• type DAO

Functions

func Migrate

func Migrate(f, t dao.DAO, dryRun bool, status chan dao.MigratorStatus) (map[string]int, error)

func NewDAO

func NewDAO(ctx context.Context, o dao.DAO) (dao.DAO, error)

Types

type BoltStore

type BoltStore struct {
	boltdb.DAO
}

func NewBoltStore

func NewBoltStore(dao boltdb.DAO) (*BoltStore, error)

func (*BoltStore) DeleteJob

func (s *BoltStore) DeleteJob(jobID string) error

func (*BoltStore) DeleteTasks

func (s *BoltStore) DeleteTasks(jobId string, taskId []string) error

func (*BoltStore) GetJob

func (s *BoltStore) GetJob(jobId string, withTasks jobs.TaskStatus) (*jobs.Job, error)

func (*BoltStore) ListJobs

func (s *BoltStore) ListJobs(owner string, eventsOnly bool, timersOnly bool, withTasks jobs.TaskStatus, jobIDs []string, taskCursor ...int32) (chan *jobs.Job, chan bool, error)

func (*BoltStore) ListTasks

func (s *BoltStore) ListTasks(jobId string, taskStatus jobs.TaskStatus, cursor ...int32) (chan *jobs.Task, chan bool, error)

func (*BoltStore) PutJob

func (s *BoltStore) PutJob(job *jobs.Job) error

func (*BoltStore) PutTask

func (s *BoltStore) PutTask(task *jobs.Task) error

func (*BoltStore) PutTasks

func (s *BoltStore) PutTasks(tasks map[string]map[string]*jobs.Task) error

PutTasks batch updates DB with tasks organized by JobID and TaskID

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, chan bool, 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
}

DAO provides method interface to access the store for scheduler job and task definitions.