Struct ntp_daemon::spawn::standard::StandardSpawner

pub struct StandardSpawner { /* private fields */ }

Implementations

impl StandardSpawner

pub fn new( config: StandardPeerConfig, network_wait_period: Duration ) -> StandardSpawner

Trait Implementations

impl BasicSpawner for StandardSpawner

type Error = StandardSpawnError

fn handle_init<'life0, 'life1, 'async_trait>( &'life0 mut self, action_tx: &'life1 Sender<SpawnEvent> ) -> Pin<Box<dyn Future<Output = Result<(), StandardSpawnError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle initial spawning.

fn handle_peer_removed<'life0, 'life1, 'async_trait>( &'life0 mut self, removed_peer: PeerRemovedEvent, action_tx: &'life1 Sender<SpawnEvent> ) -> Pin<Box<dyn Future<Output = Result<(), StandardSpawnError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Event handler for when a peer is removed.

fn get_id(&self) -> SpawnerId

Get the id of the spawner

fn get_addr_description(&self) -> String

Get a description of the address this spawner is connected to

fn get_description(&self) -> &str

Get a description of the type of spawner

fn handle_registered<'life0, 'life1, 'async_trait>( &'life0 mut self, _event: PeerCreateParameters, _action_tx: &'life1 Sender<SpawnEvent> ) -> Pin<Box<dyn Future<Output = Result<(), Self::Error>> + Send + 'async_trait>>where Self: Send + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Event handler for when a peer is succesfully registered in the system