jobs

package

v0.14.0 Latest Latest Go to latest Published: Apr 24, 2020 License: Apache-2.0 Imports: 6 Imported by: 0

Details

View Source

const (
	New Status = iota
	InProgress
	Completed
	Failed

	Max_Retry_Count int = 3
)

This section is empty.

This section is empty.

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

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

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 int