Struct Langfuse 

pub struct Langfuse {
    pub prompts: PromptManager,
    pub scores: ScoreManager,
    pub datasets: DatasetManager,
    pub media: MediaManager,
    /* private fields */
}

The main Langfuse client. Holds all managers and the tracing pipeline.

Fields

prompts: PromptManager

Prompt management: fetching, caching, and compilation.

scores: ScoreManager

Score creation and batched submission.

datasets: DatasetManager

Dataset CRUD operations.

media: MediaManager

Media upload and fetch.

Implementations

impl Langfuse

pub fn new(config: LangfuseConfig) -> Result<Self, LangfuseError>

Create a new Langfuse client from config.

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

Create from environment variables.

pub fn init(config: LangfuseConfig) -> Result<&'static Langfuse, LangfuseError>

Initialize the global singleton.

pub fn get() -> &'static Langfuse

Get the global singleton (panics if not initialized).

pub fn try_get() -> Option<&'static Langfuse>

Try to get the global singleton.

pub fn init_named( name: &str, config: LangfuseConfig, ) -> Result<(), LangfuseError>

Initialize a named instance.

Named instances are independent of the global singleton and allow multiple Langfuse clients (e.g. for different projects or environments) to coexist.

pub fn get_named(name: &str) -> Option<Ref<'static, String, Langfuse>>

Get a named instance by name.

Returns None if no instance with the given name has been initialized.

pub fn try_get_named( name: &str, ) -> Result<Ref<'static, String, Langfuse>, LangfuseError>

Try to get a named instance, returning an error if not found.

pub fn config(&self) -> &LangfuseConfig

Get the config.

pub async fn auth_check(&self) -> Result<(), LangfuseError>

Check if authentication is valid by making a test API call.

pub async fn flush(&self) -> Result<(), LangfuseError>

Flush all pending data (scores, traces).

pub async fn shutdown(&self) -> Result<(), LangfuseError>

Shut down the client, flushing all pending data.

pub fn start_span(&self, name: &str) -> LangfuseSpan

Start a new span.

pub fn start_generation(&self, name: &str) -> LangfuseGeneration

Start a new generation.

pub fn start_span_with_type( &self, name: &str, obs_type: ObservationType, ) -> LangfuseSpan

Start a new span with a specific observation type.

pub fn create_event(&self, name: &str, input: &impl Serialize)

Create a standalone root-level event observation.

Events are zero-duration observations that carry input data. The event span is created and immediately ended.

pub fn get_trace_url(&self, trace_id: &str) -> String

Generate the Langfuse UI URL for a trace.

pub fn register_tracing(&self)

Register the internal tracer provider as the OpenTelemetry global provider.

This must be called once after Langfuse::new for spans created via LangfuseSpan::start (which uses opentelemetry::global::tracer("langfuse")) to be exported through the Langfuse OTLP pipeline.

Calling this more than once replaces the previous global provider.

Trait Implementations

impl Debug for Langfuse

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Langfuse

fn drop(&mut self)

Executes the destructor for this type.