Struct mithril_aggregator::database::repository::StakePoolStore

pub struct StakePoolStore { /* private fields */ }

Service to deal with stake pools (read & write).

Implementations

impl StakePoolStore

pub fn new( connection: Arc<SqliteConnection>, retention_limit: Option<u64>, ) -> Self

Create a new StakePool service

Trait Implementations

impl EpochPruningTask for StakePoolStore

fn pruned_data(&self) -> &'static str

Get the name of the data that will be pruned.

fn prune<'life0, 'async_trait>( &'life0 self, epoch: Epoch, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>

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

Prune the datasource based on the given current epoch.

impl StakeDistributionRetriever for StakePoolStore

fn retrieve<'life0, 'async_trait>( &'life0 self, epoch: Epoch, ) -> Pin<Box<dyn Future<Output = StdResult<Option<StakeDistribution>>> + Send + 'async_trait>>

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

Retrieve the StakeDistribution for a given epoch

impl StakeStorer for StakePoolStore

fn save_stakes<'life0, 'async_trait>( &'life0 self, epoch: Epoch, stakes: StakeDistribution, ) -> Pin<Box<dyn Future<Output = StdResult<Option<StakeDistribution>>> + Send + 'async_trait>>

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

Save the stakes in the store for a given epoch.

fn get_stakes<'life0, 'async_trait>( &'life0 self, epoch: Epoch, ) -> Pin<Box<dyn Future<Output = StdResult<Option<StakeDistribution>>> + Send + 'async_trait>>

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

Get the stakes of all party at a given epoch.