postgres

Nov 8, 2018

Changes in this version

type Checkpoint

+ func (c *Checkpoint) GetMaxInterval() time.Duration

Jul 28, 2018

Changes in this version

+ type Checkpoint struct

+ func New(appName, tableName, connectionStr string, opts ...Option) (*Checkpoint, error)

+ func (c *Checkpoint) Get(streamName, shardID string) (string, error)

+ func (c *Checkpoint) Set(streamName, shardID, sequenceNumber string) error

+ func (c *Checkpoint) Shutdown() error

+ type Option func(*Checkpoint)

+ func WithMaxInterval(maxInterval time.Duration) Option