Trait AggregatorProxyInterface

pub trait AggregatorProxyInterface: Send + Sync {
    type ReportDiscreteActivityResponseFut: Future<Output = Result<(), Error>> + Send;

    // Required method
    fn report_discrete_activity(
        &self,
        event_time: i64,
    ) -> Self::ReportDiscreteActivityResponseFut;
}

Required Associated Types

type ReportDiscreteActivityResponseFut: Future<Output = Result<(), Error>> + Send

Required Methods

fn report_discrete_activity( &self, event_time: i64, ) -> Self::ReportDiscreteActivityResponseFut

Implementors

impl AggregatorProxyInterface for AggregatorProxy

type ReportDiscreteActivityResponseFut = QueryResponseFut<()>