agents-core/ai.koog.agents.core.feature.model.events

Package-level declarations

Types

typealias ~~AfterLLMCallEvent~~ = LLMCallCompletedEvent

data class AgentClosingEvent(val agentId: String, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event that signifies the closure or termination of an AI agent identified by a unique agentId.

AgentCompletedEvent

@Serializable

data class AgentCompletedEvent(val agentId: String, val runId: String, val result: String?, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Event representing the completion of an AI Agent's execution.

AgentExecutionFailedEvent

@Serializable

data class AgentExecutionFailedEvent(val agentId: String, val runId: String, val error: AIAgentError, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event triggered when an AI agent run encounters an error.

AgentStartingEvent

@Serializable

data class AgentStartingEvent(val agentId: String, val runId: String, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event triggered when an AI agent starts executing a strategy.

AIAgentBeforeCloseEvent

typealias ~~AIAgentBeforeCloseEvent~~ = AgentClosingEvent

AIAgentFinishedEvent

typealias ~~AIAgentFinishedEvent~~ = AgentCompletedEvent

AIAgentNodeExecutionEndEvent

typealias ~~AIAgentNodeExecutionEndEvent~~ = NodeExecutionCompletedEvent

AIAgentNodeExecutionErrorEvent

typealias ~~AIAgentNodeExecutionErrorEvent~~ = NodeExecutionFailedEvent

AIAgentNodeExecutionStartEvent

typealias ~~AIAgentNodeExecutionStartEvent~~ = NodeExecutionStartingEvent

AIAgentRunErrorEvent

typealias ~~AIAgentRunErrorEvent~~ = AgentExecutionFailedEvent

AIAgentStartedEvent

typealias ~~AIAgentStartedEvent~~ = AgentStartingEvent

AIAgentStrategyFinishedEvent

typealias ~~AIAgentStrategyFinishedEvent~~ = StrategyCompletedEvent

AIAgentStrategyStartEvent

typealias ~~AIAgentStrategyStartEvent~~ = StrategyStartingEvent

BeforeLLMCallEvent

typealias ~~BeforeLLMCallEvent~~ = LLMCallStartingEvent

DefinedFeatureEvent

sealed class DefinedFeatureEvent : FeatureEvent

Represents a sealed class for defining feature-related events in the system.

FunctionalStrategyStartingEvent

@Serializable

data class FunctionalStrategyStartingEvent(val runId: String, val strategyName: String, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : StrategyStartingEvent

Represents an event triggered at the start of executing a functional strategy by an AI agent.

GraphStrategyStartingEvent

@Serializable

data class GraphStrategyStartingEvent(val runId: String, val strategyName: String, val graph: StrategyEventGraph, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : StrategyStartingEvent

Represents an event triggered at the start of an AI agent strategy execution that involves the use of a graph-based operational model.

LLMCallCompletedEvent

@Serializable

data class LLMCallCompletedEvent(val runId: String, val prompt: Prompt, val model: String, val responses: List<Message.Response>, val moderationResponse: ModerationResult? = null, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event signaling the completion of an LLM (Large Language Model) call.

LLMCallStartingEvent

@Serializable

data class LLMCallStartingEvent(val runId: String, val prompt: Prompt, val model: String, val tools: List<String>, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event indicating the start of a call to a Language Learning Model (LLM).

LLMStreamingCompletedEvent

@Serializable

data class LLMStreamingCompletedEvent(val runId: String, val prompt: Prompt, val model: String, val tools: List<String>, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event that occurs when the streaming process of a Large Language Model (LLM) call is completed.

LLMStreamingFailedEvent

@Serializable

data class LLMStreamingFailedEvent(val runId: String, val error: AIAgentError, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event indicating a failure in the streaming process of a Language Learning Model (LLM).

LLMStreamingFrameReceivedEvent

@Serializable

data class LLMStreamingFrameReceivedEvent(val runId: String, val frame: StreamFrame, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Event representing the receipt of a streaming frame from a Language Learning Model (LLM).

LLMStreamingStartingEvent

@Serializable

data class LLMStreamingStartingEvent(val runId: String, val prompt: Prompt, val model: String, val tools: List<String>, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event triggered when a language model (LLM) streaming operation is starting.

NodeExecutionCompletedEvent

@Serializable

data class NodeExecutionCompletedEvent(val runId: String, val nodeName: String, val input: String, val output: String, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event indicating the completion of a node's execution within an AI agent.

NodeExecutionFailedEvent

@Serializable

data class NodeExecutionFailedEvent(val runId: String, val nodeName: String, val error: AIAgentError, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event that signifies the occurrence of an error during the execution of a specific node within an AI agent's process.

NodeExecutionStartingEvent

@Serializable

data class NodeExecutionStartingEvent(val runId: String, val nodeName: String, val input: String, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event triggered when the execution of a specific AI agent node starts.

StrategyCompletedEvent

@Serializable

data class StrategyCompletedEvent(val runId: String, val strategyName: String, val result: String?, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Event that represents the completion of an AI agent's strategy execution.

StrategyEventGraph

@Serializable

data class StrategyEventGraph(val nodes: List<StrategyEventGraphNode>, val edges: List<StrategyEventGraphEdge>)

Represents a graph structure used by an AI agent, consisting of a collection of nodes and directed edges connecting these nodes.

StrategyEventGraphEdge

@Serializable

data class StrategyEventGraphEdge(val sourceNode: StrategyEventGraphNode, val targetNode: StrategyEventGraphNode)

Represents a directed edge in the AI agent graph.

StrategyEventGraphNode

@Serializable

data class StrategyEventGraphNode(val id: String, val name: String)

Represents a node within an AI agent's processing graph.

StrategyStartingEvent

abstract class StrategyStartingEvent : DefinedFeatureEvent

Represents an event triggered at the start of an AI agent strategy execution.

ToolCallCompletedEvent

@Serializable

data class ToolCallCompletedEvent(val runId: String, val toolCallId: String?, val toolName: String, val toolArgs: JsonObject, val result: String?, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event that contains the results of a tool invocation.

ToolCallEvent

typealias ~~ToolCallEvent~~ = ToolCallStartingEvent

ToolCallFailedEvent

@Serializable

data class ToolCallFailedEvent(val runId: String, val toolCallId: String?, val toolName: String, val toolArgs: JsonObject, val error: AIAgentError, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Captures an event where a tool call has failed during its execution.

ToolCallFailureEvent

typealias ~~ToolCallFailureEvent~~ = ToolCallFailedEvent

ToolCallResultEvent

typealias ~~ToolCallResultEvent~~ = ToolCallCompletedEvent

ToolCallStartingEvent

@Serializable

data class ToolCallStartingEvent(val runId: String, val toolCallId: String?, val toolName: String, val toolArgs: JsonObject, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event triggered when a tool is called within the system.

ToolValidationErrorEvent

typealias ~~ToolValidationErrorEvent~~ = ToolValidationFailedEvent

ToolValidationFailedEvent

@Serializable

data class ToolValidationFailedEvent(val runId: String, val toolCallId: String?, val toolName: String, val toolArgs: JsonObject, val error: String, val timestamp: Long = Clock.System.now().toEpochMilliseconds()) : DefinedFeatureEvent

Represents an event indicating that a tool encountered a validation error during its execution.

Functions

startNodeToGraph

fun <TInput, TOutput> AIAgentGraphStrategy<TInput, TOutput>.startNodeToGraph(): StrategyEventGraph

Constructs an instance of AIAgentEventGraph by converting the metadata information of the current AIAgentGraphStrategy into its graph representation. The method creates nodes and edges that define the structure and flow of execution for the underlying AI agent strategy.