Struct fuel_core::database::Database

source · [−]

pub struct Database { /* private fields */ }

Implementations

source

Iterates over a KV mapping of [address + block height + tx idx] => transaction id. This allows for efficient lookup of transaction ids associated with an address, sorted by block age and ordering within a block. The cursor tracks the [block height + tx idx] for pagination purposes.

source

pub fn record_tx_id_owner(
 &self,
 owner: &Address,
 block_height: BlockHeight,
 tx_idx: TransactionIndex,
 tx_id: &Bytes32
) -> Result<Option<Bytes32>, Error>

source

pub fn update_tx_status(
 &self,
 tx_id: &Bytes32,
 status: TransactionStatus
) -> Result<Option<TransactionStatus>, Error>

source

pub fn get_tx_status(
&self,
tx_id: &Bytes32
) -> Result<Option<TransactionStatus>, Error>

source

pub fn transaction(&self) -> DatabaseTransaction

Trait Implementations

source

impl AsMut<Database> for DatabaseTransaction

source

fn as_mut(&mut self) -> &mut Database

Converts this type into a mutable reference of the (usually inferred) input type.

source

impl AsRef<Database> for DatabaseTransaction

source

fn as_ref(&self) -> &Database

Converts this type into a shared reference of the (usually inferred) input type.

source

impl AsRef<Database> for Database

source

fn as_ref(&self) -> &Database

Converts this type into a shared reference of the (usually inferred) input type.

source

impl Clone for Database

source

fn clone(&self) -> Database

Returns a copy of the value. Read more

1.0.0 · source

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

Performs copy-assignment from source. Read more

source

impl Debug for Database

source

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

Formats the value using the given formatter. Read more

source

impl Default for Database

Construct an ephemeral database uses rocksdb when rocksdb features are enabled uses in-memory when rocksdb features are disabled

source

fn default() -> Self

Returns the “default value” for a type. Read more

source

impl From<&Database> for DatabaseTransaction

source

fn from(source: &Database) -> Self

Converts to this type from the input type.

source

impl InterpreterStorage for Database

type DataError = Error

Error implementation for reasons unspecified in the protocol.

source

fn block_height(&self) -> Result<u32, Error>

Provide the current block height in which the transactions should be executed. Read more

source

fn block_hash(&self, block_height: u32) -> Result<Bytes32, Error>

Provide the block hash from a given height.

source

fn coinbase(&self) -> Result<Address, Error>

Provide the coinbase address for the VM instructions implementation.

fn storage_contract(
&self,
id: &ContractId
) -> Result<Option<Cow<'_, Contract>>, Self::DataError>

Fetch a previously inserted contract code from the chain state for a given contract. Read more

fn storage_contract_insert(
 &mut self,
 id: &ContractId,
 contract: &Contract
) -> Result<Option<Contract>, Self::DataError>

Append a contract to the chain, provided its identifier. Read more

fn storage_contract_exists(
&self,
id: &ContractId
) -> Result<bool, Self::DataError>

Check if a provided contract exists in the chain.

fn storage_contract_root(
&self,
id: &ContractId
) -> Result<Option<Cow<'_, (Salt, Bytes32)>>, Self::DataError>

Fetch a previously inserted salt+root tuple from the chain state for a given contract. Read more

fn storage_contract_root_insert(
 &mut self,
 id: &ContractId,
 salt: &Salt,
 root: &Bytes32
) -> Result<Option<(Salt, Bytes32)>, Self::DataError>

Append the salt+root of a contract that was appended to the chain.

fn merkle_contract_state(
 &self,
 id: &ContractId,
 key: &Bytes32
) -> Result<Option<Cow<'_, Bytes32>>, Self::DataError>

Fetch the value form a key-value mapping in a contract storage.

fn merkle_contract_state_insert(
 &mut self,
 contract: &ContractId,
 key: &Bytes32,
 value: &Bytes32
) -> Result<Option<Bytes32>, Self::DataError>

Insert a key-value mapping in a contract storage.

