Enum TransitionFrontierSyncLedgerSnarkedState

pub enum TransitionFrontierSyncLedgerSnarkedState {
    NumAccountsPending {
        time: Timestamp,
        target: SyncLedgerTarget,
        pending_num_accounts: LedgerNumAccountsQueryPending,
    },
    NumAccountsSuccess {
        time: Timestamp,
        target: SyncLedgerTarget,
        num_accounts: u64,
        contents_hash: LedgerHash,
    },
    MerkleTreeSyncPending {
        time: Timestamp,
        target: SyncLedgerTarget,
        total_accounts_expected: u64,
        synced_accounts_count: u64,
        synced_hashes_count: u64,
        queue: BTreeMap<LedgerAddress, LedgerHash>,
        pending_addresses: BTreeMap<LedgerAddress, LedgerAddressQueryPending>,
    },
    MerkleTreeSyncSuccess {
        time: Timestamp,
        target: SyncLedgerTarget,
    },
    Success {
        time: Timestamp,
        target: SyncLedgerTarget,
    },
}

Variants

NumAccountsPending

Fields

time: Timestamp

target: SyncLedgerTarget

pending_num_accounts: LedgerNumAccountsQueryPending

NumAccountsSuccess

Fields

time: Timestamp

target: SyncLedgerTarget

num_accounts: u64

NumAccounts value accepted from peer

contents_hash: LedgerHash

Hash of the subtree containing all accounts

MerkleTreeSyncPending

Doing BFS to sync snarked ledger tree.

Fields

time: Timestamp

target: SyncLedgerTarget

total_accounts_expected: u64

Number of accounts in this ledger (as claimed by the Num_accounts query result)

synced_accounts_count: u64

Number of accounts received and accepted so far

synced_hashes_count: u64

Number of hashes received and accepted so far

queue: BTreeMap<LedgerAddress, LedgerHash>

Pending addresses to query and the expected contents hash

pending_addresses: BTreeMap<LedgerAddress, LedgerAddressQueryPending>

Pending ongoing address queries and their attempts

MerkleTreeSyncSuccess

Fields

time: Timestamp

target: SyncLedgerTarget

Success

Fields

time: Timestamp

target: SyncLedgerTarget

Implementations

impl TransitionFrontierSyncLedgerSnarkedState

pub fn pending(time: Timestamp, target: SyncLedgerTarget) -> Self

pub fn is_pending(&self) -> bool

pub fn target(&self) -> &SyncLedgerTarget

pub fn ledger_hash(&self) -> &LedgerHash

pub fn is_num_accounts_query_next(&self) -> bool

pub fn num_accounts_pending(&self) -> Option<&LedgerNumAccountsQueryPending>

pub fn fetch_pending( &self, ) -> Option<&BTreeMap<LedgerAddress, LedgerAddressQueryPending>>

pub fn sync_address_retry_iter( &self, ) -> impl '_ + Iterator<Item = LedgerAddress>

Addresses that were being queried already and need to be retried

pub fn sync_address_query_iter( &self, ) -> impl '_ + Iterator<Item = (LedgerAddress, LedgerHash)>

Addresses that need to be queried but are still not in process

pub fn contains_pending_address_queries(&self) -> bool

pub fn estimation(&self) -> Option<LedgerSyncProgress>

pub fn peer_num_account_query_get( &self, peer_id: &PeerId, rpc_id: P2pRpcId, ) -> Option<&LedgerNumAccountsQueryPending>

pub fn peer_num_account_query_state_get_mut( &mut self, peer_id: &PeerId, rpc_id: P2pRpcId, ) -> Option<&mut PeerRpcState>

pub fn peer_address_query_get( &self, peer_id: &PeerId, rpc_id: P2pRpcId, ) -> Option<(&LedgerAddress, &LedgerAddressQueryPending)>

pub fn peer_address_query_state_get_mut( &mut self, peer_id: &PeerId, rpc_id: P2pRpcId, ) -> Option<&mut PeerRpcState>

pub fn peer_address_query_pending_rpc_ids<'a>( &'a self, peer_id: &'a PeerId, ) -> impl 'a + Iterator<Item = P2pRpcId>

pub fn peer_num_accounts_rpc_id(&self, peer_id: &PeerId) -> Option<P2pRpcId>

impl TransitionFrontierSyncLedgerSnarkedState

pub fn reducer( state_context: Substate<'_, Self>, action: TransitionFrontierSyncLedgerSnarkedActionWithMetaRef<'_>, )

Trait Implementations

impl Clone for TransitionFrontierSyncLedgerSnarkedState

fn clone(&self) -> TransitionFrontierSyncLedgerSnarkedState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TransitionFrontierSyncLedgerSnarkedState

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TransitionFrontierSyncLedgerSnarkedState

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl From<TransitionFrontierSyncLedgerSnarkedState> for TransitionFrontierSyncLedgerState

fn from( original: TransitionFrontierSyncLedgerSnarkedState, ) -> TransitionFrontierSyncLedgerState

Converts to this type from the input type.

impl Serialize for TransitionFrontierSyncLedgerSnarkedState

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl SubstateAccess<TransitionFrontierSyncLedgerSnarkedState> for State

fn substate(&self) -> SubstateResult<&TransitionFrontierSyncLedgerSnarkedState>

Attempts to obtain an immutable reference to the substate.

fn substate_mut( &mut self, ) -> SubstateResult<&mut TransitionFrontierSyncLedgerSnarkedState>

Attempts to obtain a mutable reference to the substate.