processes

Nov 22, 2023

Changes in this version

+ var ErrAborted = errors.Warning("processes: abort")

+ func IsAbortErr(err error) (ok bool)

+ type Process struct

+ func New() *Process

+ func (p *Process) Abort(timeout time.Duration) (err error)

+ func (p *Process) Add(name string, units ...Unit)

+ func (p *Process) Start(ctx context.Context) (results <-chan Result)

+ func (p *Process) Steps() (n int64)

+ func (p *Process) Units() (n int64)

+ type ProcessController interface

+ Abort func(timeout time.Duration) (err error)

+ Start func(ctx context.Context) (results <-chan Result)

+ Steps func() (n int64)

+ Units func() (n int64)

+ type Result struct

+ Data interface{}

+ Error error

+ StepName string

+ StepNo int64

+ StepNum int64

+ UnitNo int64

+ UnitNum int64

+ func (result Result) String() string

+ type Step struct

+ func (step *Step) Execute(ctx context.Context) (err error)

+ type Unit interface

+ Handle func(ctx context.Context) (result interface{}, err error)