google-adk-kotlin-integrations/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 invocation lifecycle 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.

Constructors

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

Types

Companion

object Companion

Properties

name

open override val name: String

Functions

afterAgent

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

afterModel

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

afterRun

open suspend override fun afterRun(invocationContext: InvocationContext)

afterTool

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

beforeAgent

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

beforeModel

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

beforeRun

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

beforeTool

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

open override fun close()

onEvent

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

onModelError

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

onToolError

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

onUserMessage

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