seq

package

v0.0.12 Latest Latest Go to latest Published: Dec 12, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Seq struct {
	sync.Mutex
	Root string
}

func NewSeq(root string) *Seq

func (s *Seq) CurrentSeqState() (*State, error)

CurrentSeqState returns the current sequence state without incrementing.

func (s *Seq) NextCommit() (int64, error)

NextCommit atomically increments and returns the next commit count.

func (s *Seq) NextCommitLocked() (int64, error)

func (s *Seq) NextTxSeq() (int64, error)

NextTxSeq atomically increments and returns the next transaction sequence number.

func (s *Seq) ReadStateLocked() (*State, error)

readSeqState reads the sequence state from disk. Caller must hold seqMu lock.

func (s *Seq) WriteStateLocked(state *State) error

WriteStateLocked writes the sequence state to disk atomically. Caller must hold seqMu lock.

type State struct {
	Commit int64 // Monotonic commit count
	TxSeq  int64 // Transaction sequence number
}

State represents the sequence number state.