Struct MipStore 

pub struct MipStore(pub Arc<RwLock<MipStoreRaw>>);

Database for all MIP info

Tuple Fields

0: Arc<RwLock<MipStoreRaw>>

Implementations

impl MipStore

pub fn get_network_version_current(&self) -> u32

Retrieve the current network version to set in block header

pub fn get_network_version_active_at(&self, ts: MassaTime) -> u32

Retrieve the last active version at the given timestamp

pub fn get_network_version_to_announce(&self) -> Option<u32>

Retrieve the network version number to announce in block header return 0 is there is nothing to announce

pub fn update_network_version_stats( &mut self, slot_timestamp: MassaTime, network_versions: Option<(u32, Option<u32>)>, )

pub fn update_with( &mut self, mip_store: &MipStore, ) -> Result<(Vec<MipInfo>, BTreeMap<MipInfo, MipState>), UpdateWithError>

pub fn get_latest_component_version_at( &self, component: &MipComponent, ts: MassaTime, ) -> u32

Get latest version at given timestamp (e.g. slot) for the given MipComponent

pub(crate) fn get_all_active_component_versions( &self, component: &MipComponent, ) -> Vec<u32>

Get all versions in ‘Active state’ for the given MipComponent

pub(crate) fn get_all_component_versions( &self, component: &MipComponent, ) -> BTreeMap<u32, ComponentStateTypeId>

Get all versions (at any state) for the given MipComponent

pub fn get_mip_status(&self) -> BTreeMap<MipInfo, ComponentStateTypeId>

Retrieve a list of MIP info with their corresponding state (as id) - used for grpc API

pub fn is_consistent_with_shutdown_period( &self, shutdown_start: Slot, shutdown_end: Slot, thread_count: u8, t0: MassaTime, genesis_timestamp: MassaTime, ) -> Result<(), IsConsistentWithShutdownPeriodError>

pub fn update_for_network_shutdown( &mut self, shutdown_start: Slot, shutdown_end: Slot, thread_count: u8, t0: MassaTime, genesis_timestamp: MassaTime, ) -> Result<(), ModelsError>

pub fn is_key_value_valid( &self, serialized_key: &[u8], serialized_value: &[u8], ) -> bool

pub fn update_batches( &self, db_batch: &mut DBBatch, db_versioning_batch: &mut DBBatch, between: Option<(&MassaTime, &MassaTime)>, ) -> Result<(), SerializeError>

pub fn extend_from_db( &mut self, db: ShareableMassaDBController, ) -> Result<(Vec<MipInfo>, BTreeMap<MipInfo, MipState>), ExtendFromDbError>

pub fn started_mips_missing_from_db( &self, db: &ShareableMassaDBController, at: MassaTime, ) -> Vec<MipInfo>

MIPs of this store that a bootstrap server’s streamed state (db) does not contain, and whose start is at or before at, the timestamp of the bootstrapped final slot.

Such a server runs a release that predates the MIP, so it cannot provide the MIP’s state. Accepting it would leave this node replaying the MIP from its compiled-in Defined state, starting at its own first processed slot: the history it records (and, past lock-in, its activation) would differ from the rest of the network’s, and once the MIP is Active that history is part of the hashed final state. Before start nobody has recorded anything for the MIP yet, so replaying it locally is deterministic and such a server is still usable.

pub fn reset_db(&self, db: ShareableMassaDBController)

pub fn try_from_db( db: ShareableMassaDBController, cfg: MipStatsConfig, ) -> Result<Self, ExtendFromDbError>

Create a MIP store with what is written on the disk

Trait Implementations

impl Clone for MipStore

fn clone(&self) -> MipStore

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MipStore

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<const N: usize> TryFrom<([(MipInfo, MipState); N], MipStatsConfig)> for MipStore

type Error = UpdateWithError

The type returned in the event of a conversion error.

fn try_from( (value, cfg): ([(MipInfo, MipState); N], MipStatsConfig), ) -> Result<Self, Self::Error>

Performs the conversion.