Struct FlowBacklog 

pub struct FlowBacklog { /* private fields */ }

Implementations

impl FlowBacklog

pub fn new(limit: ByteSize) -> Self

pub fn limit(&self) -> ByteSize

pub fn set_waker(&self, waker: impl Fn() + Send + Sync + 'static)

pub fn notify(&self)

pub fn disarm(&self)

pub fn publish(&self, version: CommitVersion, cdc: Option<Arc<Cdc>>)

pub fn pull( &self, cursor: CommitVersion, up_to: CommitVersion, budget: ByteSize, ) -> BacklogPull

pub fn evict_below(&self, version: CommitVersion)

pub fn set_anchor(&self, version: CommitVersion)

Trait Implementations

impl Clone for FlowBacklog

fn clone(&self) -> FlowBacklog

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl MetricsCollector for FlowBacklog

fn collect(&self, out: &mut Vec<MetricsSample>)