pipeline

Aug 14, 2022

Changes in this version

+ type DependencyError struct

+ MissingSteps []string

+ func (d *DependencyError) Error() string

+ type DependencyRecorder struct

+ Records []Step[T]

+ func NewDependencyRecorder() *DependencyRecorder[T]

+ func (s *DependencyRecorder[T]) MustRequireDependencyByFuncName(actions ...ActionFunc[T])

+ func (s *DependencyRecorder[T]) MustRequireDependencyByStepName(stepNames ...string)

+ func (s *DependencyRecorder[T]) Record(step Step[T])

+ func (s *DependencyRecorder[T]) RequireDependencyByFuncName(actions ...ActionFunc[T]) error

+ func (s *DependencyRecorder[T]) RequireDependencyByStepName(stepNames ...string) error

+ type DependencyResolver interface

+ MustRequireDependencyByFuncName func(actions ...ActionFunc[T])

+ MustRequireDependencyByStepName func(stepNames ...string)

+ RequireDependencyByFuncName func(actions ...ActionFunc[T]) error

+ RequireDependencyByStepName func(stepNames ...string) error

+ type Recorder interface

+ Record func(step Step[T])

Aug 7, 2022

Changes in this version

+ func LoadFromContextOrDefault(ctx context.Context, key any, defValue any) any

+ type ErrorHandler func(ctx T, err error) error

+ type Options struct

+ DisableErrorWrapping bool

type Pipeline

+ func (p *Pipeline[T]) NewStep(name string, action ActionFunc[T]) Step[T]

+ func (p *Pipeline[T]) When(predicate Predicate[T], name string, action ActionFunc[T]) Step[T]

type Step

+ Action ActionFunc[T]

+ Condition Predicate[T]

+ Handler ErrorHandler[T]

+ func NewStepIf(predicate Predicate[T], name string, actionFunc ActionFunc[T]) Step[T]

+ func (s Step[T]) When(predicate Predicate[T]) Step[T]

Jul 4, 2022

Changes in this version

type Step

+ func IfOrElse(predicate Predicate, trueStep Step, falseStep Step) Step

May 3, 2022

Changes in this version

+ func MustLoadFromContext(ctx context.Context, key interface{}) interface

Apr 13, 2022

Changes in this version

+ func LoadFromContext(ctx context.Context, key interface{}) (interface{}, bool)

+ func MutableContext(parent context.Context) context.Context

+ func StoreInContext(ctx context.Context, key, value interface{})

Apr 12, 2022

Changes in this version

type Pipeline

+ func (p *Pipeline) AddStepFromFunc(name string, fn func(ctx context.Context) error) *Pipeline

Apr 12, 2022

Changes in this version

+ func AddToContext(ctx context.Context, key, value interface{})

+ func ValueFromContext(ctx context.Context, key interface{}) (interface{}, bool)

+ func VariableContext(parent context.Context) context.Context

type Pipeline

+ func NewAnonymous(funcs ...func(ctx context.Context) error) *Pipeline

Mar 22, 2022

Changes in this version

+ type ParallelResultHandler func(ctx context.Context, results map[uint64]Result) error

type Pipeline

+ func (p *Pipeline) RunWithContext(ctx context.Context) Result

type Predicate

+ func BoolPtr(v *bool) Predicate

+ func Or(p1, p2 Predicate) Predicate

type Result

+ IsAborted func() bool

+ IsCanceled func() bool

+ IsCompleted func() bool

type Step

+ func If(predicate Predicate, originalStep Step) Step

+ func NewFanOutStep(name string, pipelineSupplier Supplier, handler ParallelResultHandler) Step

+ func NewWorkerPoolStep(name string, size int, pipelineSupplier Supplier, ...) Step

+ func ToNestedStep(name string, predicate Predicate, p *Pipeline) Step

+ func ToStep(name string, action func(ctx context.Context) error, predicate Predicate) Step

+ type Supplier func(ctx context.Context, pipelinesChan chan *Pipeline)

+ func SupplierFromSlice(pipelines []*Pipeline) Supplier

