WardrikEvents.
Copy Markdown
Reads kept events back from the logs patterns match.
Summary
Functions
Returns cursor moved past each of entries.
Streams every entry of log, oldest first.
Returns the logs resources match.
Returns up to limit entries of log after the sequence number at.
Returns the cursor at the end of the logs resources match.
Returns up to limit entries after cursor from the logs resources match, oldest first, and the cursor after them.
Types
@type entry() :: {String.t(), non_neg_integer(), WardrikEvents.CloudEvent.t()}
{log, sequence, event}.
Functions
@spec advanced(WardrikEvents.Cursor.t(), [entry()]) :: WardrikEvents.Cursor.t()
Returns cursor moved past each of entries.
@spec all(map(), String.t()) :: Enumerable.t(entry())
Streams every entry of log, oldest first.
@spec covered(WardrikStore.t(), [String.t()]) :: [String.t()]
Returns the logs resources match.
@spec entries(map(), String.t(), non_neg_integer(), pos_integer()) :: [entry()]
Returns up to limit entries of log after the sequence number at.
If retention dropped the next one, the entries start with a wardrik.events.dropped.
@spec head(WardrikStore.t(), [String.t()]) :: WardrikEvents.Cursor.t()
Returns the cursor at the end of the logs resources match.
@spec page(map(), [String.t()], WardrikEvents.Cursor.t(), pos_integer()) :: {[entry()], WardrikEvents.Cursor.t()}
Returns up to limit entries after cursor from the logs resources match, oldest first, and the cursor after them.