Struct scrypto_test::prelude::Track

pub struct Track<'s, S, M>
where
    S: SubstateDatabase,
    M: DatabaseKeyMapper + 'static,
{
    substate_db: &'s S,
    tracked_nodes: IndexMap<NodeId, TrackedNode>,
    force_write_tracked_nodes: IndexMap<NodeId, TrackedNode>,
    deleted_partitions: IndexSet<(NodeId, PartitionNumber)>,
    transient_substates: TransientSubstates,
    phantom_data: PhantomData<M>,
}

Transaction-wide states and side effects

Fields

substate_db: &'s S

tracked_nodes: IndexMap<NodeId, TrackedNode>

force_write_tracked_nodes: IndexMap<NodeId, TrackedNode>

deleted_partitions: IndexSet<(NodeId, PartitionNumber)>

transient_substates: TransientSubstates

phantom_data: PhantomData<M>

Implementations

impl<'s, S, M> Track<'s, S, M>

where S: SubstateDatabase, M: DatabaseKeyMapper + 'static,

pub fn new(substate_db: &'s S) -> Track<'s, S, M>

pub fn revert_non_force_write_changes(&mut self)

Reverts all non force write changes.

Note that dependencies will never be reverted.

pub fn finalize( self ) -> Result<(IndexMap<NodeId, TrackedNode>, IndexSet<(NodeId, PartitionNumber)>), TrackFinalizeError>

Finalizes changes captured by this substate store.

Returns the state changes and dependencies.

Trait Implementations

impl<'s, S, M> BootStore for Track<'s, S, M>

where S: SubstateDatabase, M: DatabaseKeyMapper + 'static,

fn read_substate( &self, node_id: &NodeId, partition_num: PartitionNumber, substate_key: &SubstateKey ) -> Option<IndexedScryptoValue>

Read a substate from the store

impl<'s, S, M> CommitableSubstateStore for Track<'s, S, M>

where S: SubstateDatabase, M: DatabaseKeyMapper + 'static,

fn mark_as_transient( &mut self, node_id: NodeId, partition_num: PartitionNumber, substate_key: SubstateKey )

Marks a substate as transient, or a substate which was never and will never be persisted

fn create_node<E, F>( &mut self, node_id: NodeId, node_substates: BTreeMap<PartitionNumber, BTreeMap<SubstateKey, IndexedScryptoValue>>, on_io_access: &mut F ) -> Result<(), E>

where F: FnMut(IOAccess) -> Result<(), E>,

Inserts a node into the substate store.

fn get_tracked_substate_info( &mut self, node_id: &NodeId, partition_num: PartitionNumber, substate_key: &SubstateKey ) -> TrackedSubstateInfo

fn get_substate<E, F>( &mut self, node_id: &NodeId, partition_num: PartitionNumber, substate_key: &SubstateKey, on_io_access: &mut F ) -> Result<Option<&IndexedScryptoValue>, E>

where F: FnMut(IOAccess) -> Result<(), E>,

fn set_substate<E, F>( &mut self, node_id: NodeId, partition_number: PartitionNumber, substate_key: SubstateKey, substate_value: IndexedScryptoValue, on_io_access: &mut F ) -> Result<(), E>

where F: FnMut(IOAccess) -> Result<(), E>,

Inserts a substate into the substate store.

fn force_write( &mut self, node_id: &NodeId, partition_num: &PartitionNumber, substate_key: &SubstateKey )

fn remove_substate<E, F>( &mut self, node_id: &NodeId, partition_number: PartitionNumber, substate_key: &SubstateKey, on_io_access: &mut F ) -> Result<Option<IndexedScryptoValue>, E>

where F: FnMut(IOAccess) -> Result<(), E>,

Deletes a substate from the substate store.

fn scan_keys<K, E, F>( &mut self, node_id: &NodeId, partition_number: PartitionNumber, limit: u32, on_io_access: &mut F ) -> Result<Vec<SubstateKey>, E>

where K: SubstateKeyContent + 'static, F: FnMut(IOAccess) -> Result<(), E>,

Returns Substate Keys of maximum count for a given partition.

fn drain_substates<K, E, F>( &mut self, node_id: &NodeId, partition_number: PartitionNumber, limit: u32, on_io_access: &mut F ) -> Result<Vec<(SubstateKey, IndexedScryptoValue)>, E>

where K: SubstateKeyContent + 'static, F: FnMut(IOAccess) -> Result<(), E>,

Removes substates of maximum count for a given partition.

fn scan_sorted_substates<E, F>( &mut self, node_id: &NodeId, partition_number: PartitionNumber, limit: u32, on_io_access: &mut F ) -> Result<Vec<(([u8; 2], Vec<u8>), IndexedScryptoValue)>, E>

where F: FnMut(IOAccess) -> Result<(), E>,

Returns tuple of substate vector and boolean which is true for the first database access.

fn delete_partition(&mut self, node_id: &NodeId, partition_num: PartitionNumber)

Note: unstable interface, for intent transaction tracker only

fn get_commit_info(&mut self) -> Vec<StoreCommit>

Return the commit info

fn read_substate( &mut self, node_id: &NodeId, partition_num: PartitionNumber, substate_key: &SubstateKey ) -> Option<&IndexedScryptoValue>