Skip to main content

NodeManager

Trait NodeManager 

Source
pub trait NodeManager {
    // Required methods
    fn clone_box(&self) -> Box<dyn NodeManager>;
    fn bind(&self, node: &Rc<Node>, tracker: Rc<RefCell<BindResultTracker>>);
    fn bind_to_url(
        &self,
        node: &Rc<Node>,
        driver_url_suffix: &str,
        tracker: Rc<RefCell<BindResultTracker>>,
    );
    fn create_driver_host<'life0, 'async_trait>(
        &'life0 self,
        use_next_vdso: bool,
        driver_host_name_for_colocation: String,
    ) -> Pin<Box<dyn Future<Output = Result<Rc<dyn DriverHost>, Status>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn create_driver_host_dynamic_linker<'life0, 'async_trait>(
        &'life0 self,
        driver_host_name_for_colocation: String,
    ) -> Pin<Box<dyn Future<Output = Result<Rc<dyn DriverHost>, Status>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn is_test_shutdown_delay_enabled(&self) -> bool;
    fn get_shutdown_test_rng(&self) -> Weak<RefCell<StdRng>>;
    fn wait_for_bootup<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = ()> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_dictionary_util(&self) -> Result<Rc<DictionaryUtil>, Status>;
    fn memory_attributor(&self) -> Option<Rc<dyn MemoryAttributor>>;

    // Provided methods
    fn start_driver(
        &self,
        _node: &Rc<Node>,
        _url: &str,
        _package_type: DriverPackageType,
    ) -> Result<(), Status> { ... }
    fn get_driver_host(
        &self,
        _driver_host_name_for_colocation: &str,
    ) -> Option<Rc<dyn DriverHost>> { ... }
}

Required Methods§

Source

fn clone_box(&self) -> Box<dyn NodeManager>

Source

fn bind(&self, node: &Rc<Node>, tracker: Rc<RefCell<BindResultTracker>>)

Source

fn bind_to_url( &self, node: &Rc<Node>, driver_url_suffix: &str, tracker: Rc<RefCell<BindResultTracker>>, )

Source

fn create_driver_host<'life0, 'async_trait>( &'life0 self, use_next_vdso: bool, driver_host_name_for_colocation: String, ) -> Pin<Box<dyn Future<Output = Result<Rc<dyn DriverHost>, Status>> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn create_driver_host_dynamic_linker<'life0, 'async_trait>( &'life0 self, driver_host_name_for_colocation: String, ) -> Pin<Box<dyn Future<Output = Result<Rc<dyn DriverHost>, Status>> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn is_test_shutdown_delay_enabled(&self) -> bool

Source

fn get_shutdown_test_rng(&self) -> Weak<RefCell<StdRng>>

Source

fn wait_for_bootup<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn get_dictionary_util(&self) -> Result<Rc<DictionaryUtil>, Status>

Source

fn memory_attributor(&self) -> Option<Rc<dyn MemoryAttributor>>

Provided Methods§

Source

fn start_driver( &self, _node: &Rc<Node>, _url: &str, _package_type: DriverPackageType, ) -> Result<(), Status>

Source

fn get_driver_host( &self, _driver_host_name_for_colocation: &str, ) -> Option<Rc<dyn DriverHost>>

Implementors§