pub struct Persistence {
pub(super) db: SqlStorage,
gc_opt: ConsensusPruningOptions,
last_usage_check: Arc<Mutex<Option<Instant>>>,
consensus_only: bool,
internal_metrics: PersistenceMetricsValue,
pub(super) probe: Option<StorageProbe>,
}Expand description
SQL-backed persistence.
Fields§
§db: SqlStorage§gc_opt: ConsensusPruningOptions§last_usage_check: Arc<Mutex<Option<Instant>>>When consensus storage usage was last measured, shared by clones.
consensus_only: bool§internal_metrics: PersistenceMetricsValueA reference to the internal metrics
probe: Option<StorageProbe>Startup findings about the filesystem and SQLite pragmas backing db, on SQLite only.
Implementations§
Source§impl Persistence
impl Persistence
Sourceasync fn serializable_retry<F, Fut, T>(
&self,
op: &'static str,
f: F,
) -> Result<T>
async fn serializable_retry<F, Fut, T>( &self, op: &'static str, f: F, ) -> Result<T>
Run f under the database’s serialization-conflict retry policy.
Sourceasync fn migrate_quorum_proposal_leaf_hashes(&self) -> Result<()>
async fn migrate_quorum_proposal_leaf_hashes(&self) -> Result<()>
Ensure the leaf_hash column is populated for all existing quorum proposals.
This column was added in a migration, but because it requires computing a commitment of the
existing data, it is not easy to populate in the SQL migration itself. Thus, on startup, we
check if there are any just-migrated quorum proposals with a NULL value for this column,
and if so we populate the column manually.
Sourceasync fn load_processed_view(&self) -> Result<Option<ViewNumber>>
async fn load_processed_view(&self) -> Result<Option<ViewNumber>>
The last_processed_view cursor: highest view with a generated decide event, or None.
async fn generate_decide_events( &self, consumer: &impl EventConsumer, ) -> Result<()>
async fn skip_decide_events(&self, view: ViewNumber) -> Result<()>
async fn load_state_certs( tx: &mut Transaction<Read>, from_view: ViewNumber, to_view: ViewNumber, ) -> Result<BTreeMap<u64, LightClientStateUpdateCertificateV2<SeqTypes>>>
Sourceasync fn prune_to_retention(&self, cur_view: ViewNumber) -> Result<()>
async fn prune_to_retention(&self, cur_view: ViewNumber) -> Result<()>
Prune everything older than the target retention, then, at most once per usage check interval, prune toward the minimum retention if storage is over the target usage.
async fn prune_below(&self, view: u64) -> Result<()>
Sourceasync fn consensus_storage_usage(&self) -> Result<u64>
async fn consensus_storage_usage(&self) -> Result<u64>
Measured in a read transaction: on SQLite it scans every page of the pruned tables, and holding the write lock that long stalls the vote and proposal writes consensus waits on.
fn usage_check_due(&self) -> bool
Trait Implementations§
Source§impl Clone for Persistence
impl Clone for Persistence
Source§fn clone(&self) -> Persistence
fn clone(&self) -> Persistence
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for Persistence
impl Debug for Persistence
Source§impl MembershipPersistence for Persistence
impl MembershipPersistence for Persistence
Source§fn load_events<'life0, 'async_trait>(
&'life0 self,
from_l1_block: u64,
to_l1_block: u64,
) -> Pin<Box<dyn Future<Output = Result<(Option<EventsPersistenceRead>, Vec<(EventKey, StakeTableEvent)>)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_events<'life0, 'async_trait>(
&'life0 self,
from_l1_block: u64,
to_l1_block: u64,
) -> Pin<Box<dyn Future<Output = Result<(Option<EventsPersistenceRead>, Vec<(EventKey, StakeTableEvent)>)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Loads all events from persistent storage up to the specified L1 block.
§Returns
Returns a tuple containing:
Option<u64>- The queried L1 block for which all events have been successfully fetched.Vec<(EventKey, StakeTableEvent)>- A list of events, where each entry is a tuple of the event key event key is (l1 block number, log index) and the corresponding StakeTable event.
Source§fn load_stake<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<StakeTuple>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_stake<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<StakeTuple>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load stake table for epoch from storage
Source§fn load_drb_result<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<DrbResult>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_drb_result<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<DrbResult>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the DRB result for
epoch.Source§fn load_epoch_root<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<Header>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_epoch_root<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<Header>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the epoch root block header for
epoch.Source§fn store_epoch_root<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
block_header: Header,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn store_epoch_root<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
block_header: Header,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Store the epoch root block header for
epoch.Source§fn load_latest_stake<'life0, 'async_trait>(
&'life0 self,
limit: u64,
) -> Pin<Box<dyn Future<Output = Result<Option<Vec<IndexedStake>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_latest_stake<'life0, 'async_trait>(
&'life0 self,
limit: u64,
) -> Pin<Box<dyn Future<Output = Result<Option<Vec<IndexedStake>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load stake tables for storage for latest
n known epochsSource§fn store_stake<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
stake: AuthenticatedValidatorMap,
block_reward: Option<RewardAmount>,
stake_table_hash: Option<StakeTableHash>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn store_stake<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
stake: AuthenticatedValidatorMap,
block_reward: Option<RewardAmount>,
stake_table_hash: Option<StakeTableHash>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Store stake table at
epoch in the persistence layerfn store_events<'life0, 'async_trait>(
&'life0 self,
l1_finalized: u64,
events: Vec<(EventKey, StakeTableEvent)>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn delete_stake_tables<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn delete_stake_tables<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Delete all stake table events, the L1 block tracker, and the epoch DRB and root data.
fn store_all_validators<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
all_validators: RegisteredValidatorMap,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_all_validators<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
offset: u64,
limit: u64,
) -> Pin<Box<dyn Future<Output = Result<Vec<RegisteredValidator<PubKey>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§impl Provider<SeqTypes, PayloadRequest> for Persistence
impl Provider<SeqTypes, PayloadRequest> for Persistence
Source§impl Provider<SeqTypes, VidCommonRequest> for Persistence
impl Provider<SeqTypes, VidCommonRequest> for Persistence
Source§impl SequencerPersistence for Persistence
impl SequencerPersistence for Persistence
Source§fn into_catchup_provider(
self,
backoff: BackoffParams,
) -> Result<Arc<dyn StateCatchup>>
fn into_catchup_provider( self, backoff: BackoffParams, ) -> Result<Arc<dyn StateCatchup>>
Use this storage as a state catchup backend, if supported.
Source§fn load_config<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<NetworkConfig>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_config<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<NetworkConfig>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the orchestrator config from storage. Read more
Source§fn save_config<'life0, 'life1, 'async_trait>(
&'life0 self,
cfg: &'life1 NetworkConfig,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn save_config<'life0, 'life1, 'async_trait>(
&'life0 self,
cfg: &'life1 NetworkConfig,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Save the orchestrator config to storage.
Source§fn persist_decided_leaves<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
leaf_chain: impl 'async_trait + IntoIterator<Item = (&'life1 LeafInfo<SeqTypes>, CertificatePair<SeqTypes>)> + Send,
cert2: Option<&'life2 Certificate2<SeqTypes>>,
_consumer: &'life3 (impl 'async_trait + EventConsumer + 'static),
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
fn persist_decided_leaves<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
leaf_chain: impl 'async_trait + IntoIterator<Item = (&'life1 LeafInfo<SeqTypes>, CertificatePair<SeqTypes>)> + Send,
cert2: Option<&'life2 Certificate2<SeqTypes>>,
_consumer: &'life3 (impl 'async_trait + EventConsumer + 'static),
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait,
Persist decided leaves only (the critical, must-not-lag half of a decide; also the
anchor for restart recovery). Query-service ingestion and GC are deferred to
process_decided_events. Backends with no replayable storage
(e.g. NoStorage) may instead forward decide events to consumer here. Read moreSource§fn process_decided_events<'life0, 'life1, 'async_trait>(
&'life0 self,
view: ViewNumber,
consumer: &'life1 (impl 'async_trait + EventConsumer + 'static),
) -> Pin<Box<dyn Future<Output = Result<Option<ViewNumber>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn process_decided_events<'life0, 'life1, 'async_trait>(
&'life0 self,
view: ViewNumber,
consumer: &'life1 (impl 'async_trait + EventConsumer + 'static),
) -> Pin<Box<dyn Future<Output = Result<Option<ViewNumber>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Generate decide events for
consumer from persisted leaves, then GC processed data.
Cursor-driven (e.g. last_processed_view): advances only on success, so it may lag
consensus without losing data. Read moreSource§fn load_latest_acted_view<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<ViewNumber>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_latest_acted_view<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<ViewNumber>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the highest view saved with
save_voted_view.Source§fn load_restart_view<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<ViewNumber>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_restart_view<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<ViewNumber>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the view to restart from.
fn load_anchor_leaf<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<(Leaf2, CertificatePair<SeqTypes>)>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_anchor_view<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<ViewNumber>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_da_proposal<'life0, 'async_trait>(
&'life0 self,
view: ViewNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<Proposal<SeqTypes, DaProposal2<SeqTypes>>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn load_quorum_proposals<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<BTreeMap<ViewNumber, Proposal<SeqTypes, QuorumProposalWrapper<SeqTypes>>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_quorum_proposals<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<BTreeMap<ViewNumber, Proposal<SeqTypes, QuorumProposalWrapper<SeqTypes>>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the proposals saved by consensus
fn load_quorum_proposal<'life0, 'async_trait>(
&'life0 self,
view: ViewNumber,
) -> Pin<Box<dyn Future<Output = Result<Proposal<SeqTypes, QuorumProposalWrapper<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn append_vid<'life0, 'life1, 'async_trait>(
&'life0 self,
proposal: &'life1 Proposal<SeqTypes, VidDisperseShare<SeqTypes>>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn append_da<'life0, 'life1, 'async_trait>(
&'life0 self,
proposal: &'life1 Proposal<SeqTypes, DaProposal<SeqTypes>>,
vid_commit: VidCommitment,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn record_action<'life0, 'async_trait>(
&'life0 self,
view: ViewNumber,
action: HotShotAction,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn append_quorum_proposal2<'life0, 'life1, 'async_trait>(
&'life0 self,
proposal: &'life1 Proposal<SeqTypes, QuorumProposalWrapper<SeqTypes>>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Source§fn append_cert2<'life0, 'async_trait>(
&'life0 self,
view: ViewNumber,
cert2: Certificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn append_cert2<'life0, 'async_trait>(
&'life0 self,
view: ViewNumber,
cert2: Certificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Persist cert2 for the given view.
Source§fn load_cert2<'life0, 'async_trait>(
&'life0 self,
view: ViewNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<Certificate2<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_cert2<'life0, 'async_trait>(
&'life0 self,
view: ViewNumber,
) -> Pin<Box<dyn Future<Output = Result<Option<Certificate2<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load a persisted cert2 by view, if any.
Source§fn append_high_qc2<'life0, 'async_trait>(
&'life0 self,
high_qc: QuorumCertificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn append_high_qc2<'life0, 'async_trait>(
&'life0 self,
high_qc: QuorumCertificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Persist the new protocol’s locked QC, written before each phase-2 vote. Read more
Source§fn load_high_qc2<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<QuorumCertificate2<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_high_qc2<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<QuorumCertificate2<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the persisted locked QC, if any.
Source§fn append_boundary_qc2<'life0, 'async_trait>(
&'life0 self,
qc: QuorumCertificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn append_boundary_qc2<'life0, 'async_trait>(
&'life0 self,
qc: QuorumCertificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Persist the new protocol’s latest epoch boundary certificate: the own
Certificate1 of the last block of an epoch, at the block’s view. Read moreSource§fn load_boundary_qc2<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<QuorumCertificate2<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_boundary_qc2<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<QuorumCertificate2<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the persisted boundary certificate, if any.
fn load_upgrade_certificate<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<UpgradeCertificate<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn store_upgrade_certificate<'life0, 'async_trait>(
&'life0 self,
decided_upgrade_certificate: Option<UpgradeCertificate<SeqTypes>>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn append_next_epoch_high_qc2<'life0, 'async_trait>(
&'life0 self,
next_epoch_high_qc: NextEpochQuorumCertificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Source§fn store_eqc<'life0, 'async_trait>(
&'life0 self,
high_qc: QuorumCertificate2<SeqTypes>,
next_epoch_high_qc: NextEpochQuorumCertificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn store_eqc<'life0, 'async_trait>(
&'life0 self,
high_qc: QuorumCertificate2<SeqTypes>,
next_epoch_high_qc: NextEpochQuorumCertificate2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Update the current eQC in storage.
Source§fn load_eqc<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Option<(QuorumCertificate2<SeqTypes>, NextEpochQuorumCertificate2<SeqTypes>)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_eqc<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Option<(QuorumCertificate2<SeqTypes>, NextEpochQuorumCertificate2<SeqTypes>)>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
Load the current eQC from storage.
fn append_da2<'life0, 'life1, 'async_trait>(
&'life0 self,
proposal: &'life1 Proposal<SeqTypes, DaProposal2<SeqTypes>>,
vid_commit: VidCommitment,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn store_drb_result<'life0, 'async_trait>(
&'life0 self,
epoch: EpochNumber,
drb_result: DrbResult,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn store_drb_input<'life0, 'async_trait>(
&'life0 self,
drb_input: DrbInput,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_drb_input<'life0, 'async_trait>(
&'life0 self,
epoch: u64,
) -> Pin<Box<dyn Future<Output = Result<DrbInput>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn add_state_cert<'life0, 'async_trait>(
&'life0 self,
state_cert: LightClientStateUpdateCertificateV2<SeqTypes>,
) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_state_cert<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Option<LightClientStateUpdateCertificateV2<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn load_start_epoch_info<'life0, 'async_trait>(
&'life0 self,
) -> Pin<Box<dyn Future<Output = Result<Vec<InitializerEpochInfo<SeqTypes>>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn enable_metrics(&mut self, metrics: &dyn Metrics)
Source§fn load_consensus_state<'life0, 'async_trait>(
&'life0 self,
state: NodeState,
upgrade: Upgrade,
) -> Pin<Box<dyn Future<Output = Result<(HotShotInitializer<SeqTypes>, Option<ViewNumber>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
fn load_consensus_state<'life0, 'async_trait>(
&'life0 self,
state: NodeState,
upgrade: Upgrade,
) -> Pin<Box<dyn Future<Output = Result<(HotShotInitializer<SeqTypes>, Option<ViewNumber>), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
Self: 'async_trait,
Load the latest known consensus state. Read more
Source§fn persist_event<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
event: &'life1 CoordinatorEvent<SeqTypes>,
consumer: &'life2 (impl EventConsumer + 'async_trait + 'static),
) -> Pin<Box<dyn Future<Output = Option<ViewNumber>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
fn persist_event<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
event: &'life1 CoordinatorEvent<SeqTypes>,
consumer: &'life2 (impl EventConsumer + 'async_trait + 'static),
) -> Pin<Box<dyn Future<Output = Option<ViewNumber>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
Decode a consensus decide event and persist its leaves, for the consensus event loop.
Returns the decided view on a decide so the caller can wake a background task to run
process_decided_events; None otherwise. Read moreSource§fn append_decided_leaves<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
decided_view: ViewNumber,
leaf_chain: impl IntoIterator<Item = (&'life1 LeafInfo<SeqTypes>, CertificatePair<SeqTypes>)> + Send + 'async_trait,
consumer: &'life2 (impl EventConsumer + 'async_trait + 'static),
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
fn append_decided_leaves<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
decided_view: ViewNumber,
leaf_chain: impl IntoIterator<Item = (&'life1 LeafInfo<SeqTypes>, CertificatePair<SeqTypes>)> + Send + 'async_trait,
consumer: &'life2 (impl EventConsumer + 'async_trait + 'static),
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
Append decided leaves to persistent storage and emit a corresponding event. Read more
Source§impl StateCertPersistence for Persistence
impl StateCertPersistence for Persistence
Auto Trait Implementations§
impl !RefUnwindSafe for Persistence
impl !UnwindSafe for Persistence
impl Freeze for Persistence
impl Send for Persistence
impl Sync for Persistence
impl Unpin for Persistence
impl UnsafeUnpin for Persistence
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
§impl<T> Conv for T
impl<T> Conv for T
§impl<T> Downcast for Twhere
T: Any,
impl<T> Downcast for Twhere
T: Any,
§fn into_any(self: Box<T>) -> Box<dyn Any>
fn into_any(self: Box<T>) -> Box<dyn Any>
Convert
Box<dyn Trait> (where Trait: Downcast) to Box<dyn Any>. Box<dyn Any> can
then be further downcast into Box<ConcreteType> where ConcreteType implements Trait.§fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>
Convert
Rc<Trait> (where Trait: Downcast) to Rc<Any>. Rc<Any> can then be
further downcast into Rc<ConcreteType> where ConcreteType implements Trait.§fn as_any(&self) -> &(dyn Any + 'static)
fn as_any(&self) -> &(dyn Any + 'static)
Convert
&Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &Any’s vtable from &Trait’s.§fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)
Convert
&mut Trait (where Trait: Downcast) to &Any. This is needed since Rust cannot
generate &mut Any’s vtable from &mut Trait’s.§impl<T> DowncastSync for T
impl<T> DowncastSync for T
§impl<T> FmtForward for T
impl<T> FmtForward for T
§fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
fn fmt_binary(self) -> FmtBinary<Self>where
Self: Binary,
Causes
self to use its Binary implementation when Debug-formatted.§fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
fn fmt_display(self) -> FmtDisplay<Self>where
Self: Display,
Causes
self to use its Display implementation when
Debug-formatted.§fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
fn fmt_lower_exp(self) -> FmtLowerExp<Self>where
Self: LowerExp,
Causes
self to use its LowerExp implementation when
Debug-formatted.§fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
fn fmt_lower_hex(self) -> FmtLowerHex<Self>where
Self: LowerHex,
Causes
self to use its LowerHex implementation when
Debug-formatted.§fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
fn fmt_octal(self) -> FmtOctal<Self>where
Self: Octal,
Causes
self to use its Octal implementation when Debug-formatted.§fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
fn fmt_pointer(self) -> FmtPointer<Self>where
Self: Pointer,
Causes
self to use its Pointer implementation when
Debug-formatted.§fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
fn fmt_upper_exp(self) -> FmtUpperExp<Self>where
Self: UpperExp,
Causes
self to use its UpperExp implementation when
Debug-formatted.§fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
fn fmt_upper_hex(self) -> FmtUpperHex<Self>where
Self: UpperHex,
Causes
self to use its UpperHex implementation when
Debug-formatted.§fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
fn fmt_list(self) -> FmtList<Self>where
&'a Self: for<'a> IntoIterator,
Formats each item in a sequence. Read more
§impl<T> FutureExt for T
impl<T> FutureExt for T
§fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
fn with_context(self, otel_cx: Context) -> WithContext<Self> ⓘ
§fn with_current_context(self) -> WithContext<Self> ⓘ
fn with_current_context(self) -> WithContext<Self> ⓘ
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Requestimpl<T> JsonSchemaMaybe for T
§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].§impl<T> Pipe for Twhere
T: ?Sized,
impl<T> Pipe for Twhere
T: ?Sized,
§fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> Rwhere
Self: Sized,
Pipes by value. This is generally the method you want to use. Read more
§fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> Rwhere
R: 'a,
Borrows
self and passes that borrow into the pipe function. Read more§fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> Rwhere
R: 'a,
Mutably borrows
self and passes that borrow into the pipe function. Read more§fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R
§fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R,
) -> R
fn pipe_borrow_mut<'a, B, R>( &'a mut self, func: impl FnOnce(&'a mut B) -> R, ) -> R
§fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R
Borrows
self, then passes self.as_ref() into the pipe function.§fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R
Mutably borrows
self, then passes self.as_mut() into the pipe
function.§fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R
Borrows
self, then passes self.deref() into the pipe function.§impl<T> Pointable for T
impl<T> Pointable for T
§impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> PolicyExt for Twhere
T: ?Sized,
impl<T> Read<Exclusive, BecauseExclusive> for Twhere
T: ?Sized,
§impl<T> Tap for T
impl<T> Tap for T
§fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self
Immutable access to the
Borrow<B> of a value. Read more§fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self
Mutable access to the
BorrowMut<B> of a value. Read more§fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self
Immutable access to the
AsRef<R> view of a value. Read more§fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self
Mutable access to the
AsMut<R> view of a value. Read more§fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self
Immutable access to the
Deref::Target of a value. Read more§fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self
Mutable access to the
Deref::Target of a value. Read more§fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
fn tap_dbg(self, func: impl FnOnce(&Self)) -> Self
Calls
.tap() only in debug builds, and is erased in release builds.§fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
fn tap_mut_dbg(self, func: impl FnOnce(&mut Self)) -> Self
Calls
.tap_mut() only in debug builds, and is erased in release
builds.§fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self
Calls
.tap_borrow() only in debug builds, and is erased in release
builds.§fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self
Calls
.tap_borrow_mut() only in debug builds, and is erased in release
builds.§fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self
Calls
.tap_ref() only in debug builds, and is erased in release
builds.§fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self
Calls
.tap_ref_mut() only in debug builds, and is erased in release
builds.§fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self
Calls
.tap_deref() only in debug builds, and is erased in release
builds.