Struct CloudClientTransport 

pub struct CloudClientTransport { /* private fields */ }

Posts OpenLineage events to an HTTP endpoint via CloudClient.

Single events go to endpoint; batches go to batch_endpoint (by default the single endpoint with /batch appended, matching the OpenLineage HTTP API).

Implementations

impl CloudClientTransport

pub fn new(client: CloudClient, endpoint: Url) -> CloudClientTransport

Use a pre-built CloudClient (e.g. one constructed with cloud credentials via CloudClient::new_aws / CloudClient::new_databricks).

The batch endpoint defaults to endpoint with /batch appended; the request timeout defaults to DEFAULT_REQUEST_TIMEOUT. Override either with Self::with_batch_endpoint / Self::with_timeout.

pub fn with_token(endpoint: Url, token: impl ToString) -> CloudClientTransport

Authenticate with a static bearer token (e.g. OPENLINEAGE_API_KEY).

pub fn unauthenticated(endpoint: Url) -> CloudClientTransport

No authentication.

pub fn with_timeout(self, timeout: Duration) -> CloudClientTransport

Override the per-request timeout (default DEFAULT_REQUEST_TIMEOUT).

pub fn with_batch_endpoint(self, batch_endpoint: Url) -> CloudClientTransport

Override the batch endpoint (default: endpoint with /batch appended).

Trait Implementations

impl Clone for CloudClientTransport

fn clone(&self) -> CloudClientTransport

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CloudClientTransport

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

Formats the value using the given formatter.

impl Transport for CloudClientTransport

fn emit<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 RunEvent, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, CloudClientTransport: 'async_trait,

Delivers a single OpenLineage event to the backend.

fn emit_batch<'life0, 'life1, 'async_trait>( &'life0 self, events: &'life1 [RunEvent], ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, CloudClientTransport: 'async_trait,

Delivers a batch of events. The default implementation calls emit for each event in order, stopping at the first error. Override when the backend has a bulk endpoint (e.g. a batch POST).

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Flushes any internally-buffered events, blocking until they are delivered (or fail). Called by OpenLineageClient::shutdown after the drain queue empties. The default is a no-op — override it only for transports that buffer beyond a single emit call.