Enum ConsensusEvent

pub enum ConsensusEvent {
    NewGoldenTicket {
        golden_ticket: GoldenTicket,
    },
    BlockFetched {
        peer_index: u64,
        block: Block,
    },
    NewTransaction {
        transaction: Transaction,
    },
    NewTransactions {
        transactions: Vec<Transaction>,
    },
}

Variants

NewGoldenTicket

Fields

golden_ticket: GoldenTicket

BlockFetched

Fields

peer_index: u64

block: Block

NewTransaction

Fields

transaction: Transaction

NewTransactions

Fields

transactions: Vec<Transaction>

Trait Implementations

impl Debug for ConsensusEvent

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

Formats the value using the given formatter.

impl ProcessEvent<ConsensusEvent> for ConsensusThread

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: ConsensusEvent, ) -> 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