func (*ReplicationLoadSink) Descriptor() ([]byte, []int) {
	return file_ClusterStatus_proto_rawDescGZIP(), []int{5}
}
Deprecated: Use ReplicationLoadSink.ProtoReflect.Descriptor instead.
package pb
import (
	proto "github.com/golang/protobuf/proto"
	protoreflect "google.golang.org/protobuf/reflect/protoreflect"
	protoimpl "google.golang.org/protobuf/runtime/protoimpl"
	reflect "reflect"
	sync "sync"
)
const (
	_ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
	_ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)
const _ = proto.ProtoPackageIsVersion4
type RegionState_State int32
const (
	RegionState_OFFLINE       RegionState_State = 0   
	RegionState_PENDING_OPEN  RegionState_State = 1   
	RegionState_OPENING       RegionState_State = 2   
	RegionState_OPEN          RegionState_State = 3   
	RegionState_PENDING_CLOSE RegionState_State = 4   
	RegionState_CLOSING       RegionState_State = 5   
	RegionState_CLOSED        RegionState_State = 6   
	RegionState_SPLITTING     RegionState_State = 7   
	RegionState_SPLIT         RegionState_State = 8   
	RegionState_FAILED_OPEN   RegionState_State = 9   
	RegionState_FAILED_CLOSE  RegionState_State = 10  
	RegionState_MERGING       RegionState_State = 11  
	RegionState_MERGED        RegionState_State = 12  
	RegionState_SPLITTING_NEW RegionState_State = 13  
	RegionState_MERGING_NEW RegionState_State = 14  
)
var (
	RegionState_State_name = map[int32]string{
		0:  "OFFLINE",
		1:  "PENDING_OPEN",
		2:  "OPENING",
		3:  "OPEN",
		4:  "PENDING_CLOSE",
		5:  "CLOSING",
		6:  "CLOSED",
		7:  "SPLITTING",
		8:  "SPLIT",
		9:  "FAILED_OPEN",
		10: "FAILED_CLOSE",
		11: "MERGING",
		12: "MERGED",
		13: "SPLITTING_NEW",
		14: "MERGING_NEW",
	}
	RegionState_State_value = map[string]int32{
		"OFFLINE":       0,
		"PENDING_OPEN":  1,
		"OPENING":       2,
		"OPEN":          3,
		"PENDING_CLOSE": 4,
		"CLOSING":       5,
		"CLOSED":        6,
		"SPLITTING":     7,
		"SPLIT":         8,
		"FAILED_OPEN":   9,
		"FAILED_CLOSE":  10,
		"MERGING":       11,
		"MERGED":        12,
		"SPLITTING_NEW": 13,
		"MERGING_NEW":   14,
	}
)
func (x RegionState_State) Enum() *RegionState_State {
	p := new(RegionState_State)
	*p = x
	return p
}
func (x RegionState_State) String() string {
	return protoimpl.X.EnumStringOf(x.Descriptor(), protoreflect.EnumNumber(x))
}
func (RegionState_State) Descriptor() protoreflect.EnumDescriptor {
	return file_ClusterStatus_proto_enumTypes[0].Descriptor()
}
func (RegionState_State) Type() protoreflect.EnumType {
	return &file_ClusterStatus_proto_enumTypes[0]
}
func (x RegionState_State) Number() protoreflect.EnumNumber {
	return protoreflect.EnumNumber(x)
}
func (x *RegionState_State) UnmarshalJSON(b []byte) error {
	num, err := protoimpl.X.UnmarshalJSONEnum(x.Descriptor(), b)
	if err != nil {
		return err
	}
	*x = RegionState_State(num)
	return nil
}
func (RegionState_State) EnumDescriptor() ([]byte, []int) {
	return file_ClusterStatus_proto_rawDescGZIP(), []int{0, 0}
}
type RegionState struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	RegionInfo *RegionInfo        `protobuf:"bytes,1,req,name=region_info,json=regionInfo" json:"region_info,omitempty"`
	State      *RegionState_State `protobuf:"varint,2,req,name=state,enum=pb.RegionState_State" json:"state,omitempty"`
	Stamp      *uint64            `protobuf:"varint,3,opt,name=stamp" json:"stamp,omitempty"`
}
func (x *RegionState) Reset() {
	*x = RegionState{}
	if protoimpl.UnsafeEnabled {
		mi := &file_ClusterStatus_proto_msgTypes[0]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *RegionState) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*RegionState) ProtoMessage() {}
