Struct OpenLineageClient 

pub struct OpenLineageClient { /* private fields */ }

Non-blocking front-end for emitting OpenLineage events.

Must be constructed from within a Tokio runtime (it spawns a background drain task); see OpenLineageClient::try_new for the non-panicking form.

Implementations

impl OpenLineageClient

pub fn new(transport: Arc<dyn Transport>) -> OpenLineageClient

Start a client that drains events into transport on a background task.

Panics

Panics if called outside a Tokio runtime. Use Self::try_new to get a clear error instead.

pub fn try_new( transport: Arc<dyn Transport>, ) -> Result<OpenLineageClient, ClientError>

Fallible Self::new: returns ClientError::Config instead of panicking when no Tokio runtime is available to host the drain task.

pub fn with_queue_size( transport: Arc<dyn Transport>, queue_size: usize, ) -> OpenLineageClient

Self::new with an explicit in-flight queue bound.

Panics

Panics if called outside a Tokio runtime; see Self::try_with_queue_size.

pub fn try_with_queue_size( transport: Arc<dyn Transport>, queue_size: usize, ) -> Result<OpenLineageClient, ClientError>

Fallible Self::with_queue_size: returns ClientError::Config instead of panicking when no Tokio runtime is available.

Errors

Returns ClientError::Config if called outside a Tokio runtime.

pub fn builder() -> OpenLineageClientBuilder

Returns a builder for configuring a client’s transport and queue size.

pub fn noop() -> OpenLineageClient

A client whose transport drops everything (NoopTransport).

pub fn from_env() -> Result<OpenLineageClient, ClientError>

Construct from the standard OpenLineage environment.

If OPENLINEAGE_URL is set, builds an HTTP transport (requires the http feature); otherwise returns a no-op client. OPENLINEAGE_API_KEY, if present, is sent as a bearer token.

pub fn emit(&self, event: RunEvent)

Emit an event without blocking. On a full queue the event is dropped with a warning — lineage never applies back-pressure to the query.

pub fn dropped_count(&self) -> u64

Total events dropped so far — on a full/closed queue (back-pressure) or by transport failure. Process-global (shared across clones).

pub async fn shutdown(self)

Flush queued events, flush the transport, and stop the background drain task.

Awaits the drain task to completion so events still queued at process exit are delivered rather than lost, then calls Transport::flush so a transport that buffers internally (e.g. a Kafka producer) delivers its tail before exit. The drain task ends once the event channel closes, which requires every sender to be dropped — so call this after (or while) dropping all other clones of the client; this consumes the clone it is called on. Idempotent across clones: only the clone holding the drain handle awaits it, the rest return immediately.

Trait Implementations

impl Clone for OpenLineageClient

fn clone(&self) -> OpenLineageClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpenLineageClient

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

Formats the value using the given formatter.