ai-elements-core/dev.ai.elements.core.protocol.agui/AgUiEventLog

AgUiEventLog

A thread's AG-UI events, as AG-UI serialization specifies: an append-only log of the events exactly as they were streamed, per threadId, runs linked by RUN_STARTED.parentRunId, stored as a JSON array of events. AgUiBackend appends every run to it; replay plays runs back through the same event parser.

Events without a timestamp get the time they arrived (the optional BaseEvent.timestamp, milliseconds since the epoch), so a replay keeps the run's pace.

Inheritors

InMemory

Files

Types

Companion

object Companion

Files

class Files(directory: File) : AgUiEventLog

One JSON file per thread in directory (<threadId>.json, a JSON array of events).

InMemory

class InMemory : AgUiEventLog

Kept in memory for the life of the process.

Functions

append

abstract suspend fun append(threadId: String, events: List<JsonObject>)

delete

abstract suspend fun delete(threadId: String)

Forgets threadId's events, e.g. when its conversation is deleted.

load

abstract suspend fun load(threadId: String): List<JsonObject>

replayOf

open fun replayOf(message: Message, speed: Float = 1.0f): Flow<ChatEvent>?

The recorded run of message (the runs named in its metadata, see runsOf) played back through the event parser, or null when this log has no runs for it. For Chat(replay = …).