Versions in this module Expand all Collapse all v0 v0.3.7 Feb 25, 2021 v0.3.6 Feb 25, 2021 Changes in this version + type Checkpoint struct + func New(appName, tableName, connectionStr string, opts ...Option) (*Checkpoint, error) + func (c *Checkpoint) GetCheckpoint(streamName, shardID string) (string, error) + func (c *Checkpoint) GetMaxInterval() time.Duration + func (c *Checkpoint) SetCheckpoint(streamName, shardID, sequenceNumber string) error + func (c *Checkpoint) Shutdown() error + type Option func(*Checkpoint) + func WithMaxInterval(maxInterval time.Duration) Option