Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2026 Changes in this version + type Decoder func([]byte) (T, error) + func JSONDecoder[T any]() Decoder[T] + type Handler = func(context.Context, events.KinesisEvent) (events.KinesisEventResponse, 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(raw []byte, sequenceNumber, partitionKey string, 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