mvcc

package

v0.2.2 Latest Latest Go to latest Published: Jun 22, 2026 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Package mvcc implements Multi-Version Concurrency Control for ScoriaDB, providing snapshot isolation with versioned key-value pairs.

This section is empty.

This section is empty.

func InvertTimestamp(ts uint64) uint64

InvertTimestamp инвертирует timestamp для сортировки новых версий первыми. Используется в MVCCKey.

func RevertTimestamp(inverted uint64) uint64

RevertTimestamp восстанавливает оригинальный timestamp из инвертированного.

type MVCCKey struct {
	Key       []byte
	Timestamp uint64 // инвертированный: MaxUint64 - commitTS
}

MVCCKey представляет ключ с версией (инвертированный timestamp).

func NewMVCCKey(key []byte, commitTS uint64) MVCCKey

NewMVCCKey создает MVCCKey из пользовательского ключа и commit timestamp.

func (k MVCCKey) CommitTS() uint64

CommitTS возвращает оригинальный commit timestamp.

func (k MVCCKey) Compare(other MVCCKey) int

Compare сравнивает два ключа лексикографически (ключ, затем timestamp).

func (k MVCCKey) Less(than btree.Item) bool

Less реализует интерфейс btree.Item для сортировки.

type TimestampGenerator struct {
	// contains filtered or unexported fields
}

TimestampGenerator генерирует монотонные временные метки.

func NewTimestampGenerator() *TimestampGenerator

NewTimestampGenerator создает новый генератор.

func (tg *TimestampGenerator) Increment() uint64

Increment увеличивает счетчик и возвращает новый timestamp.

func (tg *TimestampGenerator) Next() uint64

Next возвращает следующий timestamp.

func (tg *TimestampGenerator) Set(val uint64)

Set устанавливает счетчик в значение (для восстановления).