Struct EpochSettingsStore

pub struct EpochSettingsStore { /* private fields */ }

Service to deal with epoch settings (read & write).

Implementations

impl EpochSettingsStore

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

Create a new EpochSettings store

pub fn replace_cardano_signing_config_empty_values( &self, cardano_signing_config: CardanoTransactionsSigningConfig, ) -> StdResult<()>

👎Deprecated since 0.5.72: temporary fix, should be removed

Replace empty JSON values ‘{}’ injected with Migration #28

Trait Implementations

impl EpochPruningTask for EpochSettingsStore

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 useless old epoch settings.

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

Get the name of the data that will be pruned.

impl EpochSettingsStorer for EpochSettingsStore

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

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

Save the given AggregatorEpochSettings for the given Epoch.

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

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

Get the saved ProtocolParameter for the given Epoch if any.

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

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

Get the saved AggregatorEpochSettings for the given Epoch if any.

fn handle_discrepancies_at_startup<'life0, 'life1, 'async_trait>( &'life0 self, current_epoch: Epoch, epoch_settings_configuration: &'life1 AggregatorEpochSettings, ) -> Pin<Box<dyn Future<Output = StdResult<()>> + Send + 'async_trait>>

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

Handle discrepancies at startup in the epoch settings store. In case an aggregator has been launched after some epochs of not being up or at initial startup, the discrepancies in the epoch settings store needs to be fixed. The epoch settings needs to be recorded for the working epoch and the next 2 epochs.