Trait StreamExecutorStats

pub trait StreamExecutorStats: Debug {
    // Required methods
    fn executor_name(&self) -> &String;
    fn futures_timeout(&self) -> &Duration;
    fn creation_time(&self) -> &Instant;
    fn executor_status(&self) -> &AtomicExecutorStatus;
    fn execution_start_delta_nanos(&self) -> u64;
    fn execution_finish_delta_nanos(&self) -> u64;
    fn ok_events_avg_future_duration(&self) -> &AtomicIncrementalAverage64;
    fn timed_out_events_avg_future_duration(
        &self,
    ) -> &AtomicIncrementalAverage64;
    fn failed_events_avg_future_duration(&self) -> &AtomicIncrementalAverage64;
    fn report_scheduled_to_finish(&self);
}

The trait to be passed along after the executor has been started

Required Methods

fn executor_name(&self) -> &String

fn futures_timeout(&self) -> &Duration

fn creation_time(&self) -> &Instant

fn executor_status(&self) -> &AtomicExecutorStatus

fn execution_start_delta_nanos(&self) -> u64

fn execution_finish_delta_nanos(&self) -> u64

fn ok_events_avg_future_duration(&self) -> &AtomicIncrementalAverage64

fn timed_out_events_avg_future_duration(&self) -> &AtomicIncrementalAverage64

fn failed_events_avg_future_duration(&self) -> &AtomicIncrementalAverage64

fn report_scheduled_to_finish(&self)

Tells this executor that its Stream will be artificially ended – so to cause it to cease its execution

Implementors

impl<const INSTRUMENTS_USIZE: usize> StreamExecutorStats for StreamExecutor<INSTRUMENTS_USIZE>