pub trait ProgressReporter: EventFirerwhere
    Self::State: HasClientPerfMonitor + HasMetadata + HasExecutions,
{ fn maybe_report_progress(
        &mut self,
        state: &mut Self::State,
        last_report_time: Duration,
        monitor_timeout: Duration
    ) -> Result<Duration, Error> { ... } }
Expand description

ProgressReporter report progress to the broker.

Provided Methods§

source

fn maybe_report_progress(
    &mut self,
    state: &mut Self::State,
    last_report_time: Duration,
    monitor_timeout: Duration
) -> Result<Duration, Error>

Given the last time, if monitor_timeout seconds passed, send off an info/monitor/heartbeat message to the broker. Returns the new last time (so the old one, unless monitor_timeout time has passed and monitor have been sent) Will return an crate::Error, if the stats could not be sent.

Implementors§