Versions in this module Expand all Collapse all v1 v1.1.1 Dec 9, 2020 v1.1.0 Dec 9, 2020 Changes in this version + const CHECKPOINT_SEQUENCE_NUMBER_KEY + const ErrInvalidDynamoDBSchema + const ErrLeaseNotAquired + const LEASE_KEY_KEY + const LEASE_OWNER_KEY + const LEASE_TIMEOUT_KEY + const NumMaxRetries + const PARENT_SHARD_ID_KEY + const SHARD_END + var ErrSequenceIDNotFound = errors.New("SequenceIDNotFoundForShard") + type Checkpointer interface + CheckpointSequence func(*par.ShardStatus) error + FetchCheckpoint func(*par.ShardStatus) error + GetLease func(*par.ShardStatus, string) error + Init func() error + RemoveLeaseInfo func(string) error + RemoveLeaseOwner func(string) error + type DynamoCheckpoint struct + LeaseDuration int + Retries int + TableName string + func NewDynamoCheckpoint(kclConfig *config.KinesisClientLibConfiguration) *DynamoCheckpoint + func (checkpointer *DynamoCheckpoint) CheckpointSequence(shard *par.ShardStatus) error + func (checkpointer *DynamoCheckpoint) FetchCheckpoint(shard *par.ShardStatus) error + func (checkpointer *DynamoCheckpoint) GetLease(shard *par.ShardStatus, newAssignTo string) error + func (checkpointer *DynamoCheckpoint) Init() error + func (checkpointer *DynamoCheckpoint) RemoveLeaseInfo(shardID string) error + func (checkpointer *DynamoCheckpoint) RemoveLeaseOwner(shardID string) error + func (checkpointer *DynamoCheckpoint) WithDynamoDB(svc dynamodbiface.DynamoDBAPI) *DynamoCheckpoint
Go to main page