Trait ReaderProxyInterface

pub trait ReaderProxyInterface: Send + Sync {
    type GetElementsResponseFut: Future<Output = Result<ReaderGetElementsResult, Error>> + Send;
    type WatchElementStateResponseFut: Future<Output = Result<ElementState, Error>> + Send;
    type GetTopologiesResponseFut: Future<Output = Result<ReaderGetTopologiesResult, Error>> + Send;
    type WatchTopologyResponseFut: Future<Output = Result<u64, Error>> + Send;

    // Required methods
    fn get_elements(&self) -> Self::GetElementsResponseFut;
    fn watch_element_state(
        &self,
        processing_element_id: u64,
    ) -> Self::WatchElementStateResponseFut;
    fn get_topologies(&self) -> Self::GetTopologiesResponseFut;
    fn watch_topology(&self) -> Self::WatchTopologyResponseFut;
}

Required Associated Types

type GetElementsResponseFut: Future<Output = Result<ReaderGetElementsResult, Error>> + Send

type WatchElementStateResponseFut: Future<Output = Result<ElementState, Error>> + Send

type GetTopologiesResponseFut: Future<Output = Result<ReaderGetTopologiesResult, Error>> + Send

type WatchTopologyResponseFut: Future<Output = Result<u64, Error>> + Send

Required Methods

fn get_elements(&self) -> Self::GetElementsResponseFut

fn watch_element_state( &self, processing_element_id: u64, ) -> Self::WatchElementStateResponseFut

fn get_topologies(&self) -> Self::GetTopologiesResponseFut

fn watch_topology(&self) -> Self::WatchTopologyResponseFut

Implementors

impl ReaderProxyInterface for ReaderProxy

type GetElementsResponseFut = QueryResponseFut<Result<Vec<Element>, i32>>

type WatchElementStateResponseFut = QueryResponseFut<ElementState>

type GetTopologiesResponseFut = QueryResponseFut<Result<Vec<Topology>, i32>>

type WatchTopologyResponseFut = QueryResponseFut<u64>