Struct DataAccessLayer

pub struct DataAccessLayer<S> {
    pub block_store: BlockStore,
    pub state: S,
    pub max_query_depth: u64,
    pub enable_addressable_entity: bool,
}

Data access layer.

Fields

block_store: BlockStore

Block store instance.

state: S

Memoized state.

max_query_depth: u64

Max query depth.

enable_addressable_entity: bool

Enable the addressable entity capability.

Implementations

impl<S> DataAccessLayer<S>

pub fn state(&self) -> &S

Returns reference to current state of the data access layer.

Trait Implementations

impl<S: Clone> Clone for DataAccessLayer<S>

fn clone(&self) -> DataAccessLayer<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<S> CommitProvider for DataAccessLayer<S>

where S: CommitProvider,

fn commit_effects( &self, state_hash: Digest, effects: Effects, ) -> Result<Digest, GlobalStateError>

Applies changes and returns a new post state hash. block_hash is used for computing a deterministic and unique keys.

fn commit_values( &self, state_hash: Digest, values_to_write: Vec<(Key, StoredValue)>, keys_to_prune: BTreeSet<Key>, ) -> Result<Digest, GlobalStateError>

Commit values to global state.

fn genesis(&self, request: GenesisRequest) -> GenesisResult

Runs and commits the genesis process, once per network.

fn protocol_upgrade( &self, request: ProtocolUpgradeRequest, ) -> ProtocolUpgradeResult

Runs and commits the protocol upgrade process.

fn prune(&self, request: PruneRequest) -> PruneResult

Safely prune specified keys from global state, using a tracking copy.

fn step(&self, request: StepRequest) -> StepResult

Step auction state at era end.

fn distribute_block_rewards( &self, request: BlockRewardsRequest, ) -> BlockRewardsResult

Distribute block rewards.

fn distribute_fees(&self, request: FeeRequest) -> FeeResult

Distribute fees, if relevant to the chainspec configured behavior.

fn forced_undelegate( &self, request: ForcedUndelegateRequest, ) -> ForcedUndelegateResult

Forcibly unbonds delegator bids which fall outside configured delegation limits.

fn block_global(&self, request: BlockGlobalRequest) -> BlockGlobalResult

Gets block global data.

impl ScratchProvider for DataAccessLayer<LmdbGlobalState>

fn get_scratch_global_state(&self) -> ScratchGlobalState

Provide a local cached-only version of engine-state.

fn write_scratch_to_db( &self, state_root_hash: Digest, scratch_global_state: ScratchGlobalState, ) -> Result<Digest, GlobalStateError>

Writes state cached in an EngineState<ScratchEngineState> to LMDB.

fn prune_keys(&self, state_root_hash: Digest, keys: &[Key]) -> TriePruneResult

Prune keys.

impl<S> StateProvider for DataAccessLayer<S>

where S: StateProvider,

type Reader = <S as StateProvider>::Reader

Associated reader type for StateProvider.

fn flush(&self, request: FlushRequest) -> FlushResult

Flush the state provider.

fn empty_root(&self) -> Digest

Returns an empty root hash.

fn tracking_copy( &self, hash: Digest, ) -> Result<Option<TrackingCopy<S::Reader>>, GlobalStateError>

Get a tracking copy.

fn checkout( &self, state_hash: Digest, ) -> Result<Option<Self::Reader>, GlobalStateError>

Checkouts a slice of initial state using root state hash.

fn trie(&self, request: TrieRequest) -> TrieResult

Reads a Trie from the state if it is present

fn put_trie(&self, request: PutTrieRequest) -> PutTrieResult

Persists a trie element.

fn missing_children( &self, trie_raw: &[u8], ) -> Result<Vec<Digest>, GlobalStateError>

Finds all the children of trie_raw which aren’t present in the state.

fn enable_entity(&self) -> bool

Gets the value of enable entity flag.

fn query(&self, request: QueryRequest) -> QueryResult

Query state.

fn message_topics( &self, message_topics_request: MessageTopicsRequest, ) -> MessageTopicsResult

Message topics request.

fn balance_purse( &self, request: BalanceIdentifierPurseRequest, ) -> BalanceIdentifierPurseResult

Provides the underlying addr for the imputed balance identifier.

fn balance(&self, request: BalanceRequest) -> BalanceResult

Balance inquiry.

fn balance_hold(&self, request: BalanceHoldRequest) -> BalanceHoldResult

Balance hold.

fn era_validators(&self, request: EraValidatorsRequest) -> EraValidatorsResult

Get the requested era validators.

fn seigniorage_recipients( &self, request: SeigniorageRecipientsRequest, ) -> SeigniorageRecipientsResult

Get the requested seigniorage recipients.

fn bids(&self, request: BidsRequest) -> BidsResult

Gets the bids.

fn bidding(&self, _: BiddingRequest) -> BiddingResult

Direct auction interaction for all variations of bid management.

fn handle_refund(&self, _: HandleRefundRequest) -> HandleRefundResult

Handle refund.

fn handle_fee(&self, _: HandleFeeRequest) -> HandleFeeResult

Handle payment.

fn execution_result_checksum( &self, request: ExecutionResultsChecksumRequest, ) -> ExecutionResultsChecksumResult

Gets the execution result checksum.

fn addressable_entity( &self, request: AddressableEntityRequest, ) -> AddressableEntityResult

Gets an addressable entity.

fn system_entity_registry( &self, request: SystemEntityRegistryRequest, ) -> SystemEntityRegistryResult

Returns the system entity registry or the key for a system entity registered within it.

fn entry_point(&self, request: EntryPointRequest) -> EntryPointResult

Gets an entry point value.

fn contract(&self, request: ContractRequest) -> ContractResult

Gets a contract value.

fn entry_point_exists( &self, request: EntryPointExistsRequest, ) -> EntryPointExistsResult

Gets an entry point value.

fn total_supply(&self, request: TotalSupplyRequest) -> TotalSupplyResult

Gets total supply.

fn round_seigniorage_rate( &self, request: RoundSeigniorageRateRequest, ) -> RoundSeigniorageRateResult

Gets the current round seigniorage rate.

fn transfer(&self, request: TransferRequest) -> TransferResult

Direct transfer.

fn burn(&self, request: BurnRequest) -> BurnResult

Direct burn.

fn tagged_values(&self, request: TaggedValuesRequest) -> TaggedValuesResult

Gets all values under a given key tag.

fn prefixed_values( &self, request: PrefixedValuesRequest, ) -> PrefixedValuesResult

Gets all values under a given key prefix. Currently, this ignores the cache and only provides values from the trie.

impl<S: Copy> Copy for DataAccessLayer<S>