Struct LangSmithHandler 

pub struct LangSmithHandler { /* private fields */ }

LangSmith callback handler

Automatically sends trace data to LangSmith.

Implementations

impl LangSmithHandler

pub fn new(config: LangSmithConfig) -> Self

Creates a new handler with the given LangSmith configuration.

pub fn from_env() -> Result<Self, LangSmithError>

Creates a handler from environment variables.

pub fn with_async_mode(self, async_mode: bool) -> Self

Enables or disables asynchronous mode for sending traces.

Trait Implementations

impl CallbackHandler for LangSmithHandler

fn on_run_start<'life0, 'life1, 'async_trait>( &'life0 self, run: &'life1 RunTree, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when any run starts

fn on_run_end<'life0, 'life1, 'async_trait>( &'life0 self, run: &'life1 RunTree, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Called when a run ends successfully

fn on_run_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a run fails

fn on_llm_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, _messages: &'life2 [Message], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when an LLM starts

fn on_llm_end<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, _response: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when an LLM ends

fn on_llm_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when an LLM errors

fn on_chain_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, _inputs: &'life2 Value, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a chain starts

fn on_chain_end<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, _outputs: &'life2 Value, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a chain ends

fn on_chain_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a chain errors

fn on_tool_start<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, run: &'life1 RunTree, _tool_name: &'life2 str, _input: &'life3 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Called when a tool starts

fn on_tool_end<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, _output: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a tool ends

fn on_tool_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a tool errors

fn on_retriever_start<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, _query: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a retriever starts

fn on_retriever_end<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, _documents: &'life2 [Value], ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a retriever ends

fn on_retriever_error<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, run: &'life1 RunTree, error: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called when a retriever errors

fn on_llm_new_token<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _run: &'life1 RunTree, _token: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called for each new token during streaming

fn on_llm_thinking<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _run: &'life1 RunTree, _thinking: &'life2 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Called for each thinking token during streaming (extended thinking).