feat: Add telemetry and metrics recording capabilities

The key changes include:

1.  **New `Instrumentation.java` class:** This class provides a unified context manager for instrumenting agent invocations and tool executions. It uses OpenTelemetry to create trace spans, record exceptions, and manage the scope of telemetry contexts. It includes inner classes `AgentInvocation` and `ToolExecution`, both implementing `AutoCloseable` to automatically handle the lifecycle of spans and metric recording.

2.  **New `Metrics.java` class:** This utility class is responsible for defining and recording various OpenTelemetry metrics (histograms) related to ADK components. These metrics cover:
    *   Agent invocation duration, request size, response size, and workflow steps.
    *   Tool execution duration, request size, and response size.
    The class uses `GlobalOpenTelemetry` to get a `Meter` and defines static histogram instances. It includes methods to record values for these metrics, often including attributes like agent name, tool name, and error type.

3.  **New Unit Tests:**
    *   `InstrumentationTest.java`: Contains unit tests for the `Instrumentation` class, verifying that spans are created correctly, contexts are managed, and metrics are recorded for both successful and error scenarios during agent invocations and tool executions. It uses `OpenTelemetryRule` for testing.
    *   `MetricsTest.java`: Contains unit tests for the `Metrics` class, ensuring that the various static methods correctly record histogram data with the expected values and attributes. It also uses `OpenTelemetryRule`.

PiperOrigin-RevId: 920699267

Author: google-genai-bot

core/src/main/java/com/google/adk/telemetry/Instrumentation.java

