Struct PipelineBridge 

pub struct PipelineBridge { /* private fields */ }

Ring 0 side of the pipeline bridge (producer).

Sends compiled pipeline output through a lock-free SPSC queue. The send_* methods take &self because SpscQueue::push uses atomic internals and does not require &mut self.

Implementations

impl PipelineBridge

pub fn send_event( &self, row: &EventRow<'_>, event_time: i64, key_hash: u64, ) -> Result<(), PipelineBridgeError>

Sends a processed event row through the bridge.

Copies row.data() into a SmallVec (inline for <=256 bytes) so the caller’s arena can be reset after this call returns.

Errors

Returns PipelineBridgeError::Backpressure if the queue is full and the strategy is BackpressureStrategy::DropNewest.

pub fn send_watermark(&self, timestamp: i64) -> Result<(), PipelineBridgeError>

Sends a watermark advance through the bridge.

Errors

Returns PipelineBridgeError::Backpressure if the queue is full.

pub fn send_checkpoint(&self, epoch: u64) -> Result<(), PipelineBridgeError>

Sends a checkpoint barrier through the bridge.

Errors

Returns PipelineBridgeError::Backpressure if the queue is full.

pub fn send_eof(&self) -> Result<(), PipelineBridgeError>

Sends an end-of-stream marker through the bridge.

Errors

Returns PipelineBridgeError::Backpressure if the queue is full.

pub fn has_capacity(&self) -> bool

Returns true if the SPSC queue has room for at least one more message.

pub fn is_backpressured(&self) -> bool

Returns true if the SPSC queue is full.

pub fn stats(&self) -> &Arc<BridgeStats>

Returns a reference to the shared statistics.

pub fn output_schema(&self) -> &Arc<RowSchema>

Returns the output schema.

Trait Implementations

impl Debug for PipelineBridge

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

Formats the value using the given formatter.