Struct FakeObserver

pub struct FakeObserver {
    pub signers: RwLock<Vec<SignerWithStake>>,
    pub current_time_point: RwLock<Option<TimePoint>>,
    pub datums: RwLock<Vec<TxDatum>>,
    pub current_era: RwLock<String>,
}

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_time_point: RwLock<Option<TimePoint>>

A TimePoint, used by get_current_epoch

datums: RwLock<Vec<TxDatum>>

A list of TxDatum, used by get_current_datums

current_era: RwLock<String>

A Cardano era, used by get_current_era

Implementations

impl FakeObserver

pub fn new(current_time_point: Option<TimePoint>) -> Self

FakeObserver factory

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

Increase by one the epoch of the current_time_point.

pub async fn increase_block_number(&self, increment: u64) -> Option<BlockNumber>

Increase the block number of the current_time_point by the given increment.

pub async fn decrease_block_number(&self, decrement: u64) -> Option<BlockNumber>

Decrease the block number of the current_time_point by the given decrement.

pub async fn increase_slot_number(&self, increment: u64) -> Option<SlotNumber>

Increase the slot number of the current_time_point by the given increment.

pub async fn decrease_slot_number(&self, decrement: u64) -> Option<SlotNumber>

Decrease the slot number of the current_time_point by the given decrement.

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

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

pub async fn set_current_time_point( &self, new_current_time_point: Option<TimePoint>, )

Set the time point

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

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

pub async fn set_current_era(&self, new_current_era: String)

Set the current Era get_current_era.

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_era<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<String>, ChainObserverError>> + Send + 'async_trait>>

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

Retrieve the current era of the Cardano network

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_chain_point<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<ChainPoint>, ChainObserverError>> + Send + 'async_trait>>

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

Retrieve the current chain point 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.