Struct storage_interface::mock::MockDbReaderWriter

source · [−]

pub struct MockDbReaderWriter;

Expand description

This is a mock of the DbReaderWriter in tests.

Trait Implementations

source

impl DbReader for MockDbReaderWriter

source

fn get_latest_state_value(
&self,
state_key: StateKey
) -> Result<Option<StateValue>>

See AptosDB::get_latest_account_state. Read more

source

fn get_latest_version_option(&self) -> Result<Option<Version>>

Returns the latest version, None for non-bootstrapped DB.

source

fn get_latest_state_snapshot(&self) -> Result<Option<(Version, HashValue)>>

Returns the latest state checkpoint version if any.

source

fn get_state_value_by_version(
 &self,
 state_key: &StateKey,
 _: Version
) -> Result<Option<StateValue>>

Gets an account state by account address. See AptosDB::get_state_value_by_version. Read more

source

fn get_state_proof_by_version(
 &self,
 _state_key: &StateKey,
 _version: Version
) -> Result<SparseMerkleProof>

Returns the proof of the given state key and version.

source

fn get_epoch_ending_ledger_infos(
 &self,
 start_epoch: u64,
 end_epoch: u64
) -> Result<EpochChangeProof>

See AptosDB::get_epoch_ending_ledger_infos. Read more

source

fn get_transactions(
 &self,
 start_version: Version,
 batch_size: u64,
 ledger_version: Version,
 fetch_events: bool
) -> Result<TransactionListWithProof>

See AptosDB::get_transactions. Read more

source

fn get_transaction_by_hash(
 &self,
 hash: HashValue,
 ledger_version: Version,
 fetch_events: bool
) -> Result<Option<TransactionWithProof>>

See AptosDB::get_transaction_by_hash. Read more

source

fn get_transaction_by_version(
 &self,
 version: Version,
 ledger_version: Version,
 fetch_events: bool
) -> Result<TransactionWithProof>

See AptosDB::get_transaction_by_version. Read more

source

fn get_first_txn_version(&self) -> Result<Option<Version>>

See AptosDB::get_first_txn_version. Read more

source

fn get_first_write_set_version(&self) -> Result<Option<Version>>

See AptosDB::get_first_write_set_version. Read more

source

fn get_transaction_outputs(
 &self,
 start_version: Version,
 limit: u64,
 ledger_version: Version
) -> Result<TransactionOutputListWithProof>

See AptosDB::get_transaction_outputs. Read more

source

fn get_write_sets(
 &self,
 start_version: Version,
 end_version: Version
) -> Result<Vec<WriteSet>>

See AptosDB::get_write_sets. Read more

source

fn get_events(
 &self,
 event_key: &EventKey,
 start: u64,
 order: Order,
 limit: u64
) -> Result<Vec<EventWithVersion>>

Returns events by given event key

source

fn get_block_timestamp(&self, version: u64) -> Result<u64>

See AptosDB::get_block_timestamp. Read more

source

fn get_block_boundaries(
 &self,
 version: u64,
 latest_ledger_version: u64
) -> Result<(u64, u64)>

See AptosDB::get_block_boundaries. Read more

source

fn get_last_version_before_timestamp(
 &self,
 _timestamp: u64,
 _ledger_version: Version
) -> Result<Version>

Gets the version of the last transaction committed before timestamp, a committed block at or after the required timestamp must exist (otherwise it’s possible the next block committed as a timestamp smaller than the one in the request). Read more

source

fn get_latest_epoch_state(&self) -> Result<EpochState>

Gets the latest epoch state currently held in storage.

source

fn get_state_values_by_key_prefix(
 &self,
 key_prefix: &StateKeyPrefix,
 version: Version
) -> Result<HashMap<StateKey, StateValue>>

Returns the key, value pairs for a particular state key prefix at at desired version. This API can be used to get all resources of an account by passing the account address as the key prefix. Read more

source

fn get_latest_ledger_info_option(
&self
) -> Result<Option<LedgerInfoWithSignatures>>

Returns the latest ledger info, if any.

source

fn get_latest_ledger_info(&self) -> Result<LedgerInfoWithSignatures>

Returns the latest ledger info.

source

fn get_latest_version(&self) -> Result<Version>

Returns the latest version, error on on non-bootstrapped DB.

source

fn get_state_snapshot_before(
&self,
next_version: Version
) -> Result<Option<(Version, HashValue)>>

Returns the latest state snapshot strictly before next_version if any.

source

fn get_latest_commit_metadata(&self) -> Result<(Version, u64)>

Returns the latest version and committed block timestamp

source

fn get_startup_info(&self) -> Result<Option<StartupInfo>>

Gets information needed from storage during the main node startup. See AptosDB::get_startup_info. Read more

source

