google-adk-kotlin-integrations-bigquery/com.google.adk.kt.plugins.agentanalytics/BigQueryAgentAnalyticsPlugin

BigQueryAgentAnalyticsPlugin

class BigQueryAgentAnalyticsPlugin(config: BigQueryLoggerConfig, bigQuery: BigQuery = createBigQuery(config), ioContext: CoroutineContext = Dispatchers.IO, timeSource: TimeSource = TimeSource.Monotonic) : Plugin

An ADK Plugin that records agent execution events to a BigQuery table. If the destination table does not exist, the plugin automatically creates and configures the partitioned table on first use. Row inserts currently execute synchronously on the invocation path, blocking until the BigQuery write completes, so partial streaming responses are not logged.

Constructors

constructor(config: BigQueryLoggerConfig, bigQuery: BigQuery = createBigQuery(config), ioContext: CoroutineContext = Dispatchers.IO, timeSource: TimeSource = TimeSource.Monotonic)

Types

Builder

class Builder

Fluent builder for BigQueryAgentAnalyticsPlugin, provided primarily for Java callers. Any property left unset falls back to the same default as the constructor.

Companion

object Companion

Properties

name

open override val name: String

Functions

afterAgent

open suspend override fun afterAgent(context: CallbackContext): CallbackChoice<Unit, Content>

afterModel

open suspend override fun afterModel(context: CallbackContext, response: LlmResponse): LlmResponse

afterRun

open suspend override fun afterRun(invocationContext: InvocationContext)

afterTool

open suspend override fun afterTool(context: ToolContext, tool: BaseTool, args: Map<String, Any?>, result: Map<String, Any?>): Map<String, Any?>

beforeAgent

open suspend override fun beforeAgent(context: CallbackContext): CallbackChoice<EventActions, Content>

beforeModel

open suspend override fun beforeModel(context: CallbackContext, request: LlmRequest): CallbackChoice<LlmRequest, LlmResponse>

beforeRun

open suspend override fun beforeRun(invocationContext: InvocationContext): CallbackChoice<Unit, Content>

beforeTool

open suspend override fun beforeTool(context: ToolContext, tool: BaseTool, args: Map<String, Any?>): CallbackChoice<Map<String, Any?>, Map<String, Any?>>

open override fun close()

onEvent

open suspend override fun onEvent(invocationContext: InvocationContext, event: Event): Event

onModelError

open suspend override fun onModelError(context: CallbackContext, request: LlmRequest, error: Throwable): CallbackChoice<Unit, LlmResponse>

onRunError

open suspend override fun onRunError(invocationContext: InvocationContext, error: Throwable)

onToolError

open suspend override fun onToolError(context: ToolContext, tool: BaseTool, args: Map<String, Any?>, error: Throwable): CallbackChoice<Unit, Map<String, Any?>>

onUserMessage

open suspend override fun onUserMessage(invocationContext: InvocationContext, userMessage: Content): Content