pub trait ProgressReporter<I>: EventFirer<I>where
    I: Input,
{ fn maybe_report_progress<S>(
        &mut self,
        state: &mut S,
        last_report_time: Duration,
        monitor_timeout: Duration
    ) -> Result<Duration, Error>
    where
        S: HasExecutions + HasClientPerfMonitor + HasMetadata
, { ... } }
Expand description

ProgressReporter report progress to the broker.

Provided Methods

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