shard_watcher

type RunInput struct {
	Context           context.Context
	ContextCancelFunc context.CancelFunc

	InputTableName       string
	OperationDescription string

	Client *dynamodbstreams.DynamoDBStreams
}

type Watcher struct {
	*RunInput

	ShardProcessor func(*shard_tree.Shard) error
	StreamARN      string
	// contains filtered or unexported fields
}