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 + func NewRecordProcessorCheckpoint(shard *par.ShardStatus, checkpoint chk.Checkpointer) kcl.IRecordProcessorCheckpointer + type FanOutShardConsumer struct + type PollingShardConsumer struct + 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 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) WithKinesis(svc kinesisiface.KinesisAPI) *Worker
Go to main page