package
0.0.0-20230218052111-a2042b57b1d3
Repository: https://github.com/kinde-engineering/kinesis-consumer.git
Documentation: pkg.go.dev

# Functions

New returns a checkpoint that uses PostgresDB for underlying storage Using connectionStr turn it more flexible to use specific db configs.
WithMaxInterval sets the flush interval.

# Structs

Checkpoint stores and retrieves the last evaluated key from a DDB scan.

# Type aliases

Option is used to override defaults when creating a new Checkpoint.