NewBatch creates a new batch.

NewQueueStore - Creates an instance for QueueStore.

StreamItems reads the keys from the store and replays the corresponding item to the target.

ErrBatchFull indicates that the batch is full.

ErrNotConnected - indicates that the target connection is not active.

Batch represents an ordered batch.

Key denotes the key present in the store.

QueueStore - Filestore for persisting items.

Store - Used to persist items.

Target - store target interface.