Enum CommitState 

pub enum CommitState<Clock: LogicalClock, A: ConcurrentAllocator = TursoAllocator> {
    Initial,
    Commit {
        end_ts: u64,
    },
    WaitForDependencies {
        end_ts: u64,
    },
    BuildLogRecord(BuildLogRecordCtx),
    BeginCommitLogicalLog {
        end_ts: u64,
        log_record: LogRecord,
    },
    UpgradeLogicalLogHeader {
        end_ts: u64,
        log_record: LogRecord,
    },
    WriteLogicalLog {
        end_ts: u64,
        log_record: LogRecord,
    },
    FinishLogicalLogWrite {
        end_ts: u64,
    },
    SyncLogicalLog {
        end_ts: u64,
    },
    EndCommitLogicalLog {
        end_ts: u64,
    },
    Checkpoint {
        state_machine: Mutex<StateMachine<CheckpointStateMachine<Clock, A>>>,
    },
    CommitEnd {
        end_ts: u64,
    },
    RewriteLiveVersions(RewriteLiveVersionsCtx),
    FinalizeCommit {
        end_ts: u64,
    },
}

Variants

Initial

Commit

Fields

end_ts: u64

WaitForDependencies

Wait for unresolved commit dependencies before building the durable committed view for the logical log. Hekaton Section 3.2: “If T passes validation, it must wait for outstanding commit dependencies to be resolved.”

Fields

end_ts: u64

BuildLogRecord(BuildLogRecordCtx)

Build the committed log record incrementally, yielding every MVCC_COMMIT_BATCH_SIZE rowids so that very large write sets (e.g. CREATE INDEX on a multi-million row table) don’t monopolize the executor.

BeginCommitLogicalLog

Fields

end_ts: u64

log_record: LogRecord

UpgradeLogicalLogHeader

Fields

end_ts: u64

log_record: LogRecord

WriteLogicalLog

Fields

end_ts: u64

log_record: LogRecord

FinishLogicalLogWrite

Fields

end_ts: u64

SyncLogicalLog

Fields

end_ts: u64

EndCommitLogicalLog

Fields

end_ts: u64

Checkpoint

Fields

state_machine: Mutex<StateMachine<CheckpointStateMachine<Clock, A>>>

CommitEnd

Fields

end_ts: u64

RewriteLiveVersions(RewriteLiveVersionsCtx)

Publish committed timestamps into the live MVCC chains in chunks of MVCC_COMMIT_BATCH_SIZE rowids, yielding between chunks. The transaction is already in the Committed state at this point, so readers consult txs[tx_id] to resolve any TxID references that haven’t been rewritten yet.

FinalizeCommit

Final post-rewrite cleanup: drain commit dependents, release the commit lock, update the global header, finish the tx, and start auto-checkpoint if needed.

Fields

end_ts: u64

Trait Implementations

impl<Clock: LogicalClock, A: ConcurrentAllocator> Debug for CommitState<Clock, A>

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

Formats the value using the given formatter.