pub struct BridgeConsumer { /* private fields */ }Expand description
Ring 1 side of the pipeline bridge (consumer).
Drains BridgeMessages from the SPSC queue, accumulates events in a
RowBatchBridge, and produces Ring1Actions when flush conditions
are met.
Implementations§
Source§impl BridgeConsumer
impl BridgeConsumer
Sourcepub fn drain(&mut self) -> SmallVec<[Ring1Action; 4]>
pub fn drain(&mut self) -> SmallVec<[Ring1Action; 4]>
Drains all available messages from the queue and returns the resulting actions.
Actions are returned in order:
ProcessBatchwhen flush conditions are metAdvanceWatermarkafter any pending rows are flushedCheckpointafter any pending rows are flushedEofafter any pending rows are flushed
Sourcepub fn check_latency_flush(&mut self) -> Option<Ring1Action>
pub fn check_latency_flush(&mut self) -> Option<Ring1Action>
Checks whether the maximum latency has been exceeded and flushes if so.
Returns Some(Ring1Action::ProcessBatch) if a latency-triggered flush
occurred, or None otherwise.
Sourcepub fn current_watermark(&self) -> i64
pub fn current_watermark(&self) -> i64
Returns the current watermark as last seen from the producer.
Sourcepub fn pending_rows(&self) -> usize
pub fn pending_rows(&self) -> usize
Returns the number of rows pending in the batch (not yet flushed).
Sourcepub fn stats(&self) -> &Arc<BridgeStats>
pub fn stats(&self) -> &Arc<BridgeStats>
Returns a reference to the shared statistics.
Trait Implementations§
Auto Trait Implementations§
impl Freeze for BridgeConsumer
impl !RefUnwindSafe for BridgeConsumer
impl Send for BridgeConsumer
impl Sync for BridgeConsumer
impl Unpin for BridgeConsumer
impl UnsafeUnpin for BridgeConsumer
impl !UnwindSafe for BridgeConsumer
Blanket Implementations§
§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Returns the layout of the type.