fn merkle_contract_asset_id_balance(
 &self,
 id: &ContractId,
 asset_id: &AssetId
) -> Result<Option<u64>, Self::DataError>

Fetch the balance of an asset ID in a contract storage.

fn merkle_contract_asset_id_balance_insert(
 &mut self,
 contract: &ContractId,
 asset_id: &AssetId,
 value: u64
) -> Result<Option<u64>, Self::DataError>

Update the balance of an asset ID in a contract storage.

source

impl MerkleStorage<ContractId, AssetId, u64> for Database

type Error = Error

Error implementation of the merkle storage functions

source

fn insert(
 &mut self,
 parent: &ContractId,
 key: &AssetId,
 value: &Word
) -> Result<Option<Word>, Error>

Append P->K->V mapping to the storage. Read more

source

fn remove(
 &mut self,
 parent: &ContractId,
 key: &AssetId
) -> Result<Option<Word>, Error>

Remove P->K->V mapping from the storage. Read more

source

fn get(
 &self,
 parent: &ContractId,
 key: &AssetId
) -> Result<Option<Cow<'_, Word>>, Error>

Retrieve Cow<V> such as P->K->V.

source

fn contains_key(
 &self,
 parent: &ContractId,
 key: &AssetId
) -> Result<bool, Error>

Return true if there is a P->K mapping to a value in the storage.

source

fn root(&mut self, parent: &ContractId) -> Result<MerkleRoot, Error>

Return the merkle root of the domain of P. Read more

source

impl MerkleStorage<ContractId, Bytes32, Bytes32> for Database

type Error = Error

Error implementation of the merkle storage functions

source

fn insert(
 &mut self,
 parent: &ContractId,
 key: &Bytes32,
 value: &Bytes32
) -> Result<Option<Bytes32>, Error>

Append P->K->V mapping to the storage. Read more

source

fn remove(
 &mut self,
 parent: &ContractId,
 key: &Bytes32
) -> Result<Option<Bytes32>, Error>

Remove P->K->V mapping from the storage. Read more

source

fn get(
 &self,
 parent: &ContractId,
 key: &Bytes32
) -> Result<Option<Cow<'_, Bytes32>>, Error>

Retrieve Cow<V> such as P->K->V.

source

fn contains_key(
 &self,
 parent: &ContractId,
 key: &Bytes32
) -> Result<bool, Error>

Return true if there is a P->K mapping to a value in the storage.

source

fn root(&mut self, parent: &ContractId) -> Result<MerkleRoot, Error>

Return the merkle root of the domain of P. Read more

source

impl RelayerDb for Database

source

fn get_validators<'life0, 'async_trait>(
 &'life0 self
) -> Pin<Box<dyn Future<Output = HashMap<ValidatorId, (ValidatorStake, Option<ConsensusId>)>> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

get validator set for current eth height

source

fn get_staking_diffs<'life0, 'async_trait>(
 &'life0 self,
 from_da_height: DaBlockHeight,
 to_da_height: Option<DaBlockHeight>
) -> Pin<Box<dyn Future<Output = Vec<(DaBlockHeight, StakingDiff)>> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

get stakes difference between fuel blocks. Return vector of changed (some blocks are not going to have any change)

source

fn apply_validator_diffs<'life0, 'life1, 'async_trait>(
 &'life0 mut self,
 da_height: DaBlockHeight,
 changes: &'life1 HashMap<ValidatorId, (ValidatorStake, Option<ConsensusId>)>
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Apply validators diff to validator set and update validators_da_height. This operation needs to be atomic. Read more

source

fn get_chain_height<'life0, 'async_trait>(
 &'life0 self
) -> Pin<Box<dyn Future<Output = BlockHeight> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

current best block number

source

fn get_sealed_block<'life0, 'async_trait>(
 &'life0 self,
 _height: BlockHeight
) -> Pin<Box<dyn Future<Output = Option<Arc<SealedFuelBlock>>> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

source

