asyncjob

Documentation

Index

• func NewGroup(isConcurrent bool, jobs ...Job) *group
• func NewJob(handler JobHandler) *job
• func NewQueryJob(handler JobHandler) *job
• type Job
• type JobHandler
• type JobState
  • func (js JobState) String() string

Functions

func NewGroup

func NewGroup(isConcurrent bool, jobs ...Job) *group

func NewJob

func NewJob(handler JobHandler) *job

func NewQueryJob

func NewQueryJob(handler JobHandler) *job

Types

type Job

type Job interface {
	Execute(ctx context.Context) error
	Retry(ctx context.Context) error
	State() JobState
	SetRetryDurations(times []time.Duration)
}

type JobHandler

type JobHandler func(ctx context.Context) error

type JobState

type JobState int

const (
	StateInit JobState = iota
	StateRunning
	StateFailed
	StateTimeout
	StateCompleted
	StateRetryFailed
)

func (JobState) String

func (js JobState) String() string