fn get_account_transaction(
 &self,
 address: AccountAddress,
 seq_num: u64,
 include_events: bool,
 ledger_version: Version
) -> Result<Option<TransactionWithProof>>

Returns a transaction that is the seq_num-th one associated with the given account. If the transaction with given seq_num doesn’t exist, returns None. Read more

source

fn get_account_transactions(
 &self,
 address: AccountAddress,
 seq_num: u64,
 limit: u64,
 include_events: bool,
 ledger_version: Version
) -> Result<AccountTransactionsWithProof>

Returns the list of transactions sent by an account with address starting at sequence number seq_num. Will return no more than limit transactions. Will ignore transactions with txn.version > ledger_version. Optionally fetch events for each transaction when fetch_events is true. Read more

source

fn get_state_proof_with_ledger_info(
 &self,
 known_version: u64,
 ledger_info: LedgerInfoWithSignatures
) -> Result<StateProof>

Returns proof of new state for a given ledger info with signatures relative to version known to client Read more

source

fn get_state_proof(&self, known_version: u64) -> Result<StateProof>

Returns proof of new state relative to version known to client

source

fn get_state_value_with_proof_by_version(
 &self,
 state_key: &StateKey,
 version: Version
) -> Result<(Option<StateValue>, SparseMerkleProof)>

Gets a state value by state key along with the proof, out of the ledger state indicated by the state Merkle tree root with a sparse merkle proof proving state tree root. See AptosDB::get_account_state_with_proof_by_version. Read more

source

fn get_latest_executed_trees(&self) -> Result<ExecutedTrees>

Gets the latest ExecutedTrees no matter if db has been bootstrapped. Used by the Db-bootstrapper. Read more

source

fn get_epoch_ending_ledger_info(
&self,
known_version: u64
) -> Result<LedgerInfoWithSignatures>

Get the ledger info of the epoch that known_version belongs to.

source

fn get_latest_transaction_info_option(
&self
) -> Result<Option<(Version, TransactionInfo)>>

Gets the latest transaction info. N.B. Unlike get_startup_info(), even if the db is not bootstrapped, this can return Some – those from a db-restore run. Read more

source

fn get_accumulator_root_hash(&self, _version: Version) -> Result<HashValue>

Gets the transaction accumulator root hash at specified version. Caller must guarantee the version is not greater than the latest version. Read more

source

fn get_accumulator_consistency_proof(
 &self,
 _client_known_version: Option<Version>,
 _ledger_version: Version
) -> Result<AccumulatorConsistencyProof>

Gets an AccumulatorConsistencyProof starting from client_known_version (or pre-genesis if None) until ledger_version. Read more

source

fn get_accumulator_summary(
&self,
ledger_version: Version
) -> Result<TransactionAccumulatorSummary>

A convenience function for building a TransactionAccumulatorSummary at the given ledger_version. Read more

source

fn get_state_leaf_count(&self, version: Version) -> Result<usize>

Returns total number of leaves in state store at given version.

source

fn get_state_value_chunk_with_proof(
 &self,
 version: Version,
 start_idx: usize,
 chunk_size: usize
) -> Result<StateValueChunkWithProof>

Get a chunk of state store value, addressed by the index.

source

fn get_state_prune_window(&self) -> Result<Option<usize>>

Get the state prune window config value.

source

fn get_ledger_prune_window(&self) -> Result<Option<usize>>

Get the ledger prune window config value.

source

impl DbWriter for MockDbReaderWriter

source

fn get_state_snapshot_receiver(
 &self,
 version: Version,
 expected_root_hash: HashValue
) -> Result<Box<dyn StateSnapshotReceiver<StateKey, StateValue>>>

Get a (stateful) state snapshot receiver. Read more

source

fn finalize_state_snapshot(
 &self,
 version: Version,
 output_with_proof: TransactionOutputListWithProof
) -> Result<()>

Finalizes a state snapshot that has already been restored to the database through a state snapshot receiver. This is required to bootstrap the transaction accumulator and populate transaction and event information. Read more

source

fn save_ledger_infos(
&self,
ledger_infos: &[LedgerInfoWithSignatures]
) -> Result<()>

Persists the specified ledger infos. Read more

source

fn save_transactions_ext(
 &self,
 txns_to_commit: &[TransactionToCommit],
 first_version: Version,
 base_state_version: Option<Version>,
 ledger_info_with_sigs: Option<&LedgerInfoWithSignatures>,
 save_state_snapshots: bool,
 latest_in_memory_state: StateDelta
) -> Result<()>

Persist transactions. Called by the executor module when either syncing nodes or committing blocks during normal operation. See AptosDB::save_transactions. Read more

source

fn save_transactions(
 &self,
 txns_to_commit: &[TransactionToCommit],
 first_version: Version,
 base_state_version: Option<Version>,
 ledger_info_with_sigs: Option<&LedgerInfoWithSignatures>,
 latest_in_memory_state: StateDelta
) -> Result<()>

