package
1.0.0
Repository: https://github.com/vmware/vmware-go-kcl-v2.git
Documentation: pkg.go.dev

# Functions

No description provided by the author

# Constants

No description provided by the author
ErrShardClaimed is returned when shard is claimed.
No description provided by the author
No description provided by the author
No description provided by the author
NumMaxRetries is the max times of doing retry.
No description provided by the author
No description provided by the author
ShardEnd We've completely processed all records in this shard.

# Variables

ErrSequenceIDNotFound is returned by FetchCheckpoint when no SequenceID is found.
ErrShardNotAssigned is returned by ListActiveWorkers when no AssignedTo is found.
No description provided by the author

# Structs

DynamoCheckpoint implements the Checkpoint interface using DynamoDB as a backend.
No description provided by the author

# Interfaces

Checkpointer handles checkpointing when a record has been processed.
DynamoDBAPI provides an interface to enable mocking the dynamodb.DynamoDB service client's API operation, paginators, and waiters.