Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2026 Changes in this version + var ErrSkipRecord = errors.New("dynamodbstreams: skip record") + type Decoder func(*events.DynamoDBEventRecord) (T, error) + type Handler = func(context.Context, events.DynamoDBEvent) (events.DynamoDBEventResponse, error) + func NewHandler[T any, V any](p *pipeline.Pipeline[T, V], decode Decoder[T], opts ...HandlerOption) (Handler, error) + type HandlerOption func(*handlerConfig) + func WithClock(now func() time.Time) HandlerOption + func WithDecodeErrorCallback(fn func(rec *events.DynamoDBEventRecord, err error)) HandlerOption + func WithDedup(d state.Deduper) HandlerOption + func WithMaxAttempts(n int) HandlerOption + func WithMetrics(r metrics.Recorder) HandlerOption + func WithRetryBackoff(base, max time.Duration) HandlerOption
Go to main page