core/community.flock.aigentic.core.agent.state

Package-level declarations

Types

data class ModelRequestInfo(val startedAt: Instant, val finishedAt: Instant, val inputTokenCount: Int, val outputTokenCount: Int, val thinkingOutputTokenCount: Int = 0, val cachedInputTokenCount: Int = 0)

State

data class State(val startedAt: Instant = Clock.System.now(), var finishedAt: Instant? = null, val messages: MutableSharedFlow<Message> = MutableSharedFlow(replay = 1000), val events: MutableSharedFlow<AgentStatus> = MutableSharedFlow(replay = 1000), val modelRequestInfos: MutableSharedFlow<ModelRequestInfo> = MutableSharedFlow(replay = 1000), val exampleRunIds: MutableSharedFlow<RunId> = MutableSharedFlow(replay = 1000))