Documentation ¶
Overview ¶
Package store
The memory store provides a store that can be used for testing and single-threaded applications. DO NOT USE this in a production application where persistence beyond a single application lifecycle is necessary or when there are multiple consumers.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Store ¶
Store is the in-memory data structure that holds the offsets per stream
func (*Store) GetCheckpoint ¶
GetCheckpoint determines if a checkpoint for a particular Shard exists. Typically, this is used to determine whether processing should start with TRIM_HORIZON or AFTER_SEQUENCE_NUMBER (if checkpoint exists).
func (*Store) SetCheckpoint ¶
SetCheckpoint stores a checkpoint for a shard (e.g. sequence number of last record processed by application).