Dec 27, 2021

Changes in this version

+ type Option func(pipeline *Pipeline)

+ var DisableErrorWrapping Option = func(pipeline *Pipeline) { ... }

type Pipeline

+ func (p *Pipeline) WithOptions(options ...Option) *Pipeline

Dec 20, 2021

Changes in this version

+ var ErrAbort = errors.New("abort")

Dec 20, 2021

Changes in this version

type Step

+ func (s Step) WithErrorHandler(errorHandler func(ctx Context, err error) error) Step

Sep 7, 2021

Changes in this version

type Pipeline

+ func (p *Pipeline) WithFinalizer(handler ResultHandler) *Pipeline

Aug 29, 2021

Changes in this version

+ type Listener interface

+ Accept func(step Step)

type Pipeline

+ func (p *Pipeline) AddBeforeHook(listener Listener) *Pipeline

+ func (p *Pipeline) WithBeforeHooks(listeners []Listener) *Pipeline

Aug 27, 2021

Changes in this version

+ type Context interface

+ BoolValue func(key interface{}, defaultValue bool) bool

+ IntValue func(key interface{}, defaultValue int) int

+ SetValue func(key interface{}, value interface{})

+ StringValue func(key interface{}, defaultValue string) string

+ Value func(key interface{}) interface{}

+ ValueOrDefault func(key interface{}, defaultValue interface{}) interface{}

+ type DefaultContext struct

+ func (ctx *DefaultContext) BoolValue(key interface{}, defaultValue bool) bool

+ func (ctx *DefaultContext) IntValue(key interface{}, defaultValue int) int

+ func (ctx *DefaultContext) SetValue(key interface{}, value interface{})

+ func (ctx *DefaultContext) StringValue(key interface{}, defaultValue string) string

+ func (ctx *DefaultContext) Value(key interface{}) interface{}

+ func (ctx *DefaultContext) ValueOrDefault(key interface{}, defaultValue interface{}) interface{}

type Pipeline

+ func NewPipelineWithContext(ctx Context) *Pipeline

+ func (p *Pipeline) WithContext(ctx Context) *Pipeline

type Step

+ func NewStepFromFunc(name string, fn func(ctx Context) error) Step

Jul 21, 2021

Changes in this version

type Pipeline

+ func (p *Pipeline) WithNestedSteps(name string, steps ...Step) Step

Jul 18, 2021

Changes in this version

type Result

+ Name string

+ type ResultHandler func(result Result) error

type Step

+ H ResultHandler

+ func (s Step) WithResultHandler(handler ResultHandler) Step

Jul 11, 2021

Changes in this version

type Result

+ func (r Result) IsFailed() bool

Jul 3, 2021

Changes in this version

+ type ActionFunc func() Result

+ func Abort() ActionFunc

+ type Handler func(result Result)

+ type Logger interface

+ Log func(message, name string)

+ type Pipeline struct

+ func NewPipeline() *Pipeline

+ func NewPipelineWithLogger(logger Logger) *Pipeline

+ func (p *Pipeline) AddStep(step Step) *Pipeline

+ func (p *Pipeline) AsNestedStep(name string, predicate Predicate) Step

+ func (p *Pipeline) Run() Result

+ func (p *Pipeline) WithAbortHandler(handler Handler) *Pipeline

+ func (p *Pipeline) WithSteps(steps ...Step) *Pipeline

+ type Predicate func(step Step) bool

+ func And(p1, p2 Predicate) Predicate

+ func Bool(v bool) Predicate

+ func False() Predicate

+ func Not(predicate Predicate) Predicate

+ func True() Predicate

+ type Result struct

+ Abort bool

+ Err error

+ func (r Result) IsSuccessful() bool

+ type Step struct

+ F ActionFunc

+ Name string

+ P Predicate

+ func NewIfElseStep(name string, predicate Predicate, trueAction, falseAction ActionFunc) Step

+ func NewStep(name string, action ActionFunc) Step

+ func NewStepWithPredicate(name string, action ActionFunc, predicate Predicate) Step