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