func (x *RegionState) ProtoReflect() protoreflect.Message {
	mi := &file_ClusterStatus_proto_msgTypes[0]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*RegionState) Descriptor() ([]byte, []int) {
	return file_ClusterStatus_proto_rawDescGZIP(), []int{0}
}
func (x *RegionState) GetRegionInfo() *RegionInfo {
	if x != nil {
		return x.RegionInfo
	}
	return nil
}
func (x *RegionState) GetState() RegionState_State {
	if x != nil && x.State != nil {
		return *x.State
	}
	return RegionState_OFFLINE
}
func (x *RegionState) GetStamp() uint64 {
	if x != nil && x.Stamp != nil {
		return *x.Stamp
	}
	return 0
}
type RegionInTransition struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	Spec        *RegionSpecifier `protobuf:"bytes,1,req,name=spec" json:"spec,omitempty"`
	RegionState *RegionState     `protobuf:"bytes,2,req,name=region_state,json=regionState" json:"region_state,omitempty"`
}
func (x *RegionInTransition) Reset() {
	*x = RegionInTransition{}
	if protoimpl.UnsafeEnabled {
		mi := &file_ClusterStatus_proto_msgTypes[1]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *RegionInTransition) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*RegionInTransition) ProtoMessage() {}
func (x *RegionInTransition) ProtoReflect() protoreflect.Message {
	mi := &file_ClusterStatus_proto_msgTypes[1]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*RegionInTransition) Descriptor() ([]byte, []int) {
	return file_ClusterStatus_proto_rawDescGZIP(), []int{1}
}
func (x *RegionInTransition) GetSpec() *RegionSpecifier {
	if x != nil {
		return x.Spec
	}
	return nil
}
func (x *RegionInTransition) GetRegionState() *RegionState {
	if x != nil {
		return x.RegionState
	}
	return nil
}
type StoreSequenceId struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	FamilyName []byte  `protobuf:"bytes,1,req,name=family_name,json=familyName" json:"family_name,omitempty"`
	SequenceId *uint64 `protobuf:"varint,2,req,name=sequence_id,json=sequenceId" json:"sequence_id,omitempty"`
}
func (x *StoreSequenceId) Reset() {
	*x = StoreSequenceId{}
	if protoimpl.UnsafeEnabled {
		mi := &file_ClusterStatus_proto_msgTypes[2]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *StoreSequenceId) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*StoreSequenceId) ProtoMessage() {}
func (x *StoreSequenceId) ProtoReflect() protoreflect.Message {
	mi := &file_ClusterStatus_proto_msgTypes[2]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*StoreSequenceId) Descriptor() ([]byte, []int) {
	return file_ClusterStatus_proto_rawDescGZIP(), []int{2}
}
func (x *StoreSequenceId) GetFamilyName() []byte {
	if x != nil {
		return x.FamilyName
	}
	return nil
}
func (x *StoreSequenceId) GetSequenceId() uint64 {
	if x != nil && x.SequenceId != nil {
		return *x.SequenceId
	}
	return 0
}
type RegionStoreSequenceIds struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	LastFlushedSequenceId *uint64            `protobuf:"varint,1,req,name=last_flushed_sequence_id,json=lastFlushedSequenceId" json:"last_flushed_sequence_id,omitempty"`
	StoreSequenceId       []*StoreSequenceId `protobuf:"bytes,2,rep,name=store_sequence_id,json=storeSequenceId" json:"store_sequence_id,omitempty"`
}
func (x *RegionStoreSequenceIds) Reset() {
	*x = RegionStoreSequenceIds{}
	if protoimpl.UnsafeEnabled {
		mi := &file_ClusterStatus_proto_msgTypes[3]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *RegionStoreSequenceIds) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*RegionStoreSequenceIds) ProtoMessage() {}
