workflow

type Config struct {
	// ErrorHandler is handler called when a workflow experiences an error. The error may originate
	// from hook or from a task. The original error is alwasy returned from the workflow's Execute.
	// Optional. Defaults to a no-op handler.
	ErrorHandler ErrorHandler
}

type ErrDuplicateTaskName struct {
	Name TaskName
}

type ErrorHandler func(context.Context, error)

type HookBinder interface {
	// BindPreWorkflowHook binds a task to a workflow that is run _before_ a workflow is executed.
	BindPreWorkflowHook(Task)

	// BindPostWorkflowHook binds a task to a workflow that is run _after_ a workflow is executed.
	BindPostWorkflowHook(Task)

	// BindPreTaskHook binds task to be run _before_ the anchor task is executed.
	BindPreTaskHook(anchor TaskName, task Task)

	// BindPostTaskHook binds Task to be run _after_ the anchor task is executed.
	BindPostTaskHook(anchor TaskName, task Task)
}

type Task interface {
	// RunTask executes the task. Tasks may return a context that should be used in subsequent task
	// execution.
	RunTask(context.Context) (context.Context, error)
}

type TaskFunc func(context.Context) (context.Context, error)

type TaskName string

type Workflow struct {
	Config
	// contains filtered or unexported fields
}