Trait Telemetry 

pub trait Telemetry:
    Send
    + Sync
    + 'static {
    // Provided methods
    fn on_start(&self, _event: &StartEvent) { ... }
    fn on_step_start(&self, _event: &StepStartEvent) { ... }
    fn on_language_model_call_start(&self, _event: &ModelCallStartEvent) { ... }
    fn on_language_model_call_end(&self, _event: &ModelCallEndEvent) { ... }
    fn on_tool_execution_start(&self, _event: &ToolExecutionStartEvent) { ... }
    fn on_tool_execution_end(&self, _event: &ToolExecutionEndEvent) { ... }
    fn on_step_end(&self, _event: &StepEndEvent) { ... }
    fn on_embed_start(&self, _event: &EmbedStartEvent) { ... }
    fn on_embed_end(&self, _event: &EmbedEndEvent) { ... }
    fn on_rerank_start(&self, _event: &RerankStartEvent) { ... }
    fn on_rerank_end(&self, _event: &RerankEndEvent) { ... }
    fn on_end(&self, _event: &EndEvent) { ... }
    fn on_abort(&self, _event: &AbortEvent) { ... }
    fn on_error(&self, _event: &ErrorEvent<'_>) { ... }
    fn execute_language_model_call<'a>(
        &'a self,
        _ctx: &'a ModelCallContext,
        call: BoxFuture<'a, Result<ModelCallOutcome, Error>>,
    ) -> BoxFuture<'a, Result<ModelCallOutcome, Error>> { ... }
    fn execute_tool<'a>(
        &'a self,
        _ctx: &'a ToolExecutionContext,
        call: BoxFuture<'a, Result<ToolOutcome, ToolError>>,
    ) -> BoxFuture<'a, Result<ToolOutcome, ToolError>> { ... }
}

A telemetry integration.

Every method has a no-op default; implement the ones you need. Callbacks must not block: hand events to your own channel when processing is slow.

Provided Methods

fn on_start(&self, _event: &StartEvent)

A call started.

fn on_step_start(&self, _event: &StepStartEvent)

A step started.

fn on_language_model_call_start(&self, _event: &ModelCallStartEvent)

A model call is about to be made.

fn on_language_model_call_end(&self, _event: &ModelCallEndEvent)

A model call finished.

fn on_tool_execution_start(&self, _event: &ToolExecutionStartEvent)

A tool execution started.

fn on_tool_execution_end(&self, _event: &ToolExecutionEndEvent)

A tool execution finished.

fn on_step_end(&self, _event: &StepEndEvent)

A step finished.

fn on_embed_start(&self, _event: &EmbedStartEvent)

An embedding call started.

fn on_embed_end(&self, _event: &EmbedEndEvent)

An embedding call finished.

fn on_rerank_start(&self, _event: &RerankStartEvent)

A rerank call started.

fn on_rerank_end(&self, _event: &RerankEndEvent)

A rerank call finished.

fn on_end(&self, _event: &EndEvent)

A call finished.

fn on_abort(&self, _event: &AbortEvent)

A streaming call was aborted.

fn on_error(&self, _event: &ErrorEvent<'_>)

An error occurred.

fn execute_language_model_call<'a>( &'a self, _ctx: &'a ModelCallContext, call: BoxFuture<'a, Result<ModelCallOutcome, Error>>, ) -> BoxFuture<'a, Result<ModelCallOutcome, Error>>

Runs a model call inside integration-specific context (for example an OpenTelemetry span). The default runs call unchanged.

fn execute_tool<'a>( &'a self, _ctx: &'a ToolExecutionContext, call: BoxFuture<'a, Result<ToolOutcome, ToolError>>, ) -> BoxFuture<'a, Result<ToolOutcome, ToolError>>

Runs a tool execution inside integration-specific context.

Implementations

impl dyn Telemetry

pub fn ptr_eq(this: &Arc<Self>, other: &Arc<Self>) -> bool

Convenience for tests: returns true when self is the same object.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors