tasks

Documentation

Index

• type Effector
  • func Retry(effector Effector, retries int, delay time.Duration) Effector
• type Task
  • func NewTask(name string, action TaskAction) Task
• type TaskAction
• type TaskRunner
  • func NewTaskRunner() TaskRunner
• type TaskType

Types

type Effector

type Effector func(context.Context, Task) error

func Retry

func Retry(effector Effector, retries int, delay time.Duration) Effector

type Task

type Task interface {
	Name() string
	Run(ctx context.Context) error
}

Runnable task

func NewTask

func NewTask(name string, action TaskAction) Task

type TaskAction

type TaskAction func(ctx context.Context) error

type TaskRunner

type TaskRunner interface {
	Add(task Task)
	Start() error
}

func NewTaskRunner

func NewTaskRunner() TaskRunner

type TaskType

type TaskType string

const (
	RunnableTask TaskType = "FireAndForgetTask"
)