PartialGraphStat

risingwave_meta::barrier::partial_graph

Trait PartialGraphStat 

Source 
pub(super) trait PartialGraphStat:
    Send
    + Sync
    + 'static {
    // Required methods
    fn observe_barrier_latency(
        &self,
        epoch: EpochPair,
        barrier_latency_secs: f64,
    );
    fn observe_barrier_num(
        &self,
        inflight_barrier_num: usize,
        collected_barrier_num: usize,
    );
}

Required Methods§

Source

fn observe_barrier_latency(&self, epoch: EpochPair, barrier_latency_secs: f64)

Source

fn observe_barrier_num( &self, inflight_barrier_num: usize, collected_barrier_num: usize, )

Implementors§