Struct mainnet_lib::InMemoryNode

pub struct InMemoryNode {
    block_notifier: SharedPharos<Block>,
    ledger: Arc<RwLock<Ledger>>,
    leadership_process: JoinHandle<()>,
}

In memory cardano node implementation. Basic design contains read write lock over ledger struct as well as background task for updating ledger

Fields

block_notifier: SharedPharos<Block>

ledger: Arc<RwLock<Ledger>>

leadership_process: JoinHandle<()>

Implementations

impl InMemoryNode

pub fn settings( &self ) -> Result<Settings, PoisonError<RwLockReadGuard<'_, Ledger>>>

Retrieves settings carved in block0

Errors

On accessing shard ledger state

pub fn push_transaction(&mut self, transaction: Transaction)

Adds new transaction to mempool

Panics

On accessing shard ledger state

pub fn push_transactions(&mut self, transaction: Vec<Transaction>)

Adds collection of new transactions to mempool

Panics

On accessing shard ledger state

pub fn wait_for_txs_to_be_in_block(&self)

Waits for all transactions from mempool to be included in block

Panics

On accessing shard ledger state

pub fn start(block0: Block0) -> Self

Starts node process

Panics

On accessing ledger state

pub fn start_from_ledger(ledger: Ledger) -> Self

Starts node process from ledger

Panics

On accessing ledger state

Trait Implementations

impl Drop for InMemoryNode

fn drop(&mut self)

Executes the destructor for this type.

impl Observable<Block> for InMemoryNode

type Error = PharErr

The error type that is returned if observing is not possible.

fn observe( &mut self, options: ObserveConfig<Block> ) -> Observe<'_, Block, Self::Error>

Add an observer to the observable. Options allow chosing the channel type and to filter events with a predicate.