index

Documentation

Index

• Variables
• type Index
  • func New[T any](opts Options) Index[T]
• type Options
• type Txn
• type Value
• type VersionChainHead

Variables

var (
	ErrAnotherTxnHeldWLock  = errors.New("another txn held write-lock")
	ErrFailedToAcquireWLock = errors.New("failed to acquire write-lock")
	ErrWriteConflicts       = errors.New("write conflicts")
	ErrKeyNotExists         = errors.New("key not exists")
)

Types

type Index

type Index[T any] interface {
	NewTransactionAt(readTs uint64, update bool) Txn[T]
}

func New

func New[T any](opts Options) Index[T]

type Options

type Options struct {
}

type Txn

type Txn[T any] interface {
	Get(key []byte) (ret T, err error)
	Set(key []byte, value T) error
	CommitAt(commitTs uint64, callback func(error)) error
	ReadTS() uint64
}

type Value

type Value[T any] struct {
	// contains filtered or unexported fields
}

Value value and Timestamp Ordering header (MVTO)

type VersionChainHead

type VersionChainHead[T any] struct {
	// contains filtered or unexported fields
}