func (x *RegionStoreSequenceIds) ProtoReflect() protoreflect.Message {
	mi := &file_ClusterStatus_proto_msgTypes[3]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*RegionStoreSequenceIds) Descriptor() ([]byte, []int) {
	return file_ClusterStatus_proto_rawDescGZIP(), []int{3}
}
func (x *RegionStoreSequenceIds) GetLastFlushedSequenceId() uint64 {
	if x != nil && x.LastFlushedSequenceId != nil {
		return *x.LastFlushedSequenceId
	}
	return 0
}
func (x *RegionStoreSequenceIds) GetStoreSequenceId() []*StoreSequenceId {
	if x != nil {
		return x.StoreSequenceId
	}
	return nil
}
type RegionLoad struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	RegionSpecifier *RegionSpecifier `protobuf:"bytes,1,req,name=region_specifier,json=regionSpecifier" json:"region_specifier,omitempty"`
	Stores *uint32 `protobuf:"varint,2,opt,name=stores" json:"stores,omitempty"`
	Storefiles *uint32 `protobuf:"varint,3,opt,name=storefiles" json:"storefiles,omitempty"`
	StoreUncompressedSize_MB *uint32 `protobuf:"varint,4,opt,name=store_uncompressed_size_MB,json=storeUncompressedSizeMB" json:"store_uncompressed_size_MB,omitempty"`
	StorefileSize_MB *uint32 `protobuf:"varint,5,opt,name=storefile_size_MB,json=storefileSizeMB" json:"storefile_size_MB,omitempty"`
	MemstoreSize_MB *uint32 `protobuf:"varint,6,opt,name=memstore_size_MB,json=memstoreSizeMB" json:"memstore_size_MB,omitempty"`
	StorefileIndexSize_MB *uint32 `protobuf:"varint,7,opt,name=storefile_index_size_MB,json=storefileIndexSizeMB" json:"storefile_index_size_MB,omitempty"`
	ReadRequestsCount *uint64 `protobuf:"varint,8,opt,name=read_requests_count,json=readRequestsCount" json:"read_requests_count,omitempty"`
	WriteRequestsCount *uint64 `protobuf:"varint,9,opt,name=write_requests_count,json=writeRequestsCount" json:"write_requests_count,omitempty"`
	TotalCompacting_KVs *uint64 `protobuf:"varint,10,opt,name=total_compacting_KVs,json=totalCompactingKVs" json:"total_compacting_KVs,omitempty"`
	CurrentCompacted_KVs *uint64 `protobuf:"varint,11,opt,name=current_compacted_KVs,json=currentCompactedKVs" json:"current_compacted_KVs,omitempty"`
	RootIndexSize_KB *uint32 `protobuf:"varint,12,opt,name=root_index_size_KB,json=rootIndexSizeKB" json:"root_index_size_KB,omitempty"`
	TotalStaticIndexSize_KB *uint32 `protobuf:"varint,13,opt,name=total_static_index_size_KB,json=totalStaticIndexSizeKB" json:"total_static_index_size_KB,omitempty"`
	TotalStaticBloomSize_KB *uint32 `protobuf:"varint,14,opt,name=total_static_bloom_size_KB,json=totalStaticBloomSizeKB" json:"total_static_bloom_size_KB,omitempty"`
	CompleteSequenceId *uint64 `protobuf:"varint,15,opt,name=complete_sequence_id,json=completeSequenceId" json:"complete_sequence_id,omitempty"`
	DataLocality          *float32 `protobuf:"fixed32,16,opt,name=data_locality,json=dataLocality" json:"data_locality,omitempty"`
	LastMajorCompactionTs *uint64  `protobuf:"varint,17,opt,name=last_major_compaction_ts,json=lastMajorCompactionTs,def=0" json:"last_major_compaction_ts,omitempty"`
	StoreCompleteSequenceId []*StoreSequenceId `protobuf:"bytes,18,rep,name=store_complete_sequence_id,json=storeCompleteSequenceId" json:"store_complete_sequence_id,omitempty"`
}
const (
	Default_RegionLoad_LastMajorCompactionTs = uint64(0)
)
func (x *RegionLoad) Reset() {
	*x = RegionLoad{}
	if protoimpl.UnsafeEnabled {
		mi := &file_ClusterStatus_proto_msgTypes[4]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *RegionLoad) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*RegionLoad) ProtoMessage() {}
func (x *RegionLoad) ProtoReflect() protoreflect.Message {
	mi := &file_ClusterStatus_proto_msgTypes[4]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}
