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 ShutdownReasonMessage(reason ShutdownReason) *string + type ExtendedSequenceNumber struct + SequenceNumber *string + SubSequenceNumber int64 + type IPreparedCheckpointer interface + Checkpoint func() error + GetPendingCheckpoint func() *ExtendedSequenceNumber + type IRecordProcessor interface + Initialize func(initializationInput *InitializationInput) + ProcessRecords func(processRecordsInput *ProcessRecordsInput) + Shutdown func(shutdownInput *ShutdownInput) + type IRecordProcessorCheckpointer interface + Checkpoint func(sequenceNumber *string) error + PrepareCheckpoint func(sequenceNumber *string) (IPreparedCheckpointer, error) + type IRecordProcessorFactory interface + CreateProcessor func() IRecordProcessor + type InitializationInput struct + ExtendedSequenceNumber *ExtendedSequenceNumber + ShardId string + type ProcessRecordsInput struct + CacheEntryTime *time.Time + CacheExitTime *time.Time + Checkpointer IRecordProcessorCheckpointer + MillisBehindLatest int64 + Records []*ks.Record + type ShutdownInput struct + Checkpointer IRecordProcessorCheckpointer + ShutdownReason ShutdownReason + type ShutdownReason int + const REQUESTED + const TERMINATE + const ZOMBIE
Go to main page