pub enum CommitPhase {
AdmissionWait,
Build,
Expand,
Durable,
WalEncode,
WalAppendSync,
BackendApply,
Derive,
Publish,
}Expand description
One timed step of the commit pipeline. Committer-side phases are observed once per commit; publisher-side phases once per publish group.
Variants§
AdmissionWait
Waiting for the admission (sequencer) lock.
Build
Running the caller’s planner/build closure.
Expand
Deterministic expansion into ops, including slot-reservation retries.
Durable
Enqueue until the durable acknowledgement (the end-to-end latency the client waits for after expansion).
WalEncode
Publisher: encoding a group’s WAL records.
WalAppendSync
Publisher: appending and fsyncing a group’s WAL records.
BackendApply
Publisher: applying a group’s ops to the backend materialization.
Derive
Publisher: advancing derived state for a group.
Publish
Publisher: conflict-window recording, watermark advance and acks.
Implementations§
Trait Implementations§
Source§impl Clone for CommitPhase
impl Clone for CommitPhase
impl Copy for CommitPhase
Source§impl Debug for CommitPhase
impl Debug for CommitPhase
impl Eq for CommitPhase
Source§impl Hash for CommitPhase
impl Hash for CommitPhase
Source§impl PartialEq for CommitPhase
impl PartialEq for CommitPhase
impl StructuralPartialEq for CommitPhase
Auto Trait Implementations§
impl Freeze for CommitPhase
impl RefUnwindSafe for CommitPhase
impl Send for CommitPhase
impl Sync for CommitPhase
impl Unpin for CommitPhase
impl UnsafeUnpin for CommitPhase
impl UnwindSafe for CommitPhase
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.