Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowMetapb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthMetapb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupMetapb = fmt.Errorf("proto: unexpected end of group") + var NodeState_name = map[int32]string + var NodeState_value = map[string]int32 + var PeerRole_name = map[int32]string + var PeerRole_value = map[string]int32 + var StoreState_name = map[int32]string + var StoreState_value = map[string]int32 + type BucketStats struct + ReadBytes []uint64 + ReadKeys []uint64 + ReadQps []uint64 + WriteBytes []uint64 + WriteKeys []uint64 + WriteQps []uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BucketStats) Descriptor() ([]byte, []int) + func (*BucketStats) ProtoMessage() + func (m *BucketStats) GetReadBytes() []uint64 + func (m *BucketStats) GetReadKeys() []uint64 + func (m *BucketStats) GetReadQps() []uint64 + func (m *BucketStats) GetWriteBytes() []uint64 + func (m *BucketStats) GetWriteKeys() []uint64 + func (m *BucketStats) GetWriteQps() []uint64 + func (m *BucketStats) Marshal() (dAtA []byte, err error) + func (m *BucketStats) MarshalTo(dAtA []byte) (int, error) + func (m *BucketStats) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BucketStats) Reset() + func (m *BucketStats) Size() (n int) + func (m *BucketStats) String() string + func (m *BucketStats) Unmarshal(dAtA []byte) error + func (m *BucketStats) XXX_DiscardUnknown() + func (m *BucketStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BucketStats) XXX_Merge(src proto.Message) + func (m *BucketStats) XXX_Size() int + func (m *BucketStats) XXX_Unmarshal(b []byte) error + type Buckets struct + Keys [][]byte + PeriodInMs uint64 + RegionId uint64 + Stats *BucketStats + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Buckets) Descriptor() ([]byte, []int) + func (*Buckets) ProtoMessage() + func (m *Buckets) GetKeys() [][]byte + func (m *Buckets) GetPeriodInMs() uint64 + func (m *Buckets) GetRegionId() uint64 + func (m *Buckets) GetStats() *BucketStats + func (m *Buckets) GetVersion() uint64 + func (m *Buckets) Marshal() (dAtA []byte, err error) + func (m *Buckets) MarshalTo(dAtA []byte) (int, error) + func (m *Buckets) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Buckets) Reset() + func (m *Buckets) Size() (n int) + func (m *Buckets) String() string + func (m *Buckets) Unmarshal(dAtA []byte) error + func (m *Buckets) XXX_DiscardUnknown() + func (m *Buckets) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Buckets) XXX_Merge(src proto.Message) + func (m *Buckets) XXX_Size() int + func (m *Buckets) XXX_Unmarshal(b []byte) error + type Cluster struct + Id uint64 + MaxPeerCount uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Cluster) Descriptor() ([]byte, []int) + func (*Cluster) ProtoMessage() + func (m *Cluster) GetId() uint64 + func (m *Cluster) GetMaxPeerCount() uint32 + func (m *Cluster) Marshal() (dAtA []byte, err error) + func (m *Cluster) MarshalTo(dAtA []byte) (int, error) + func (m *Cluster) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Cluster) Reset() + func (m *Cluster) Size() (n int) + func (m *Cluster) String() string + func (m *Cluster) Unmarshal(dAtA []byte) error + func (m *Cluster) XXX_DiscardUnknown() + func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cluster) XXX_Merge(src proto.Message) + func (m *Cluster) XXX_Size() int + func (m *Cluster) XXX_Unmarshal(b []byte) error + type NodeState int32 + const NodeState_Preparing + const NodeState_Removed + const NodeState_Removing + const NodeState_Serving + func (NodeState) EnumDescriptor() ([]byte, []int) + func (x NodeState) String() string + type Peer struct + Id uint64 + IsWitness bool + Role PeerRole + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Peer) Descriptor() ([]byte, []int) + func (*Peer) ProtoMessage() + func (m *Peer) GetId() uint64 + func (m *Peer) GetIsWitness() bool + func (m *Peer) GetRole() PeerRole + func (m *Peer) GetStoreId() uint64 + func (m *Peer) Marshal() (dAtA []byte, err error) + func (m *Peer) MarshalTo(dAtA []byte) (int, error) + func (m *Peer) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Peer) Reset() + func (m *Peer) Size() (n int) + func (m *Peer) String() string + func (m *Peer) Unmarshal(dAtA []byte) error + func (m *Peer) XXX_DiscardUnknown() + func (m *Peer) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Peer) XXX_Merge(src proto.Message) + func (m *Peer) XXX_Size() int + func (m *Peer) XXX_Unmarshal(b []byte) error + type PeerRole int32 + const PeerRole_DemotingVoter + const PeerRole_IncomingVoter + const PeerRole_Learner + const PeerRole_Voter + func (PeerRole) EnumDescriptor() ([]byte, []int) + func (x PeerRole) String() string + type Region struct + EncryptionMeta *encryptionpb.EncryptionMeta + EndKey []byte + FlashbackStartTs uint64 + Id uint64 + IsInFlashback bool + Peers []*Peer + RegionEpoch *RegionEpoch + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Region) Descriptor() ([]byte, []int) + func (*Region) ProtoMessage() + func (m *Region) GetEncryptionMeta() *encryptionpb.EncryptionMeta + func (m *Region) GetEndKey() []byte + func (m *Region) GetFlashbackStartTs() uint64 + func (m *Region) GetId() uint64 + func (m *Region) GetIsInFlashback() bool + func (m *Region) GetPeers() []*Peer + func (m *Region) GetRegionEpoch() *RegionEpoch + func (m *Region) GetStartKey() []byte + func (m *Region) Marshal() (dAtA []byte, err error) + func (m *Region) MarshalTo(dAtA []byte) (int, error) + func (m *Region) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Region) Reset() + func (m *Region) Size() (n int) + func (m *Region) String() string + func (m *Region) Unmarshal(dAtA []byte) error + func (m *Region) XXX_DiscardUnknown() + func (m *Region) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Region) XXX_Merge(src proto.Message) + func (m *Region) XXX_Size() int + func (m *Region) XXX_Unmarshal(b []byte) error + type RegionEpoch struct + ConfVer uint64 + Version uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RegionEpoch) Descriptor() ([]byte, []int) + func (*RegionEpoch) ProtoMessage() + func (m *RegionEpoch) GetConfVer() uint64 + func (m *RegionEpoch) GetVersion() uint64 + func (m *RegionEpoch) Marshal() (dAtA []byte, err error) + func (m *RegionEpoch) MarshalTo(dAtA []byte) (int, error) + func (m *RegionEpoch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RegionEpoch) Reset() + func (m *RegionEpoch) Size() (n int) + func (m *RegionEpoch) String() string + func (m *RegionEpoch) Unmarshal(dAtA []byte) error + func (m *RegionEpoch) XXX_DiscardUnknown() + func (m *RegionEpoch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RegionEpoch) XXX_Merge(src proto.Message) + func (m *RegionEpoch) XXX_Size() int + func (m *RegionEpoch) XXX_Unmarshal(b []byte) error + type Store struct + Address string + DeployPath string + GitHash string + Id uint64 + Labels []*StoreLabel + LastHeartbeat int64 + NodeState NodeState + PeerAddress string + PhysicallyDestroyed bool + StartTimestamp int64 + State StoreState + StatusAddress string + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Store) Descriptor() ([]byte, []int) + func (*Store) ProtoMessage() + func (m *Store) GetAddress() string + func (m *Store) GetDeployPath() string + func (m *Store) GetGitHash() string + func (m *Store) GetId() uint64 + func (m *Store) GetLabels() []*StoreLabel + func (m *Store) GetLastHeartbeat() int64 + func (m *Store) GetNodeState() NodeState + func (m *Store) GetPeerAddress() string + func (m *Store) GetPhysicallyDestroyed() bool + func (m *Store) GetStartTimestamp() int64 + func (m *Store) GetState() StoreState + func (m *Store) GetStatusAddress() string + func (m *Store) GetVersion() string + func (m *Store) Marshal() (dAtA []byte, err error) + func (m *Store) MarshalTo(dAtA []byte) (int, error) + func (m *Store) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Store) Reset() + func (m *Store) Size() (n int) + func (m *Store) String() string + func (m *Store) Unmarshal(dAtA []byte) error + func (m *Store) XXX_DiscardUnknown() + func (m *Store) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Store) XXX_Merge(src proto.Message) + func (m *Store) XXX_Size() int + func (m *Store) XXX_Unmarshal(b []byte) error + type StoreLabel struct + Key string + Value string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StoreLabel) Descriptor() ([]byte, []int) + func (*StoreLabel) ProtoMessage() + func (m *StoreLabel) GetKey() string + func (m *StoreLabel) GetValue() string + func (m *StoreLabel) Marshal() (dAtA []byte, err error) + func (m *StoreLabel) MarshalTo(dAtA []byte) (int, error) + func (m *StoreLabel) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StoreLabel) Reset() + func (m *StoreLabel) Size() (n int) + func (m *StoreLabel) String() string + func (m *StoreLabel) Unmarshal(dAtA []byte) error + func (m *StoreLabel) XXX_DiscardUnknown() + func (m *StoreLabel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *StoreLabel) XXX_Merge(src proto.Message) + func (m *StoreLabel) XXX_Size() int + func (m *StoreLabel) XXX_Unmarshal(b []byte) error + type StoreState int32 + const StoreState_Offline + const StoreState_Tombstone + const StoreState_Up + func (StoreState) EnumDescriptor() ([]byte, []int) + func (x StoreState) String() string