fn set_finalized_da_height<'life0, 'async_trait>(
 &'life0 self,
 block: DaBlockHeight
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

set finalized da height that represent last block from da layer that got finalized.

source

fn get_finalized_da_height<'life0, 'async_trait>(
 &'life0 self
) -> Pin<Box<dyn Future<Output = DaBlockHeight> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

Assume it is allways set as initialization of database.

source

fn set_validators_da_height<'life0, 'async_trait>(
 &'life0 self,
 block: DaBlockHeight
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

Set data availability block height that corresponds to current_validator_set

source

fn get_validators_da_height<'life0, 'async_trait>(
 &'life0 self
) -> Pin<Box<dyn Future<Output = DaBlockHeight> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

Assume it is allways set as initialization of database.

source

fn get_last_commited_finalized_fuel_height<'life0, 'async_trait>(
 &'life0 self
) -> Pin<Box<dyn Future<Output = BlockHeight> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

Until blocks gets commited to da layer it is expected for it to still contains consensus votes and be saved in database until commitment is send to da layer and finalization pariod passes. In case that commited_finalized_fuel_height is zero we need to return genesis block. Read more

source

fn set_last_commited_finalized_fuel_height<'life0, 'async_trait>(
 &'life0 self,
 block_height: BlockHeight
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
 'life0: 'async_trait,
 Self: 'async_trait,

Set last commited finalized fuel height this means we are safe to remove consensus votes from db as from this moment they are not needed any more Read more

source

fn insert_coin_deposit<'life0, 'async_trait>(
 &'life0 mut self,
 deposit: DepositCoin
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
 'life0: 'async_trait,
 Self: 'async_trait,

deposit token to database. Token deposits are not revertable

source

fn insert_staking_diff<'life0, 'life1, 'async_trait>(
 &'life0 mut self,
 da_height: u32,
 stakes: &'life1 StakingDiff
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Insert difference make on staking in this particular DA height.

source

fn get_first_lesser_delegation<'life0, 'life1, 'async_trait>(
 &'life0 mut self,
 delegate: &'life1 Address,
 da_height: u32
) -> Pin<Box<dyn Future<Output = Option<HashMap<Address, u64, RandomState>>> + Send + 'async_trait, Global>> where
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Query delegate index to find list of blocks that delegation changed iterate over list of indexed to find height that is less but closest to da_height Query that block StakeDiff to find actual delegation change. Read more

source

fn append_delegate_index<'life0, 'life1, 'async_trait>(
 &'life0 mut self,
 delegate: &'life1 Address,
 da_height: u32
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

source

impl Storage<Address, (u64, Option<Bytes32>)> for Database

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &ValidatorId,
 value: &(ValidatorStake, Option<ConsensusId>)
) -> Result<Option<(ValidatorStake, Option<ConsensusId>)>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(
&mut self,
key: &ValidatorId
) -> Result<Option<(ValidatorStake, Option<ConsensusId>)>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &ValidatorId
) -> Result<Option<Cow<'_, (ValidatorStake, Option<ConsensusId>)>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &ValidatorId) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<Address, Vec<u32, Global>> for Database

Delegate Index maps delegateAddress with list of da block where delegation happened. so that we can access those changes

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &Address,
 value: &Vec<DaBlockHeight>
) -> Result<Option<Vec<DaBlockHeight>>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(
&mut self,
key: &Address
) -> Result<Option<Vec<DaBlockHeight>>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &Address
) -> Result<Option<Cow<'_, Vec<DaBlockHeight>>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &Address) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<Bytes32, DepositCoin> for Database

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &Bytes32,
 value: &DepositCoin
) -> Result<Option<DepositCoin>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(&mut self, key: &Bytes32) -> Result<Option<DepositCoin>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, DepositCoin>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &Bytes32) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<Bytes32, FuelBlockDb> for Database

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &Bytes32,
 value: &FuelBlockDb
) -> Result<Option<FuelBlockDb>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(&mut self, key: &Bytes32) -> Result<Option<FuelBlockDb>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, FuelBlockDb>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &Bytes32) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<Bytes32, Transaction> for Database

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &Bytes32,
 value: &Transaction
) -> Result<Option<Transaction>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(&mut self, key: &Bytes32) -> Result<Option<Transaction>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, Transaction>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &Bytes32) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<Bytes32, Vec<Receipt, Global>> for Database

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &Bytes32,
 value: &Vec<Receipt>
) -> Result<Option<Vec<Receipt>>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(
&mut self,
key: &Bytes32
) -> Result<Option<Vec<Receipt>>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, Vec<Receipt>>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &Bytes32) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<ContractId, (Salt, Bytes32)> for Database

