asyncjob

Documentation

Index

• Variables
• func Compose(isParallel bool, logger logger.Logger, jobs ...Job) *asyncGroup
• func NewAsyncJob(name string, logger logger.Logger, handler func(ctx context.Context) error) *asyncJob
• type Job
• type State

Variables

var ErrTaskFailed = errors.New("job has failed after many retries")

Functions

func Compose

func Compose(isParallel bool, logger logger.Logger, jobs ...Job) *asyncGroup

func NewAsyncJob

func NewAsyncJob(name string, logger logger.Logger, handler func(ctx context.Context) error) *asyncJob

Types

type Job

type Job interface {
	Execute(ctx context.Context) error
	Retry(ctx context.Context) error
	Cancel()
	SetRetryDurations(retryDurations []time.Duration)
}

type State

type State int

const (
	Init State = iota
	Doing
	Retrying
	Failed
	Completed
)