Documentation ¶
Index ¶
- Variables
- type BucketStats
- func (*BucketStats) Descriptor() ([]byte, []int)
- 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 (*BucketStats) ProtoMessage()
- 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
- func (*Buckets) Descriptor() ([]byte, []int)
- 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 (*Buckets) ProtoMessage()
- 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
- func (*Cluster) Descriptor() ([]byte, []int)
- 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 (*Cluster) ProtoMessage()
- 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
- type Peer
- func (*Peer) Descriptor() ([]byte, []int)
- 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 (*Peer) ProtoMessage()
- 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
- type Region
- func (*Region) Descriptor() ([]byte, []int)
- 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 (*Region) ProtoMessage()
- 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
- func (*RegionEpoch) Descriptor() ([]byte, []int)
- 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 (*RegionEpoch) ProtoMessage()
- 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
- func (*Store) Descriptor() ([]byte, []int)
- 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 (*Store) ProtoMessage()
- 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
- func (*StoreLabel) Descriptor() ([]byte, []int)
- 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 (*StoreLabel) ProtoMessage()
- 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
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthMetapb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowMetapb = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupMetapb = fmt.Errorf("proto: unexpected end of group") )
View Source
var NodeState_name = map[int32]string{
0: "Preparing",
1: "Serving",
2: "Removing",
3: "Removed",
}
View Source
var NodeState_value = map[string]int32{
"Preparing": 0,
"Serving": 1,
"Removing": 2,
"Removed": 3,
}
View Source
var PeerRole_name = map[int32]string{
0: "Voter",
1: "Learner",
2: "IncomingVoter",
3: "DemotingVoter",
}
View Source
var PeerRole_value = map[string]int32{
"Voter": 0,
"Learner": 1,
"IncomingVoter": 2,
"DemotingVoter": 3,
}
View Source
var StoreState_name = map[int32]string{
0: "Up",
1: "Offline",
2: "Tombstone",
}
View Source
var StoreState_value = map[string]int32{
"Up": 0,
"Offline": 1,
"Tombstone": 2,
}
Functions ¶
This section is empty.
Types ¶
type BucketStats ¶
type BucketStats struct { // total read in bytes of each bucket ReadBytes []uint64 `protobuf:"varint,1,rep,packed,name=read_bytes,json=readBytes,proto3" json:"read_bytes,omitempty"` // total write in bytes of each bucket WriteBytes []uint64 `protobuf:"varint,2,rep,packed,name=write_bytes,json=writeBytes,proto3" json:"write_bytes,omitempty"` // total read qps of each bucket ReadQps []uint64 `protobuf:"varint,3,rep,packed,name=read_qps,json=readQps,proto3" json:"read_qps,omitempty"` // total write qps of each bucket WriteQps []uint64 `protobuf:"varint,4,rep,packed,name=write_qps,json=writeQps,proto3" json:"write_qps,omitempty"` // total read keys of each bucket ReadKeys []uint64 `protobuf:"varint,5,rep,packed,name=read_keys,json=readKeys,proto3" json:"read_keys,omitempty"` // total write keys of each bucket WriteKeys []uint64 `protobuf:"varint,6,rep,packed,name=write_keys,json=writeKeys,proto3" json:"write_keys,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BucketStats) Descriptor ¶
func (*BucketStats) Descriptor() ([]byte, []int)
func (*BucketStats) GetReadBytes ¶
func (m *BucketStats) GetReadBytes() []uint64
func (*BucketStats) GetReadKeys ¶
func (m *BucketStats) GetReadKeys() []uint64
func (*BucketStats) GetReadQps ¶
func (m *BucketStats) GetReadQps() []uint64
func (*BucketStats) GetWriteBytes ¶
func (m *BucketStats) GetWriteBytes() []uint64
func (*BucketStats) GetWriteKeys ¶
func (m *BucketStats) GetWriteKeys() []uint64
func (*BucketStats) GetWriteQps ¶
func (m *BucketStats) GetWriteQps() []uint64
func (*BucketStats) Marshal ¶
func (m *BucketStats) Marshal() (dAtA []byte, err error)
func (*BucketStats) MarshalToSizedBuffer ¶
func (m *BucketStats) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*BucketStats) ProtoMessage ¶
func (*BucketStats) ProtoMessage()
func (*BucketStats) Reset ¶
func (m *BucketStats) Reset()
func (*BucketStats) Size ¶
func (m *BucketStats) Size() (n int)
func (*BucketStats) String ¶
func (m *BucketStats) String() string
func (*BucketStats) Unmarshal ¶
func (m *BucketStats) Unmarshal(dAtA []byte) error
func (*BucketStats) XXX_DiscardUnknown ¶
func (m *BucketStats) XXX_DiscardUnknown()
func (*BucketStats) XXX_Marshal ¶
func (m *BucketStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*BucketStats) XXX_Merge ¶
func (m *BucketStats) XXX_Merge(src proto.Message)
func (*BucketStats) XXX_Size ¶
func (m *BucketStats) XXX_Size() int
func (*BucketStats) XXX_Unmarshal ¶
func (m *BucketStats) XXX_Unmarshal(b []byte) error
type Buckets ¶
type Buckets struct { RegionId uint64 `protobuf:"varint,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"` // A hint indicate if keys have changed. Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` // keys of buckets, include start/end key of region Keys [][]byte `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"` // bucket stats Stats *BucketStats `protobuf:"bytes,4,opt,name=stats,proto3" json:"stats,omitempty"` // The period in milliseconds that stats are collected with in PeriodInMs uint64 `protobuf:"varint,5,opt,name=period_in_ms,json=periodInMs,proto3" json:"period_in_ms,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Buckets) Descriptor ¶
func (*Buckets) GetPeriodInMs ¶
func (*Buckets) GetRegionId ¶
func (*Buckets) GetStats ¶
func (m *Buckets) GetStats() *BucketStats
func (*Buckets) GetVersion ¶
func (*Buckets) MarshalToSizedBuffer ¶
func (*Buckets) ProtoMessage ¶
func (*Buckets) ProtoMessage()
func (*Buckets) XXX_DiscardUnknown ¶
func (m *Buckets) XXX_DiscardUnknown()
func (*Buckets) XXX_Marshal ¶
func (*Buckets) XXX_Unmarshal ¶
type Cluster ¶
type Cluster struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // max peer count for a region. // pd will do the auto-balance if region peer count mismatches. MaxPeerCount uint32 `protobuf:"varint,2,opt,name=max_peer_count,json=maxPeerCount,proto3" json:"max_peer_count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Cluster) Descriptor ¶
func (*Cluster) GetMaxPeerCount ¶
func (*Cluster) MarshalToSizedBuffer ¶
func (*Cluster) ProtoMessage ¶
func (*Cluster) ProtoMessage()
func (*Cluster) XXX_DiscardUnknown ¶
func (m *Cluster) XXX_DiscardUnknown()
func (*Cluster) XXX_Marshal ¶
func (*Cluster) XXX_Unmarshal ¶
type NodeState ¶
type NodeState int32
NodeState is going to replace StoreState to make the state concept more clear. "Up" is devided into "Preparing" and "Serving" stages so that we can better describe the online process. "Removing" is just like previous `Offline` which is more accurate. "Removed" has the same meaning with `Tombstone`.
func (NodeState) EnumDescriptor ¶
type Peer ¶
type Peer struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` StoreId uint64 `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"` Role PeerRole `protobuf:"varint,3,opt,name=role,proto3,enum=metapb.PeerRole" json:"role,omitempty"` IsWitness bool `protobuf:"varint,4,opt,name=is_witness,json=isWitness,proto3" json:"is_witness,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Peer) Descriptor ¶
func (*Peer) GetIsWitness ¶
func (*Peer) GetStoreId ¶
func (*Peer) ProtoMessage ¶
func (*Peer) ProtoMessage()
func (*Peer) XXX_DiscardUnknown ¶
func (m *Peer) XXX_DiscardUnknown()
func (*Peer) XXX_Unmarshal ¶
type Region ¶
type Region struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // Region key range [start_key, end_key). StartKey []byte `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"` EndKey []byte `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"` RegionEpoch *RegionEpoch `protobuf:"bytes,4,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"` Peers []*Peer `protobuf:"bytes,5,rep,name=peers,proto3" json:"peers,omitempty"` // Encryption metadata for start_key and end_key. encryption_meta.iv is IV for start_key. // IV for end_key is calculated from (encryption_meta.iv + len(start_key)). // The field is only used by PD and should be ignored otherwise. // If encryption_meta is empty (i.e. nil), it means start_key and end_key are unencrypted. EncryptionMeta *encryptionpb.EncryptionMeta `protobuf:"bytes,6,opt,name=encryption_meta,json=encryptionMeta,proto3" json:"encryption_meta,omitempty"` // The flashback state indicates whether this region is in the flashback state. // TODO: only check by `flashback_start_ts` in the future. Keep for compatibility now. IsInFlashback bool `protobuf:"varint,7,opt,name=is_in_flashback,json=isInFlashback,proto3" json:"is_in_flashback,omitempty"` // The start_ts that the current flashback progress is using. FlashbackStartTs uint64 `protobuf:"varint,8,opt,name=flashback_start_ts,json=flashbackStartTs,proto3" json:"flashback_start_ts,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Region) Descriptor ¶
func (*Region) GetEncryptionMeta ¶
func (m *Region) GetEncryptionMeta() *encryptionpb.EncryptionMeta
func (*Region) GetFlashbackStartTs ¶
func (*Region) GetIsInFlashback ¶
func (*Region) GetRegionEpoch ¶
func (m *Region) GetRegionEpoch() *RegionEpoch
func (*Region) GetStartKey ¶
func (*Region) MarshalToSizedBuffer ¶
func (*Region) ProtoMessage ¶
func (*Region) ProtoMessage()
func (*Region) XXX_DiscardUnknown ¶
func (m *Region) XXX_DiscardUnknown()
func (*Region) XXX_Marshal ¶
func (*Region) XXX_Unmarshal ¶
type RegionEpoch ¶
type RegionEpoch struct { // Conf change version, auto increment when add or remove peer ConfVer uint64 `protobuf:"varint,1,opt,name=conf_ver,json=confVer,proto3" json:"conf_ver,omitempty"` // Region version, auto increment when split or merge Version uint64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*RegionEpoch) Descriptor ¶
func (*RegionEpoch) Descriptor() ([]byte, []int)
func (*RegionEpoch) GetConfVer ¶
func (m *RegionEpoch) GetConfVer() uint64
func (*RegionEpoch) GetVersion ¶
func (m *RegionEpoch) GetVersion() uint64
func (*RegionEpoch) Marshal ¶
func (m *RegionEpoch) Marshal() (dAtA []byte, err error)
func (*RegionEpoch) MarshalToSizedBuffer ¶
func (m *RegionEpoch) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RegionEpoch) ProtoMessage ¶
func (*RegionEpoch) ProtoMessage()
func (*RegionEpoch) Reset ¶
func (m *RegionEpoch) Reset()
func (*RegionEpoch) Size ¶
func (m *RegionEpoch) Size() (n int)
func (*RegionEpoch) String ¶
func (m *RegionEpoch) String() string
func (*RegionEpoch) Unmarshal ¶
func (m *RegionEpoch) Unmarshal(dAtA []byte) error
func (*RegionEpoch) XXX_DiscardUnknown ¶
func (m *RegionEpoch) XXX_DiscardUnknown()
func (*RegionEpoch) XXX_Marshal ¶
func (m *RegionEpoch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RegionEpoch) XXX_Merge ¶
func (m *RegionEpoch) XXX_Merge(src proto.Message)
func (*RegionEpoch) XXX_Size ¶
func (m *RegionEpoch) XXX_Size() int
func (*RegionEpoch) XXX_Unmarshal ¶
func (m *RegionEpoch) XXX_Unmarshal(b []byte) error
type Store ¶
type Store struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // Address to handle client requests (kv, cop, etc.) Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` State StoreState `protobuf:"varint,3,opt,name=state,proto3,enum=metapb.StoreState" json:"state,omitempty"` Labels []*StoreLabel `protobuf:"bytes,4,rep,name=labels,proto3" json:"labels,omitempty"` Version string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"` // Address to handle peer requests (raft messages from other store). // Empty means same as address. PeerAddress string `protobuf:"bytes,6,opt,name=peer_address,json=peerAddress,proto3" json:"peer_address,omitempty"` // Status address provides the HTTP service for external components StatusAddress string `protobuf:"bytes,7,opt,name=status_address,json=statusAddress,proto3" json:"status_address,omitempty"` GitHash string `protobuf:"bytes,8,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"` // The start timestamp of the current store StartTimestamp int64 `protobuf:"varint,9,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"` DeployPath string `protobuf:"bytes,10,opt,name=deploy_path,json=deployPath,proto3" json:"deploy_path,omitempty"` // The last heartbeat timestamp of the store. LastHeartbeat int64 `protobuf:"varint,11,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"` // If the store is physically destroyed, which means it can never up again. PhysicallyDestroyed bool `protobuf:"varint,12,opt,name=physically_destroyed,json=physicallyDestroyed,proto3" json:"physically_destroyed,omitempty"` // NodeState is used to replace StoreState which will be deprecated in the future. NodeState NodeState `protobuf:"varint,13,opt,name=node_state,json=nodeState,proto3,enum=metapb.NodeState" json:"node_state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Store) Descriptor ¶
func (*Store) GetAddress ¶
func (*Store) GetDeployPath ¶
func (*Store) GetGitHash ¶
func (*Store) GetLabels ¶
func (m *Store) GetLabels() []*StoreLabel
func (*Store) GetLastHeartbeat ¶
func (*Store) GetNodeState ¶
func (*Store) GetPeerAddress ¶
func (*Store) GetPhysicallyDestroyed ¶
func (*Store) GetStartTimestamp ¶
func (*Store) GetState ¶
func (m *Store) GetState() StoreState
func (*Store) GetStatusAddress ¶
func (*Store) GetVersion ¶
func (*Store) ProtoMessage ¶
func (*Store) ProtoMessage()
func (*Store) XXX_DiscardUnknown ¶
func (m *Store) XXX_DiscardUnknown()
func (*Store) XXX_Marshal ¶
func (*Store) XXX_Unmarshal ¶
type StoreLabel ¶
type StoreLabel struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Case insensitive key/value for replica constraints.
func (*StoreLabel) Descriptor ¶
func (*StoreLabel) Descriptor() ([]byte, []int)
func (*StoreLabel) GetKey ¶
func (m *StoreLabel) GetKey() string
func (*StoreLabel) GetValue ¶
func (m *StoreLabel) GetValue() string
func (*StoreLabel) Marshal ¶
func (m *StoreLabel) Marshal() (dAtA []byte, err error)
func (*StoreLabel) MarshalToSizedBuffer ¶
func (m *StoreLabel) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*StoreLabel) ProtoMessage ¶
func (*StoreLabel) ProtoMessage()
func (*StoreLabel) Reset ¶
func (m *StoreLabel) Reset()
func (*StoreLabel) Size ¶
func (m *StoreLabel) Size() (n int)
func (*StoreLabel) String ¶
func (m *StoreLabel) String() string
func (*StoreLabel) Unmarshal ¶
func (m *StoreLabel) Unmarshal(dAtA []byte) error
func (*StoreLabel) XXX_DiscardUnknown ¶
func (m *StoreLabel) XXX_DiscardUnknown()
func (*StoreLabel) XXX_Marshal ¶
func (m *StoreLabel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*StoreLabel) XXX_Merge ¶
func (m *StoreLabel) XXX_Merge(src proto.Message)
func (*StoreLabel) XXX_Size ¶
func (m *StoreLabel) XXX_Size() int
func (*StoreLabel) XXX_Unmarshal ¶
func (m *StoreLabel) XXX_Unmarshal(b []byte) error
type StoreState ¶
type StoreState int32
const ( StoreState_Up StoreState = 0 StoreState_Offline StoreState = 1 StoreState_Tombstone StoreState = 2 )
func (StoreState) EnumDescriptor ¶
func (StoreState) EnumDescriptor() ([]byte, []int)
func (StoreState) String ¶
func (x StoreState) String() string
Click to show internal directories.
Click to hide internal directories.