Versions in this module Expand all Collapse all v1 v1.6.1 Jul 9, 2019 Changes in this version + type BoltStore struct + func NewBoltStore(fileName string) (*BoltStore, error) + func (b *BoltStore) Close() + 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 interface + DeleteJob func(jobId string) error + DeleteTasks func(jobId string, taskId []string) error + GetJob func(jobId string, withTasks jobs.TaskStatus) (*jobs.Job, error) + ListJobs func(owner string, eventsOnly bool, timersOnly bool, withTasks jobs.TaskStatus, ...) (chan *jobs.Job, chan bool, error) + ListTasks func(jobId string, taskStatus jobs.TaskStatus, cursor ...int32) (chan *jobs.Task, chan bool, error) + PutJob func(job *jobs.Job) error + PutTask func(task *jobs.Task) error + PutTasks func(task map[string]map[string]*jobs.Task) error Incompatible versions in this module v2.0.6+incompatible Apr 23, 2020