processor

Nov 21, 2025

Changes in this version

type Transform

+ StopOnError bool

May 17, 2025

Changes in this version

+ type Channel struct

+ Output chan<- interface{}

+ func (p *Channel) Process(ctx context.Context, items []*batch.Item) ([]*batch.Item, error)

Apr 24, 2025

Changes in this version

type Error

+ FailFraction float64

+ type Filter struct

+ InvertMatch bool

+ Predicate FilterFunc

+ func (p *Filter) Process(_ context.Context, items []*batch.Item) ([]*batch.Item, error)

+ type FilterFunc func(item *batch.Item) bool

type Nil

+ MarkCancelled bool

+ type Transform struct

+ ContinueOnError bool

+ Func TransformFunc

+ func (p *Transform) Process(_ context.Context, items []*batch.Item) ([]*batch.Item, error)

+ type TransformFunc func(data interface{}) (interface{}, error)

Jan 29, 2021

Changes in this version

+ type Error struct

+ Err error

+ func (p *Error) Process(ctx context.Context, ps *batch.PipelineStage)

+ type Nil struct

+ Duration time.Duration

+ func (p *Nil) Process(ctx context.Context, ps *batch.PipelineStage)