Trait ManagerProxyInterface

pub trait ManagerProxyInterface: Send + Sync {
    type RestartDriverHostsResponseFut: Future<Output = Result<ManagerRestartDriverHostsResult, Error>> + Send;
    type DisableDriverResponseFut: Future<Output = Result<ManagerDisableDriverResult, Error>> + Send;
    type EnableDriverResponseFut: Future<Output = Result<ManagerEnableDriverResult, Error>> + Send;
    type BindAllUnboundNodesResponseFut: Future<Output = Result<ManagerBindAllUnboundNodesResult, Error>> + Send;
    type AddTestNodeResponseFut: Future<Output = Result<ManagerAddTestNodeResult, Error>> + Send;
    type RemoveTestNodeResponseFut: Future<Output = Result<ManagerRemoveTestNodeResult, Error>> + Send;
    type WaitForBootupResponseFut: Future<Output = Result<(), Error>> + Send;
    type RestartWithDictionaryResponseFut: Future<Output = Result<ManagerRestartWithDictionaryResult, Error>> + Send;
    type RebindCompositesWithDriverResponseFut: Future<Output = Result<ManagerRebindCompositesWithDriverResult, Error>> + Send;

    // Required methods
    fn get_driver_info(
        &self,
        driver_filter: &[String],
        iterator: ServerEnd<DriverInfoIteratorMarker>,
    ) -> Result<(), Error>;
    fn get_composite_node_specs(
        &self,
        name_filter: Option<&str>,
        iterator: ServerEnd<CompositeNodeSpecIteratorMarker>,
    ) -> Result<(), Error>;
    fn get_node_info(
        &self,
        node_filter: &[String],
        iterator: ServerEnd<NodeInfoIteratorMarker>,
        exact_match: bool,
    ) -> Result<(), Error>;
    fn get_composite_info(
        &self,
        iterator: ServerEnd<CompositeInfoIteratorMarker>,
    ) -> Result<(), Error>;
    fn get_driver_host_info(
        &self,
        iterator: ServerEnd<DriverHostInfoIteratorMarker>,
    ) -> Result<(), Error>;
    fn restart_driver_hosts(
        &self,
        driver_url: &str,
        rematch_flags: RestartRematchFlags,
    ) -> Self::RestartDriverHostsResponseFut;
    fn disable_driver(
        &self,
        driver_url: &str,
        package_hash: Option<&str>,
    ) -> Self::DisableDriverResponseFut;
    fn enable_driver(
        &self,
        driver_url: &str,
        package_hash: Option<&str>,
    ) -> Self::EnableDriverResponseFut;
    fn bind_all_unbound_nodes(&self) -> Self::BindAllUnboundNodesResponseFut;
    fn add_test_node(
        &self,
        args: &TestNodeAddArgs,
    ) -> Self::AddTestNodeResponseFut;
    fn remove_test_node(&self, name: &str) -> Self::RemoveTestNodeResponseFut;
    fn wait_for_bootup(&self) -> Self::WaitForBootupResponseFut;
    fn restart_with_dictionary(
        &self,
        moniker: &str,
        dictionary: DictionaryRef,
    ) -> Self::RestartWithDictionaryResponseFut;
    fn rebind_composites_with_driver(
        &self,
        driver_url: &str,
    ) -> Self::RebindCompositesWithDriverResponseFut;
}

Required Associated Types

type RestartDriverHostsResponseFut: Future<Output = Result<ManagerRestartDriverHostsResult, Error>> + Send

type DisableDriverResponseFut: Future<Output = Result<ManagerDisableDriverResult, Error>> + Send

type EnableDriverResponseFut: Future<Output = Result<ManagerEnableDriverResult, Error>> + Send

type BindAllUnboundNodesResponseFut: Future<Output = Result<ManagerBindAllUnboundNodesResult, Error>> + Send

type AddTestNodeResponseFut: Future<Output = Result<ManagerAddTestNodeResult, Error>> + Send

type RemoveTestNodeResponseFut: Future<Output = Result<ManagerRemoveTestNodeResult, Error>> + Send

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

type RestartWithDictionaryResponseFut: Future<Output = Result<ManagerRestartWithDictionaryResult, Error>> + Send

type RebindCompositesWithDriverResponseFut: Future<Output = Result<ManagerRebindCompositesWithDriverResult, Error>> + Send

Required Methods

fn get_driver_info( &self, driver_filter: &[String], iterator: ServerEnd<DriverInfoIteratorMarker>, ) -> Result<(), Error>

fn get_composite_node_specs( &self, name_filter: Option<&str>, iterator: ServerEnd<CompositeNodeSpecIteratorMarker>, ) -> Result<(), Error>

fn get_node_info( &self, node_filter: &[String], iterator: ServerEnd<NodeInfoIteratorMarker>, exact_match: bool, ) -> Result<(), Error>

fn get_composite_info( &self, iterator: ServerEnd<CompositeInfoIteratorMarker>, ) -> Result<(), Error>

fn get_driver_host_info( &self, iterator: ServerEnd<DriverHostInfoIteratorMarker>, ) -> Result<(), Error>

fn restart_driver_hosts( &self, driver_url: &str, rematch_flags: RestartRematchFlags, ) -> Self::RestartDriverHostsResponseFut

fn disable_driver( &self, driver_url: &str, package_hash: Option<&str>, ) -> Self::DisableDriverResponseFut

fn enable_driver( &self, driver_url: &str, package_hash: Option<&str>, ) -> Self::EnableDriverResponseFut

fn bind_all_unbound_nodes(&self) -> Self::BindAllUnboundNodesResponseFut

fn add_test_node(&self, args: &TestNodeAddArgs) -> Self::AddTestNodeResponseFut

fn remove_test_node(&self, name: &str) -> Self::RemoveTestNodeResponseFut

fn wait_for_bootup(&self) -> Self::WaitForBootupResponseFut

fn restart_with_dictionary( &self, moniker: &str, dictionary: DictionaryRef, ) -> Self::RestartWithDictionaryResponseFut

fn rebind_composites_with_driver( &self, driver_url: &str, ) -> Self::RebindCompositesWithDriverResponseFut

Implementors

impl ManagerProxyInterface for ManagerProxy

type RestartDriverHostsResponseFut = QueryResponseFut<Result<u32, i32>>

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

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

type BindAllUnboundNodesResponseFut = QueryResponseFut<Result<Vec<NodeBindingInfo>, i32>>

type AddTestNodeResponseFut = QueryResponseFut<Result<(), NodeError>>

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

type WaitForBootupResponseFut = QueryResponseFut<()>

type RestartWithDictionaryResponseFut = QueryResponseFut<Result<EventPair, i32>>

type RebindCompositesWithDriverResponseFut = QueryResponseFut<Result<u32, i32>>