Struct ConsensusEngine 

pub struct ConsensusEngine { /* private fields */ }

The consensus engine.

Implementations

impl ConsensusEngine

pub fn new( config: EngineConfig, validator_key: Option<PrivateKey>, validators: ValidatorSet, mempool: Arc<Mempool>, ) -> Self

Creates a new consensus engine.

pub fn transaction_sender(&self) -> Sender<Transaction>

Returns a handle for submitting transactions.

pub fn subscribe(&self) -> Receiver<ConsensusEvent>

Subscribes to consensus events.

pub fn state(&self) -> EngineState

Returns the current engine state.

pub fn view(&self) -> u64

Returns the current view.

pub fn finalized_height(&self) -> u64

Returns the latest finalized height.

pub fn is_leader(&self) -> bool

Checks if we are the leader for the current view.

pub fn current_leader(&self) -> Option<SerializablePublicKey>

Gets the current leader.

pub async fn submit_transaction(&self, tx: Transaction) -> Result<TransactionId>

Submits a transaction to the mempool.

pub fn get_block(&self, height: u64) -> Option<FinalizedBlock>

Gets a finalized block by height.

pub fn validators(&self) -> Arc<RwLock<ValidatorSet>>

Gets the validator set.

pub async fn run<A: ConsensusApplication>(&self, app: Arc<A>) -> Result<()>

Runs the consensus engine.

This is the main event loop that drives consensus.

pub fn advance_view(&self)

Advances to the next view.

pub fn stop(&self)

Stops the engine.