Struct PreCommitContext 

pub struct PreCommitContext {
    pub flow_changes: Vec<Change>,
    pub pending_writes: Vec<(EncodedKey, Option<EncodedRow>)>,
    pub pending_shapes: Vec<RowShape>,
    pub transaction_writes: Vec<(EncodedKey, Option<EncodedRow>)>,
    pub view_entries: Vec<(ShapeId, Diff)>,
}

flow_changes carries the table-level changes accumulated during the transaction (input for transactional flow interceptors). pending_writes is populated by interceptors with view writes to be merged back into the transaction before it commits.

Fields

flow_changes: Vec<Change>

Table changes accumulated during this transaction (input to flow interceptors).

pending_writes: Vec<(EncodedKey, Option<EncodedRow>)>

View writes produced by flow interceptors to merge back into the transaction. Some(value) = set the key, None = remove the key.

pending_shapes: Vec<RowShape>

Row shapes created during flow processing, to be persisted at commit time.

transaction_writes: Vec<(EncodedKey, Option<EncodedRow>)>

Snapshot of the committing transaction’s pending KV writes (read-only base for flow processing). Some(value) = set the key, None = remove the key.

view_entries: Vec<(ShapeId, Diff)>

View-level accumulator entries produced by flow interceptors. Used by test infrastructure to feed view diffs back into the change accumulator.

Implementations

impl PreCommitContext

pub fn new() -> Self

Trait Implementations

impl Default for PreCommitContext

fn default() -> Self

Returns the “default value” for a type.