tasks

type ConcurrentTask ¶

type ConcurrentTask struct {
	// contains filtered or unexported fields
}

ConcurrentTask represent a set of tasks that are executed concurrently using an errgroup.Group. Externally it act as a Task, and as such, can be included on a workflow or wrapped on a retry. Keep in mmind in the latter case that, given the nature of errgroup.Group, on failure the whole task set will be retried, including tasks that potentially have already finished.

func NewConcurrentTask(name string, tasks ...Task) *ConcurrentTask

func (c *ConcurrentTask) Name() string

func (c *ConcurrentTask) Run() error

func (c *ConcurrentTask) String() string

type DockerTaskConfig ¶

type DockerTaskConfig struct {
	Volumes          []string
	Env              []string
	WorkingDirectory string
	Image            string
	Args             []string
}

type ExecTask ¶

type ExecTask struct {
	Args []string
	// contains filtered or unexported fields
}

ExecTask is a task backed by os/exec.

func NewDockerTask(name string, config DockerTaskConfig) ExecTask

func NewExecTask(name string, args []string) ExecTask

func (t ExecTask) Name() string

func (t ExecTask) Run() error

func (t ExecTask) String() string

type RetryTask ¶

type RetryTask struct {
	BackOff backoff.BackOff
	Task    Task
}

RetryTask is a task to retry wrapped tasks.

func NewRetryTask(backOff backoff.BackOff, task Task) RetryTask

func (t RetryTask) Name() string

func (t RetryTask) Run() error

func (t RetryTask) String() string

type Task ¶

type Task interface {
	Name() string
	Run() error

	fmt.Stringer
}

Task represents a piece of work to perform.