@@ -0,0 +1,207 @@
+/*
+ * Copyright 2026 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.google.adk.telemetry;
+
+import com.google.adk.agents.BaseAgent;
+import com.google.adk.agents.InvocationContext;
+import com.google.adk.events.Event;
+import com.google.adk.tools.BaseTool;
+import io.opentelemetry.api.trace.Span;
+import io.opentelemetry.api.trace.StatusCode;
+import io.opentelemetry.context.Context;
+import io.opentelemetry.context.Scope;
+import java.time.Duration;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.atomic.AtomicBoolean;
+import org.jspecify.annotations.Nullable;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+/** Unified context manager utility class for agent and tool execution telemetry in ADK. */
+public final class Instrumentation {
+
+  private static final Logger logger = LoggerFactory.getLogger(Instrumentation.class);
+
+  private Instrumentation() {}
+
+  /** Stores all telemetry related state. */
+  public static final class TelemetryContext {
+    private final Context otelContext;
+    private @Nullable Event functionResponseEvent;
+
+    public TelemetryContext(Context otelContext) {
+      this.otelContext = otelContext;
+    }
+
+    public Context otelContext() {
+      return otelContext;
+    }
+
+    public @Nullable Event functionResponseEvent() {
+      return functionResponseEvent;
+    }
+
+    public void setFunctionResponseEvent(@Nullable Event functionResponseEvent) {
+      this.functionResponseEvent = functionResponseEvent;
+    }
+  }
+
+  /** Base class for AutoCloseable telemetry tracking scopes. */
+  public abstract static class ClosableTelemetryScope implements AutoCloseable {
+    protected final long startTimeNanos;
+    protected final Span span;
+    protected final Scope scope;
+    protected final TelemetryContext telemetryContext;
+    protected @Nullable Throwable caughtError;
+    protected final AtomicBoolean closed = new AtomicBoolean(false);
+
+    @SuppressWarnings("MustBeClosedChecker")
+    ClosableTelemetryScope(Span span) {
+      this.startTimeNanos = System.nanoTime();
+      this.span = span;
+      this.scope = span.makeCurrent();
+      this.telemetryContext = new TelemetryContext(Context.current());
+    }
+
+    public TelemetryContext context() {
+      return telemetryContext;
+    }
+
+    public void setError(Throwable caughtError) {
+      this.caughtError = caughtError;
+      span.recordException(caughtError);
+      span.setStatus(StatusCode.ERROR, caughtError.getMessage());
+    }
+
+    @Override
+    public final void close() {
+      if (closed.getAndSet(true)) {
+        return;
+      }
+      try {
+        beforeSpanEnd();
+        span.end();
+        Duration elapsed = Duration.ofNanos(System.nanoTime() - startTimeNanos);
+        try {
+          recordMetrics(elapsed, caughtError);
+        } catch (RuntimeException e) {
+          handleMetricsError(e);
+        }
+      } finally {
+        scope.close();
+      }
+    }
+
+    /** Hook for subclasses to run code before span ends. */
+    protected void beforeSpanEnd() {}
+
+    /** Hook for subclasses to record metrics. */
+    protected abstract void recordMetrics(Duration elapsed, @Nullable Throwable error);
+
+    /** Hook for subclasses to handle metrics recording errors. */
+    protected abstract void handleMetricsError(RuntimeException e);
+  }
+
+  /** AutoCloseable telemetry tracking scope for agent invocations. */
+  public static final class AgentInvocation extends ClosableTelemetryScope {
+    private final BaseAgent agent;
+    private final InvocationContext ctx;
+    private final List<Event> events = Collections.synchronizedList(new ArrayList<>());
+
+    public AgentInvocation(InvocationContext ctx, BaseAgent agent) {
+      super(Tracing.getTracer().spanBuilder("invoke_agent " + agent.name()).startSpan());
+      this.agent = agent;
+      this.ctx = ctx;
+      Tracing.traceAgentInvocation(span, agent.name(), agent.description(), ctx);
+    }
+
+    public InvocationContext getCtx() {
+      return ctx;
+    }
+
+    public void addEvent(Event event) {
+      events.add(event);
+    }
+
+    @Override
+    protected void recordMetrics(Duration elapsed, @Nullable Throwable error) {
+      Metrics.recordAgentInvocationDuration(agent.name(), elapsed, error);
+      Metrics.recordAgentRequestSize(agent.name(), ctx.userContent().orElse(null));
+      Metrics.recordAgentResponseSize(agent.name(), events);
+      Metrics.recordAgentWorkflowSteps(agent.name(), events);
+    }
+
+    @Override
+    protected void handleMetricsError(RuntimeException e) {
+      logger.error("Failed to record agent metrics for agent {}", agent.name(), e);
+    }
+  }
+
+  /** AutoCloseable telemetry tracking scope for tool executions. */
+  public static final class ToolExecution extends ClosableTelemetryScope {
+    private final BaseTool tool;
+    private final BaseAgent agent;
+    private final Map<String, Object> functionArgs;
+
+    public ToolExecution(BaseTool tool, BaseAgent agent, Map<String, Object> functionArgs) {
+      super(Tracing.getTracer().spanBuilder("execute_tool " + tool.name()).startSpan());
+      this.tool = tool;
+      this.agent = agent;
+      this.functionArgs = functionArgs;
+    }
+
+    @Override
+    protected void beforeSpanEnd() {
+      Event responseEvent = caughtError == null ? context().functionResponseEvent() : null;
+      Tracing.traceToolExecution(
+          span,
+          tool.name(),
+          tool.description(),
+          tool.getClass().getSimpleName(),
+          functionArgs,
+          responseEvent,
+          caughtError);
+    }
+
+    @Override
+    protected void recordMetrics(Duration elapsed, @Nullable Throwable error) {
+      Metrics.recordToolExecutionDuration(tool.name(), agent.name(), elapsed, error);
+      Metrics.recordToolRequestSize(tool.name(), agent.name(), functionArgs);
+      Event responseEvent = error == null ? context().functionResponseEvent() : null;
+      Metrics.recordToolResponseSize(tool.name(), agent.name(), responseEvent);
+    }
+
+    @Override
+    protected void handleMetricsError(RuntimeException e) {
+      logger.error("Failed to record tool execution duration for tool {}", tool.name(), e);
+    }
+  }
+
+  /** Creates an AgentInvocation context to record agent invocation telemetry. */
+  public static AgentInvocation recordAgentInvocation(InvocationContext ctx, BaseAgent agent) {
+    return new AgentInvocation(ctx, agent);
+  }
+
+  /** Creates a ToolExecution context to record tool execution telemetry. */
+  public static ToolExecution recordToolExecution(
+      BaseTool tool, BaseAgent agent, Map<String, Object> functionArgs) {
+    return new ToolExecution(tool, agent, functionArgs);
+  }
+}