Struct mithril_common::chain_observer::FakeObserver

pub struct FakeObserver {
    pub signers: RwLock<Vec<SignerWithStake>>,
    pub current_beacon: RwLock<Option<Beacon>>,
    pub datums: RwLock<Vec<TxDatum>>,
}

Available on crate feature test_tools only.

A Fake ChainObserver for testing purpose using fixed data.

Fields

signers: RwLock<Vec<SignerWithStake>>

A list of SignerWithStake, used for get_current_stake_distribution.

current_beacon: RwLock<Option<Beacon>>

A Beacon, used by get_current_epoch

datums: RwLock<Vec<TxDatum>>

A list of TxDatum, used by get_current_datums

Implementations

impl FakeObserver

pub fn new(current_beacon: Option<Beacon>) -> Self

FakeObserver factory

pub async fn next_epoch(&self) -> Option<Epoch>

Increase by one the epoch of the current_beacon.

pub async fn set_signers(&self, new_signers: Vec<SignerWithStake>)

Set the signers that will used to compute the result of get_current_stake_distribution.

pub async fn set_datums(&self, new_datums: Vec<TxDatum>)

Set the datums that will used to compute the result of get_current_datums.

Trait Implementations

impl ChainObserver for FakeObserver

fn get_current_datums<'life0, 'life1, 'async_trait>( &'life0 self, _address: &'life1 ChainAddress ) -> Pin<Box<dyn Future<Output = Result<Vec<TxDatum>, ChainObserverError>> + Send + 'async_trait>>

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

Retrieve the datums associated to an address

fn get_current_epoch<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<Epoch>, ChainObserverError>> + Send + 'async_trait>>

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

Retrieve the current epoch of the Cardano network

fn get_current_stake_distribution<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = Result<Option<StakeDistribution>, ChainObserverError>> + Send + 'async_trait>>

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

Retrieve the current stake distribution of the Cardano network

fn get_current_kes_period<'life0, 'life1, 'async_trait>( &'life0 self, _opcert: &'life1 OpCert ) -> Pin<Box<dyn Future<Output = Result<Option<KESPeriod>, ChainObserverError>> + Send + 'async_trait>>

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

Retrieve the KES period of an operational certificate

impl Default for FakeObserver

fn default() -> Self

Returns the “default value” for a type.