Struct snarkos_node_bft::Worker

pub struct Worker<N: Network> { /* private fields */ }

Implementations

impl<N: Network> Worker<N>

pub fn new( id: u8, gateway: Arc<dyn Transport<N>>, storage: Storage<N>, ledger: Arc<dyn LedgerService<N>>, proposed_batch: Arc<ProposedBatch<N>> ) -> Result<Self>

Initializes a new worker instance.

pub fn run(&self, receiver: WorkerReceiver<N>)

Run the worker instance.

pub const fn id(&self) -> u8

Returns the worker ID.

impl<N: Network> Worker<N>

pub fn num_transmissions(&self) -> usize

Returns the number of transmissions in the ready queue.

pub fn num_ratifications(&self) -> usize

Returns the number of ratifications in the ready queue.

pub fn num_solutions(&self) -> usize

Returns the number of solutions in the ready queue.

pub fn num_transactions(&self) -> usize

Returns the number of transactions in the ready queue.

impl<N: Network> Worker<N>

pub fn transmission_ids(&self) -> IndexSet<TransmissionID<N>>

Returns the transmission IDs in the ready queue.

pub fn transmissions(&self) -> IndexMap<TransmissionID<N>, Transmission<N>>

Returns the transmissions in the ready queue.

pub fn solutions( &self ) -> impl '_ + Iterator<Item = (PuzzleCommitment<N>, Data<ProverSolution<N>>)>

Returns the solutions in the ready queue.

pub fn transactions( &self ) -> impl '_ + Iterator<Item = (N::TransactionID, Data<Transaction<N>>)>

Returns the transactions in the ready queue.

impl<N: Network> Worker<N>

pub fn contains_transmission( &self, transmission_id: impl Into<TransmissionID<N>> ) -> bool

Returns true if the transmission ID exists in the ready queue, proposed batch, storage, or ledger.

pub fn get_transmission( &self, transmission_id: TransmissionID<N> ) -> Option<Transmission<N>>

Returns the transmission if it exists in the ready queue, proposed batch, storage.

Note: We explicitly forbid retrieving a transmission from the ledger, as transmissions in the ledger are not guaranteed to be invalid for the current batch.

pub async fn get_or_fetch_transmission( &self, peer_ip: SocketAddr, transmission_id: TransmissionID<N> ) -> Result<(TransmissionID<N>, Transmission<N>)>

Returns the transmissions if it exists in the worker, or requests it from the specified peer.

Trait Implementations

impl<N: Clone + Network> Clone for Worker<N>

fn clone(&self) -> Worker<N>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.