Struct LedgerCtx

pub struct LedgerCtx {
    snarked_ledgers: BTreeMap<LedgerHash, Mask>,
    additional_snarked_ledgers: BTreeMap<LedgerHash, Mask>,
    staged_ledgers: StagedLedgersStorage,
    sync: LedgerSyncState,
    archive_mode: bool,
    event_sender: Option<UnboundedSender<Event>>,
}

Fields

snarked_ledgers: BTreeMap<LedgerHash, Mask>

additional_snarked_ledgers: BTreeMap<LedgerHash, Mask>

Additional snarked ledgers specified at startup (loaded from disk)

staged_ledgers: StagedLedgersStorage

sync: LedgerSyncState

archive_mode: bool

Returns more data on block application necessary for archive node

event_sender: Option<UnboundedSender<Event>>

Implementations

impl LedgerCtx

pub fn new_with_additional_snarked_ledgers<P>(path: P) -> Self

where P: AsRef<Path>,

pub fn set_archive_mode(&mut self)

pub fn set_event_sender(&mut self, event_sender: UnboundedSender<Event>)

pub(super) fn send_event(&self, event: LedgerEvent)

pub(super) fn send_write_response(&self, resp: LedgerWriteResponse)

pub(super) fn send_read_response( &self, id: LedgerReadId, resp: LedgerReadResponse, )

pub fn insert_genesis_ledger(&mut self, mask: Mask)

pub fn staged_ledger_reconstruct_result_store(&mut self, ledger: StagedLedger)

pub fn get_accounts_for_rpc( &self, ledger_hash: LedgerHash, requested_public_key: Option<AccountPublicKey>, ) -> Vec<Account>

pub fn mask(&self, hash: &LedgerHash) -> Option<(Mask, bool)>

Returns a tuple of (mask, is_synced) for a Mask with the specified hash if it exists or None otherwise.

pub fn contains_snarked_ledger(&self, hash: &LedgerHash) -> bool

pub fn pending_sync_snarked_ledger_mask( &self, hash: &LedgerHash, ) -> Result<Mask, String>

Returns the mask for a snarked ledger being synchronized or an error if it is not present

pub fn copy_snarked_ledger_contents_for_sync( &mut self, origin_snarked_ledger_hash: LedgerHash, target_snarked_ledger_hash: LedgerHash, overwrite: bool, ) -> Result<bool, String>

Copies the contents of an existing snarked ledger into the target hash under the pending sync snarked ledgers state.

pub fn compute_snarked_ledger_hashes( &mut self, snarked_ledger_hash: &LedgerHash, ) -> Result<(), String>

fn staged_ledger_mut( &mut self, hash: &MinaBaseStagedLedgerHashStableV1, ) -> Option<&mut StagedLedger>

Returns a mutable reference to the StagedLedger with the specified hash if it exists or None otherwise.

fn recreate_snarked_ledger( &mut self, root_snarked_ledger_updates: &TransitionFrontierRootSnarkedLedgerUpdates, needed_protocol_states: &BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>, snarked_ledger_hash: &LedgerHash, ) -> Result<(), String>

fn push_snarked_ledger( &mut self, protocol_states: &BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>, old_root_snarked_ledger_hash: &LedgerHash, new_root_snarked_ledger_hash: &LedgerHash, new_root_staged_ledger_hash: &MinaBaseStagedLedgerHashStableV1, ) -> Result<(), String>

pub fn get_account_delegators( &self, ledger_hash: &LedgerHash, account_id: &AccountId, ) -> Option<Vec<Account>>

pub fn producers_with_delegates<F: FnMut(&CompressedPubKey) -> bool>( &self, ledger_hash: &LedgerHash, filter: F, ) -> Option<BTreeMap<AccountPublicKey, Vec<(AccountIndex, AccountPublicKey, u64)>>>

pub fn child_hashes_get( &mut self, snarked_ledger_hash: LedgerHash, parent: &LedgerAddress, ) -> Result<(LedgerHash, LedgerHash), String>

pub fn accounts_set( &mut self, snarked_ledger_hash: LedgerHash, parent: &LedgerAddress, accounts: Vec<MinaBaseAccountBinableArgStableV2>, ) -> Result<LedgerHash, String>

pub fn staged_ledger_reconstruct<F>( &mut self, snarked_ledger_hash: LedgerHash, parts: Option<Arc<StagedLedgerAuxAndPendingCoinbasesValid>>, callback: F, ) -> Result<(), InvalidBigInt>

where F: 'static + FnOnce(LedgerHash, Result<StagedLedger, String>) + Send,

pub fn staged_ledger_reconstruct_sync( &mut self, snarked_ledger_hash: LedgerHash, parts: Option<Arc<StagedLedgerAuxAndPendingCoinbasesValid>>, ) -> Result<(LedgerHash, Result<(), String>), InvalidBigInt>

pub fn block_apply( &mut self, block: ArcBlockWithHash, pred_block: AppliedBlock, skip_verification: Option<SkipVerification>, ) -> Result<BlockApplyResult, String>

pub fn commit( &mut self, ledgers_to_keep: LedgersToKeep, root_snarked_ledger_updates: TransitionFrontierRootSnarkedLedgerUpdates, needed_protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>, new_root: &ArcBlockWithHash, new_best_tip: &ArcBlockWithHash, ) -> CommitResult

fn check_alive_masks(&mut self)

pub fn get_num_accounts( &mut self, ledger_hash: LedgerHash, ) -> Option<(u64, LedgerHash)>

pub fn get_child_hashes( &mut self, ledger_hash: LedgerHash, addr: LedgerAddress, ) -> Option<(LedgerHash, LedgerHash)>

pub fn get_child_accounts( &mut self, ledger_hash: LedgerHash, addr: LedgerAddress, ) -> Option<Vec<MinaBaseAccountBinableArgStableV2>>

pub fn get_accounts( &mut self, ledger_hash: LedgerHash, ids: Vec<AccountId>, ) -> Vec<Account>

pub fn staged_ledger_aux_and_pending_coinbase( &mut self, ledger_hash: &MinaBaseStagedLedgerHashStableV1, protocol_states: BTreeMap<StateHash, MinaStateProtocolStateValueStableV2>, ) -> Option<Arc<StagedLedgerAuxAndPendingCoinbases>>

pub fn staged_ledger_diff_create( &mut self, pred_block: AppliedBlock, global_slot_since_genesis: MinaNumbersGlobalSlotSinceGenesisMStableV1, is_new_epoch: bool, producer: NonZeroCurvePoint, delegator: NonZeroCurvePoint, coinbase_receiver: NonZeroCurvePoint, completed_snarks: BTreeMap<SnarkJobId, Snark>, supercharge_coinbase: bool, transactions_by_fee: Vec<UserCommand>, ) -> Result<StagedLedgerDiffCreateOutput, String>

pub fn stake_proof_sparse_ledger( &mut self, staking_ledger: &LedgerHash, producer: &NonZeroCurvePoint, delegator: &NonZeroCurvePoint, ) -> Result<MinaBaseSparseLedgerBaseStableV2, InvalidBigInt>

pub fn scan_state_summary( &self, staged_ledger_hash: &MinaBaseStagedLedgerHashStableV1, ) -> Result<Vec<Vec<RpcScanStateSummaryScanStateJob>>, String>

Trait Implementations

impl Default for LedgerCtx

fn default() -> LedgerCtx

Returns the “default value” for a type.