Versions in this module Expand all Collapse all v1 v1.1.1 Dec 9, 2020 Changes in this version type Worker + func (w *Worker) Publish(streamName, partitionKey string, data []byte) error + func (w *Worker) WithKinesis(svc kinesisiface.KinesisAPI) *Worker v1.1.0 Dec 9, 2020 Changes in this version + func NewRecordProcessorCheckpoint(shard *par.ShardStatus, checkpoint chk.Checkpointer) kcl.IRecordProcessorCheckpointer + type PreparedCheckpointer struct + func (pc *PreparedCheckpointer) Checkpoint() error + func (pc *PreparedCheckpointer) GetPendingCheckpoint() *kcl.ExtendedSequenceNumber + type RecordProcessorCheckpointer struct + func (rc *RecordProcessorCheckpointer) Checkpoint(sequenceNumber *string) error + func (rc *RecordProcessorCheckpointer) PrepareCheckpoint(sequenceNumber *string) (kcl.IPreparedCheckpointer, error) + type ShardConsumer struct + type ShardConsumerState int + const ErrCodeKMSThrottlingException + const INITIALIZING + const PROCESSING + const SHUTDOWN_COMPLETE + const SHUTDOWN_REQUESTED + const SHUTTING_DOWN + const WAITING_ON_PARENT_SHARDS + type Worker struct + func NewWorker(factory kcl.IRecordProcessorFactory, ...) *Worker + func (w *Worker) Shutdown() + func (w *Worker) Start() error + func (w *Worker) WithCheckpointer(checker chk.Checkpointer) *Worker + func (w *Worker) WithDynamoDBStreams(svc dynamodbstreamsiface.DynamoDBStreamsAPI) *Worker
Go to main page