Enum RoutingEvent

pub enum RoutingEvent {
    BlockchainUpdated(BlockHash),
    BlockFetchRequest(PeerIndex, BlockHash, BlockId),
    BlockchainRequest(PeerIndex),
}

Variants

BlockchainUpdated(BlockHash)

BlockFetchRequest(PeerIndex, BlockHash, BlockId)

BlockchainRequest(PeerIndex)

Trait Implementations

impl Debug for RoutingEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl ProcessEvent<RoutingEvent> for RoutingThread

fn process_network_event<'life0, 'async_trait>( &'life0 mut self, event: NetworkEvent, ) -> Pin<Box<dyn Future<Output = Option<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Processes an event coming from other peers via network controller

fn process_timer_event<'life0, 'async_trait>( &'life0 mut self, duration: Duration, ) -> Pin<Box<dyn Future<Output = Option<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Triggered with each timer tick. duration will vary due to other processing tasks in the same thread.

fn process_event<'life0, 'async_trait>( &'life0 mut self, event: RoutingEvent, ) -> Pin<Box<dyn Future<Output = Option<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Processes the incoming events from other threads/controllers.

fn on_init<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn on_stat_interval<'life0, 'async_trait>( &'life0 mut self, current_time: Timestamp, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn is_ready_to_process(&self) -> bool