pub trait PushSourcePuppetProxyInterface: Send + Sync {
type SetSampleResponseFut: Future<Output = Result<(), Error>> + Send;
type SetStatusResponseFut: Future<Output = Result<(), Error>> + Send;
type CrashResponseFut: Future<Output = Result<(), Error>> + Send;
type GetLifetimeServedConnectionsResponseFut: Future<Output = Result<u32, Error>> + Send;
// Required methods
fn set_sample(&self, sample: &TimeSample) -> Self::SetSampleResponseFut;
fn set_status(&self, status: Status) -> Self::SetStatusResponseFut;
fn crash(&self) -> Self::CrashResponseFut;
fn get_lifetime_served_connections(
&self,
) -> Self::GetLifetimeServedConnectionsResponseFut;
}