Versions in this module Expand all Collapse all v1 v1.5.3 Dec 16, 2021 v1.5.2 Dec 16, 2021 Changes in this version + const ClaimRequestKey + const ErrInvalidDynamoDBSchema + const ErrShardClaimed + const LeaseKeyKey + const LeaseOwnerKey + const LeaseTimeoutKey + const NumMaxRetries + const ParentShardIdKey + const SequenceNumberKey + const ShardEnd + var ErrSequenceIDNotFound = errors.New("SequenceIDNotFoundForShard") + var ErrShardNotAssigned = errors.New("AssignedToNotFoundForShard") + type Checkpointer interface + CheckpointSequence func(*par.ShardStatus) error + ClaimShard func(*par.ShardStatus, string) error + FetchCheckpoint func(*par.ShardStatus) error + GetLease func(*par.ShardStatus, string) error + Init func() error + ListActiveWorkers func(map[string]*par.ShardStatus) (map[string][]*par.ShardStatus, 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) ClaimShard(shard *par.ShardStatus, claimID string) 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) ListActiveWorkers(shardStatus map[string]*par.ShardStatus) (map[string][]*par.ShardStatus, error) + func (checkpointer *DynamoCheckpoint) RemoveLeaseInfo(shardID string) error + func (checkpointer *DynamoCheckpoint) RemoveLeaseOwner(shardID string) error + func (checkpointer *DynamoCheckpoint) WithDynamoDB(svc dynamodbiface.DynamoDBAPI) *DynamoCheckpoint + type ErrLeaseNotAcquired struct + func (e ErrLeaseNotAcquired) Error() string
Go to main page