ddb

Apr 10, 2024

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 *dynamodb.Client) Option

+ func WithMaxInterval(maxInterval time.Duration) Option

+ func WithRetryer(r Retryer) Option

+ type Retryer interface

+ ShouldRetry func(error) bool