type Error = Error

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &ContractId,
 value: &(Salt, Bytes32)
) -> Result<Option<(Salt, Bytes32)>, Error>

Append K->V mapping to the storage. Read more

source

fn remove(&mut self, key: &ContractId) -> Result<Option<(Salt, Bytes32)>, Error>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &ContractId
) -> Result<Option<Cow<'_, (Salt, Bytes32)>>, Error>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &ContractId) -> Result<bool, Error>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<ContractId, Contract> for Database

type Error = Error

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &ContractId,
 value: &Contract
) -> Result<Option<Contract>, Error>

Append K->V mapping to the storage. Read more

source

fn remove(&mut self, key: &ContractId) -> Result<Option<Contract>, Error>

Remove K->V mapping from the storage. Read more

source

fn get(&self, key: &ContractId) -> Result<Option<Cow<'_, Contract>>, Error>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &ContractId) -> Result<bool, Error>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<ContractId, UtxoId> for Database

type Error = Error

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &ContractId,
 value: &UtxoId
) -> Result<Option<UtxoId>, Self::Error>

Append K->V mapping to the storage. Read more

source

fn remove(&mut self, key: &ContractId) -> Result<Option<UtxoId>, Self::Error>

Remove K->V mapping from the storage. Read more

source

fn get<'a>(
&'a self,
key: &ContractId
) -> Result<Option<Cow<'a, UtxoId>>, Self::Error>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &ContractId) -> Result<bool, Self::Error>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<UtxoId, Coin> for Database

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &UtxoId,
 value: &Coin
) -> Result<Option<Coin>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(&mut self, key: &UtxoId) -> Result<Option<Coin>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(&self, key: &UtxoId) -> Result<Option<Cow<'_, Coin>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &UtxoId) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl Storage<u32, StakingDiff> for Database

type Error = KvStoreError

Error implementation of the storage functions

source

fn insert(
 &mut self,
 key: &DaBlockHeight,
 value: &StakingDiff
) -> Result<Option<StakingDiff>, KvStoreError>

Append K->V mapping to the storage. Read more

source

fn remove(
&mut self,
key: &DaBlockHeight
) -> Result<Option<StakingDiff>, KvStoreError>

Remove K->V mapping from the storage. Read more

source

fn get(
&self,
key: &DaBlockHeight
) -> Result<Option<Cow<'_, StakingDiff>>, KvStoreError>

Retrieve Cow<V> such as K->V.

source

fn contains_key(&self, key: &DaBlockHeight) -> Result<bool, KvStoreError>

Return true if there is a K mapping to a value in the storage.

source

impl TxPoolDb for Database

source

fn utxo(&self, utxo_id: &UtxoId) -> Result<Option<Coin>, KvStoreError>

source

fn contract_exist(&self, contract_id: ContractId) -> Result<bool, Error>

source

impl Send for Database

source

impl Sync for Database

Auto Trait Implementations

impl !RefUnwindSafe for Database

impl Unpin for Database

impl !UnwindSafe for Database

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

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> 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.

source

impl<T> Same<T> for T

type Output = T

Should always be Self

source

impl<T> ToOwned for T where
T: Clone,

type Owned = T

The resulting type after obtaining ownership.

source

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more

source

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. 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

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 fuel_core::database::Database

Implementations

impl Database

pub fn get_block_height(&self) -> Result<Option<BlockHeight>, Error>

pub fn get_block_id( &self, height: BlockHeight) -> Result<Option<Bytes32>, Error>

