Trait SourceProxyInterface 

pub trait SourceProxyInterface: Send + Sync {
    type GetSpecResponseFut: Future<Output = Result<SourceGetSpecResult, Error>> + Send;
    type GetStatusResponseFut: Future<Output = Result<SourceGetStatusResult, Error>> + Send;
    type SetRoleResponseFut: Future<Output = Result<SourceSetRoleResult, Error>> + Send;
    type WatchResponseFut: Future<Output = Result<(Status, Option<EventPair>), Error>> + Send;

    // Required methods
    fn get_spec(&self) -> Self::GetSpecResponseFut;
    fn get_status(&self) -> Self::GetStatusResponseFut;
    fn set_role(&self, role: &Role) -> Self::SetRoleResponseFut;
    fn watch(
        &self,
        interest: &Status,
        wake_on: &Status,
        lease: Option<EventPair>,
    ) -> Self::WatchResponseFut;
}

Required Associated Types

type GetSpecResponseFut: Future<Output = Result<SourceGetSpecResult, Error>> + Send

type GetStatusResponseFut: Future<Output = Result<SourceGetStatusResult, Error>> + Send

type SetRoleResponseFut: Future<Output = Result<SourceSetRoleResult, Error>> + Send

type WatchResponseFut: Future<Output = Result<(Status, Option<EventPair>), Error>> + Send

Required Methods

fn get_spec(&self) -> Self::GetSpecResponseFut

fn get_status(&self) -> Self::GetStatusResponseFut

fn set_role(&self, role: &Role) -> Self::SetRoleResponseFut

fn watch( &self, interest: &Status, wake_on: &Status, lease: Option<EventPair>, ) -> Self::WatchResponseFut

Implementors

impl SourceProxyInterface for SourceProxy

type GetSpecResponseFut = QueryResponseFut<Result<Spec, Error>>

type GetStatusResponseFut = QueryResponseFut<Result<Status, Error>>

type SetRoleResponseFut = QueryResponseFut<Result<(), Error>>

type WatchResponseFut = QueryResponseFut<(Status, Option<EventPair>)>