workflow

README

go-workflow

Simple control flow library to setup a series of steps to execute.

Example

w := workflow.New()
w.OnFailure = workflow.InteractiveFailure
steps := []*workflow.Step{
	&workflow.Step{
		Label: "one",
		Run:   stepOne,
	},
	&workflow.Step{
		Label: "two",
		Run:   stepTwo,
		},
	}
}
w.AddSteps(steps)
w.Run()

Documentation

Index

• Variables
• func InteractiveFailure(err error, step *Step, context Context) error
• type Context
• type FailureFunc
  • func RetryFailure(tries int) FailureFunc
• type Step
• type StepFunc
• type Workflow
  • func New() *Workflow
  • func (w *Workflow) Run() error

Variables

var (
	InputFile io.Reader = os.Stdin
)

Functions

func InteractiveFailure

func InteractiveFailure(err error, step *Step, context Context) error

Types

type Context

type Context interface{}

type FailureFunc

type FailureFunc func(err error, step *Step, context Context) error

func RetryFailure

func RetryFailure(tries int) FailureFunc

type Step

type Step struct {
	Label     string
	Run       StepFunc
	DependsOn []*Step
}

type StepFunc

type StepFunc func(context Context) error

type Workflow

type Workflow struct {
	Start     *Step
	OnFailure FailureFunc
	Context   Context
	// contains filtered or unexported fields
}

func New

func New() *Workflow

func (*Workflow) Run

func (w *Workflow) Run() error