package
0.3.16
Repository: https://github.com/alexgridx/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.
WithConnection overwrites the default sql.DB.
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.