func (*RegionLoad) Descriptor() ([]byte, []int) {
	return file_ClusterStatus_proto_rawDescGZIP(), []int{4}
}
func (x *RegionLoad) GetRegionSpecifier() *RegionSpecifier {
	if x != nil {
		return x.RegionSpecifier
	}
	return nil
}
func (x *RegionLoad) GetStores() uint32 {
	if x != nil && x.Stores != nil {
		return *x.Stores
	}
	return 0
}
func (x *RegionLoad) GetStorefiles() uint32 {
	if x != nil && x.Storefiles != nil {
		return *x.Storefiles
	}
	return 0
}
func (x *RegionLoad) GetStoreUncompressedSize_MB() uint32 {
	if x != nil && x.StoreUncompressedSize_MB != nil {
		return *x.StoreUncompressedSize_MB
	}
	return 0
}
func (x *RegionLoad) GetStorefileSize_MB() uint32 {
	if x != nil && x.StorefileSize_MB != nil {
		return *x.StorefileSize_MB
	}
	return 0
}
func (x *RegionLoad) GetMemstoreSize_MB() uint32 {
	if x != nil && x.MemstoreSize_MB != nil {
		return *x.MemstoreSize_MB
	}
	return 0
}
func (x *RegionLoad) GetStorefileIndexSize_MB() uint32 {
	if x != nil && x.StorefileIndexSize_MB != nil {
		return *x.StorefileIndexSize_MB
	}
	return 0
}
func (x *RegionLoad) GetReadRequestsCount() uint64 {
	if x != nil && x.ReadRequestsCount != nil {
		return *x.ReadRequestsCount
	}
	return 0
}
func (x *RegionLoad) GetWriteRequestsCount() uint64 {
	if x != nil && x.WriteRequestsCount != nil {
		return *x.WriteRequestsCount
	}
	return 0
}
func (x *RegionLoad) GetTotalCompacting_KVs() uint64 {
	if x != nil && x.TotalCompacting_KVs != nil {
		return *x.TotalCompacting_KVs
	}
	return 0
}
func (x *RegionLoad) GetCurrentCompacted_KVs() uint64 {
	if x != nil && x.CurrentCompacted_KVs != nil {
		return *x.CurrentCompacted_KVs
	}
	return 0
}
func (x *RegionLoad) GetRootIndexSize_KB() uint32 {
	if x != nil && x.RootIndexSize_KB != nil {
		return *x.RootIndexSize_KB
	}
	return 0
}
func (x *RegionLoad) GetTotalStaticIndexSize_KB() uint32 {
	if x != nil && x.TotalStaticIndexSize_KB != nil {
		return *x.TotalStaticIndexSize_KB
	}
	return 0
}
func (x *RegionLoad) GetTotalStaticBloomSize_KB() uint32 {
	if x != nil && x.TotalStaticBloomSize_KB != nil {
		return *x.TotalStaticBloomSize_KB
	}
	return 0
}
func (x *RegionLoad) GetCompleteSequenceId() uint64 {
	if x != nil && x.CompleteSequenceId != nil {
		return *x.CompleteSequenceId
	}
	return 0
}
func (x *RegionLoad) GetDataLocality() float32 {
	if x != nil && x.DataLocality != nil {
		return *x.DataLocality
	}
	return 0
}
func (x *RegionLoad) GetLastMajorCompactionTs() uint64 {
	if x != nil && x.LastMajorCompactionTs != nil {
		return *x.LastMajorCompactionTs
	}
	return Default_RegionLoad_LastMajorCompactionTs
}
func (x *RegionLoad) GetStoreCompleteSequenceId() []*StoreSequenceId {
	if x != nil {
		return x.StoreCompleteSequenceId
	}
	return nil
}
type ReplicationLoadSink struct {
	state         protoimpl.MessageState
	sizeCache     protoimpl.SizeCache
	unknownFields protoimpl.UnknownFields
	AgeOfLastAppliedOp        *uint64 `protobuf:"varint,1,req,name=ageOfLastAppliedOp" json:"ageOfLastAppliedOp,omitempty"`
	TimeStampsOfLastAppliedOp *uint64 `protobuf:"varint,2,req,name=timeStampsOfLastAppliedOp" json:"timeStampsOfLastAppliedOp,omitempty"`
}
func (x *ReplicationLoadSink) Reset() {
	*x = ReplicationLoadSink{}
	if protoimpl.UnsafeEnabled {
		mi := &file_ClusterStatus_proto_msgTypes[5]
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		ms.StoreMessageInfo(mi)
	}
}
func (x *ReplicationLoadSink) String() string {
	return protoimpl.X.MessageStringOf(x)
}
func (*ReplicationLoadSink) ProtoMessage() {}
func (x *ReplicationLoadSink) ProtoReflect() protoreflect.Message {
	mi := &file_ClusterStatus_proto_msgTypes[5]
	if protoimpl.UnsafeEnabled && x != nil {
		ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
		if ms.LoadMessageInfo() == nil {
			ms.StoreMessageInfo(mi)
		}
		return ms
	}
	return mi.MessageOf(x)
}