# Functions
NewCheckpointStore returns a new CheckpointStore instance.
NewConsistentSegmentStore returns a new ConsistentSegmentStore instance.
NewS3SegmentStore returns a new S3SegmentStore instance.
NewSQSSegmentEventSource returns a new SQSSegmentEventSource instance.
# Variables
DefaultEventsRetentionCheckInterval is the default interval when background expiration task is running.
DefaultS3KeyPrefix is the default prefix for stored segments.
DefaultS3TempKeyPrefix is the default prefix for temporary segments.
DefaultSegmentEventsChanSize is the default size of events buffered channel.
DefaultSQSEventsChanSize is the default size of events buffered channel.
DefaultSQSMessageMaxRetryCount is the default maximum number of retries for a failed message before it is dropped.
DefaultSQSMessageVisibilityTimeout is the default duration that the received messages are hidden from subsequent retrieve requests.
DefaultSQSReceiveMaxNumberOfMessages is the default maximum number of messages to return in each receive messages call.
DefaultSQSReceiveWaitTime is default duration for which the receive call waits for a message to arrive in the queue before returning.
# Structs
CheckpointStore represents the checkpoint store used by ingress controller.
CheckpointStoreConfig is the checkpoint store configuration.
ConsistentSegmentStore is the decorator that handles segment events to provide a consistent view of underlying store state.
ConsistentSegmentStoreConfig is the ConsistentSegmentStore configuration.
S3SegmentStore is the segment storage backed by AWS S3.
S3SegmentStoreConfig is the configuration for AWS S3 segment storage.
SQSSegmentEventSource is the worker for AWS S3 notification events sent to AWS SQS.
SQSSegmentEventSourceConfig is the configuration for AWS SQS segment event source.