source

fn save_state_snapshot_for_bench(
 &self,
 jmt_updates: Vec<(HashValue, (HashValue, StateKey))>,
 node_hashes: Option<&HashMap<NibblePath, HashValue>>,
 version: Version,
 base_version: Option<Version>,
 state_tree_at_snapshot: SparseMerkleTree<StateValue>
) -> Result<()>

source

fn save_state_snapshot(&self) -> Result<()>

Persists merklized states as authenticated state checkpoint. See AptosDB::save_state_snapshot. Read more

source

fn delete_genesis(&self) -> Result<()>

Deletes transaction data associated with the genesis transaction. This is useful for cleaning up the database after a node has bootstrapped all accounts through state sync. Read more

Auto Trait Implementations

impl RefUnwindSafe for MockDbReaderWriter

impl Send for MockDbReaderWriter

impl Sync for MockDbReaderWriter

impl Unpin for MockDbReaderWriter

impl UnwindSafe for MockDbReaderWriter

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

impl<T> Conv for T

fn conv<T>(self) -> T where
Self: Into<T>,

Converts self into T using Into<T>. Read more

impl<T> Conv for T

fn conv<T>(self) -> T where
Self: Into<T>,

Converts self into a target type. Read more

impl<T> FmtForward for T

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,

Causes self to use its Display implementation when Debug-formatted. Read more

fn fmt_lower_exp(self) -> FmtLowerExp<Self> where
Self: LowerExp,

Causes self to use its LowerExp implementation when Debug-formatted. Read more

fn fmt_lower_hex(self) -> FmtLowerHex<Self> where
Self: LowerHex,

Causes self to use its LowerHex implementation when Debug-formatted. Read more

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,

Causes self to use its Pointer implementation when Debug-formatted. Read more

fn fmt_upper_exp(self) -> FmtUpperExp<Self> where
Self: UpperExp,

Causes self to use its UpperExp implementation when Debug-formatted. Read more

fn fmt_upper_hex(self) -> FmtUpperHex<Self> where
Self: UpperHex,

Causes self to use its UpperHex implementation when Debug-formatted. Read more

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Pipe for T where
T: ?Sized,

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R

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) -> R where
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) -> R where
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 where
 Self: Borrow,
 B: 'a + ?Sized,
 R: 'a,

Borrows self, then passes self.borrow() into the pipe function. Read more

fn pipe_borrow_mut<'a, B, R>(
 &'a mut self,
 func: impl FnOnce(&'a mut B) -> R
) -> R where
 Self: BorrowMut,
 B: 'a + ?Sized,
 R: 'a,

Mutably borrows self, then passes self.borrow_mut() into the pipe function. Read more

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R where
 Self: AsRef,
 U: 'a + ?Sized,
 R: 'a,

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 where
 Self: AsMut,
 U: 'a + ?Sized,
 R: 'a,

Mutably borrows self, then passes self.as_mut() into the pipe function. Read more

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where
 Self: Deref<Target = T>,
 T: 'a + ?Sized,
 R: 'a,

Borrows self, then passes self.deref() into the pipe function.

fn pipe_deref_mut<'a, T, R>(&'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where
 Self: DerefMut<Target = T> + Deref,
 T: 'a + ?Sized,
 R: 'a,

Mutably borrows self, then passes self.deref_mut() into the pipe function. Read more

impl<T> Pipe for T

fn pipe<R>(self, func: impl FnOnce(Self) -> R) -> R

Pipes a value into a function that cannot ordinarily be called in suffix position. Read more

impl<T> PipeAsRef for T

fn pipe_as_ref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where
 Self: AsRef<T>,
 T: 'a,
 R: 'a,

Pipes a trait borrow into a function that cannot normally be called in suffix position. Read more

fn pipe_as_mut<'a, T, R>(&'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where
 Self: AsMut<T>,
 T: 'a,
 R: 'a,

Pipes a trait mutable borrow into a function that cannot normally be called in suffix position. Read more

impl<T> PipeBorrow for T

fn pipe_borrow<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where
 Self: Borrow<T>,
 T: 'a,
 R: 'a,

Pipes a trait borrow into a function that cannot normally be called in suffix position. Read more

fn pipe_borrow_mut<'a, T, R>(
 &'a mut self,
 func: impl FnOnce(&'a mut T) -> R
) -> R where
 Self: BorrowMut<T>,
 T: 'a,
 R: 'a,

Pipes a trait mutable borrow into a function that cannot normally be called in suffix position. Read more

impl<T> PipeDeref for T