pub fn all_block_ids( &self, start: Option<BlockHeight>, direction: Option<IterDirection>) -> impl Iterator<Item = Result<(BlockHeight, Bytes32), Error>> + '_

impl Database

pub fn owned_coins( &self, owner: Address, start_coin: Option<UtxoId>, direction: Option<IterDirection>) -> impl Iterator<Item = Result<UtxoId, Error>> + '_

pub fn owned_coins_by_asset_id( &self, owner: Address, asset_id: AssetId, start_coin: Option<UtxoId>, direction: Option<IterDirection>) -> impl Iterator<Item = Result<UtxoId, Error>> + '_

impl Database

pub fn contract_balances( &self, contract: ContractId, start_asset: Option<AssetId>, direction: Option<IterDirection>) -> impl Iterator<Item = Result<(AssetId, Word), Error>> + '_

impl Database

pub fn init_chain_name(&self, name: String) -> Result<(), Error>

pub fn get_chain_name(&self) -> Result<Option<String>, Error>

pub fn init_chain_height(&self, height: BlockHeight) -> Result<(), Error>

pub fn get_starting_chain_height(&self) -> Result<Option<BlockHeight>, Error>

impl Database

pub fn all_transactions( &self, start: Option<&Bytes32>, direction: Option<IterDirection>) -> impl Iterator<Item = Result<Transaction, Error>> + '_

pub fn owned_transactions( &self, owner: &Address, start: Option<&OwnedTransactionIndexCursor>, direction: Option<IterDirection>) -> impl Iterator<Item = Result<(OwnedTransactionIndexCursor, Bytes32), Error>> + '_

pub fn record_tx_id_owner( &self, owner: &Address, block_height: BlockHeight, tx_idx: TransactionIndex, tx_id: &Bytes32) -> Result<Option<Bytes32>, Error>

pub fn update_tx_status( &self, tx_id: &Bytes32, status: TransactionStatus) -> Result<Option<TransactionStatus>, Error>

pub fn get_tx_status( &self, tx_id: &Bytes32) -> Result<Option<TransactionStatus>, Error>

impl Database

pub fn open(path: &Path) -> Result<Self, Error>

pub fn in_memory() -> Self

pub fn transaction(&self) -> DatabaseTransaction

Trait Implementations

impl AsMut<Database> for DatabaseTransaction

fn as_mut(&mut self) -> &mut Database

impl AsRef<Database> for DatabaseTransaction

fn as_ref(&self) -> &Database

impl AsRef<Database> for Database

fn as_ref(&self) -> &Database

impl Clone for Database

fn clone(&self) -> Database

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

impl Debug for Database

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

impl Default for Database

fn default() -> Self

impl From<&Database> for DatabaseTransaction

fn from(source: &Database) -> Self

impl InterpreterStorage for Database

type DataError = Error

fn block_height(&self) -> Result<u32, Error>

fn block_hash(&self, block_height: u32) -> Result<Bytes32, Error>

fn coinbase(&self) -> Result<Address, Error>

fn storage_contract( &self, id: &ContractId) -> Result<Option<Cow<'_, Contract>>, Self::DataError>

fn storage_contract_insert( &mut self, id: &ContractId, contract: &Contract) -> Result<Option<Contract>, Self::DataError>

fn storage_contract_exists( &self, id: &ContractId) -> Result<bool, Self::DataError>

fn storage_contract_root( &self, id: &ContractId) -> Result<Option<Cow<'_, (Salt, Bytes32)>>, Self::DataError>

fn storage_contract_root_insert( &mut self, id: &ContractId, salt: &Salt, root: &Bytes32) -> Result<Option<(Salt, Bytes32)>, Self::DataError>

fn merkle_contract_state( &self, id: &ContractId, key: &Bytes32) -> Result<Option<Cow<'_, Bytes32>>, Self::DataError>

fn merkle_contract_state_insert( &mut self, contract: &ContractId, key: &Bytes32, value: &Bytes32) -> Result<Option<Bytes32>, Self::DataError>

