EventStore

class EventStore(replayCapacity: Int = 0)

Append-only buffer of TracerEvents plus a hot SharedFlow for live consumers.

Reads return immutable snapshots. The append path uses an internal Mutex so the buffer is safe to share across coroutines.

Mirrors the Python reference EventStore (tracer/event_store.py).

Constructors

constructor(replayCapacity: Int = 0)

val events: SharedFlow<TracerEvent>

Hot stream of every event recorded since this store was created.

suspend fun clear()

Drop every event from the buffer.

suspend fun getEvents(type: KClass<out TracerEvent>? = null, startTime: Instant? = null, endTime: Instant? = null, predicate: (TracerEvent) -> Boolean? = null): List<TracerEvent>

Returns a snapshot of every event matching the supplied filters.

Returns the last n events, optionally filtered to type. Order matches insertion order (oldest first).

suspend fun size(): Int

Current number of buffered events.

suspend fun store(event: TracerEvent)

Store event in the buffer and emit it to live subscribers.