workflow

Documentation

Index

• type WorkflowExecute
  • func NewWorkflowExecute(e ...execute.Executor) *WorkflowExecute
  • func (e *WorkflowExecute) AppendExecutor(executor execute.Executor) *WorkflowExecute
  • func (e *WorkflowExecute) Execute(ctx context.Context) error
  • func (e *WorkflowExecute) WithContinueOnError() *WorkflowExecute
  • func (e *WorkflowExecute) WithTrace() *WorkflowExecute

Types

type WorkflowExecute

type WorkflowExecute struct {
	// ExecutorList is a list of executors
	ExecutorList []execute.Executor
	// ContinueOnError is a flag to continue on error
	ContinueOnError bool
	// Trace is a flag to trace the execution
	Trace bool
}

func NewWorkflowExecute

func NewWorkflowExecute(e ...execute.Executor) *WorkflowExecute

NewWorkflowExecute creates a new WorkflowExecute

func (*WorkflowExecute) AppendExecutor

func (e *WorkflowExecute) AppendExecutor(executor execute.Executor) *WorkflowExecute

AppendExecutor appends an executor to the list

func (*WorkflowExecute) Execute

func (e *WorkflowExecute) Execute(ctx context.Context) error

Execute runs the executors

func (*WorkflowExecute) WithContinueOnError

func (e *WorkflowExecute) WithContinueOnError() *WorkflowExecute

WithContinueOnError sets the continue on error flag to true

func (*WorkflowExecute) WithTrace

func (e *WorkflowExecute) WithTrace() *WorkflowExecute

WithTrace sets the trace flag to true