chain

May 20, 2026

Changes in this version

type Action

+ func AsBestEffortAction[T any](action Action[T], fallback BestEffortFallbackFunc[T]) Action[T]

+ type BestEffortFallbackFunc func(ctx context.Context, input T, err error)

type BranchAction

+ func AsBranchAction[T any](baseAction Action[T], branchFunc BranchFunc[T], directions ...string) BranchAction[T]

Sep 15, 2025

Changes in this version

+ const Failure

+ type RunPlan map[string]Action[T]

Sep 1, 2025

Changes in this version

type Action

+ func SkipRollback[T any]() Action[T]

Aug 31, 2025

Changes in this version

type Action

+ func AdaptAction[T any, U any](action Action[U], getter InternalTypeGetter[T, U], ...) Action[T]

+ func AsParallelMapAction[K comparable, T any](name string, action Action[T]) Action[map[K]T]

+ func AsParallelSliceAction[T any](name string, action Action[T]) Action[[]T]

+ func AsRetryableAction[T any](name string, mainAction, rollbackAction Action[T], maxRetry int) Action[T]

+ func AsSequenceMapAction[K comparable, T any](name string, action Action[T]) Action[map[K]T]

+ func AsSequenceSliceAction[T any](name string, action Action[T], stopOnError bool) Action[[]T]

+ func NewInternalValueAction[T any, U any](action Action[U], getter InternalValueGetter[T, U], ...) Action[T]

+ type ExternalTypeSetter func(T, U) T

+ type InternalTypeGetter func(T) U

Aug 24, 2025

Changes in this version

type Action

+ func NewParallelMapAction[K comparable, T any](name string, action Action[T]) Action[map[K]T]

+ func NewParallelSliceAction[T any](name string, action Action[T]) Action[[]T]

+ func NewSequenceMapAction[K comparable, T any](name string, action Action[T]) Action[map[K]T]

+ func NewSequenceSliceAction[T any](name string, action Action[T], stopOnError bool) Action[[]T]

+ func NewTypeAdapterAction[T any, U any](action Action[U], getter InternalValueGetter[T, U], ...) Action[T]

+ type InternalValueGetter func(T) U

+ type InternalValueSetter func(T, U) T

+ type Workflow struct

+ func NewWorkflow[T any](name string, memberActions ...Action[T]) *Workflow[T]

+ func (w *Workflow[T]) Name() string

+ func (w *Workflow[T]) Run(ctx context.Context, input T) (output T, err error)

+ func (w *Workflow[T]) RunAt(initAction Action[T], ctx context.Context, input T) (output T, lastErr error)

+ func (w *Workflow[T]) SetRunPlan(currentAction Action[T], plan ActionPlan[T])

+ func (w *Workflow[T]) ValidateGraph() error

Aug 3, 2025

Changes in this version

type Action

+ func NewParallelMapPipeline[K comparable, T any](name string, action Action[T]) Action[map[K]T]

+ func NewParallelSlicePipeline[T any](name string, action Action[T]) Action[[]T]

+ func NewSequenceMapPipeline[K comparable, T any](name string, action Action[T]) Action[map[K]T]

+ func NewSequenceSlicePipeline[T any](name string, action Action[T], stopOnError bool) Action[[]T]

Nov 26, 2024

Changes in this version

+ const Abort

+ const Error

+ const Success

+ type Action interface

+ Name func() string

+ Run func(ctx context.Context, input T) (output T, err error)

+ func NewAggregateAction[T any, U any](action Action[U], getter AggregateGetter[T, U], setter AggregateSetter[T, U]) Action[T]

+ func NewSimpleAction[T any](name string, runFunc RunFunc[T]) Action[T]

+ func Terminate[T any]() Action[T]

+ type ActionPlan map[string]Action[T]

+ func DefaultPlanWithAbort[T any](success, error, abort Action[T]) ActionPlan[T]

+ func DefaultPlan[T any](success, error Action[T]) ActionPlan[T]

+ func SuccessOnlyPlan[T any](success Action[T]) ActionPlan[T]

+ func TerminationPlan[T any]() ActionPlan[T]

+ type AggregateGetter func(T) U

+ type AggregateSetter func(T, U) T

+ type BranchAction interface

+ Directions func() []string

+ Name func() string

+ NextDirection func(ctx context.Context, output T) (direction string, err error)

+ Run func(ctx context.Context, input T) (output T, err error)

+ func NewSimpleBranchAction[T any](name string, runFunc RunFunc[T], directions []string, branchFunc BranchFunc[T]) BranchAction[T]

+ type BranchFunc func(ctx context.Context, output T) (direction string, err error)

+ type Pipeline struct

+ func NewPipeline[T any](name string, memberActions ...Action[T]) *Pipeline[T]

+ func (p *Pipeline[T]) Name() string

+ func (p *Pipeline[T]) Run(ctx context.Context, input T) (output T, err error)

+ func (p *Pipeline[T]) RunAt(initAction Action[T], ctx context.Context, input T) (output T, lastErr error)

+ func (p *Pipeline[T]) SetRunPlan(currentAction Action[T], plan ActionPlan[T])

+ func (p *Pipeline[T]) ValidateGraph() error

+ type RunFunc func(ctx context.Context, input T) (output T, err error)