Struct ConsoleTransport 

pub struct ConsoleTransport;

Logs each event as pretty JSON via tracing. For development/tests.

Trait Implementations

impl Debug for ConsoleTransport

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

Formats the value using the given formatter.

impl Default for ConsoleTransport

fn default() -> ConsoleTransport

Returns the “default value” for a type.

impl Transport for ConsoleTransport

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, ConsoleTransport: '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, Self: '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.