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;

    // 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 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;
}

Required Associated Types§

Required Methods§

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

source

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

Implementors§

source§

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>>