Struct MediaManager 

pub struct MediaManager { /* private fields */ }

Manages media uploads and downloads against the Langfuse API.

Cheaply cloneable (backed by Arc). Background uploads are bounded by a semaphore whose size is controlled by LangfuseConfig::media_upload_thread_count.

Implementations

impl MediaManager

pub fn new(config: &LangfuseConfig) -> Self

Create a new MediaManager from the given configuration.

pub async fn upload( &self, trace_id: &str, observation_id: Option<&str>, field: &str, media: &LangfuseMedia, ) -> Result<String, LangfuseError>

Upload media and return the media ID.

This performs a two-step upload:

1. Request a presigned upload URL from the Langfuse API.
2. Upload the raw bytes to the presigned URL.

pub fn upload_background( &self, trace_id: String, observation_id: Option<String>, field: String, media: LangfuseMedia, )

Upload media in a background task.

Spawns a tokio task that acquires a permit from the upload semaphore (bounded by media_upload_thread_count) before performing the upload. Errors are logged via tracing::warn and otherwise silently dropped.

pub async fn fetch( &self, media_id: &str, ) -> Result<LangfuseMedia, LangfuseError>

Fetch media by ID.

Retrieves the media metadata from the Langfuse API, then downloads the actual content from the returned URL.

Trait Implementations

impl Clone for MediaManager

fn clone(&self) -> MediaManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MediaManager

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

Formats the value using the given formatter.