Struct CurrentStaged 

pub struct CurrentStaged<F, E, C, I, H, U, const N: usize, S>
where
    F: Graftable,
    E: Context,
    U: Update,
    C: Contiguous<Item = Operation<F, U>>,
    I: UnorderedIndex<Value = Location<F>>,
    H: Hasher,
    S: Strategy,
    Operation<F, U>: Codec,
{ /* private fields */ }

Staged batch returned by CurrentUnmerkleized::stage, wrapping a QMDB Staged with a reference to the parent database.

Like any speculative batch, this handle is a branch-scoped view of the shared database: it stays valid only while every batch finalized on the database is an ancestor of this batch (see MerkleizedBatch’s branch-validity contract).

Implementations

impl<F, E, C, I, H, U, const N: usize, S> CurrentStaged<F, E, C, I, H, U, N, S>

where F: Graftable, E: Context, U: Update, C: Contiguous<Item = Operation<F, U>>, I: UnorderedIndex<Value = Location<F>> + 'static, H: Hasher, S: Strategy, Operation<F, U>: Codec,

Read-expansion operations for the current staged batch.

pub fn with_metadata(self, metadata: U::Value) -> Self

Set commit metadata included in the merkleize call, replacing any metadata set before staging.

pub async fn expand( self, keys: &[&U::Key], ) -> Result<(Range<usize>, Vec<Option<U::Value>>, Self), Error<F>>

Expand this staged batch with more reads.

Existing read indices remain stable. Newly read keys are appended to the staged read set and assigned the returned range. Expansion does not deduplicate against previously staged keys and does not observe values computed for earlier staged slots but not yet passed to merkleize.

impl<F, E, C, I, H, K, V, const N: usize, S> CurrentStaged<F, E, C, I, H, Update<K, V>, N, S>

where F: Graftable, E: Context, K: Key, V: ValueEncoding + 'static, C: Mutable<Item = Operation<F, Update<K, V>>>, I: UnorderedIndex<Value = Location<F>> + 'static, H: Hasher, S: Strategy, Operation<F, Update<K, V>>: Codec,

Staged merkleize for the current unordered update kind.

pub async fn merkleize( self, updates: Vec<(usize, Option<V::Value>)>, upserts: Vec<(K, Option<V::Value>)>, ) -> Result<CurrentMerkleized<F, E, C, I, H, Update<K, V>, N, S>, Error<F>>

Record updates for staged reads and upserts for unread keys, then merkleize.

Consumes the staged handle and write vectors. Call expand before this method if more keys must be read into the staged index space.

A Some value is an upsert. None is a delete. Update indices refer to the staged read set: the initial stage input followed by any expand ranges. Metadata set via with_metadata (or before staging) is committed with the returned batch.

Panics

Panics if any update’s read_index is out of the staged read range.

impl<F, E, C, I, H, K, V, const N: usize, S> CurrentStaged<F, E, C, I, H, Update<K, V>, N, S>

where F: Graftable, E: Context, K: Key, V: ValueEncoding + 'static, C: Mutable<Item = Operation<F, Update<K, V>>>, I: OrderedIndex<Value = Location<F>> + 'static, H: Hasher, S: Strategy, Operation<F, Update<K, V>>: Codec,

Staged merkleize for the current ordered update kind.

pub async fn merkleize( self, updates: Vec<(usize, Option<V::Value>)>, upserts: Vec<(K, Option<V::Value>)>, ) -> Result<CurrentMerkleized<F, E, C, I, H, Update<K, V>, N, S>, Error<F>>

Record updates for staged reads and upserts for unread keys, then merkleize.

Consumes the staged handle and write vectors. Call expand before this method if more keys must be read into the staged index space.

A Some value is an upsert. None is a delete. Update indices refer to the staged read set: the initial stage input followed by any expand ranges. Metadata set via with_metadata (or before staging) is committed with the returned batch.

Panics

Panics if any update’s read_index is out of the staged read range.