import { Channel } from "node:diagnostics_channel"; //#region src/observability/base.d.ts /** * Base event structure for all observability events */ type BaseEvent< T extends string, Payload extends Record = Record > = { type: T; /** * The class name of the agent that emitted this event * (e.g. "MyChatAgent"). * Always present on events emitted by an Agent instance. */ agent?: string; /** * The instance name (Durable Object ID name) of the agent. * Always present on events emitted by an Agent instance. */ name?: string; /** * The payload of the event */ payload: Payload; /** * The timestamp of the event in milliseconds since epoch */ timestamp: number; }; //#endregion //#region src/observability/mcp.d.ts /** * MCP-specific observability events * These track the lifecycle of MCP connections and operations */ type MCPObservabilityEvent = | BaseEvent< "mcp:client:preconnect", { serverId: string; } > | BaseEvent< "mcp:client:connect", { url: string; transport: string; state: string; error?: string; } > | BaseEvent< "mcp:client:authorize", { serverId: string; authUrl: string; clientId?: string; } > | BaseEvent< "mcp:client:discover", { url?: string; state?: string; error?: string; capability?: string; } > | BaseEvent< "mcp:client:close", { url: string; transport?: string; state: string; error?: string; phase?: "terminate-session" | "client-close"; } >; //#endregion //#region src/observability/agent.d.ts /** * Agent-specific observability events * These track the lifecycle and operations of an Agent */ type AgentObservabilityEvent = | BaseEvent<"state:update"> | BaseEvent< "rpc", { method: string; streaming?: boolean; } > | BaseEvent< "rpc:error", { method: string; error: string; } > | BaseEvent<"message:request"> | BaseEvent<"message:response"> | BaseEvent<"message:clear"> | BaseEvent< "message:cancel", { requestId: string; } > | BaseEvent< "message:error", { error: string; } > | BaseEvent< "tool:result", { toolCallId: string; toolName: string; } > | BaseEvent< "tool:approval", { toolCallId: string; approved: boolean; } > | BaseEvent< "schedule:create", { callback: string; id: string; } > | BaseEvent< "schedule:execute", { callback: string; id: string; } > | BaseEvent< "schedule:cancel", { callback: string; id: string; } > | BaseEvent< "schedule:retry", { callback: string; id: string; attempt: number; maxAttempts: number; } > | BaseEvent< "schedule:error", { callback: string; id: string; error: string; attempts: number; } > | BaseEvent< "schedule:duplicate_warning", { callback: string; count: number; type: string; } > | BaseEvent< "alarm:memory_limit_reset", { strikes: number; limit: number; sealed: boolean; error: string; } > | BaseEvent< "queue:create", { callback: string; id: string; } > | BaseEvent< "queue:retry", { callback: string; id: string; attempt: number; maxAttempts: number; } > | BaseEvent< "queue:error", { callback: string; id: string; error: string; attempts: number; } > | BaseEvent< "submission:create", { submissionId: string; requestId?: string; idempotencyKey?: string; } > | BaseEvent< "submission:status", { submissionId: string; requestId?: string; status: string; } > | BaseEvent< "submission:error", { submissionId: string; requestId?: string; error: string; } > | BaseEvent< "action:ledger:replayed", { action: string; key: string; inputHash: string; } > | BaseEvent< "action:ledger:pending", { action: string; key: string; inputHash: string; } > | BaseEvent< "action:ledger:conflict", { action: string; key: string; inputHash: string; } > | BaseEvent< "action:ledger:serialize_failed", { action: string; key: string; } > | BaseEvent< "action:ledger:settled", { action: string; key: string; inputHash: string; } > | BaseEvent< "action:ledger:reclaimed", { action: string; key: string; inputHash: string; ageMs: number; } > | BaseEvent< "action:ledger:swept", { settled: number; pending: number; } > | BaseEvent< "action:pause:created", { action: string; executionId: string; toolCallId: string; } > | BaseEvent< "action:pause:approved", { action: string; executionId: string; } > | BaseEvent< "action:pause:rejected", { action: string; executionId: string; } > | BaseEvent< "action:pause:swept", { swept: number; } > | BaseEvent< "action:reply-attached", { action?: string; attachmentType: string; } > | BaseEvent< "channel:resolved", { channel: string; kind: string; requestId?: string; } > | BaseEvent< "channel:delivered", { channel: string; kind: string; turnEnded: boolean; } > | BaseEvent< "notice:delivered", { channel: string; kind: string; informModel: boolean; } > | BaseEvent< "notice:failed", { channel: string; error: string; } > | BaseEvent< "fiber:run:started", { fiberId: string; fiberName: string; managed?: boolean; } > | BaseEvent< "fiber:run:completed", { fiberId: string; fiberName: string; elapsedMs?: number; managed?: boolean; } > | BaseEvent< "fiber:run:failed", { fiberId: string; fiberName: string; error: string; elapsedMs?: number; managed?: boolean; } > | BaseEvent< "fiber:run:interrupted", { fiberId: string; fiberName: string; elapsedMs?: number; managed?: boolean; recoveryReason: "interrupted"; } > | BaseEvent< "fiber:recovery:detected", { fiberId: string; fiberName: string; elapsedMs?: number; managed?: boolean; recoveryReason: "interrupted"; } > | BaseEvent< "fiber:recovery:attempt", { fiberId: string; fiberName: string; managed?: boolean; recoveryReason: "interrupted"; } > | BaseEvent< "fiber:recovery:handled", { fiberId: string; fiberName: string; status?: string; elapsedMs?: number; managed?: boolean; } > | BaseEvent< "fiber:recovery:skipped", { fiberId: string; fiberName: string; reason: string; elapsedMs?: number; managed?: boolean; } > | BaseEvent< "fiber:recovery:failed", { fiberId: string; fiberName: string; error: string; elapsedMs?: number; reason?: string; } > | BaseEvent< "chat:request:failed", { requestId?: string; stage: | "parse" | "persist" | "turn" | "stream" | "recovery" | "transcript"; messagesPersisted?: boolean; error: string; } > | BaseEvent< "chat:turn:start", { requestId: string; trigger: string; admission: string; continuation?: boolean; generation?: number; } > | BaseEvent< "chat:turn:finish", { requestId: string; trigger: string; admission: string; continuation?: boolean; generation?: number; status: string; durationMs: number; error?: string; } > | BaseEvent< "chat:recovery:detected", { incidentId: string; requestId: string; attempt: number; maxAttempts: number; recoveryKind: "retry" | "continue"; } > | BaseEvent< "chat:recovery:scheduled", { incidentId: string; requestId: string; attempt: number; maxAttempts: number; recoveryKind: "retry" | "continue"; } > | BaseEvent< "chat:recovery:attempt", { incidentId: string; requestId: string; attempt: number; maxAttempts: number; recoveryKind: "retry" | "continue"; } > | BaseEvent< "chat:recovery:completed", { incidentId: string; requestId: string; attempt: number; maxAttempts: number; recoveryKind: "retry" | "continue"; } > | BaseEvent< "chat:recovery:skipped", { incidentId: string; requestId: string; attempt: number; maxAttempts: number; recoveryKind: "retry" | "continue"; reason?: string; } > | BaseEvent< "chat:recovery:exhausted", { incidentId: string; requestId: string; attempt: number; maxAttempts: number; recoveryKind: "retry" | "continue"; reason: string; } > | BaseEvent< "chat:recovery:failed", { incidentId: string; requestId: string; attempt: number; maxAttempts: number; recoveryKind: "retry" | "continue"; reason?: string; } > | BaseEvent< "chat:transcript:repaired", { requestId?: string; removedToolCalls: number; normalizedInputs: number; toolCallIds?: string[]; } > | BaseEvent< "chat:onstart:degraded", { /** * Internal onStart step that failed and was skipped so the agent * could still come up instead of bricking the DO (#1710). */ step: | "transcript-hydration" | "scheduled-task-reconcile" | "durable-work-recovery"; error: string; } > | BaseEvent< "chat:hydration:windowed", { /** Stored size of the full active path, in bytes. */ totalContentBytes: number /** The configured `hydrationByteBudget`. */; budgetBytes: number /** Number of recent messages hydrated into the in-memory window. */; hydratedMessages: number; } > | BaseEvent< "chat:media:evicted", { /** Stored messages rewritten during this eviction pass. */ messages: number /** Individual oversized parts evicted across those messages. */; parts: number /** Total bytes removed from the stored transcript. */; bytes: number /** Bytes preserved as workspace files (≤ `bytes`). */; externalizedBytes: number; } > | BaseEvent< "chat:stream:stalled", { requestId: string /** Inactivity window that elapsed with no stream chunk, in ms. */; timeoutMs: number; } > | BaseEvent< "chat:context:compacted", { /** * `"proactive"` — the pre-step token guard compacted before the next * step; `"reactive"` — a context-overflow error triggered compaction * before a retry. */ reason: | "proactive" | "reactive" /** Whether compaction actually shortened history (false = no-op). */; shortened: boolean; requestId?: string /** Recovery attempt index (reactive backstop only). */; attempt?: number; } > | BaseEvent< "agent_tool:recovery:begin", { runCount: number; totalTimeoutMs?: number; } > | BaseEvent< "agent_tool:recovery:row", { runId: string; agentType: string; status: string; reason?: string; elapsedMs?: number; } > | BaseEvent< "agent_tool:recovery:deadline", { runId: string; agentType: string; elapsedMs?: number; } > | BaseEvent< "agent_tool:recovery:reattach", { runId: string; agentType: string; budgetMs: number; } > | BaseEvent< "agent_tool:recovery:complete", { runCount: number; elapsedMs?: number; } > | BaseEvent< "agent_tool:recovery:failed", { error: string; } > | BaseEvent< "agent_tool:detached:delivery_failed", { runId: string /** Which ledger slot was being delivered. */; kind: | "finish" | "give_up" /** Terminal status that was being delivered. */; status: string /** The per-run `onFinish` callback name, if one was wired. */; callback?: string; error: string; } > | BaseEvent< "agent_tool:detached:live_count_warning", { /** Detached runs currently holding a concurrency slot (non-terminal). */ liveCount: number /** The threshold that was crossed. */; threshold: number; } > | BaseEvent<"destroy"> | BaseEvent< "connect", { connectionId: string; } > | BaseEvent< "disconnect", { connectionId: string; code: number; reason: string; } > | BaseEvent< "email:receive", { from: string; to: string; subject?: string; } > | BaseEvent< "email:reply", { from: string; to: string; subject?: string; } > | BaseEvent< "email:send", { from: string; to: string | string[]; subject: string; } > | BaseEvent< "workflow:start", { workflowId: string; workflowName?: string; } > | BaseEvent< "workflow:event", { workflowId: string; eventType?: string; } > | BaseEvent< "workflow:approved", { workflowId: string; reason?: string; } > | BaseEvent< "workflow:rejected", { workflowId: string; reason?: string; } > | BaseEvent< "workflow:terminated", { workflowId: string; workflowName?: string; } > | BaseEvent< "workflow:paused", { workflowId: string; workflowName?: string; } > | BaseEvent< "workflow:resumed", { workflowId: string; workflowName?: string; } > | BaseEvent< "workflow:restarted", { workflowId: string; workflowName?: string; } >; //#endregion //#region src/observability/diagnostics.d.ts /** Diagnostics channels for Agent and Lifecycle telemetry. */ declare const channels: { readonly state: Channel; readonly rpc: Channel; readonly message: Channel; readonly chat: Channel; readonly transcript: Channel; readonly fiber: Channel; readonly task: Channel; readonly stream: Channel; readonly agentTool: Channel; readonly schedule: Channel; readonly lifecycle: Channel; readonly workflow: Channel; readonly mcp: Channel; readonly email: Channel; readonly channel: Channel; }; //#endregion //#region src/observability/index.d.ts /** * Union of all observability event types from different domains */ type ObservabilityEvent = AgentObservabilityEvent | MCPObservabilityEvent; interface Observability { /** * Emit an event for the Agent's observability implementation to handle. * @param event - The event to emit */ emit(event: ObservabilityEvent): void; } /** * The default observability implementation. * * Publishes events to diagnostics_channel. Events are silent unless * a subscriber is registered or a Tail Worker is attached. */ declare const genericObservability: Observability; /** * Maps each channel key to the observability events it carries. */ type ChannelEventMap = { state: Extract< ObservabilityEvent, { type: `state:${string}`; } >; rpc: Extract< ObservabilityEvent, { type: "rpc" | `rpc:${string}`; } >; message: Extract< ObservabilityEvent, { type: | `message:${string}` | `tool:${string}` | `submission:${string}` | `action:${string}`; } >; chat: Exclude< Extract< ObservabilityEvent, { type: `chat:${string}`; } >, { type: `chat:transcript:${string}`; } >; transcript: Extract< ObservabilityEvent, { type: `transcript:${string}` | `chat:transcript:${string}`; } >; fiber: Extract< ObservabilityEvent, { type: `fiber:${string}`; } >; agentTool: Extract< ObservabilityEvent, { type: `agent_tool:${string}`; } >; schedule: Extract< ObservabilityEvent, { type: `schedule:${string}` | `queue:${string}`; } >; lifecycle: Extract< ObservabilityEvent, { type: "connect" | "disconnect" | "destroy"; } >; workflow: Extract< ObservabilityEvent, { type: `workflow:${string}`; } >; mcp: Extract< ObservabilityEvent, { type: `mcp:${string}`; } >; email: Extract< ObservabilityEvent, { type: `email:${string}`; } >; channel: Extract< ObservabilityEvent, { type: `channel:${string}` | `notice:${string}`; } >; }; /** * Subscribe to a typed observability channel. * * ```ts * import { subscribe } from "agents/observability"; * * const unsub = subscribe("rpc", (event) => { * console.log(event.payload.method); // fully typed * }); * ``` * * @returns A function that unsubscribes the callback. */ declare function subscribe$1( channelKey: K, callback: (event: ChannelEventMap[K]) => void ): () => void; //#endregion export { subscribe$1 as a, genericObservability as i, Observability as n, channels as o, ObservabilityEvent as r, MCPObservabilityEvent as s, ChannelEventMap as t }; //# sourceMappingURL=index-YSKgfgg9.d.ts.map