fn merkle_contract_asset_id_balance( &self, id: &ContractId, asset_id: &AssetId) -> Result<Option<u64>, Self::DataError>

fn merkle_contract_asset_id_balance_insert( &mut self, contract: &ContractId, asset_id: &AssetId, value: u64) -> Result<Option<u64>, Self::DataError>

impl MerkleStorage<ContractId, AssetId, u64> for Database

type Error = Error

fn insert( &mut self, parent: &ContractId, key: &AssetId, value: &Word) -> Result<Option<Word>, Error>

fn remove( &mut self, parent: &ContractId, key: &AssetId) -> Result<Option<Word>, Error>

fn get( &self, parent: &ContractId, key: &AssetId) -> Result<Option<Cow<'_, Word>>, Error>

fn contains_key( &self, parent: &ContractId, key: &AssetId) -> Result<bool, Error>

fn root(&mut self, parent: &ContractId) -> Result<MerkleRoot, Error>

impl MerkleStorage<ContractId, Bytes32, Bytes32> for Database

type Error = Error

fn insert( &mut self, parent: &ContractId, key: &Bytes32, value: &Bytes32) -> Result<Option<Bytes32>, Error>

fn remove( &mut self, parent: &ContractId, key: &Bytes32) -> Result<Option<Bytes32>, Error>

fn get( &self, parent: &ContractId, key: &Bytes32) -> Result<Option<Cow<'_, Bytes32>>, Error>

fn contains_key( &self, parent: &ContractId, key: &Bytes32) -> Result<bool, Error>

fn root(&mut self, parent: &ContractId) -> Result<MerkleRoot, Error>

impl RelayerDb for Database

fn get_validators<'life0, 'async_trait>( &'life0 self) -> Pin<Box<dyn Future<Output = HashMap<ValidatorId, (ValidatorStake, Option<ConsensusId>)>> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn get_staking_diffs<'life0, 'async_trait>( &'life0 self, from_da_height: DaBlockHeight, to_da_height: Option<DaBlockHeight>) -> Pin<Box<dyn Future<Output = Vec<(DaBlockHeight, StakingDiff)>> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn get_chain_height<'life0, 'async_trait>( &'life0 self) -> Pin<Box<dyn Future<Output = BlockHeight> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn get_sealed_block<'life0, 'async_trait>( &'life0 self, _height: BlockHeight) -> Pin<Box<dyn Future<Output = Option<Arc<SealedFuelBlock>>> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn set_finalized_da_height<'life0, 'async_trait>( &'life0 self, block: DaBlockHeight) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn get_finalized_da_height<'life0, 'async_trait>( &'life0 self) -> Pin<Box<dyn Future<Output = DaBlockHeight> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn set_validators_da_height<'life0, 'async_trait>( &'life0 self, block: DaBlockHeight) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn get_validators_da_height<'life0, 'async_trait>( &'life0 self) -> Pin<Box<dyn Future<Output = DaBlockHeight> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

