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 events: MutableSharedFlow<AgentStatus> = MutableSharedFlow(replay = 1000), val modelRequestInfos: MutableSharedFlow<ModelRequestInfo> = MutableSharedFlow(replay = 1000), val exampleRunIds: MutableSharedFlow<RunId> = MutableSharedFlow(replay = 1000), systemPromptMessage: Message.SystemPrompt? = null, messages: MutableSharedFlow<Message> = MutableSharedFlow(replay = 1000))

Functions

addConfigContextMessage

suspend fun State.addConfigContextMessage(message: Message): <Error class: unknown class>

addSystemPromptMessage

fun State.addSystemPromptMessage(message: Message.SystemPrompt)