Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2026 Changes in this version + func Run[T any, V any](ctx context.Context, p *pipeline.Pipeline[T, V], src snapshot.Source[T], ...) (snapshot.HandoffToken, error) + type RunOption func(*runConfig) + func WithBatchTick(d time.Duration) RunOption + func WithDedup(d state.Deduper) RunOption + func WithFailOnError(v bool) RunOption + func WithMaxAttempts(n int) RunOption + func WithMetrics(r metrics.Recorder) RunOption + func WithRetryBackoff(base, max time.Duration) RunOption
Go to main page