fn get_last_commited_finalized_fuel_height<'life0, 'async_trait>( &'life0 self) -> Pin<Box<dyn Future<Output = BlockHeight> + Send + 'async_trait>> where 'life0: 'async_trait, Self: 'async_trait,

pub fn get_block_id(
&self,
height: BlockHeight
) -> Result<Option<Bytes32>, Error>

pub fn all_block_ids(
&self,
start: Option<BlockHeight>,
direction: Option<IterDirection>
) -> impl Iterator<Item = Result<(BlockHeight, Bytes32), Error>> + '_

pub fn owned_coins(
&self,
owner: Address,
start_coin: Option<UtxoId>,
direction: Option<IterDirection>
) -> impl Iterator<Item = Result<UtxoId, Error>> + '_

pub fn owned_coins_by_asset_id(
&self,
owner: Address,
asset_id: AssetId,
start_coin: Option<UtxoId>,
direction: Option<IterDirection>
) -> impl Iterator<Item = Result<UtxoId, Error>> + '_

pub fn contract_balances(
&self,
contract: ContractId,
start_asset: Option<AssetId>,
direction: Option<IterDirection>
) -> impl Iterator<Item = Result<(AssetId, Word), Error>> + '_

pub fn all_transactions(
&self,
start: Option<&Bytes32>,
direction: Option<IterDirection>
) -> impl Iterator<Item = Result<Transaction, Error>> + '_

pub fn owned_transactions(
&self,
owner: &Address,
start: Option<&OwnedTransactionIndexCursor>,
direction: Option<IterDirection>
) -> impl Iterator<Item = Result<(OwnedTransactionIndexCursor, Bytes32), Error>> + '_

pub fn record_tx_id_owner(
&self,
owner: &Address,
block_height: BlockHeight,
tx_idx: TransactionIndex,
tx_id: &Bytes32
) -> Result<Option<Bytes32>, Error>

pub fn update_tx_status(
&self,
tx_id: &Bytes32,
status: TransactionStatus
) -> Result<Option<TransactionStatus>, Error>

pub fn get_tx_status(
&self,
tx_id: &Bytes32
) -> Result<Option<TransactionStatus>, Error>

fn storage_contract(
&self,
id: &ContractId
) -> Result<Option<Cow<'_, Contract>>, Self::DataError>

fn storage_contract_insert(
&mut self,
id: &ContractId,
contract: &Contract
) -> Result<Option<Contract>, Self::DataError>

fn storage_contract_exists(
&self,
id: &ContractId
) -> Result<bool, Self::DataError>

fn storage_contract_root(
&self,
id: &ContractId
) -> Result<Option<Cow<'_, (Salt, Bytes32)>>, Self::DataError>

fn storage_contract_root_insert(
&mut self,
id: &ContractId,
salt: &Salt,
root: &Bytes32
) -> Result<Option<(Salt, Bytes32)>, Self::DataError>

fn merkle_contract_state(
&self,
id: &ContractId,
key: &Bytes32
) -> Result<Option<Cow<'_, Bytes32>>, Self::DataError>

fn merkle_contract_state_insert(
&mut self,
contract: &ContractId,
key: &Bytes32,
value: &Bytes32
) -> Result<Option<Bytes32>, Self::DataError>

fn merkle_contract_asset_id_balance(
&self,
id: &ContractId,
asset_id: &AssetId
) -> Result<Option<u64>, Self::DataError>

fn merkle_contract_asset_id_balance_insert(
&mut self,
contract: &ContractId,
asset_id: &AssetId,
value: u64
) -> Result<Option<u64>, Self::DataError>

fn insert(
&mut self,
parent: &ContractId,
key: &AssetId,
value: &Word
) -> Result<Option<Word>, Error>

fn remove(
&mut self,
parent: &ContractId,
key: &AssetId
) -> Result<Option<Word>, Error>

fn get(
&self,
parent: &ContractId,
key: &AssetId
) -> Result<Option<Cow<'_, Word>>, Error>

fn contains_key(
&self,
parent: &ContractId,
key: &AssetId
) -> Result<bool, Error>

fn insert(
&mut self,
parent: &ContractId,
key: &Bytes32,
value: &Bytes32
) -> Result<Option<Bytes32>, Error>

fn remove(
&mut self,
parent: &ContractId,
key: &Bytes32
) -> Result<Option<Bytes32>, Error>

fn get(
&self,
parent: &ContractId,
key: &Bytes32
) -> Result<Option<Cow<'_, Bytes32>>, Error>

fn contains_key(
&self,
parent: &ContractId,
key: &Bytes32
) -> Result<bool, Error>

fn get_validators<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = HashMap<ValidatorId, (ValidatorStake, Option<ConsensusId>)>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn get_staking_diffs<'life0, 'async_trait>(
&'life0 self,
from_da_height: DaBlockHeight,
to_da_height: Option<DaBlockHeight>
) -> Pin<Box<dyn Future<Output = Vec<(DaBlockHeight, StakingDiff)>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn get_chain_height<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = BlockHeight> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn get_sealed_block<'life0, 'async_trait>(
&'life0 self,
_height: BlockHeight
) -> Pin<Box<dyn Future<Output = Option<Arc<SealedFuelBlock>>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn set_finalized_da_height<'life0, 'async_trait>(
&'life0 self,
block: DaBlockHeight
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn get_finalized_da_height<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = DaBlockHeight> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn set_validators_da_height<'life0, 'async_trait>(
&'life0 self,
block: DaBlockHeight
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn get_validators_da_height<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = DaBlockHeight> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn get_last_commited_finalized_fuel_height<'life0, 'async_trait>(
&'life0 self
) -> Pin<Box<dyn Future<Output = BlockHeight> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn set_last_commited_finalized_fuel_height<'life0, 'async_trait>(
&'life0 self,
block_height: BlockHeight
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,

fn insert_coin_deposit<'life0, 'async_trait>(
&'life0 mut self,
deposit: DepositCoin
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
Self: 'async_trait,

fn insert_staking_diff<'life0, 'life1, 'async_trait>(
&'life0 mut self,
da_height: u32,
stakes: &'life1 StakingDiff
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,

fn append_delegate_index<'life0, 'life1, 'async_trait>(
&'life0 mut self,
delegate: &'life1 Address,
da_height: u32
) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait, Global>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,

fn insert(
&mut self,
key: &ValidatorId,
value: &(ValidatorStake, Option<ConsensusId>)
) -> Result<Option<(ValidatorStake, Option<ConsensusId>)>, KvStoreError>

fn remove(
&mut self,
key: &ValidatorId
) -> Result<Option<(ValidatorStake, Option<ConsensusId>)>, KvStoreError>

fn get(
&self,
key: &ValidatorId
) -> Result<Option<Cow<'_, (ValidatorStake, Option<ConsensusId>)>>, KvStoreError>

fn insert(
&mut self,
key: &Address,
value: &Vec<DaBlockHeight>
) -> Result<Option<Vec<DaBlockHeight>>, KvStoreError>

fn remove(
&mut self,
key: &Address
) -> Result<Option<Vec<DaBlockHeight>>, KvStoreError>

fn get(
&self,
key: &Address
) -> Result<Option<Cow<'_, Vec<DaBlockHeight>>>, KvStoreError>

fn insert(
&mut self,
key: &Bytes32,
value: &DepositCoin
) -> Result<Option<DepositCoin>, KvStoreError>

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, DepositCoin>>, KvStoreError>

fn insert(
&mut self,
key: &Bytes32,
value: &FuelBlockDb
) -> Result<Option<FuelBlockDb>, KvStoreError>

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, FuelBlockDb>>, KvStoreError>

fn insert(
&mut self,
key: &Bytes32,
value: &Transaction
) -> Result<Option<Transaction>, KvStoreError>

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, Transaction>>, KvStoreError>

fn insert(
&mut self,
key: &Bytes32,
value: &Vec<Receipt>
) -> Result<Option<Vec<Receipt>>, KvStoreError>

fn remove(
&mut self,
key: &Bytes32
) -> Result<Option<Vec<Receipt>>, KvStoreError>

fn get(
&self,
key: &Bytes32
) -> Result<Option<Cow<'_, Vec<Receipt>>>, KvStoreError>

fn insert(
&mut self,
key: &ContractId,
value: &(Salt, Bytes32)
) -> Result<Option<(Salt, Bytes32)>, Error>

fn get(
&self,
key: &ContractId
) -> Result<Option<Cow<'_, (Salt, Bytes32)>>, Error>

fn insert(
&mut self,
key: &ContractId,
value: &Contract
) -> Result<Option<Contract>, Error>

fn insert(
&mut self,
key: &ContractId,
value: &UtxoId
) -> Result<Option<UtxoId>, Self::Error>

fn get<'a>(
&'a self,
key: &ContractId
) -> Result<Option<Cow<'a, UtxoId>>, Self::Error>

fn insert(
&mut self,
key: &UtxoId,
value: &Coin
) -> Result<Option<Coin>, KvStoreError>