EventStore

The component that persists and buffers events before sending.

Functions

abstract fun add(payload: Payload)

Adds an event to the store.

Returns a list of EmitterEvent objects which contain events and related IDs.

Empties the store of all the events.

Removes an event from the store.

Removes a range of events from the store.

abstract fun removeOldEvents(maxSize: Long, maxAge: Duration)

Remove events older than maxAge seconds and keep only the latest maxSize events.

abstract fun size(): Long

Returns amount of events currently in the store.