tasks

Documentation

Index

• func IsInvalidConfig(err error) bool
• func Run(ctx context.Context, tasks []Task) error
• type RetryTaskConfig
• type Task
  • func NewRetryTask(config RetryTaskConfig) (Task, error)

Functions

func IsInvalidConfig

func IsInvalidConfig(err error) bool

IsInvalidConfig asserts invalidConfigError.

func Run

func Run(ctx context.Context, tasks []Task) error

Types

type RetryTaskConfig

type RetryTaskConfig struct {
	Logger     micrologger.Logger
	Underlying Task
}

type Task

type Task func(ctx context.Context) error

Task represent a generic step in a pipeline.

func NewRetryTask

func NewRetryTask(config RetryTaskConfig) (Task, error)