Versions in this module Expand all Collapse all v1 v1.0.2 May 30, 2025 Changes in this version + type BaseMetaData struct + IsCommand bool + MainCommand string + TraceID string + type Operator interface + PostRun func(context.Context, *T, *K) error + PreRun func(context.Context, *T, *K) error + Run func(context.Context, *T, *K) error + type OperatorBase struct + func (op *OperatorBase[T, K]) PostRun(context.Context, *T, *K) error + func (op *OperatorBase[T, K]) PreRun(context.Context, *T, *K) error + func (op *OperatorBase[T, K]) Run(context.Context, *T, *K) error + type ProcDeferFunc func(context.Context, *T, *K) + type ProcPanicFunc func(context.Context, K, *T) + type Processor struct + func (p *Processor[T, K]) AddParallelStages(stage Operator[T, K]) *Processor[T, K] + func (p *Processor[T, K]) AddStages(stage Operator[T, K]) *Processor[T, K] + func (p *Processor[T, K]) Clean() *Processor[T, K] + func (p *Processor[T, K]) Defer() + func (p *Processor[T, K]) OnPanic(fn ProcPanicFunc[T, error]) *Processor[T, K] + func (p *Processor[T, K]) Run() + func (p *Processor[T, K]) RunParallelStages() error + func (p *Processor[T, K]) RunStages() (err error) + func (p *Processor[T, K]) WithCtx(ctx context.Context) *Processor[T, K] + func (p *Processor[T, K]) WithDefer(fns ...ProcDeferFunc[T, K]) *Processor[T, K] + func (p *Processor[T, K]) WithEvent(event *T) *Processor[T, K]
Go to main page