package
0.3.6-alpha
Repository: https://github.com/lepek/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.