task

Documentation

Index

• type ExecutionOption
  • func OnFailure(task Task) ExecutionOption
  • func OnSuccess(task Task) ExecutionOption
  • func Parallel(tasks ...Task) ExecutionOption
  • func Sequential(tasks ...Task) ExecutionOption
  • func SequentialAll(tasks ...Task) ExecutionOption
  • func WithContext(ctx context.Context) ExecutionOption
• type MultiError
  • func (e MultiError) Error() string
• type Periodic
  • func (t *Periodic) Close() error
  • func (t *Periodic) Start() error
• type Task
  • func Close(v interface{}) Task
  • func Run(opts ...ExecutionOption) Task
  • func Single(task Task, opts ...ExecutionOption) Task

Types

type ExecutionOption

type ExecutionOption func(*executionContext)

func OnFailure

func OnFailure(task Task) ExecutionOption

func OnSuccess

func OnSuccess(task Task) ExecutionOption

func Parallel

func Parallel(tasks ...Task) ExecutionOption

func Sequential

func Sequential(tasks ...Task) ExecutionOption

Sequential runs all tasks sequentially, and returns the first error encountered.Sequential Once a task returns an error, the following tasks will not run.

func SequentialAll

func SequentialAll(tasks ...Task) ExecutionOption

func WithContext

func WithContext(ctx context.Context) ExecutionOption

type MultiError

type MultiError []error

func (MultiError) Error

func (e MultiError) Error() string

type Periodic

type Periodic struct {
	// Interval of the task being run
	Interval time.Duration
	// Execute is the task function
	Execute func() error
	// contains filtered or unexported fields
}

Periodic is a task that runs periodically.

func (*Periodic) Close

func (t *Periodic) Close() error

Close implements common.Closable.

func (*Periodic) Start

func (t *Periodic) Start() error

Start implements common.Runnable.

type Task

type Task func() error

func Close

func Close(v interface{}) Task

func Run

func Run(opts ...ExecutionOption) Task

func Single

func Single(task Task, opts ...ExecutionOption) Task