chain

package module

Go to main page

Versions in this module

v1

v1.2.2

Sep 15, 2025

Changes in this version

+ const Failure

+ type RunPlan map[string]Action[T]

v1.2.1

Sep 1, 2025

Changes in this version

type Action

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

v1.2.0

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

v1.1.1

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

v1.1.0

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]

v1.0.0

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL