NewHistorical returns a Store which can be used to queue up items to process.

WithoutCancel returns a chan that may never be closed and always blocks.

If multiple adds/updates of a single item happen while an item is in the queue before it has been processed, it will only be processed once, and when it is processed, the most recent version will be processed.

concurrency-safe, deadline-oriented queue that returns items after their delay period has expired.

HistoricalFIFO receives adds and updates from a Reflector, and puts them in a queue for FIFO order processing.

an optional interface to be implemented by Delayed objects; returning a nil channel from Breaker() results in waiting the full delay duration.

Decide whether a pre-existing deadline for an item in a delay-queue should be updated if an attempt is made to offer/add a new deadline for said item.

Decide whether a pre-existing data blob in a delay-queue should be replaced if an an attempt is made to add/offer a new data blob in its place.