Trait SignalProcessingProxyInterface

pub trait SignalProcessingProxyInterface: 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;
    type SetElementStateResponseFut: Future<Output = Result<SignalProcessingSetElementStateResult, Error>> + Send;
    type SetTopologyResponseFut: Future<Output = Result<SignalProcessingSetTopologyResult, 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;
    fn set_element_state(
        &self,
        processing_element_id: u64,
        state: &SettableElementState,
    ) -> Self::SetElementStateResponseFut;
    fn set_topology(&self, topology_id: u64) -> Self::SetTopologyResponseFut;
}

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

type SetElementStateResponseFut: Future<Output = Result<SignalProcessingSetElementStateResult, Error>> + Send

type SetTopologyResponseFut: Future<Output = Result<SignalProcessingSetTopologyResult, 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

fn set_element_state( &self, processing_element_id: u64, state: &SettableElementState, ) -> Self::SetElementStateResponseFut

fn set_topology(&self, topology_id: u64) -> Self::SetTopologyResponseFut

Implementors

impl SignalProcessingProxyInterface for SignalProcessingProxy

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

type WatchElementStateResponseFut = QueryResponseFut<ElementState>

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

type WatchTopologyResponseFut = QueryResponseFut<u64>

type SetElementStateResponseFut = QueryResponseFut<Result<(), i32>>

type SetTopologyResponseFut = QueryResponseFut<Result<(), i32>>