storagepb

Documentation

Index

• Variables
• type EngineStatus
  • func (*EngineStatus) Descriptor() ([]byte, []int)
  • func (x *EngineStatus) GetGarbageDiskSize() int64
  • func (x *EngineStatus) GetKeys() int64
  • func (x *EngineStatus) GetLiveDiskSize() int64
  • func (x *EngineStatus) GetName() string
  • func (x *EngineStatus) GetSize() int64
  • func (x *EngineStatus) GetTotalDiskSize() int64
  • func (*EngineStatus) ProtoMessage()
  • func (x *EngineStatus) ProtoReflect() protoreflect.Message
  • func (x *EngineStatus) Reset()
  • func (x *EngineStatus) String() string
• type MVCCStatus
  • func (*MVCCStatus) Descriptor() ([]byte, []int)
  • func (x *MVCCStatus) GetActiveTxns() int64
  • func (x *MVCCStatus) GetStorage() *EngineStatus
  • func (x *MVCCStatus) GetVersions() int64
  • func (*MVCCStatus) ProtoMessage()
  • func (x *MVCCStatus) ProtoReflect() protoreflect.Message
  • func (x *MVCCStatus) Reset()
  • func (x *MVCCStatus) String() string
• type MVCCTxnState
  • func (*MVCCTxnState) Descriptor() ([]byte, []int)
  • func (x *MVCCTxnState) GetActiveTxns() []uint64
  • func (x *MVCCTxnState) GetReadOnly() bool
  • func (x *MVCCTxnState) GetVersion() uint64
  • func (m *MVCCTxnState) IsVisible(version uint64) bool
  • func (*MVCCTxnState) ProtoMessage()
  • func (x *MVCCTxnState) ProtoReflect() protoreflect.Message
  • func (x *MVCCTxnState) Reset()
  • func (x *MVCCTxnState) String() string

Variables

var File_storage_storagepb_storage_proto protoreflect.FileDescriptor

Types

type EngineStatus

type EngineStatus struct {

	// Name is the name of the engine.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Keys is the number of live keys in the engine.
	Keys int64 `protobuf:"varint,2,opt,name=keys,proto3" json:"keys,omitempty"`
	// Size is the logical size of live key/values pairs.
	Size int64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// TotalDiskSize is the on-disk size of all data, live and garbage.
	TotalDiskSize int64 `protobuf:"varint,4,opt,name=total_disk_size,json=totalDiskSize,proto3" json:"total_disk_size,omitempty"`
	// LiveDiskSize is the on-disk size of live data.
	LiveDiskSize int64 `protobuf:"varint,5,opt,name=live_disk_size,json=liveDiskSize,proto3" json:"live_disk_size,omitempty"`
	// GarbageDiskSize is the on-disk size of garbage data.
	GarbageDiskSize int64 `protobuf:"varint,6,opt,name=garbage_disk_size,json=garbageDiskSize,proto3" json:"garbage_disk_size,omitempty"`
	// contains filtered or unexported fields
}

EngineStatus contains the current status of the storage engine.

func (*EngineStatus) Descriptor

func (*EngineStatus) Descriptor() ([]byte, []int)

Deprecated: Use EngineStatus.ProtoReflect.Descriptor instead.

func (*EngineStatus) GetGarbageDiskSize

func (x *EngineStatus) GetGarbageDiskSize() int64

func (*EngineStatus) GetKeys

func (x *EngineStatus) GetKeys() int64

func (*EngineStatus) GetLiveDiskSize

func (x *EngineStatus) GetLiveDiskSize() int64

func (*EngineStatus) GetName

func (x *EngineStatus) GetName() string

func (*EngineStatus) GetSize

func (x *EngineStatus) GetSize() int64

func (*EngineStatus) GetTotalDiskSize

func (x *EngineStatus) GetTotalDiskSize() int64

func (*EngineStatus) ProtoMessage

func (*EngineStatus) ProtoMessage()

func (*EngineStatus) ProtoReflect

func (x *EngineStatus) ProtoReflect() protoreflect.Message

func (*EngineStatus) Reset

func (x *EngineStatus) Reset()

func (*EngineStatus) String

func (x *EngineStatus) String() string

type MVCCStatus

type MVCCStatus struct {

	// Versions is the number of MVCC versions (i.e. read-write transactions).
	Versions int64 `protobuf:"varint,1,opt,name=versions,proto3" json:"versions,omitempty"`
	// ActiveTxns is the number of active transactions.
	ActiveTxns int64 `protobuf:"varint,2,opt,name=active_txns,json=activeTxns,proto3" json:"active_txns,omitempty"`
	// Storage is the underlying storage engine status.
	Storage *EngineStatus `protobuf:"bytes,3,opt,name=storage,proto3" json:"storage,omitempty"`
	// contains filtered or unexported fields
}

MVCCStatus contains the current status of the MVCC engine.

func (*MVCCStatus) Descriptor

func (*MVCCStatus) Descriptor() ([]byte, []int)

Deprecated: Use MVCCStatus.ProtoReflect.Descriptor instead.

func (*MVCCStatus) GetActiveTxns

func (x *MVCCStatus) GetActiveTxns() int64

func (*MVCCStatus) GetStorage

func (x *MVCCStatus) GetStorage() *EngineStatus

func (*MVCCStatus) GetVersions

func (x *MVCCStatus) GetVersions() int64

func (*MVCCStatus) ProtoMessage

func (*MVCCStatus) ProtoMessage()

func (*MVCCStatus) ProtoReflect

func (x *MVCCStatus) ProtoReflect() protoreflect.Message

func (*MVCCStatus) Reset

func (x *MVCCStatus) Reset()

func (*MVCCStatus) String

func (x *MVCCStatus) String() string

type MVCCTxnState

type MVCCTxnState struct {

	// Version is the version this transaction is running at. Only one read-write
	// transaction can run at a given version, since this identifies the its write.
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	// ReadOnly is true if this transaction is read-only.
	ReadOnly bool `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
	// ActiveTxns is the set of concurrent active (uncommitted) transactions, as of
	// the start of this transaction. Their writes should be invisible to this
	// transaction even if they're writting at a lower version, since they're not
	// committed yet.
	ActiveTxns []uint64 `protobuf:"varint,3,rep,packed,name=active_txns,json=activeTxns,proto3" json:"active_txns,omitempty"`
	// contains filtered or unexported fields
}

MVCCTxnState is the MVCC transaction state, which determines its write version and isolation. It is separate from the transaction itself to allow it to be passed around independently of the engine.

func (*MVCCTxnState) Descriptor

func (*MVCCTxnState) Descriptor() ([]byte, []int)

Deprecated: Use MVCCTxnState.ProtoReflect.Descriptor instead.

func (*MVCCTxnState) GetActiveTxns

func (x *MVCCTxnState) GetActiveTxns() []uint64

func (*MVCCTxnState) GetReadOnly

func (x *MVCCTxnState) GetReadOnly() bool

func (*MVCCTxnState) GetVersion

func (x *MVCCTxnState) GetVersion() uint64

func (*MVCCTxnState) IsVisible

func (m *MVCCTxnState) IsVisible(version uint64) bool

func (*MVCCTxnState) ProtoMessage

func (*MVCCTxnState) ProtoMessage()

func (*MVCCTxnState) ProtoReflect

func (x *MVCCTxnState) ProtoReflect() protoreflect.Message

func (*MVCCTxnState) Reset

func (x *MVCCTxnState) Reset()

func (*MVCCTxnState) String

func (x *MVCCTxnState) String() string