Struct LangfuseIngest 

pub struct LangfuseIngest { /* private fields */ }

Ingest handle. Clone is cheap (inner Arc) — each session’s observer holds one.

Implementations

impl LangfuseIngest

pub fn spawn(config: IngestConfig) -> Self

Spawns the background flush task and returns a handle.

pub fn enqueue(&self, event: IngestionEvent)

Non‑blocking enqueue. Drops and counts when the channel is full — never blocks the caller (agent main loop).

pub async fn flush(&self)

Flushes the buffer and waits for completion. Used for best-effort delivery before a session stream ends or the process exits.

Returns immediately if the background task has already exited (receiver closed) — best-effort, no delivery guarantee.

Trait Implementations

impl Clone for LangfuseIngest

fn clone(&self) -> LangfuseIngest

Returns a duplicate of the value.

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

Performs copy-assignment from source.