fn pipe_deref<'a, R>(&'a self, func: impl FnOnce(&'a Self::Target) -> R) -> R where
Self: Deref,
R: 'a,

Pipes a dereference into a function that cannot normally be called in suffix position. Read more

fn pipe_deref_mut<'a, R>(
 &'a mut self,
 func: impl FnOnce(&'a mut Self::Target) -> R
) -> R where
 Self: DerefMut,
 R: 'a,

Pipes a mutable dereference into a function that cannot normally be called in suffix position. Read more

impl<T> PipeRef for T

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where
R: 'a,

Pipes a reference into a function that cannot ordinarily be called in suffix position. Read more

fn pipe_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R where
R: 'a,

Pipes a mutable reference into a function that cannot ordinarily be called in suffix position. Read more

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::<T>()

The alignment of pointer.

type Init = T

The type for initializers.

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

source

impl<T> Same<T> for T

type Output = T

Should always be Self

impl<T> Tap for T

fn tap(self, func: impl FnOnce(&Self)) -> Self

Immutable access to a value. Read more

fn tap_mut(self, func: impl FnOnce(&mut Self)) -> Self

Mutable access to a value. Read more

fn tap_borrow(self, func: impl FnOnce(&B)) -> Self where
Self: Borrow,
B: ?Sized,

Immutable access to the Borrow of a value. Read more

fn tap_borrow_mut(self, func: impl FnOnce(&mut B)) -> Self where
Self: BorrowMut,
B: ?Sized,

Mutable access to the BorrowMut of a value. Read more

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self where
Self: AsRef<R>,
R: ?Sized,

Immutable access to the AsRef<R> view of a value. Read more

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self where
Self: AsMut<R>,
R: ?Sized,

Mutable access to the AsMut<R> view of a value. Read more

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self where
Self: Deref<Target = T>,
T: ?Sized,

Immutable access to the Deref::Target of a value. Read more

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self where
Self: DerefMut<Target = T> + Deref,
T: ?Sized,

Mutable access to the Deref::Target of a value. Read more

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

Calls .tap_mut() only in debug builds, and is erased in release builds. Read more

fn tap_borrow_dbg(self, func: impl FnOnce(&B)) -> Self where
Self: Borrow,
B: ?Sized,

Calls .tap_borrow() only in debug builds, and is erased in release builds. Read more

fn tap_borrow_mut_dbg(self, func: impl FnOnce(&mut B)) -> Self where
Self: BorrowMut,
B: ?Sized,

Calls .tap_borrow_mut() only in debug builds, and is erased in release builds. Read more

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self where
Self: AsRef<R>,
R: ?Sized,

Calls .tap_ref() only in debug builds, and is erased in release builds. Read more

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self where
Self: AsMut<R>,
R: ?Sized,

Calls .tap_ref_mut() only in debug builds, and is erased in release builds. Read more

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self where
Self: Deref<Target = T>,
T: ?Sized,

Calls .tap_deref() only in debug builds, and is erased in release builds. Read more

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self where
Self: DerefMut<Target = T> + Deref,
T: ?Sized,

Calls .tap_deref_mut() only in debug builds, and is erased in release builds. Read more

impl<T> Tap for T

fn tap<F, R>(self, func: F) -> Self where
F: FnOnce(&Self) -> R,

Provides immutable access for inspection. Read more

fn tap_dbg<F, R>(self, func: F) -> Self where
F: FnOnce(&Self) -> R,

Calls tap in debug builds, and does nothing in release builds.

fn tap_mut<F, R>(self, func: F) -> Self where
F: FnOnce(&mut Self) -> R,

Provides mutable access for modification. Read more

fn tap_mut_dbg<F, R>(self, func: F) -> Self where
F: FnOnce(&mut Self) -> R,

Calls tap_mut in debug builds, and does nothing in release builds.

impl<T, U> TapAsRef for T where
U: ?Sized,

fn tap_ref<F, R>(self, func: F) -> Self where
Self: AsRef<T>,
F: FnOnce(&T) -> R,

Provides immutable access to the reference for inspection.

fn tap_ref_dbg<F, R>(self, func: F) -> Self where
Self: AsRef<T>,
F: FnOnce(&T) -> R,

Calls tap_ref in debug builds, and does nothing in release builds.

fn tap_ref_mut<F, R>(self, func: F) -> Self where
Self: AsMut<T>,
F: FnOnce(&mut T) -> R,

Provides mutable access to the reference for modification.

fn tap_ref_mut_dbg<F, R>(self, func: F) -> Self where
Self: AsMut<T>,
F: FnOnce(&mut T) -> R,

Calls tap_ref_mut in debug builds, and does nothing in release builds.

impl<T, U> TapBorrow for T where
U: ?Sized,

fn tap_borrow<F, R>(self, func: F) -> Self where
Self: Borrow<T>,
F: FnOnce(&T) -> R,

Provides immutable access to the borrow for inspection. Read more

fn tap_borrow_dbg<F, R>(self, func: F) -> Self where
Self: Borrow<T>,
F: FnOnce(&T) -> R,

Calls tap_borrow in debug builds, and does nothing in release builds.

fn tap_borrow_mut<F, R>(self, func: F) -> Self where
Self: BorrowMut<T>,
F: FnOnce(&mut T) -> R,

Provides mutable access to the borrow for modification.

fn tap_borrow_mut_dbg<F, R>(self, func: F) -> Self where
Self: BorrowMut<T>,
F: FnOnce(&mut T) -> R,

Calls tap_borrow_mut in debug builds, and does nothing in release builds. Read more

impl<T> TapDeref for T

fn tap_deref<F, R>(self, func: F) -> Self where
Self: Deref,
F: FnOnce(&Self::Target) -> R,

Immutably dereferences self for inspection.

fn tap_deref_dbg<F, R>(self, func: F) -> Self where
Self: Deref,
F: FnOnce(&Self::Target) -> R,

Calls tap_deref in debug builds, and does nothing in release builds.

fn tap_deref_mut<F, R>(self, func: F) -> Self where
Self: DerefMut,
F: FnOnce(&mut Self::Target) -> R,

Mutably dereferences self for modification.

fn tap_deref_mut_dbg<F, R>(self, func: F) -> Self where
Self: DerefMut,
F: FnOnce(&mut Self::Target) -> R,

Calls tap_deref_mut in debug builds, and does nothing in release builds. Read more

impl<T> TryConv for T

fn try_conv<T>(self) -> Result<T, Self::Error> where
Self: TryInto<T>,

Attempts to convert self into T using TryInto<T>. Read more

impl<T> TryConv for T

fn try_conv<T>(self) -> Result<T, Self::Error> where
Self: TryInto<T>,

Attempts to convert self into a target type. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn vzip(self) -> V

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct storage_interface::mock::MockDbReaderWriter

Trait Implementations

impl DbReader for MockDbReaderWriter

fn get_latest_state_value( &self, state_key: StateKey) -> Result<Option<StateValue>>

fn get_latest_version_option(&self) -> Result<Option<Version>>

fn get_latest_state_snapshot(&self) -> Result<Option<(Version, HashValue)>>

fn get_state_value_by_version( &self, state_key: &StateKey, _: Version) -> Result<Option<StateValue>>

fn get_state_proof_by_version( &self, _state_key: &StateKey, _version: Version) -> Result<SparseMerkleProof>

fn get_epoch_ending_ledger_infos( &self, start_epoch: u64, end_epoch: u64) -> Result<EpochChangeProof>

fn get_transactions( &self, start_version: Version, batch_size: u64, ledger_version: Version, fetch_events: bool) -> Result<TransactionListWithProof>

fn get_transaction_by_hash( &self, hash: HashValue, ledger_version: Version, fetch_events: bool) -> Result<Option<TransactionWithProof>>

fn get_transaction_by_version( &self, version: Version, ledger_version: Version, fetch_events: bool) -> Result<TransactionWithProof>

fn get_first_txn_version(&self) -> Result<Option<Version>>

fn get_first_write_set_version(&self) -> Result<Option<Version>>

fn get_transaction_outputs( &self, start_version: Version, limit: u64, ledger_version: Version) -> Result<TransactionOutputListWithProof>

fn get_write_sets( &self, start_version: Version, end_version: Version) -> Result<Vec<WriteSet>>

fn get_events( &self, event_key: &EventKey, start: u64, order: Order, limit: u64) -> Result<Vec<EventWithVersion>>

fn get_block_timestamp(&self, version: u64) -> Result<u64>

fn get_block_boundaries( &self, version: u64, latest_ledger_version: u64) -> Result<(u64, u64)>

fn get_last_version_before_timestamp( &self, _timestamp: u64, _ledger_version: Version) -> Result<Version>

fn get_latest_epoch_state(&self) -> Result<EpochState>

fn get_state_values_by_key_prefix( &self, key_prefix: &StateKeyPrefix, version: Version) -> Result<HashMap<StateKey, StateValue>>

fn get_latest_ledger_info_option( &self) -> Result<Option<LedgerInfoWithSignatures>>

fn get_latest_ledger_info(&self) -> Result<LedgerInfoWithSignatures>

fn get_latest_version(&self) -> Result<Version>

fn get_state_snapshot_before( &self, next_version: Version) -> Result<Option<(Version, HashValue)>>

fn get_latest_commit_metadata(&self) -> Result<(Version, u64)>

fn get_startup_info(&self) -> Result<Option<StartupInfo>>

fn get_account_transaction( &self, address: AccountAddress, seq_num: u64, include_events: bool, ledger_version: Version) -> Result<Option<TransactionWithProof>>

fn get_account_transactions( &self, address: AccountAddress, seq_num: u64, limit: u64, include_events: bool, ledger_version: Version) -> Result<AccountTransactionsWithProof>

fn get_state_proof_with_ledger_info( &self, known_version: u64, ledger_info: LedgerInfoWithSignatures) -> Result<StateProof>

fn get_state_proof(&self, known_version: u64) -> Result<StateProof>

fn get_state_value_with_proof_by_version( &self, state_key: &StateKey, version: Version) -> Result<(Option<StateValue>, SparseMerkleProof)>

fn get_latest_executed_trees(&self) -> Result<ExecutedTrees>

fn get_epoch_ending_ledger_info( &self, known_version: u64) -> Result<LedgerInfoWithSignatures>

fn get_latest_transaction_info_option( &self) -> Result<Option<(Version, TransactionInfo)>>

fn get_accumulator_root_hash(&self, _version: Version) -> Result<HashValue>

fn get_accumulator_consistency_proof( &self, _client_known_version: Option<Version>, _ledger_version: Version) -> Result<AccumulatorConsistencyProof>

fn get_accumulator_summary( &self, ledger_version: Version) -> Result<TransactionAccumulatorSummary>

fn get_state_leaf_count(&self, version: Version) -> Result<usize>

fn get_state_value_chunk_with_proof( &self, version: Version, start_idx: usize, chunk_size: usize) -> Result<StateValueChunkWithProof>

fn get_state_prune_window(&self) -> Result<Option<usize>>

fn get_ledger_prune_window(&self) -> Result<Option<usize>>

impl DbWriter for MockDbReaderWriter

fn get_state_snapshot_receiver( &self, version: Version, expected_root_hash: HashValue) -> Result<Box<dyn StateSnapshotReceiver<StateKey, StateValue>>>

fn finalize_state_snapshot( &self, version: Version, output_with_proof: TransactionOutputListWithProof) -> Result<()>

fn save_ledger_infos( &self, ledger_infos: &[LedgerInfoWithSignatures]) -> Result<()>

fn save_transactions_ext( &self, txns_to_commit: &[TransactionToCommit], first_version: Version, base_state_version: Option<Version>, ledger_info_with_sigs: Option<&LedgerInfoWithSignatures>, save_state_snapshots: bool, latest_in_memory_state: StateDelta) -> Result<()>

fn save_transactions( &self, txns_to_commit: &[TransactionToCommit], first_version: Version, base_state_version: Option<Version>, ledger_info_with_sigs: Option<&LedgerInfoWithSignatures>, latest_in_memory_state: StateDelta) -> Result<()>

fn save_state_snapshot_for_bench( &self, jmt_updates: Vec<(HashValue, (HashValue, StateKey))>, node_hashes: Option<&HashMap<NibblePath, HashValue>>, version: Version, base_version: Option<Version>, state_tree_at_snapshot: SparseMerkleTree<StateValue>) -> Result<()>

fn save_state_snapshot(&self) -> Result<()>

fn delete_genesis(&self) -> Result<()>

Auto Trait Implementations

impl RefUnwindSafe for MockDbReaderWriter

impl Send for MockDbReaderWriter

impl Sync for MockDbReaderWriter

impl Unpin for MockDbReaderWriter

impl UnwindSafe for MockDbReaderWriter

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> Conv for T

fn conv<T>(self) -> T where Self: Into<T>,

impl<T> Conv for T

fn conv<T>(self) -> T where Self: Into<T>,

impl<T> FmtForward for T

fn fmt_binary(self) -> FmtBinary<Self> where Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self> where Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self> where Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self> where Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self> where Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self> where Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self> where Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self> where Self: UpperHex,

impl<T> From<T> for T

fn from(t: T) -> T

fn get_latest_state_value(
&self,
state_key: StateKey
) -> Result<Option<StateValue>>

fn get_state_value_by_version(
&self,
state_key: &StateKey,
_: Version
) -> Result<Option<StateValue>>

fn get_state_proof_by_version(
&self,
_state_key: &StateKey,
_version: Version
) -> Result<SparseMerkleProof>

fn get_epoch_ending_ledger_infos(
&self,
start_epoch: u64,
end_epoch: u64
) -> Result<EpochChangeProof>

fn get_transactions(
&self,
start_version: Version,
batch_size: u64,
ledger_version: Version,
fetch_events: bool
) -> Result<TransactionListWithProof>

fn get_transaction_by_hash(
&self,
hash: HashValue,
ledger_version: Version,
fetch_events: bool
) -> Result<Option<TransactionWithProof>>

fn get_transaction_by_version(
&self,
version: Version,
ledger_version: Version,
fetch_events: bool
) -> Result<TransactionWithProof>

fn get_transaction_outputs(
&self,
start_version: Version,
limit: u64,
ledger_version: Version
) -> Result<TransactionOutputListWithProof>

fn get_write_sets(
&self,
start_version: Version,
end_version: Version
) -> Result<Vec<WriteSet>>

fn get_events(
&self,
event_key: &EventKey,
start: u64,
order: Order,
limit: u64
) -> Result<Vec<EventWithVersion>>

fn get_block_boundaries(
&self,
version: u64,
latest_ledger_version: u64
) -> Result<(u64, u64)>

fn get_last_version_before_timestamp(
&self,
_timestamp: u64,
_ledger_version: Version
) -> Result<Version>

fn get_state_values_by_key_prefix(
&self,
key_prefix: &StateKeyPrefix,
version: Version
) -> Result<HashMap<StateKey, StateValue>>

fn get_latest_ledger_info_option(
&self
) -> Result<Option<LedgerInfoWithSignatures>>

fn get_state_snapshot_before(
&self,
next_version: Version
) -> Result<Option<(Version, HashValue)>>

fn get_account_transaction(
&self,
address: AccountAddress,
seq_num: u64,
include_events: bool,
ledger_version: Version
) -> Result<Option<TransactionWithProof>>

fn get_account_transactions(
&self,
address: AccountAddress,
seq_num: u64,
limit: u64,
include_events: bool,
ledger_version: Version
) -> Result<AccountTransactionsWithProof>

fn get_state_proof_with_ledger_info(
&self,
known_version: u64,
ledger_info: LedgerInfoWithSignatures
) -> Result<StateProof>

fn get_state_value_with_proof_by_version(
&self,
state_key: &StateKey,
version: Version
) -> Result<(Option<StateValue>, SparseMerkleProof)>

fn get_epoch_ending_ledger_info(
&self,
known_version: u64
) -> Result<LedgerInfoWithSignatures>

fn get_latest_transaction_info_option(
&self
) -> Result<Option<(Version, TransactionInfo)>>

fn get_accumulator_consistency_proof(
&self,
_client_known_version: Option<Version>,
_ledger_version: Version
) -> Result<AccumulatorConsistencyProof>

fn get_accumulator_summary(
&self,
ledger_version: Version
) -> Result<TransactionAccumulatorSummary>

fn get_state_value_chunk_with_proof(
&self,
version: Version,
start_idx: usize,
chunk_size: usize
) -> Result<StateValueChunkWithProof>

fn get_state_snapshot_receiver(
&self,
version: Version,
expected_root_hash: HashValue
) -> Result<Box<dyn StateSnapshotReceiver<StateKey, StateValue>>>

fn finalize_state_snapshot(
&self,
version: Version,
output_with_proof: TransactionOutputListWithProof
) -> Result<()>

fn save_ledger_infos(
&self,
ledger_infos: &[LedgerInfoWithSignatures]
) -> Result<()>

fn save_transactions_ext(
&self,
txns_to_commit: &[TransactionToCommit],
first_version: Version,
base_state_version: Option<Version>,
ledger_info_with_sigs: Option<&LedgerInfoWithSignatures>,
save_state_snapshots: bool,
latest_in_memory_state: StateDelta
) -> Result<()>

fn save_transactions(
&self,
txns_to_commit: &[TransactionToCommit],
first_version: Version,
base_state_version: Option<Version>,
ledger_info_with_sigs: Option<&LedgerInfoWithSignatures>,
latest_in_memory_state: StateDelta
) -> Result<()>

fn save_state_snapshot_for_bench(
&self,
jmt_updates: Vec<(HashValue, (HashValue, StateKey))>,
node_hashes: Option<&HashMap<NibblePath, HashValue>>,
version: Version,
base_version: Option<Version>,
state_tree_at_snapshot: SparseMerkleTree<StateValue>
) -> Result<()>

impl<T> Any for T where
T: 'static + ?Sized,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

fn conv<T>(self) -> T where
Self: Into<T>,

fn conv<T>(self) -> T where
Self: Into<T>,

fn fmt_binary(self) -> FmtBinary<Self> where
Self: Binary,

fn fmt_display(self) -> FmtDisplay<Self> where
Self: Display,

fn fmt_lower_exp(self) -> FmtLowerExp<Self> where
Self: LowerExp,

fn fmt_lower_hex(self) -> FmtLowerHex<Self> where
Self: LowerHex,

fn fmt_octal(self) -> FmtOctal<Self> where
Self: Octal,

fn fmt_pointer(self) -> FmtPointer<Self> where
Self: Pointer,

fn fmt_upper_exp(self) -> FmtUpperExp<Self> where
Self: UpperExp,

fn fmt_upper_hex(self) -> FmtUpperHex<Self> where
Self: UpperHex,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> Pipe for T where
T: ?Sized,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where
R: 'a,

fn pipe_ref_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R where
R: 'a,

fn pipe_borrow<'a, B, R>(&'a self, func: impl FnOnce(&'a B) -> R) -> R where
Self: Borrow<B>,
B: 'a + ?Sized,
R: 'a,

fn pipe_borrow_mut<'a, B, R>(
&'a mut self,
func: impl FnOnce(&'a mut B) -> R
) -> R where
Self: BorrowMut<B>,
B: 'a + ?Sized,
R: 'a,

fn pipe_as_ref<'a, U, R>(&'a self, func: impl FnOnce(&'a U) -> R) -> R where
Self: AsRef<U>,
U: 'a + ?Sized,
R: 'a,

fn pipe_as_mut<'a, U, R>(&'a mut self, func: impl FnOnce(&'a mut U) -> R) -> R where
Self: AsMut<U>,
U: 'a + ?Sized,
R: 'a,

fn pipe_deref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where
Self: Deref<Target = T>,
T: 'a + ?Sized,
R: 'a,

fn pipe_deref_mut<'a, T, R>(&'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where
Self: DerefMut<Target = T> + Deref,
T: 'a + ?Sized,
R: 'a,

fn pipe_as_ref<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where
Self: AsRef<T>,
T: 'a,
R: 'a,

fn pipe_as_mut<'a, T, R>(&'a mut self, func: impl FnOnce(&'a mut T) -> R) -> R where
Self: AsMut<T>,
T: 'a,
R: 'a,

fn pipe_borrow<'a, T, R>(&'a self, func: impl FnOnce(&'a T) -> R) -> R where
Self: Borrow<T>,
T: 'a,
R: 'a,

fn pipe_borrow_mut<'a, T, R>(
&'a mut self,
func: impl FnOnce(&'a mut T) -> R
) -> R where
Self: BorrowMut<T>,
T: 'a,
R: 'a,

fn pipe_deref<'a, R>(&'a self, func: impl FnOnce(&'a Self::Target) -> R) -> R where
Self: Deref,
R: 'a,

fn pipe_deref_mut<'a, R>(
&'a mut self,
func: impl FnOnce(&'a mut Self::Target) -> R
) -> R where
Self: DerefMut,
R: 'a,

fn pipe_ref<'a, R>(&'a self, func: impl FnOnce(&'a Self) -> R) -> R where
R: 'a,

fn pipe_mut<'a, R>(&'a mut self, func: impl FnOnce(&'a mut Self) -> R) -> R where
R: 'a,

fn tap_borrow<B>(self, func: impl FnOnce(&B)) -> Self where
Self: Borrow<B>,
B: ?Sized,

fn tap_borrow_mut<B>(self, func: impl FnOnce(&mut B)) -> Self where
Self: BorrowMut<B>,
B: ?Sized,

fn tap_ref<R>(self, func: impl FnOnce(&R)) -> Self where
Self: AsRef<R>,
R: ?Sized,

fn tap_ref_mut<R>(self, func: impl FnOnce(&mut R)) -> Self where
Self: AsMut<R>,
R: ?Sized,

fn tap_deref<T>(self, func: impl FnOnce(&T)) -> Self where
Self: Deref<Target = T>,
T: ?Sized,

fn tap_deref_mut<T>(self, func: impl FnOnce(&mut T)) -> Self where
Self: DerefMut<Target = T> + Deref,
T: ?Sized,

fn tap_borrow_dbg<B>(self, func: impl FnOnce(&B)) -> Self where
Self: Borrow<B>,
B: ?Sized,

fn tap_borrow_mut_dbg<B>(self, func: impl FnOnce(&mut B)) -> Self where
Self: BorrowMut<B>,
B: ?Sized,

fn tap_ref_dbg<R>(self, func: impl FnOnce(&R)) -> Self where
Self: AsRef<R>,
R: ?Sized,

fn tap_ref_mut_dbg<R>(self, func: impl FnOnce(&mut R)) -> Self where
Self: AsMut<R>,
R: ?Sized,

fn tap_deref_dbg<T>(self, func: impl FnOnce(&T)) -> Self where
Self: Deref<Target = T>,
T: ?Sized,

fn tap_deref_mut_dbg<T>(self, func: impl FnOnce(&mut T)) -> Self where
Self: DerefMut<Target = T> + Deref,
T: ?Sized,

fn tap<F, R>(self, func: F) -> Self where
F: FnOnce(&Self) -> R,

fn tap_dbg<F, R>(self, func: F) -> Self where
F: FnOnce(&Self) -> R,

fn tap_mut<F, R>(self, func: F) -> Self where
F: FnOnce(&mut Self) -> R,

fn tap_mut_dbg<F, R>(self, func: F) -> Self where
F: FnOnce(&mut Self) -> R,

impl<T, U> TapAsRef<U> for T where
U: ?Sized,

fn tap_ref<F, R>(self, func: F) -> Self where
Self: AsRef<T>,
F: FnOnce(&T) -> R,

fn tap_ref_dbg<F, R>(self, func: F) -> Self where
Self: AsRef<T>,
F: FnOnce(&T) -> R,