persist

Aug 9, 2023

Changes in this version

+ const EndOfStream

+ const StartOfStream

+ type Checkpoint struct

+ EnqueueTime time.Time

+ Offset string

+ SequenceNumber int64

+ func NewCheckpoint(offset string, sequence int64, enqueueTime time.Time) Checkpoint

+ func NewCheckpointFromEndOfStream() Checkpoint

+ func NewCheckpointFromStartOfStream() Checkpoint

+ type CheckpointPersister interface

+ Read func(namespace, name, consumerGroup, partitionID string) (Checkpoint, error)

+ Write func(namespace, name, consumerGroup, partitionID string, checkpoint Checkpoint) error

+ type FilePersister struct

+ func NewFilePersister(directory string) (*FilePersister, error)

+ func (fp *FilePersister) Read(namespace, name, consumerGroup, partitionID string) (Checkpoint, error)

+ func (fp *FilePersister) Write(namespace, name, consumerGroup, partitionID string, checkpoint Checkpoint) error

+ type MemoryPersister struct

+ func NewMemoryPersister() *MemoryPersister

+ func (p *MemoryPersister) Read(namespace, name, consumerGroup, partitionID string) (Checkpoint, error)

+ func (p *MemoryPersister) Write(namespace, name, consumerGroup, partitionID string, checkpoint Checkpoint) error