jobs

Documentation

Index

• Constants
• type Job
• type JobStore
  • func NewJobStore(config config.Server, dbDir string) *JobStore
  • func (js *JobStore) DeleteJob(job Job) error
  • func (js *JobStore) GetJob(jobID string) (Job, error)
  • func (js *JobStore) Iterate(fn func(job Job))
  • func (js *JobStore) SaveJob(job Job) error
  • func (js *JobStore) WithChain(chain chain.Type) *JobStore
• type Status

Constants

const (
	New Status = iota
	InProgress
	Completed
	Failed

	Max_Retry_Count int = 3
)

Types

type Job

type Job interface {
	DoMyJob(ctx interface{})
	IsDone() bool
	IsFailed() bool
	GetType() string
	GetJobID() string
}

type JobStore

type JobStore struct {
	storage.SessionedStorage
	// contains filtered or unexported fields
}

func NewJobStore

func NewJobStore(config config.Server, dbDir string) *JobStore

func (*JobStore) DeleteJob

func (js *JobStore) DeleteJob(job Job) error

func (*JobStore) GetJob

func (js *JobStore) GetJob(jobID string) (Job, error)

func (*JobStore) Iterate

func (js *JobStore) Iterate(fn func(job Job))

func (*JobStore) SaveJob

func (js *JobStore) SaveJob(job Job) error

func (*JobStore) WithChain

func (js *JobStore) WithChain(chain chain.Type) *JobStore

type Status

type Status int