Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2026 Changes in this version + func RunFanout[T any](ctx context.Context, src source.Source[T], pipes []Bound[T], ...) error + func Run[T any, V any](ctx context.Context, p *pipeline.Pipeline[T, V], opts ...RunOption) error + type Bound struct + func Bind[T any, V any](p *pipeline.Pipeline[T, V], opts ...RunOption) Bound[T] + func (b Bound[T]) Name() string + type FanoutOption func(*fanoutConfig) + func WithFanoutBuffer(n int) FanoutOption + type RunOption func(*runConfig) + func WithBatchTick(d time.Duration) RunOption + func WithBatchWindow(window time.Duration, maxBatch int) RunOption + func WithConcurrency(n int) RunOption + func WithDeadLetter(fn func(eventID string, err error)) RunOption + func WithDedup(d state.Deduper) RunOption + func WithKeyDebounce(window time.Duration, maxKeys int) RunOption + func WithMaxAttempts(n int) RunOption + func WithMetrics(r metrics.Recorder) RunOption + func WithRetryBackoff(base, max time.Duration) RunOption + func WithValueDebounce(window time.Duration, maxKeys int) RunOption
Go to main page