Versions in this module Expand all Collapse all v0 v0.3.5 Jul 6, 2020 Changes in this version + type Checkpoint struct + func New(appName, tableName string, opts ...Option) (*Checkpoint, error) + func (c *Checkpoint) GetCheckpoint(streamName, shardID string) (string, error) + func (c *Checkpoint) SetCheckpoint(streamName, shardID, sequenceNumber string) error + func (c *Checkpoint) Shutdown() error + type DefaultRetryer struct + func (r *DefaultRetryer) ShouldRetry(err error) bool + type Option func(*Checkpoint) + func WithDynamoClient(svc dynamodbiface.DynamoDBAPI) Option + func WithMaxInterval(maxInterval time.Duration) Option + func WithRetryer(r Retryer) Option + type Retryer interface + ShouldRetry func(error) bool
Go to main page