storage

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

type GlobalRead struct {
	Value   []byte
	Version int64
}

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

type LocalMetadata struct {
	M backend.Metadata
	// Outdated is true if the metadata is certainly outdated.
	Outdated bool
}

type LocalRead struct {
	Value   []byte
	Version Version
	Deleted bool
	// Outdated is true if the value read is certainly outdated.
	Outdated bool
}

type LockInfo struct {
	Type       LockType
	LockedBy   []data.TxID
	LastWriter data.TxID
}

type LockOps struct {
	// Update is the possible next update on the lock. If nothing should be
	// updated, HasUpdate will be false.
	Update    LockUpdate
	HasUpdate bool
	// WaitFor is the list of transactions that need to unlock before any
	// operation can be performed.
	WaitFor []data.TxID
	// What effect these operations will have.
	LockedFor   []data.TxID
	UnlockedFor []data.TxID
}

type LockRequest struct {
	Type      LockType
	Lockers   []data.TxID
	Unlockers []data.TxID
}

type LockType int

type LockUpdate struct {
	Type     LockType
	PrevType LockType
	Lockers  []data.TxID
	Writer   data.TxID
	Value    TValue
}

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

type PathLock struct {
	Path string
	Type LockType
}

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

type TValue struct {
	Value   []byte
	Deleted bool
	// NotWritten is true when the transaction was committed but the value
	// was not written to (e.g. when only locked in read).
	NotWritten bool
}

type TxCommitStatus int

type TxLog struct {
	ID        data.TxID
	Timestamp time.Time
	Status    TxCommitStatus
	Writes    []TxWrite
	Locks     []PathLock
}

type TxPathState struct {
	Tx     data.TxID
	Status TxCommitStatus
	Value  TValue
}

type TxStatus struct {
	Status     TxCommitStatus
	LastUpdate time.Time
	Version    backend.Version
}

type TxWrite struct {
	Path       string
	Value      []byte
	Deleted    bool
	PrevWriter data.TxID
}

type Version struct {
	B      backend.Version
	Writer data.TxID
}