mspb

package
v0.0.0-...-927e444 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 23, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMspb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMspb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMspb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ErrorType_name = map[int32]string{
	0:  "No",
	1:  "UnDefine",
	2:  "ClusterIDNotSame",
	3:  "NoSelectedNode",
	4:  "InternalError",
	5:  "GenID",
	6:  "DupDatabase",
	7:  "DupTable",
	8:  "NotRuningTable",
	9:  "NotExistDatabase",
	10: "NotExistTable",
	11: "NotExistNode",
	12: "NotActiveNode",
	13: "NotExistRange",
	14: "ExistsRange",
	15: "NotExistPeer",
	16: "NotEnoughResources",
	17: "InvalidParam",
	18: "InvalidColumn",
	19: "InvalidIndex",
	20: "ColumnNameTooLong",
	21: "ColumnNotExist",
	22: "DupColumnName",
	23: "PkMustNotNull",
	24: "MissingPk",
	25: "PkMustNotSetDefaultValue",
	26: "NodeRejectNewPeer",
	27: "NodeBlocked",
	28: "NodeStateConfused",
	29: "NodeNotEnough",
	30: "SchedulerExisted",
	31: "SchedulerNotFound",
	32: "WorkerExisted",
	33: "WorkerNotFound",
	34: "SqlReservedWord",
	35: "SQLSyntaxError",
	36: "RangeMetaConflict",
	37: "NotFound",
	38: "NotAllowSplit",
	39: "NotCancel",
	40: "NotAllowDelete",
	41: "ClientIPNotSet",
	42: "DatabaseNotEmpty",
	43: "NodeStateNotExpected",
	44: "WatcherMasterHashErr",
}
View Source 
var ErrorType_value = map[string]int32{
	"No":                       0,
	"UnDefine":                 1,
	"ClusterIDNotSame":         2,
	"NoSelectedNode":           3,
	"InternalError":            4,
	"GenID":                    5,
	"DupDatabase":              6,
	"DupTable":                 7,
	"NotRuningTable":           8,
	"NotExistDatabase":         9,
	"NotExistTable":            10,
	"NotExistNode":             11,
	"NotActiveNode":            12,
	"NotExistRange":            13,
	"ExistsRange":              14,
	"NotExistPeer":             15,
	"NotEnoughResources":       16,
	"InvalidParam":             17,
	"InvalidColumn":            18,
	"InvalidIndex":             19,
	"ColumnNameTooLong":        20,
	"ColumnNotExist":           21,
	"DupColumnName":            22,
	"PkMustNotNull":            23,
	"MissingPk":                24,
	"PkMustNotSetDefaultValue": 25,
	"NodeRejectNewPeer":        26,
	"NodeBlocked":              27,
	"NodeStateConfused":        28,
	"NodeNotEnough":            29,
	"SchedulerExisted":         30,
	"SchedulerNotFound":        31,
	"WorkerExisted":            32,
	"WorkerNotFound":           33,
	"SqlReservedWord":          34,
	"SQLSyntaxError":           35,
	"RangeMetaConflict":        36,
	"NotFound":                 37,
	"NotAllowSplit":            38,
	"NotCancel":                39,
	"NotAllowDelete":           40,
	"ClientIPNotSet":           41,
	"DatabaseNotEmpty":         42,
	"NodeStateNotExpected":     43,
	"WatcherMasterHashErr":     44,
}
View Source 
var StorageEngine_name = map[int32]string{
	0: "STE_Invalid",
	1: "STE_MassTree",
	2: "STE_RocksDB",
}
View Source 
var StorageEngine_value = map[string]int32{
	"STE_Invalid":  0,
	"STE_MassTree": 1,
	"STE_RocksDB":  2,
}

Functions

This section is empty.

Types

type AskSplitRequest 

type AskSplitRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Range                *basepb.Range  `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	SplitKey             []byte         `protobuf:"bytes,3,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	Force                bool           `protobuf:"varint,4,opt,name=force,proto3" json:"force,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*AskSplitRequest) Descriptor 

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

func (*AskSplitRequest) GetForce 

func (m *AskSplitRequest) GetForce() bool

func (*AskSplitRequest) GetHeader 

func (m *AskSplitRequest) GetHeader() *RequestHeader

func (*AskSplitRequest) GetRange 

func (m *AskSplitRequest) GetRange() *basepb.Range

func (*AskSplitRequest) GetSplitKey 

func (m *AskSplitRequest) GetSplitKey() []byte

func (*AskSplitRequest) Marshal 

func (m *AskSplitRequest) Marshal() (dAtA []byte, err error)

func (*AskSplitRequest) MarshalTo 

func (m *AskSplitRequest) MarshalTo(dAtA []byte) (int, error)

func (*AskSplitRequest) MarshalToSizedBuffer 

func (m *AskSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AskSplitRequest) ProtoMessage 

func (*AskSplitRequest) ProtoMessage()

func (*AskSplitRequest) Reset 

func (m *AskSplitRequest) Reset()

func (*AskSplitRequest) Size 

func (m *AskSplitRequest) Size() (n int)

func (*AskSplitRequest) String 

func (m *AskSplitRequest) String() string

func (*AskSplitRequest) Unmarshal 

func (m *AskSplitRequest) Unmarshal(dAtA []byte) error

func (*AskSplitRequest) XXX_DiscardUnknown 

func (m *AskSplitRequest) XXX_DiscardUnknown()

func (*AskSplitRequest) XXX_Marshal 

func (m *AskSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AskSplitRequest) XXX_Merge 

func (m *AskSplitRequest) XXX_Merge(src proto.Message)

func (*AskSplitRequest) XXX_Size 

func (m *AskSplitRequest) XXX_Size() int

func (*AskSplitRequest) XXX_Unmarshal 

func (m *AskSplitRequest) XXX_Unmarshal(b []byte) error

type AskSplitResponse 

type AskSplitResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Range                *basepb.Range   `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	NewRangeId           uint64          `protobuf:"varint,3,opt,name=new_range_id,json=newRangeId,proto3" json:"new_range_id,omitempty"`
	NewPeerIds           []uint64        `protobuf:"varint,4,rep,packed,name=new_peer_ids,json=newPeerIds,proto3" json:"new_peer_ids,omitempty"`
	SplitKey             []byte          `protobuf:"bytes,5,opt,name=split_key,json=splitKey,proto3" json:"split_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*AskSplitResponse) Descriptor 

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

func (*AskSplitResponse) GetHeader 

func (m *AskSplitResponse) GetHeader() *ResponseHeader

func (*AskSplitResponse) GetNewPeerIds 

func (m *AskSplitResponse) GetNewPeerIds() []uint64

func (*AskSplitResponse) GetNewRangeId 

func (m *AskSplitResponse) GetNewRangeId() uint64

func (*AskSplitResponse) GetRange 

func (m *AskSplitResponse) GetRange() *basepb.Range

func (*AskSplitResponse) GetSplitKey 

func (m *AskSplitResponse) GetSplitKey() []byte

func (*AskSplitResponse) Marshal 

func (m *AskSplitResponse) Marshal() (dAtA []byte, err error)

func (*AskSplitResponse) MarshalTo 

func (m *AskSplitResponse) MarshalTo(dAtA []byte) (int, error)

func (*AskSplitResponse) MarshalToSizedBuffer 

func (m *AskSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AskSplitResponse) ProtoMessage 

func (*AskSplitResponse) ProtoMessage()

func (*AskSplitResponse) Reset 

func (m *AskSplitResponse) Reset()

func (*AskSplitResponse) Size 

func (m *AskSplitResponse) Size() (n int)

func (*AskSplitResponse) String 

func (m *AskSplitResponse) String() string

func (*AskSplitResponse) Unmarshal 

func (m *AskSplitResponse) Unmarshal(dAtA []byte) error

func (*AskSplitResponse) XXX_DiscardUnknown 

func (m *AskSplitResponse) XXX_DiscardUnknown()

func (*AskSplitResponse) XXX_Marshal 

func (m *AskSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AskSplitResponse) XXX_Merge 

func (m *AskSplitResponse) XXX_Merge(src proto.Message)

func (*AskSplitResponse) XXX_Size 

func (m *AskSplitResponse) XXX_Size() int

func (*AskSplitResponse) XXX_Unmarshal 

func (m *AskSplitResponse) XXX_Unmarshal(b []byte) error

type ChangeNodeStateRequest 

type ChangeNodeStateRequest struct {
	Header               *RequestHeader   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Id                   uint64           `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	State                basepb.NodeState `protobuf:"varint,3,opt,name=state,proto3,enum=basepb.NodeState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ChangeNodeStateRequest) Descriptor 

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

func (*ChangeNodeStateRequest) GetHeader 

func (m *ChangeNodeStateRequest) GetHeader() *RequestHeader

func (*ChangeNodeStateRequest) GetId 

func (m *ChangeNodeStateRequest) GetId() uint64

func (*ChangeNodeStateRequest) GetState 

func (m *ChangeNodeStateRequest) GetState() basepb.NodeState

func (*ChangeNodeStateRequest) Marshal 

func (m *ChangeNodeStateRequest) Marshal() (dAtA []byte, err error)

func (*ChangeNodeStateRequest) MarshalTo 

func (m *ChangeNodeStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*ChangeNodeStateRequest) MarshalToSizedBuffer 

func (m *ChangeNodeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeNodeStateRequest) ProtoMessage 

func (*ChangeNodeStateRequest) ProtoMessage()

func (*ChangeNodeStateRequest) Reset 

func (m *ChangeNodeStateRequest) Reset()

func (*ChangeNodeStateRequest) Size 

func (m *ChangeNodeStateRequest) Size() (n int)

func (*ChangeNodeStateRequest) String 

func (m *ChangeNodeStateRequest) String() string

func (*ChangeNodeStateRequest) Unmarshal 

func (m *ChangeNodeStateRequest) Unmarshal(dAtA []byte) error

func (*ChangeNodeStateRequest) XXX_DiscardUnknown 

func (m *ChangeNodeStateRequest) XXX_DiscardUnknown()

func (*ChangeNodeStateRequest) XXX_Marshal 

func (m *ChangeNodeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeNodeStateRequest) XXX_Merge 

func (m *ChangeNodeStateRequest) XXX_Merge(src proto.Message)

func (*ChangeNodeStateRequest) XXX_Size 

func (m *ChangeNodeStateRequest) XXX_Size() int

func (*ChangeNodeStateRequest) XXX_Unmarshal 

func (m *ChangeNodeStateRequest) XXX_Unmarshal(b []byte) error

type ChangeNodeStateResponse 

type ChangeNodeStateResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Node                 *basepb.Node    `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ChangeNodeStateResponse) Descriptor 

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

func (*ChangeNodeStateResponse) GetHeader 

func (m *ChangeNodeStateResponse) GetHeader() *ResponseHeader

func (*ChangeNodeStateResponse) GetNode 

func (m *ChangeNodeStateResponse) GetNode() *basepb.Node

func (*ChangeNodeStateResponse) Marshal 

func (m *ChangeNodeStateResponse) Marshal() (dAtA []byte, err error)

func (*ChangeNodeStateResponse) MarshalTo 

func (m *ChangeNodeStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChangeNodeStateResponse) MarshalToSizedBuffer 

func (m *ChangeNodeStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeNodeStateResponse) ProtoMessage 

func (*ChangeNodeStateResponse) ProtoMessage()

func (*ChangeNodeStateResponse) Reset 

func (m *ChangeNodeStateResponse) Reset()

func (*ChangeNodeStateResponse) Size 

func (m *ChangeNodeStateResponse) Size() (n int)

func (*ChangeNodeStateResponse) String 

func (m *ChangeNodeStateResponse) String() string

func (*ChangeNodeStateResponse) Unmarshal 

func (m *ChangeNodeStateResponse) Unmarshal(dAtA []byte) error

func (*ChangeNodeStateResponse) XXX_DiscardUnknown 

func (m *ChangeNodeStateResponse) XXX_DiscardUnknown()

func (*ChangeNodeStateResponse) XXX_Marshal 

func (m *ChangeNodeStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeNodeStateResponse) XXX_Merge 

func (m *ChangeNodeStateResponse) XXX_Merge(src proto.Message)

func (*ChangeNodeStateResponse) XXX_Size 

func (m *ChangeNodeStateResponse) XXX_Size() int

func (*ChangeNodeStateResponse) XXX_Unmarshal 

func (m *ChangeNodeStateResponse) XXX_Unmarshal(b []byte) error

type ChangeRangeStoreTypeRequest 

type ChangeRangeStoreTypeRequest struct {
	Header               *RequestHeader   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	TableId              int32            `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	RangeId              uint64           `protobuf:"varint,3,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	StoreType            basepb.StoreType `protobuf:"varint,4,opt,name=store_type,json=storeType,proto3,enum=basepb.StoreType" json:"store_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ChangeRangeStoreTypeRequest) Descriptor 

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

func (*ChangeRangeStoreTypeRequest) GetHeader 

func (m *ChangeRangeStoreTypeRequest) GetHeader() *RequestHeader

func (*ChangeRangeStoreTypeRequest) GetRangeId 

func (m *ChangeRangeStoreTypeRequest) GetRangeId() uint64

func (*ChangeRangeStoreTypeRequest) GetStoreType 

func (m *ChangeRangeStoreTypeRequest) GetStoreType() basepb.StoreType

func (*ChangeRangeStoreTypeRequest) GetTableId 

func (m *ChangeRangeStoreTypeRequest) GetTableId() int32

func (*ChangeRangeStoreTypeRequest) Marshal 

func (m *ChangeRangeStoreTypeRequest) Marshal() (dAtA []byte, err error)

func (*ChangeRangeStoreTypeRequest) MarshalTo 

func (m *ChangeRangeStoreTypeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ChangeRangeStoreTypeRequest) MarshalToSizedBuffer 

func (m *ChangeRangeStoreTypeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeRangeStoreTypeRequest) ProtoMessage 

func (*ChangeRangeStoreTypeRequest) ProtoMessage()

func (*ChangeRangeStoreTypeRequest) Reset 

func (m *ChangeRangeStoreTypeRequest) Reset()

func (*ChangeRangeStoreTypeRequest) Size 

func (m *ChangeRangeStoreTypeRequest) Size() (n int)

func (*ChangeRangeStoreTypeRequest) String 

func (m *ChangeRangeStoreTypeRequest) String() string

func (*ChangeRangeStoreTypeRequest) Unmarshal 

func (m *ChangeRangeStoreTypeRequest) Unmarshal(dAtA []byte) error

func (*ChangeRangeStoreTypeRequest) XXX_DiscardUnknown 

func (m *ChangeRangeStoreTypeRequest) XXX_DiscardUnknown()

func (*ChangeRangeStoreTypeRequest) XXX_Marshal 

func (m *ChangeRangeStoreTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeRangeStoreTypeRequest) XXX_Merge 

func (m *ChangeRangeStoreTypeRequest) XXX_Merge(src proto.Message)

func (*ChangeRangeStoreTypeRequest) XXX_Size 

func (m *ChangeRangeStoreTypeRequest) XXX_Size() int

func (*ChangeRangeStoreTypeRequest) XXX_Unmarshal 

func (m *ChangeRangeStoreTypeRequest) XXX_Unmarshal(b []byte) error

type ChangeRangeStoreTypeResponse 

type ChangeRangeStoreTypeResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ChangeRangeStoreTypeResponse) Descriptor 

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

func (*ChangeRangeStoreTypeResponse) GetHeader 

func (m *ChangeRangeStoreTypeResponse) GetHeader() *ResponseHeader

func (*ChangeRangeStoreTypeResponse) Marshal 

func (m *ChangeRangeStoreTypeResponse) Marshal() (dAtA []byte, err error)

func (*ChangeRangeStoreTypeResponse) MarshalTo 

func (m *ChangeRangeStoreTypeResponse) MarshalTo(dAtA []byte) (int, error)

func (*ChangeRangeStoreTypeResponse) MarshalToSizedBuffer 

func (m *ChangeRangeStoreTypeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangeRangeStoreTypeResponse) ProtoMessage 

func (*ChangeRangeStoreTypeResponse) ProtoMessage()

func (*ChangeRangeStoreTypeResponse) Reset 

func (m *ChangeRangeStoreTypeResponse) Reset()

func (*ChangeRangeStoreTypeResponse) Size 

func (m *ChangeRangeStoreTypeResponse) Size() (n int)

func (*ChangeRangeStoreTypeResponse) String 

func (m *ChangeRangeStoreTypeResponse) String() string

func (*ChangeRangeStoreTypeResponse) Unmarshal 

func (m *ChangeRangeStoreTypeResponse) Unmarshal(dAtA []byte) error

func (*ChangeRangeStoreTypeResponse) XXX_DiscardUnknown 

func (m *ChangeRangeStoreTypeResponse) XXX_DiscardUnknown()

func (*ChangeRangeStoreTypeResponse) XXX_Marshal 

func (m *ChangeRangeStoreTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangeRangeStoreTypeResponse) XXX_Merge 

func (m *ChangeRangeStoreTypeResponse) XXX_Merge(src proto.Message)

func (*ChangeRangeStoreTypeResponse) XXX_Size 

func (m *ChangeRangeStoreTypeResponse) XXX_Size() int

func (*ChangeRangeStoreTypeResponse) XXX_Unmarshal 

func (m *ChangeRangeStoreTypeResponse) XXX_Unmarshal(b []byte) error

type CheckNodeStateRequest 

type CheckNodeStateRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Id                   uint64         `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CheckNodeStateRequest) Descriptor 

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

func (*CheckNodeStateRequest) GetHeader 

func (m *CheckNodeStateRequest) GetHeader() *RequestHeader

func (*CheckNodeStateRequest) GetId 

func (m *CheckNodeStateRequest) GetId() uint64

func (*CheckNodeStateRequest) Marshal 

func (m *CheckNodeStateRequest) Marshal() (dAtA []byte, err error)

func (*CheckNodeStateRequest) MarshalTo 

func (m *CheckNodeStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*CheckNodeStateRequest) MarshalToSizedBuffer 

func (m *CheckNodeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckNodeStateRequest) ProtoMessage 

func (*CheckNodeStateRequest) ProtoMessage()

func (*CheckNodeStateRequest) Reset 

func (m *CheckNodeStateRequest) Reset()

func (*CheckNodeStateRequest) Size 

func (m *CheckNodeStateRequest) Size() (n int)

func (*CheckNodeStateRequest) String 

func (m *CheckNodeStateRequest) String() string

func (*CheckNodeStateRequest) Unmarshal 

func (m *CheckNodeStateRequest) Unmarshal(dAtA []byte) error

func (*CheckNodeStateRequest) XXX_DiscardUnknown 

func (m *CheckNodeStateRequest) XXX_DiscardUnknown()

func (*CheckNodeStateRequest) XXX_Marshal 

func (m *CheckNodeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckNodeStateRequest) XXX_Merge 

func (m *CheckNodeStateRequest) XXX_Merge(src proto.Message)

func (*CheckNodeStateRequest) XXX_Size 

func (m *CheckNodeStateRequest) XXX_Size() int

func (*CheckNodeStateRequest) XXX_Unmarshal 

func (m *CheckNodeStateRequest) XXX_Unmarshal(b []byte) error

type CheckNodeStateResponse 

type CheckNodeStateResponse struct {
	Header               *ResponseHeader  `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RangeNum             uint64           `protobuf:"varint,2,opt,name=range_num,json=rangeNum,proto3" json:"range_num,omitempty"`
	LeaderNum            uint64           `protobuf:"varint,3,opt,name=leader_num,json=leaderNum,proto3" json:"leader_num,omitempty"`
	State                basepb.NodeState `protobuf:"varint,4,opt,name=state,proto3,enum=basepb.NodeState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CheckNodeStateResponse) Descriptor 

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

func (*CheckNodeStateResponse) GetHeader 

func (m *CheckNodeStateResponse) GetHeader() *ResponseHeader

func (*CheckNodeStateResponse) GetLeaderNum 

func (m *CheckNodeStateResponse) GetLeaderNum() uint64

func (*CheckNodeStateResponse) GetRangeNum 

func (m *CheckNodeStateResponse) GetRangeNum() uint64

func (*CheckNodeStateResponse) GetState 

func (m *CheckNodeStateResponse) GetState() basepb.NodeState

func (*CheckNodeStateResponse) Marshal 

func (m *CheckNodeStateResponse) Marshal() (dAtA []byte, err error)

func (*CheckNodeStateResponse) MarshalTo 

func (m *CheckNodeStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*CheckNodeStateResponse) MarshalToSizedBuffer 

func (m *CheckNodeStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CheckNodeStateResponse) ProtoMessage 

func (*CheckNodeStateResponse) ProtoMessage()

func (*CheckNodeStateResponse) Reset 

func (m *CheckNodeStateResponse) Reset()

func (*CheckNodeStateResponse) Size 

func (m *CheckNodeStateResponse) Size() (n int)

func (*CheckNodeStateResponse) String 

func (m *CheckNodeStateResponse) String() string

func (*CheckNodeStateResponse) Unmarshal 

func (m *CheckNodeStateResponse) Unmarshal(dAtA []byte) error

func (*CheckNodeStateResponse) XXX_DiscardUnknown 

func (m *CheckNodeStateResponse) XXX_DiscardUnknown()

func (*CheckNodeStateResponse) XXX_Marshal 

func (m *CheckNodeStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckNodeStateResponse) XXX_Merge 

func (m *CheckNodeStateResponse) XXX_Merge(src proto.Message)

func (*CheckNodeStateResponse) XXX_Size 

func (m *CheckNodeStateResponse) XXX_Size() int

func (*CheckNodeStateResponse) XXX_Unmarshal 

func (m *CheckNodeStateResponse) XXX_Unmarshal(b []byte) error

type ClusterInfoRequest 

type ClusterInfoRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ClusterInfoRequest) Descriptor 

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

func (*ClusterInfoRequest) GetHeader 

func (m *ClusterInfoRequest) GetHeader() *RequestHeader

func (*ClusterInfoRequest) Marshal 

func (m *ClusterInfoRequest) Marshal() (dAtA []byte, err error)

func (*ClusterInfoRequest) MarshalTo 

func (m *ClusterInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*ClusterInfoRequest) MarshalToSizedBuffer 

func (m *ClusterInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterInfoRequest) ProtoMessage 

func (*ClusterInfoRequest) ProtoMessage()

func (*ClusterInfoRequest) Reset 

func (m *ClusterInfoRequest) Reset()

func (*ClusterInfoRequest) Size 

func (m *ClusterInfoRequest) Size() (n int)

func (*ClusterInfoRequest) String 

func (m *ClusterInfoRequest) String() string

func (*ClusterInfoRequest) Unmarshal 

func (m *ClusterInfoRequest) Unmarshal(dAtA []byte) error

func (*ClusterInfoRequest) XXX_DiscardUnknown 

func (m *ClusterInfoRequest) XXX_DiscardUnknown()

func (*ClusterInfoRequest) XXX_Marshal 

func (m *ClusterInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterInfoRequest) XXX_Merge 

func (m *ClusterInfoRequest) XXX_Merge(src proto.Message)

func (*ClusterInfoRequest) XXX_Size 

func (m *ClusterInfoRequest) XXX_Size() int

func (*ClusterInfoRequest) XXX_Unmarshal 

func (m *ClusterInfoRequest) XXX_Unmarshal(b []byte) error

type ClusterInfoResponse 

type ClusterInfoResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	BuildVersion         string          `protobuf:"bytes,2,opt,name=build_version,json=buildVersion,proto3" json:"build_version,omitempty"`
	BuildTime            string          `protobuf:"bytes,3,opt,name=build_time,json=buildTime,proto3" json:"build_time,omitempty"`
	CommitId             string          `protobuf:"bytes,4,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ClusterInfoResponse) Descriptor 

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

func (*ClusterInfoResponse) GetBuildTime 

func (m *ClusterInfoResponse) GetBuildTime() string

func (*ClusterInfoResponse) GetBuildVersion 

func (m *ClusterInfoResponse) GetBuildVersion() string

func (*ClusterInfoResponse) GetCommitId 

func (m *ClusterInfoResponse) GetCommitId() string

func (*ClusterInfoResponse) GetHeader 

func (m *ClusterInfoResponse) GetHeader() *ResponseHeader

func (*ClusterInfoResponse) Marshal 

func (m *ClusterInfoResponse) Marshal() (dAtA []byte, err error)

func (*ClusterInfoResponse) MarshalTo 

func (m *ClusterInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*ClusterInfoResponse) MarshalToSizedBuffer 

func (m *ClusterInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClusterInfoResponse) ProtoMessage 

func (*ClusterInfoResponse) ProtoMessage()

func (*ClusterInfoResponse) Reset 

func (m *ClusterInfoResponse) Reset()

func (*ClusterInfoResponse) Size 

func (m *ClusterInfoResponse) Size() (n int)

func (*ClusterInfoResponse) String 

func (m *ClusterInfoResponse) String() string

func (*ClusterInfoResponse) Unmarshal 

func (m *ClusterInfoResponse) Unmarshal(dAtA []byte) error

func (*ClusterInfoResponse) XXX_DiscardUnknown 

func (m *ClusterInfoResponse) XXX_DiscardUnknown()

func (*ClusterInfoResponse) XXX_Marshal 

func (m *ClusterInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterInfoResponse) XXX_Merge 

func (m *ClusterInfoResponse) XXX_Merge(src proto.Message)

func (*ClusterInfoResponse) XXX_Size 

func (m *ClusterInfoResponse) XXX_Size() int

func (*ClusterInfoResponse) XXX_Unmarshal 

func (m *ClusterInfoResponse) XXX_Unmarshal(b []byte) error

type Counter 

type Counter struct {
	DbId                 int32    `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              int32    `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Count                uint64   `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	DbName               string   `protobuf:"bytes,4,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TableName            string   `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Counter) Descriptor 

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

func (*Counter) GetCount 

func (m *Counter) GetCount() uint64

func (*Counter) GetDbId 

func (m *Counter) GetDbId() int32

func (*Counter) GetDbName 

func (m *Counter) GetDbName() string

func (*Counter) GetTableId 

func (m *Counter) GetTableId() int32

func (*Counter) GetTableName 

func (m *Counter) GetTableName() string

func (*Counter) Marshal 

func (m *Counter) Marshal() (dAtA []byte, err error)

func (*Counter) MarshalTo 

func (m *Counter) MarshalTo(dAtA []byte) (int, error)

func (*Counter) MarshalToSizedBuffer 

func (m *Counter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Counter) ProtoMessage 

func (*Counter) ProtoMessage()

func (*Counter) Reset 

func (m *Counter) Reset()

func (*Counter) Size 

func (m *Counter) Size() (n int)

func (*Counter) String 

func (m *Counter) String() string

func (*Counter) Unmarshal 

func (m *Counter) Unmarshal(dAtA []byte) error

func (*Counter) XXX_DiscardUnknown 

func (m *Counter) XXX_DiscardUnknown()

func (*Counter) XXX_Marshal 

func (m *Counter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Counter) XXX_Merge 

func (m *Counter) XXX_Merge(src proto.Message)

func (*Counter) XXX_Size 

func (m *Counter) XXX_Size() int

func (*Counter) XXX_Unmarshal 

func (m *Counter) XXX_Unmarshal(b []byte) error

type CreateRangesRequest 

type CreateRangesRequest struct {
	Header               *RequestHeader  `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 int32           `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              int32           `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Replicas             int32           `protobuf:"varint,4,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Ranges               []*basepb.Range `protobuf:"bytes,5,rep,name=ranges,proto3" json:"ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CreateRangesRequest) Descriptor 

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

func (*CreateRangesRequest) GetDbId 

func (m *CreateRangesRequest) GetDbId() int32

func (*CreateRangesRequest) GetHeader 

func (m *CreateRangesRequest) GetHeader() *RequestHeader

func (*CreateRangesRequest) GetRanges 

func (m *CreateRangesRequest) GetRanges() []*basepb.Range

func (*CreateRangesRequest) GetReplicas 

func (m *CreateRangesRequest) GetReplicas() int32

func (*CreateRangesRequest) GetTableId 

func (m *CreateRangesRequest) GetTableId() int32

func (*CreateRangesRequest) Marshal 

func (m *CreateRangesRequest) Marshal() (dAtA []byte, err error)

func (*CreateRangesRequest) MarshalTo 

func (m *CreateRangesRequest) MarshalTo(dAtA []byte) (int, error)

func (*CreateRangesRequest) MarshalToSizedBuffer 

func (m *CreateRangesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CreateRangesRequest) ProtoMessage 

func (*CreateRangesRequest) ProtoMessage()

func (*CreateRangesRequest) Reset 

func (m *CreateRangesRequest) Reset()

func (*CreateRangesRequest) Size 

func (m *CreateRangesRequest) Size() (n int)

func (*CreateRangesRequest) String 

func (m *CreateRangesRequest) String() string

func (*CreateRangesRequest) Unmarshal 

func (m *CreateRangesRequest) Unmarshal(dAtA []byte) error

func (*CreateRangesRequest) XXX_DiscardUnknown 

func (m *CreateRangesRequest) XXX_DiscardUnknown()

func (*CreateRangesRequest) XXX_Marshal 

func (m *CreateRangesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRangesRequest) XXX_Merge 

func (m *CreateRangesRequest) XXX_Merge(src proto.Message)

func (*CreateRangesRequest) XXX_Size 

func (m *CreateRangesRequest) XXX_Size() int

func (*CreateRangesRequest) XXX_Unmarshal 

func (m *CreateRangesRequest) XXX_Unmarshal(b []byte) error

type DeleteRangesRequest 

type DeleteRangesRequest struct {
	Header               *RequestHeader   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 int32            `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              int32            `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	RangeType            basepb.RangeType `protobuf:"varint,4,opt,name=range_type,json=rangeType,proto3,enum=basepb.RangeType" json:"range_type,omitempty"`
	IndexId              int32            `protobuf:"varint,5,opt,name=index_id,json=indexId,proto3" json:"index_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DeleteRangesRequest) Descriptor 

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

func (*DeleteRangesRequest) GetDbId 

func (m *DeleteRangesRequest) GetDbId() int32

func (*DeleteRangesRequest) GetHeader 

func (m *DeleteRangesRequest) GetHeader() *RequestHeader

func (*DeleteRangesRequest) GetIndexId 

func (m *DeleteRangesRequest) GetIndexId() int32

func (*DeleteRangesRequest) GetRangeType 

func (m *DeleteRangesRequest) GetRangeType() basepb.RangeType

func (*DeleteRangesRequest) GetTableId 

func (m *DeleteRangesRequest) GetTableId() int32

func (*DeleteRangesRequest) Marshal 

func (m *DeleteRangesRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRangesRequest) MarshalTo 

func (m *DeleteRangesRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRangesRequest) MarshalToSizedBuffer 

func (m *DeleteRangesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteRangesRequest) ProtoMessage 

func (*DeleteRangesRequest) ProtoMessage()

func (*DeleteRangesRequest) Reset 

func (m *DeleteRangesRequest) Reset()

func (*DeleteRangesRequest) Size 

func (m *DeleteRangesRequest) Size() (n int)

func (*DeleteRangesRequest) String 

func (m *DeleteRangesRequest) String() string

func (*DeleteRangesRequest) Unmarshal 

func (m *DeleteRangesRequest) Unmarshal(dAtA []byte) error

func (*DeleteRangesRequest) XXX_DiscardUnknown 

func (m *DeleteRangesRequest) XXX_DiscardUnknown()

func (*DeleteRangesRequest) XXX_Marshal 

func (m *DeleteRangesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteRangesRequest) XXX_Merge 

func (m *DeleteRangesRequest) XXX_Merge(src proto.Message)

func (*DeleteRangesRequest) XXX_Size 

func (m *DeleteRangesRequest) XXX_Size() int

func (*DeleteRangesRequest) XXX_Unmarshal 

func (m *DeleteRangesRequest) XXX_Unmarshal(b []byte) error

type Error 

type Error struct {
	Code                 uint32   `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() uint32

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) Marshal 

func (m *Error) Marshal() (dAtA []byte, err error)

func (*Error) MarshalTo 

func (m *Error) MarshalTo(dAtA []byte) (int, error)

func (*Error) MarshalToSizedBuffer 

func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

func (m *Error) Unmarshal(dAtA []byte) error

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

func (m *Error) XXX_Unmarshal(b []byte) error

type ErrorType 

type ErrorType int32
const (
	ErrorType_No                       ErrorType = 0
	ErrorType_UnDefine                 ErrorType = 1
	ErrorType_ClusterIDNotSame         ErrorType = 2
	ErrorType_NoSelectedNode           ErrorType = 3
	ErrorType_InternalError            ErrorType = 4
	ErrorType_GenID                    ErrorType = 5
	ErrorType_DupDatabase              ErrorType = 6
	ErrorType_DupTable                 ErrorType = 7
	ErrorType_NotRuningTable           ErrorType = 8
	ErrorType_NotExistDatabase         ErrorType = 9
	ErrorType_NotExistTable            ErrorType = 10
	ErrorType_NotExistNode             ErrorType = 11
	ErrorType_NotActiveNode            ErrorType = 12
	ErrorType_NotExistRange            ErrorType = 13
	ErrorType_ExistsRange              ErrorType = 14
	ErrorType_NotExistPeer             ErrorType = 15
	ErrorType_NotEnoughResources       ErrorType = 16
	ErrorType_InvalidParam             ErrorType = 17
	ErrorType_InvalidColumn            ErrorType = 18
	ErrorType_InvalidIndex             ErrorType = 19
	ErrorType_ColumnNameTooLong        ErrorType = 20
	ErrorType_ColumnNotExist           ErrorType = 21
	ErrorType_DupColumnName            ErrorType = 22
	ErrorType_PkMustNotNull            ErrorType = 23
	ErrorType_MissingPk                ErrorType = 24
	ErrorType_PkMustNotSetDefaultValue ErrorType = 25
	ErrorType_NodeRejectNewPeer        ErrorType = 26
	ErrorType_NodeBlocked              ErrorType = 27
	ErrorType_NodeStateConfused        ErrorType = 28
	ErrorType_NodeNotEnough            ErrorType = 29
	ErrorType_SchedulerExisted         ErrorType = 30
	ErrorType_SchedulerNotFound        ErrorType = 31
	ErrorType_WorkerExisted            ErrorType = 32
	ErrorType_WorkerNotFound           ErrorType = 33
	ErrorType_SqlReservedWord          ErrorType = 34
	ErrorType_SQLSyntaxError           ErrorType = 35
	ErrorType_RangeMetaConflict        ErrorType = 36
	ErrorType_NotFound                 ErrorType = 37
	ErrorType_NotAllowSplit            ErrorType = 38
	ErrorType_NotCancel                ErrorType = 39
	ErrorType_NotAllowDelete           ErrorType = 40
	ErrorType_ClientIPNotSet           ErrorType = 41
	ErrorType_DatabaseNotEmpty         ErrorType = 42
	ErrorType_NodeStateNotExpected     ErrorType = 43
	ErrorType_WatcherMasterHashErr     ErrorType = 44
)

func (ErrorType) EnumDescriptor 

func (ErrorType) EnumDescriptor() ([]byte, []int)

func (ErrorType) String 

func (x ErrorType) String() string

type GeneralResponse 

type GeneralResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GeneralResponse) Descriptor 

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

func (*GeneralResponse) GetHeader 

func (m *GeneralResponse) GetHeader() *ResponseHeader

func (*GeneralResponse) Marshal 

func (m *GeneralResponse) Marshal() (dAtA []byte, err error)

func (*GeneralResponse) MarshalTo 

func (m *GeneralResponse) MarshalTo(dAtA []byte) (int, error)

func (*GeneralResponse) MarshalToSizedBuffer 

func (m *GeneralResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GeneralResponse) ProtoMessage 

func (*GeneralResponse) ProtoMessage()

func (*GeneralResponse) Reset 

func (m *GeneralResponse) Reset()

func (*GeneralResponse) Size 

func (m *GeneralResponse) Size() (n int)

func (*GeneralResponse) String 

func (m *GeneralResponse) String() string

func (*GeneralResponse) Unmarshal 

func (m *GeneralResponse) Unmarshal(dAtA []byte) error

func (*GeneralResponse) XXX_DiscardUnknown 

func (m *GeneralResponse) XXX_DiscardUnknown()

func (*GeneralResponse) XXX_Marshal 

func (m *GeneralResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GeneralResponse) XXX_Merge 

func (m *GeneralResponse) XXX_Merge(src proto.Message)

func (*GeneralResponse) XXX_Size 

func (m *GeneralResponse) XXX_Size() int

func (*GeneralResponse) XXX_Unmarshal 

func (m *GeneralResponse) XXX_Unmarshal(b []byte) error

type GetColumnRequest 

type GetColumnRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 int32          `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              int32          `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	ColId                uint64         `protobuf:"varint,4,opt,name=col_id,json=colId,proto3" json:"col_id,omitempty"`
	ColName              string         `protobuf:"bytes,5,opt,name=col_name,json=colName,proto3" json:"col_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetColumnRequest) Descriptor 

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

func (*GetColumnRequest) GetColId 

func (m *GetColumnRequest) GetColId() uint64

func (*GetColumnRequest) GetColName 

func (m *GetColumnRequest) GetColName() string

func (*GetColumnRequest) GetDbId 

func (m *GetColumnRequest) GetDbId() int32

func (*GetColumnRequest) GetHeader 

func (m *GetColumnRequest) GetHeader() *RequestHeader

func (*GetColumnRequest) GetTableId 

func (m *GetColumnRequest) GetTableId() int32

func (*GetColumnRequest) Marshal 

func (m *GetColumnRequest) Marshal() (dAtA []byte, err error)

func (*GetColumnRequest) MarshalTo 

func (m *GetColumnRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetColumnRequest) MarshalToSizedBuffer 

func (m *GetColumnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetColumnRequest) ProtoMessage 

func (*GetColumnRequest) ProtoMessage()

func (*GetColumnRequest) Reset 

func (m *GetColumnRequest) Reset()

func (*GetColumnRequest) Size 

func (m *GetColumnRequest) Size() (n int)

func (*GetColumnRequest) String 

func (m *GetColumnRequest) String() string

func (*GetColumnRequest) Unmarshal 

func (m *GetColumnRequest) Unmarshal(dAtA []byte) error

func (*GetColumnRequest) XXX_DiscardUnknown 

func (m *GetColumnRequest) XXX_DiscardUnknown()

func (*GetColumnRequest) XXX_Marshal 

func (m *GetColumnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetColumnRequest) XXX_Merge 

func (m *GetColumnRequest) XXX_Merge(src proto.Message)

func (*GetColumnRequest) XXX_Size 

func (m *GetColumnRequest) XXX_Size() int

func (*GetColumnRequest) XXX_Unmarshal 

func (m *GetColumnRequest) XXX_Unmarshal(b []byte) error

type GetDBRequest 

type GetDBRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Name                 string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetDBRequest) Descriptor 

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

func (*GetDBRequest) GetHeader 

func (m *GetDBRequest) GetHeader() *RequestHeader

func (*GetDBRequest) GetName 

func (m *GetDBRequest) GetName() string

func (*GetDBRequest) Marshal 

func (m *GetDBRequest) Marshal() (dAtA []byte, err error)

func (*GetDBRequest) MarshalTo 

func (m *GetDBRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetDBRequest) MarshalToSizedBuffer 

func (m *GetDBRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetDBRequest) ProtoMessage 

func (*GetDBRequest) ProtoMessage()

func (*GetDBRequest) Reset 

func (m *GetDBRequest) Reset()

func (*GetDBRequest) Size 

func (m *GetDBRequest) Size() (n int)

func (*GetDBRequest) String 

func (m *GetDBRequest) String() string

func (*GetDBRequest) Unmarshal 

func (m *GetDBRequest) Unmarshal(dAtA []byte) error

func (*GetDBRequest) XXX_DiscardUnknown 

func (m *GetDBRequest) XXX_DiscardUnknown()

func (*GetDBRequest) XXX_Marshal 

func (m *GetDBRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDBRequest) XXX_Merge 

func (m *GetDBRequest) XXX_Merge(src proto.Message)

func (*GetDBRequest) XXX_Size 

func (m *GetDBRequest) XXX_Size() int

func (*GetDBRequest) XXX_Unmarshal 

func (m *GetDBRequest) XXX_Unmarshal(b []byte) error

type GetNodeInfo 

type GetNodeInfo struct {
	Err                  string                 `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"`
	Node                 *basepb.Node           `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	Info                 *dspb.NodeInfoResponse `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetNodeInfo) Descriptor 

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

func (*GetNodeInfo) GetErr 

func (m *GetNodeInfo) GetErr() string

func (*GetNodeInfo) GetInfo 

func (m *GetNodeInfo) GetInfo() *dspb.NodeInfoResponse

func (*GetNodeInfo) GetNode 

func (m *GetNodeInfo) GetNode() *basepb.Node

func (*GetNodeInfo) Marshal 

func (m *GetNodeInfo) Marshal() (dAtA []byte, err error)

func (*GetNodeInfo) MarshalTo 

func (m *GetNodeInfo) MarshalTo(dAtA []byte) (int, error)

func (*GetNodeInfo) MarshalToSizedBuffer 

func (m *GetNodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNodeInfo) ProtoMessage 

func (*GetNodeInfo) ProtoMessage()

func (*GetNodeInfo) Reset 

func (m *GetNodeInfo) Reset()

func (*GetNodeInfo) Size 

func (m *GetNodeInfo) Size() (n int)

func (*GetNodeInfo) String 

func (m *GetNodeInfo) String() string

func (*GetNodeInfo) Unmarshal 

func (m *GetNodeInfo) Unmarshal(dAtA []byte) error

func (*GetNodeInfo) XXX_DiscardUnknown 

func (m *GetNodeInfo) XXX_DiscardUnknown()

func (*GetNodeInfo) XXX_Marshal 

func (m *GetNodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeInfo) XXX_Merge 

func (m *GetNodeInfo) XXX_Merge(src proto.Message)

func (*GetNodeInfo) XXX_Size 

func (m *GetNodeInfo) XXX_Size() int

func (*GetNodeInfo) XXX_Unmarshal 

func (m *GetNodeInfo) XXX_Unmarshal(b []byte) error

type GetNodeInfoRequest 

type GetNodeInfoRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetNodeInfoRequest) Descriptor 

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

func (*GetNodeInfoRequest) GetHeader 

func (m *GetNodeInfoRequest) GetHeader() *RequestHeader

func (*GetNodeInfoRequest) Marshal 

func (m *GetNodeInfoRequest) Marshal() (dAtA []byte, err error)

func (*GetNodeInfoRequest) MarshalTo 

func (m *GetNodeInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetNodeInfoRequest) MarshalToSizedBuffer 

func (m *GetNodeInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNodeInfoRequest) ProtoMessage 

func (*GetNodeInfoRequest) ProtoMessage()

func (*GetNodeInfoRequest) Reset 

func (m *GetNodeInfoRequest) Reset()

func (*GetNodeInfoRequest) Size 

func (m *GetNodeInfoRequest) Size() (n int)

func (*GetNodeInfoRequest) String 

func (m *GetNodeInfoRequest) String() string

func (*GetNodeInfoRequest) Unmarshal 

func (m *GetNodeInfoRequest) Unmarshal(dAtA []byte) error

func (*GetNodeInfoRequest) XXX_DiscardUnknown 

func (m *GetNodeInfoRequest) XXX_DiscardUnknown()

func (*GetNodeInfoRequest) XXX_Marshal 

func (m *GetNodeInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeInfoRequest) XXX_Merge 

func (m *GetNodeInfoRequest) XXX_Merge(src proto.Message)

func (*GetNodeInfoRequest) XXX_Size 

func (m *GetNodeInfoRequest) XXX_Size() int

func (*GetNodeInfoRequest) XXX_Unmarshal 

func (m *GetNodeInfoRequest) XXX_Unmarshal(b []byte) error

type GetNodeInfoResponse 

type GetNodeInfoResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	NodeInfos            []*GetNodeInfo  `protobuf:"bytes,2,rep,name=nodeInfos,proto3" json:"nodeInfos,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetNodeInfoResponse) Descriptor 

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

func (*GetNodeInfoResponse) GetHeader 

func (m *GetNodeInfoResponse) GetHeader() *ResponseHeader

func (*GetNodeInfoResponse) GetNodeInfos 

func (m *GetNodeInfoResponse) GetNodeInfos() []*GetNodeInfo

func (*GetNodeInfoResponse) Marshal 

func (m *GetNodeInfoResponse) Marshal() (dAtA []byte, err error)

func (*GetNodeInfoResponse) MarshalTo 

func (m *GetNodeInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetNodeInfoResponse) MarshalToSizedBuffer 

func (m *GetNodeInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNodeInfoResponse) ProtoMessage 

func (*GetNodeInfoResponse) ProtoMessage()

func (*GetNodeInfoResponse) Reset 

func (m *GetNodeInfoResponse) Reset()

func (*GetNodeInfoResponse) Size 

func (m *GetNodeInfoResponse) Size() (n int)

func (*GetNodeInfoResponse) String 

func (m *GetNodeInfoResponse) String() string

func (*GetNodeInfoResponse) Unmarshal 

func (m *GetNodeInfoResponse) Unmarshal(dAtA []byte) error

func (*GetNodeInfoResponse) XXX_DiscardUnknown 

func (m *GetNodeInfoResponse) XXX_DiscardUnknown()

func (*GetNodeInfoResponse) XXX_Marshal 

func (m *GetNodeInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeInfoResponse) XXX_Merge 

func (m *GetNodeInfoResponse) XXX_Merge(src proto.Message)

func (*GetNodeInfoResponse) XXX_Size 

func (m *GetNodeInfoResponse) XXX_Size() int

func (*GetNodeInfoResponse) XXX_Unmarshal 

func (m *GetNodeInfoResponse) XXX_Unmarshal(b []byte) error

type GetNodeRequest 

type GetNodeRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Id                   uint64         `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetNodeRequest) Descriptor 

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

func (*GetNodeRequest) GetHeader 

func (m *GetNodeRequest) GetHeader() *RequestHeader

func (*GetNodeRequest) GetId 

func (m *GetNodeRequest) GetId() uint64

func (*GetNodeRequest) Marshal 

func (m *GetNodeRequest) Marshal() (dAtA []byte, err error)

func (*GetNodeRequest) MarshalTo 

func (m *GetNodeRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetNodeRequest) MarshalToSizedBuffer 

func (m *GetNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNodeRequest) ProtoMessage 

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) Reset 

func (m *GetNodeRequest) Reset()

func (*GetNodeRequest) Size 

func (m *GetNodeRequest) Size() (n int)

func (*GetNodeRequest) String 

func (m *GetNodeRequest) String() string

func (*GetNodeRequest) Unmarshal 

func (m *GetNodeRequest) Unmarshal(dAtA []byte) error

func (*GetNodeRequest) XXX_DiscardUnknown 

func (m *GetNodeRequest) XXX_DiscardUnknown()

func (*GetNodeRequest) XXX_Marshal 

func (m *GetNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeRequest) XXX_Merge 

func (m *GetNodeRequest) XXX_Merge(src proto.Message)

func (*GetNodeRequest) XXX_Size 

func (m *GetNodeRequest) XXX_Size() int

func (*GetNodeRequest) XXX_Unmarshal 

func (m *GetNodeRequest) XXX_Unmarshal(b []byte) error

type GetNodeResponse 

type GetNodeResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Node                 *basepb.Node    `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetNodeResponse) Descriptor 

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

func (*GetNodeResponse) GetHeader 

func (m *GetNodeResponse) GetHeader() *ResponseHeader

func (*GetNodeResponse) GetNode 

func (m *GetNodeResponse) GetNode() *basepb.Node

func (*GetNodeResponse) Marshal 

func (m *GetNodeResponse) Marshal() (dAtA []byte, err error)

func (*GetNodeResponse) MarshalTo 

func (m *GetNodeResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetNodeResponse) MarshalToSizedBuffer 

func (m *GetNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNodeResponse) ProtoMessage 

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) Reset 

func (m *GetNodeResponse) Reset()

func (*GetNodeResponse) Size 

func (m *GetNodeResponse) Size() (n int)

func (*GetNodeResponse) String 

func (m *GetNodeResponse) String() string

func (*GetNodeResponse) Unmarshal 

func (m *GetNodeResponse) Unmarshal(dAtA []byte) error

func (*GetNodeResponse) XXX_DiscardUnknown 

func (m *GetNodeResponse) XXX_DiscardUnknown()

func (*GetNodeResponse) XXX_Marshal 

func (m *GetNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodeResponse) XXX_Merge 

func (m *GetNodeResponse) XXX_Merge(src proto.Message)

func (*GetNodeResponse) XXX_Size 

func (m *GetNodeResponse) XXX_Size() int

func (*GetNodeResponse) XXX_Unmarshal 

func (m *GetNodeResponse) XXX_Unmarshal(b []byte) error

type GetNodesRequest 

type GetNodesRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetNodesRequest) Descriptor 

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

func (*GetNodesRequest) GetHeader 

func (m *GetNodesRequest) GetHeader() *RequestHeader

func (*GetNodesRequest) Marshal 

func (m *GetNodesRequest) Marshal() (dAtA []byte, err error)

func (*GetNodesRequest) MarshalTo 

func (m *GetNodesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetNodesRequest) MarshalToSizedBuffer 

func (m *GetNodesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNodesRequest) ProtoMessage 

func (*GetNodesRequest) ProtoMessage()

func (*GetNodesRequest) Reset 

func (m *GetNodesRequest) Reset()

func (*GetNodesRequest) Size 

func (m *GetNodesRequest) Size() (n int)

func (*GetNodesRequest) String 

func (m *GetNodesRequest) String() string

func (*GetNodesRequest) Unmarshal 

func (m *GetNodesRequest) Unmarshal(dAtA []byte) error

func (*GetNodesRequest) XXX_DiscardUnknown 

func (m *GetNodesRequest) XXX_DiscardUnknown()

func (*GetNodesRequest) XXX_Marshal 

func (m *GetNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodesRequest) XXX_Merge 

func (m *GetNodesRequest) XXX_Merge(src proto.Message)

func (*GetNodesRequest) XXX_Size 

func (m *GetNodesRequest) XXX_Size() int

func (*GetNodesRequest) XXX_Unmarshal 

func (m *GetNodesRequest) XXX_Unmarshal(b []byte) error

type GetNodesResponse 

type GetNodesResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Nodes                []*basepb.Node  `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetNodesResponse) Descriptor 

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

func (*GetNodesResponse) GetHeader 

func (m *GetNodesResponse) GetHeader() *ResponseHeader

func (*GetNodesResponse) GetNodes 

func (m *GetNodesResponse) GetNodes() []*basepb.Node

func (*GetNodesResponse) Marshal 

func (m *GetNodesResponse) Marshal() (dAtA []byte, err error)

func (*GetNodesResponse) MarshalTo 

func (m *GetNodesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetNodesResponse) MarshalToSizedBuffer 

func (m *GetNodesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetNodesResponse) ProtoMessage 

func (*GetNodesResponse) ProtoMessage()

func (*GetNodesResponse) Reset 

func (m *GetNodesResponse) Reset()

func (*GetNodesResponse) Size 

func (m *GetNodesResponse) Size() (n int)

func (*GetNodesResponse) String 

func (m *GetNodesResponse) String() string

func (*GetNodesResponse) Unmarshal 

func (m *GetNodesResponse) Unmarshal(dAtA []byte) error

func (*GetNodesResponse) XXX_DiscardUnknown 

func (m *GetNodesResponse) XXX_DiscardUnknown()

func (*GetNodesResponse) XXX_Marshal 

func (m *GetNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetNodesResponse) XXX_Merge 

func (m *GetNodesResponse) XXX_Merge(src proto.Message)

func (*GetNodesResponse) XXX_Size 

func (m *GetNodesResponse) XXX_Size() int

func (*GetNodesResponse) XXX_Unmarshal 

func (m *GetNodesResponse) XXX_Unmarshal(b []byte) error

type GetRouteRequest 

type GetRouteRequest struct {
	Header               *RequestHeader   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 int32            `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              int32            `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Key                  []byte           `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Max                  uint32           `protobuf:"varint,5,opt,name=max,proto3" json:"max,omitempty"`
	RangeType            basepb.RangeType `protobuf:"varint,6,opt,name=rangeType,proto3,enum=basepb.RangeType" json:"rangeType,omitempty"`
	HasAll               bool             `protobuf:"varint,7,opt,name=has_all,json=hasAll,proto3" json:"has_all,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetRouteRequest) Descriptor 

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

func (*GetRouteRequest) GetDbId 

func (m *GetRouteRequest) GetDbId() int32

func (*GetRouteRequest) GetHasAll 

func (m *GetRouteRequest) GetHasAll() bool

func (*GetRouteRequest) GetHeader 

func (m *GetRouteRequest) GetHeader() *RequestHeader

func (*GetRouteRequest) GetKey 

func (m *GetRouteRequest) GetKey() []byte

func (*GetRouteRequest) GetMax 

func (m *GetRouteRequest) GetMax() uint32

func (*GetRouteRequest) GetRangeType 

func (m *GetRouteRequest) GetRangeType() basepb.RangeType

func (*GetRouteRequest) GetTableId 

func (m *GetRouteRequest) GetTableId() int32

func (*GetRouteRequest) Marshal 

func (m *GetRouteRequest) Marshal() (dAtA []byte, err error)

func (*GetRouteRequest) MarshalTo 

func (m *GetRouteRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRouteRequest) MarshalToSizedBuffer 

func (m *GetRouteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRouteRequest) ProtoMessage 

func (*GetRouteRequest) ProtoMessage()

func (*GetRouteRequest) Reset 

func (m *GetRouteRequest) Reset()

func (*GetRouteRequest) Size 

func (m *GetRouteRequest) Size() (n int)

func (*GetRouteRequest) String 

func (m *GetRouteRequest) String() string

func (*GetRouteRequest) Unmarshal 

func (m *GetRouteRequest) Unmarshal(dAtA []byte) error

func (*GetRouteRequest) XXX_DiscardUnknown 

func (m *GetRouteRequest) XXX_DiscardUnknown()

func (*GetRouteRequest) XXX_Marshal 

func (m *GetRouteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRouteRequest) XXX_Merge 

func (m *GetRouteRequest) XXX_Merge(src proto.Message)

func (*GetRouteRequest) XXX_Size 

func (m *GetRouteRequest) XXX_Size() int

func (*GetRouteRequest) XXX_Unmarshal 

func (m *GetRouteRequest) XXX_Unmarshal(b []byte) error

type GetRouteResponse 

type GetRouteResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Routes               []*basepb.Range `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	Master               string          `protobuf:"bytes,3,opt,name=master,proto3" json:"master,omitempty"`
	Version              uint64          `protobuf:"varint,4,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetRouteResponse) Descriptor 

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

func (*GetRouteResponse) GetHeader 

func (m *GetRouteResponse) GetHeader() *ResponseHeader

func (*GetRouteResponse) GetMaster 

func (m *GetRouteResponse) GetMaster() string

func (*GetRouteResponse) GetRoutes 

func (m *GetRouteResponse) GetRoutes() []*basepb.Range

func (*GetRouteResponse) GetVersion 

func (m *GetRouteResponse) GetVersion() uint64

func (*GetRouteResponse) Marshal 

func (m *GetRouteResponse) Marshal() (dAtA []byte, err error)

func (*GetRouteResponse) MarshalTo 

func (m *GetRouteResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetRouteResponse) MarshalToSizedBuffer 

func (m *GetRouteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRouteResponse) ProtoMessage 

func (*GetRouteResponse) ProtoMessage()

func (*GetRouteResponse) Reset 

func (m *GetRouteResponse) Reset()

func (*GetRouteResponse) Size 

func (m *GetRouteResponse) Size() (n int)

func (*GetRouteResponse) String 

func (m *GetRouteResponse) String() string

func (*GetRouteResponse) Unmarshal 

func (m *GetRouteResponse) Unmarshal(dAtA []byte) error

func (*GetRouteResponse) XXX_DiscardUnknown 

func (m *GetRouteResponse) XXX_DiscardUnknown()

func (*GetRouteResponse) XXX_Marshal 

func (m *GetRouteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRouteResponse) XXX_Merge 

func (m *GetRouteResponse) XXX_Merge(src proto.Message)

func (*GetRouteResponse) XXX_Size 

func (m *GetRouteResponse) XXX_Size() int

func (*GetRouteResponse) XXX_Unmarshal 

func (m *GetRouteResponse) XXX_Unmarshal(b []byte) error

type GetTableRequest 

type GetTableRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 int32          `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	DbName               string         `protobuf:"bytes,3,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TableId              int32          `protobuf:"varint,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	TableName            string         `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetTableRequest) Descriptor 

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

func (*GetTableRequest) GetDbId 

func (m *GetTableRequest) GetDbId() int32

func (*GetTableRequest) GetDbName 

func (m *GetTableRequest) GetDbName() string

func (*GetTableRequest) GetHeader 

func (m *GetTableRequest) GetHeader() *RequestHeader

func (*GetTableRequest) GetTableId 

func (m *GetTableRequest) GetTableId() int32

func (*GetTableRequest) GetTableName 

func (m *GetTableRequest) GetTableName() string

func (*GetTableRequest) Marshal 

func (m *GetTableRequest) Marshal() (dAtA []byte, err error)

func (*GetTableRequest) MarshalTo 

func (m *GetTableRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetTableRequest) MarshalToSizedBuffer 

func (m *GetTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetTableRequest) ProtoMessage 

func (*GetTableRequest) ProtoMessage()

func (*GetTableRequest) Reset 

func (m *GetTableRequest) Reset()

func (*GetTableRequest) Size 

func (m *GetTableRequest) Size() (n int)

func (*GetTableRequest) String 

func (m *GetTableRequest) String() string

func (*GetTableRequest) Unmarshal 

func (m *GetTableRequest) Unmarshal(dAtA []byte) error

func (*GetTableRequest) XXX_DiscardUnknown 

func (m *GetTableRequest) XXX_DiscardUnknown()

func (*GetTableRequest) XXX_Marshal 

func (m *GetTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetTableRequest) XXX_Merge 

func (m *GetTableRequest) XXX_Merge(src proto.Message)

func (*GetTableRequest) XXX_Size 

func (m *GetTableRequest) XXX_Size() int

func (*GetTableRequest) XXX_Unmarshal 

func (m *GetTableRequest) XXX_Unmarshal(b []byte) error

type NodeHeartbeatRequest 

type NodeHeartbeatRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	NodeId               uint64         `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*NodeHeartbeatRequest) Descriptor 

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

func (*NodeHeartbeatRequest) GetHeader 

func (m *NodeHeartbeatRequest) GetHeader() *RequestHeader

func (*NodeHeartbeatRequest) GetNodeId 

func (m *NodeHeartbeatRequest) GetNodeId() uint64

func (*NodeHeartbeatRequest) Marshal 

func (m *NodeHeartbeatRequest) Marshal() (dAtA []byte, err error)

func (*NodeHeartbeatRequest) MarshalTo 

func (m *NodeHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)

func (*NodeHeartbeatRequest) MarshalToSizedBuffer 

func (m *NodeHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeHeartbeatRequest) ProtoMessage 

func (*NodeHeartbeatRequest) ProtoMessage()

func (*NodeHeartbeatRequest) Reset 

func (m *NodeHeartbeatRequest) Reset()

func (*NodeHeartbeatRequest) Size 

func (m *NodeHeartbeatRequest) Size() (n int)

func (*NodeHeartbeatRequest) String 

func (m *NodeHeartbeatRequest) String() string

func (*NodeHeartbeatRequest) Unmarshal 

func (m *NodeHeartbeatRequest) Unmarshal(dAtA []byte) error

func (*NodeHeartbeatRequest) XXX_DiscardUnknown 

func (m *NodeHeartbeatRequest) XXX_DiscardUnknown()

func (*NodeHeartbeatRequest) XXX_Marshal 

func (m *NodeHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeHeartbeatRequest) XXX_Merge 

func (m *NodeHeartbeatRequest) XXX_Merge(src proto.Message)

func (*NodeHeartbeatRequest) XXX_Size 

func (m *NodeHeartbeatRequest) XXX_Size() int

func (*NodeHeartbeatRequest) XXX_Unmarshal 

func (m *NodeHeartbeatRequest) XXX_Unmarshal(b []byte) error

type NodeHeartbeatResponse 

type NodeHeartbeatResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	NodeId               uint64          `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*NodeHeartbeatResponse) Descriptor 

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

func (*NodeHeartbeatResponse) GetHeader 

func (m *NodeHeartbeatResponse) GetHeader() *ResponseHeader

func (*NodeHeartbeatResponse) GetNodeId 

func (m *NodeHeartbeatResponse) GetNodeId() uint64

func (*NodeHeartbeatResponse) Marshal 

func (m *NodeHeartbeatResponse) Marshal() (dAtA []byte, err error)

func (*NodeHeartbeatResponse) MarshalTo 

func (m *NodeHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)

func (*NodeHeartbeatResponse) MarshalToSizedBuffer 

func (m *NodeHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NodeHeartbeatResponse) ProtoMessage 

func (*NodeHeartbeatResponse) ProtoMessage()

func (*NodeHeartbeatResponse) Reset 

func (m *NodeHeartbeatResponse) Reset()

func (*NodeHeartbeatResponse) Size 

func (m *NodeHeartbeatResponse) Size() (n int)

func (*NodeHeartbeatResponse) String 

func (m *NodeHeartbeatResponse) String() string

func (*NodeHeartbeatResponse) Unmarshal 

func (m *NodeHeartbeatResponse) Unmarshal(dAtA []byte) error

func (*NodeHeartbeatResponse) XXX_DiscardUnknown 

func (m *NodeHeartbeatResponse) XXX_DiscardUnknown()

func (*NodeHeartbeatResponse) XXX_Marshal 

func (m *NodeHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NodeHeartbeatResponse) XXX_Merge 

func (m *NodeHeartbeatResponse) XXX_Merge(src proto.Message)

func (*NodeHeartbeatResponse) XXX_Size 

func (m *NodeHeartbeatResponse) XXX_Size() int

func (*NodeHeartbeatResponse) XXX_Unmarshal 

func (m *NodeHeartbeatResponse) XXX_Unmarshal(b []byte) error

type PeerMoveRequest 

type PeerMoveRequest struct {
	Header               *RequestHeader   `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	TableId              int32            `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	RangeId              uint64           `protobuf:"varint,3,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	StoreType            basepb.StoreType `protobuf:"varint,4,opt,name=store_type,json=storeType,proto3,enum=basepb.StoreType" json:"store_type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PeerMoveRequest) Descriptor 

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

func (*PeerMoveRequest) GetHeader 

func (m *PeerMoveRequest) GetHeader() *RequestHeader

func (*PeerMoveRequest) GetRangeId 

func (m *PeerMoveRequest) GetRangeId() uint64

func (*PeerMoveRequest) GetStoreType 

func (m *PeerMoveRequest) GetStoreType() basepb.StoreType

func (*PeerMoveRequest) GetTableId 

func (m *PeerMoveRequest) GetTableId() int32

func (*PeerMoveRequest) Marshal 

func (m *PeerMoveRequest) Marshal() (dAtA []byte, err error)

func (*PeerMoveRequest) MarshalTo 

func (m *PeerMoveRequest) MarshalTo(dAtA []byte) (int, error)

func (*PeerMoveRequest) MarshalToSizedBuffer 

func (m *PeerMoveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeerMoveRequest) ProtoMessage 

func (*PeerMoveRequest) ProtoMessage()

func (*PeerMoveRequest) Reset 

func (m *PeerMoveRequest) Reset()

func (*PeerMoveRequest) Size 

func (m *PeerMoveRequest) Size() (n int)

func (*PeerMoveRequest) String 

func (m *PeerMoveRequest) String() string

func (*PeerMoveRequest) Unmarshal 

func (m *PeerMoveRequest) Unmarshal(dAtA []byte) error

func (*PeerMoveRequest) XXX_DiscardUnknown 

func (m *PeerMoveRequest) XXX_DiscardUnknown()

func (*PeerMoveRequest) XXX_Marshal 

func (m *PeerMoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerMoveRequest) XXX_Merge 

func (m *PeerMoveRequest) XXX_Merge(src proto.Message)

func (*PeerMoveRequest) XXX_Size 

func (m *PeerMoveRequest) XXX_Size() int

func (*PeerMoveRequest) XXX_Unmarshal 

func (m *PeerMoveRequest) XXX_Unmarshal(b []byte) error

type PeerMoveResponse 

type PeerMoveResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PeerMoveResponse) Descriptor 

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

func (*PeerMoveResponse) GetHeader 

func (m *PeerMoveResponse) GetHeader() *ResponseHeader

func (*PeerMoveResponse) Marshal 

func (m *PeerMoveResponse) Marshal() (dAtA []byte, err error)

func (*PeerMoveResponse) MarshalTo 

func (m *PeerMoveResponse) MarshalTo(dAtA []byte) (int, error)

func (*PeerMoveResponse) MarshalToSizedBuffer 

func (m *PeerMoveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PeerMoveResponse) ProtoMessage 

func (*PeerMoveResponse) ProtoMessage()

func (*PeerMoveResponse) Reset 

func (m *PeerMoveResponse) Reset()

func (*PeerMoveResponse) Size 

func (m *PeerMoveResponse) Size() (n int)

func (*PeerMoveResponse) String 

func (m *PeerMoveResponse) String() string

func (*PeerMoveResponse) Unmarshal 

func (m *PeerMoveResponse) Unmarshal(dAtA []byte) error

func (*PeerMoveResponse) XXX_DiscardUnknown 

func (m *PeerMoveResponse) XXX_DiscardUnknown()

func (*PeerMoveResponse) XXX_Marshal 

func (m *PeerMoveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PeerMoveResponse) XXX_Merge 

func (m *PeerMoveResponse) XXX_Merge(src proto.Message)

func (*PeerMoveResponse) XXX_Size 

func (m *PeerMoveResponse) XXX_Size() int

func (*PeerMoveResponse) XXX_Unmarshal 

func (m *PeerMoveResponse) XXX_Unmarshal(b []byte) error

type RangeFingerprint 

type RangeFingerprint struct {
	RangeId              uint64             `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	RangeEpoch           *basepb.RangeEpoch `protobuf:"bytes,2,opt,name=range_epoch,json=rangeEpoch,proto3" json:"range_epoch,omitempty"`
	DbId                 int32              `protobuf:"varint,3,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              int32              `protobuf:"varint,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	PeerId               uint64             `protobuf:"varint,5,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Fingerprint is used to verfiy if range is valid

func (*RangeFingerprint) Descriptor 

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

func (*RangeFingerprint) GetDbId 

func (m *RangeFingerprint) GetDbId() int32

func (*RangeFingerprint) GetPeerId 

func (m *RangeFingerprint) GetPeerId() uint64

func (*RangeFingerprint) GetRangeEpoch 

func (m *RangeFingerprint) GetRangeEpoch() *basepb.RangeEpoch

func (*RangeFingerprint) GetRangeId 

func (m *RangeFingerprint) GetRangeId() uint64

func (*RangeFingerprint) GetTableId 

func (m *RangeFingerprint) GetTableId() int32

func (*RangeFingerprint) Marshal 

func (m *RangeFingerprint) Marshal() (dAtA []byte, err error)

func (*RangeFingerprint) MarshalTo 

func (m *RangeFingerprint) MarshalTo(dAtA []byte) (int, error)

func (*RangeFingerprint) MarshalToSizedBuffer 

func (m *RangeFingerprint) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RangeFingerprint) ProtoMessage 

func (*RangeFingerprint) ProtoMessage()

func (*RangeFingerprint) Reset 

func (m *RangeFingerprint) Reset()

func (*RangeFingerprint) Size 

func (m *RangeFingerprint) Size() (n int)

func (*RangeFingerprint) String 

func (m *RangeFingerprint) String() string

func (*RangeFingerprint) Unmarshal 

func (m *RangeFingerprint) Unmarshal(dAtA []byte) error

func (*RangeFingerprint) XXX_DiscardUnknown 

func (m *RangeFingerprint) XXX_DiscardUnknown()

func (*RangeFingerprint) XXX_Marshal 

func (m *RangeFingerprint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RangeFingerprint) XXX_Merge 

func (m *RangeFingerprint) XXX_Merge(src proto.Message)

func (*RangeFingerprint) XXX_Size 

func (m *RangeFingerprint) XXX_Size() int

func (*RangeFingerprint) XXX_Unmarshal 

func (m *RangeFingerprint) XXX_Unmarshal(b []byte) error

type RangeHeartbeatRequest 

type RangeHeartbeatRequest struct {
	Header               *RequestHeader       `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Range                *basepb.Range        `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Term                 uint64               `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"`
	PeersStatus          []*basepb.PeerStatus `protobuf:"bytes,4,rep,name=peers_status,json=peersStatus,proto3" json:"peers_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*RangeHeartbeatRequest) Descriptor 

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

func (*RangeHeartbeatRequest) GetHeader 

func (m *RangeHeartbeatRequest) GetHeader() *RequestHeader

func (*RangeHeartbeatRequest) GetPeersStatus 

func (m *RangeHeartbeatRequest) GetPeersStatus() []*basepb.PeerStatus

func (*RangeHeartbeatRequest) GetRange 

func (m *RangeHeartbeatRequest) GetRange() *basepb.Range

func (*RangeHeartbeatRequest) GetTerm 

func (m *RangeHeartbeatRequest) GetTerm() uint64

func (*RangeHeartbeatRequest) Marshal 

func (m *RangeHeartbeatRequest) Marshal() (dAtA []byte, err error)

func (*RangeHeartbeatRequest) MarshalTo 

func (m *RangeHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)

func (*RangeHeartbeatRequest) MarshalToSizedBuffer 

func (m *RangeHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RangeHeartbeatRequest) ProtoMessage 

func (*RangeHeartbeatRequest) ProtoMessage()

func (*RangeHeartbeatRequest) Reset 

func (m *RangeHeartbeatRequest) Reset()

func (*RangeHeartbeatRequest) Size 

func (m *RangeHeartbeatRequest) Size() (n int)

func (*RangeHeartbeatRequest) String 

func (m *RangeHeartbeatRequest) String() string

func (*RangeHeartbeatRequest) Unmarshal 

func (m *RangeHeartbeatRequest) Unmarshal(dAtA []byte) error

func (*RangeHeartbeatRequest) XXX_DiscardUnknown 

func (m *RangeHeartbeatRequest) XXX_DiscardUnknown()

func (*RangeHeartbeatRequest) XXX_Marshal 

func (m *RangeHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RangeHeartbeatRequest) XXX_Merge 

func (m *RangeHeartbeatRequest) XXX_Merge(src proto.Message)

func (*RangeHeartbeatRequest) XXX_Size 

func (m *RangeHeartbeatRequest) XXX_Size() int

func (*RangeHeartbeatRequest) XXX_Unmarshal 

func (m *RangeHeartbeatRequest) XXX_Unmarshal(b []byte) error

type RangeHeartbeatResponse 

type RangeHeartbeatResponse struct {
	Header               *ResponseHeader    `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	RangeId              uint64             `protobuf:"varint,2,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"`
	Epoch                *basepb.RangeEpoch `protobuf:"bytes,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*RangeHeartbeatResponse) Descriptor 

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

func (*RangeHeartbeatResponse) GetEpoch 

func (m *RangeHeartbeatResponse) GetEpoch() *basepb.RangeEpoch

func (*RangeHeartbeatResponse) GetHeader 

func (m *RangeHeartbeatResponse) GetHeader() *ResponseHeader

func (*RangeHeartbeatResponse) GetRangeId 

func (m *RangeHeartbeatResponse) GetRangeId() uint64

func (*RangeHeartbeatResponse) Marshal 

func (m *RangeHeartbeatResponse) Marshal() (dAtA []byte, err error)

func (*RangeHeartbeatResponse) MarshalTo 

func (m *RangeHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)

func (*RangeHeartbeatResponse) MarshalToSizedBuffer 

func (m *RangeHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RangeHeartbeatResponse) ProtoMessage 

func (*RangeHeartbeatResponse) ProtoMessage()

func (*RangeHeartbeatResponse) Reset 

func (m *RangeHeartbeatResponse) Reset()

func (*RangeHeartbeatResponse) Size 

func (m *RangeHeartbeatResponse) Size() (n int)

func (*RangeHeartbeatResponse) String 

func (m *RangeHeartbeatResponse) String() string

func (*RangeHeartbeatResponse) Unmarshal 

func (m *RangeHeartbeatResponse) Unmarshal(dAtA []byte) error

func (*RangeHeartbeatResponse) XXX_DiscardUnknown 

func (m *RangeHeartbeatResponse) XXX_DiscardUnknown()

func (*RangeHeartbeatResponse) XXX_Marshal 

func (m *RangeHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RangeHeartbeatResponse) XXX_Merge 

func (m *RangeHeartbeatResponse) XXX_Merge(src proto.Message)

func (*RangeHeartbeatResponse) XXX_Size 

func (m *RangeHeartbeatResponse) XXX_Size() int

func (*RangeHeartbeatResponse) XXX_Unmarshal 

func (m *RangeHeartbeatResponse) XXX_Unmarshal(b []byte) error

type RegisterNodeRequest 

type RegisterNodeRequest struct {
	Header               *RequestHeader      `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ServerPort           uint32              `protobuf:"varint,2,opt,name=server_port,json=serverPort,proto3" json:"server_port,omitempty"`
	RaftPort             uint32              `protobuf:"varint,3,opt,name=raft_port,json=raftPort,proto3" json:"raft_port,omitempty"`
	AdminPort            uint32              `protobuf:"varint,4,opt,name=admin_port,json=adminPort,proto3" json:"admin_port,omitempty"`
	Version              string              `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	StEngine             StorageEngine       `protobuf:"varint,6,opt,name=st_engine,json=stEngine,proto3,enum=mspb.StorageEngine" json:"st_engine,omitempty"`
	Ranges               []*RangeFingerprint `protobuf:"bytes,7,rep,name=ranges,proto3" json:"ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RegisterNodeRequest) Descriptor 

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

func (*RegisterNodeRequest) GetAdminPort 

func (m *RegisterNodeRequest) GetAdminPort() uint32

func (*RegisterNodeRequest) GetHeader 

func (m *RegisterNodeRequest) GetHeader() *RequestHeader

func (*RegisterNodeRequest) GetRaftPort 

func (m *RegisterNodeRequest) GetRaftPort() uint32

func (*RegisterNodeRequest) GetRanges 

func (m *RegisterNodeRequest) GetRanges() []*RangeFingerprint

func (*RegisterNodeRequest) GetServerPort 

func (m *RegisterNodeRequest) GetServerPort() uint32

func (*RegisterNodeRequest) GetStEngine 

func (m *RegisterNodeRequest) GetStEngine() StorageEngine

func (*RegisterNodeRequest) GetVersion 

func (m *RegisterNodeRequest) GetVersion() string

func (*RegisterNodeRequest) Marshal 

func (m *RegisterNodeRequest) Marshal() (dAtA []byte, err error)

func (*RegisterNodeRequest) MarshalTo 

func (m *RegisterNodeRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterNodeRequest) MarshalToSizedBuffer 

func (m *RegisterNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterNodeRequest) ProtoMessage 

func (*RegisterNodeRequest) ProtoMessage()

func (*RegisterNodeRequest) Reset 

func (m *RegisterNodeRequest) Reset()

func (*RegisterNodeRequest) Size 

func (m *RegisterNodeRequest) Size() (n int)

func (*RegisterNodeRequest) String 

func (m *RegisterNodeRequest) String() string

func (*RegisterNodeRequest) Unmarshal 

func (m *RegisterNodeRequest) Unmarshal(dAtA []byte) error

func (*RegisterNodeRequest) XXX_DiscardUnknown 

func (m *RegisterNodeRequest) XXX_DiscardUnknown()

func (*RegisterNodeRequest) XXX_Marshal 

func (m *RegisterNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterNodeRequest) XXX_Merge 

func (m *RegisterNodeRequest) XXX_Merge(src proto.Message)

func (*RegisterNodeRequest) XXX_Size 

func (m *RegisterNodeRequest) XXX_Size() int

func (*RegisterNodeRequest) XXX_Unmarshal 

func (m *RegisterNodeRequest) XXX_Unmarshal(b []byte) error

type RegisterNodeResponse 

type RegisterNodeResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	NodeId               uint64          `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	InvalidRanges        []uint64        `protobuf:"varint,3,rep,packed,name=invalid_ranges,json=invalidRanges,proto3" json:"invalid_ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RegisterNodeResponse) Descriptor 

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

func (*RegisterNodeResponse) GetHeader 

func (m *RegisterNodeResponse) GetHeader() *ResponseHeader

func (*RegisterNodeResponse) GetInvalidRanges 

func (m *RegisterNodeResponse) GetInvalidRanges() []uint64

func (*RegisterNodeResponse) GetNodeId 

func (m *RegisterNodeResponse) GetNodeId() uint64

func (*RegisterNodeResponse) Marshal 

func (m *RegisterNodeResponse) Marshal() (dAtA []byte, err error)

func (*RegisterNodeResponse) MarshalTo 

func (m *RegisterNodeResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegisterNodeResponse) MarshalToSizedBuffer 

func (m *RegisterNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegisterNodeResponse) ProtoMessage 

func (*RegisterNodeResponse) ProtoMessage()

func (*RegisterNodeResponse) Reset 

func (m *RegisterNodeResponse) Reset()

func (*RegisterNodeResponse) Size 

func (m *RegisterNodeResponse) Size() (n int)

func (*RegisterNodeResponse) String 

func (m *RegisterNodeResponse) String() string

func (*RegisterNodeResponse) Unmarshal 

func (m *RegisterNodeResponse) Unmarshal(dAtA []byte) error

func (*RegisterNodeResponse) XXX_DiscardUnknown 

func (m *RegisterNodeResponse) XXX_DiscardUnknown()

func (*RegisterNodeResponse) XXX_Marshal 

func (m *RegisterNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterNodeResponse) XXX_Merge 

func (m *RegisterNodeResponse) XXX_Merge(src proto.Message)

func (*RegisterNodeResponse) XXX_Size 

func (m *RegisterNodeResponse) XXX_Size() int

func (*RegisterNodeResponse) XXX_Unmarshal 

func (m *RegisterNodeResponse) XXX_Unmarshal(b []byte) error

type RequestHeader 

type RequestHeader struct {
	ClusterId            uint64   `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestHeader) Descriptor 

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

func (*RequestHeader) GetClusterId 

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) Marshal 

func (m *RequestHeader) Marshal() (dAtA []byte, err error)

func (*RequestHeader) MarshalTo 

func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)

func (*RequestHeader) MarshalToSizedBuffer 

func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset 

func (m *RequestHeader) Reset()

func (*RequestHeader) Size 

func (m *RequestHeader) Size() (n int)

func (*RequestHeader) String 

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal 

func (m *RequestHeader) Unmarshal(dAtA []byte) error

func (*RequestHeader) XXX_DiscardUnknown 

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal 

func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestHeader) XXX_Merge 

func (m *RequestHeader) XXX_Merge(src proto.Message)

func (*RequestHeader) XXX_Size 

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal 

func (m *RequestHeader) XXX_Unmarshal(b []byte) error

type ResponseHeader 

type ResponseHeader struct {
	ClusterId            uint64   `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseHeader) Descriptor 

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

func (*ResponseHeader) GetClusterId 

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError 

func (m *ResponseHeader) GetError() *Error

func (*ResponseHeader) Marshal 

func (m *ResponseHeader) Marshal() (dAtA []byte, err error)

func (*ResponseHeader) MarshalTo 

func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)

func (*ResponseHeader) MarshalToSizedBuffer 

func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseHeader) ProtoMessage 

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset 

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size 

func (m *ResponseHeader) Size() (n int)

func (*ResponseHeader) String 

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal 

func (m *ResponseHeader) Unmarshal(dAtA []byte) error

func (*ResponseHeader) XXX_DiscardUnknown 

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal 

func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseHeader) XXX_Merge 

func (m *ResponseHeader) XXX_Merge(src proto.Message)

func (*ResponseHeader) XXX_Size 

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal 

func (m *ResponseHeader) XXX_Unmarshal(b []byte) error

type StorageEngine 

type StorageEngine int32
const (
	StorageEngine_STE_Invalid  StorageEngine = 0
	StorageEngine_STE_MassTree StorageEngine = 1
	StorageEngine_STE_RocksDB  StorageEngine = 2
)

func (StorageEngine) EnumDescriptor 

func (StorageEngine) EnumDescriptor() ([]byte, []int)

func (StorageEngine) String 

func (x StorageEngine) String() string

type WatcherEventRequest 

type WatcherEventRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Version              uint64         `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Master               string         `protobuf:"bytes,3,opt,name=master,proto3" json:"master,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WatcherEventRequest) Descriptor 

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

func (*WatcherEventRequest) GetHeader 

func (m *WatcherEventRequest) GetHeader() *RequestHeader

func (*WatcherEventRequest) GetMaster 

func (m *WatcherEventRequest) GetMaster() string

func (*WatcherEventRequest) GetVersion 

func (m *WatcherEventRequest) GetVersion() uint64

func (*WatcherEventRequest) Marshal 

func (m *WatcherEventRequest) Marshal() (dAtA []byte, err error)

func (*WatcherEventRequest) MarshalTo 

func (m *WatcherEventRequest) MarshalTo(dAtA []byte) (int, error)

func (*WatcherEventRequest) MarshalToSizedBuffer 

func (m *WatcherEventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatcherEventRequest) ProtoMessage 

func (*WatcherEventRequest) ProtoMessage()

func (*WatcherEventRequest) Reset 

func (m *WatcherEventRequest) Reset()

func (*WatcherEventRequest) Size 

func (m *WatcherEventRequest) Size() (n int)

func (*WatcherEventRequest) String 

func (m *WatcherEventRequest) String() string

func (*WatcherEventRequest) Unmarshal 

func (m *WatcherEventRequest) Unmarshal(dAtA []byte) error

func (*WatcherEventRequest) XXX_DiscardUnknown 

func (m *WatcherEventRequest) XXX_DiscardUnknown()

func (*WatcherEventRequest) XXX_Marshal 

func (m *WatcherEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatcherEventRequest) XXX_Merge 

func (m *WatcherEventRequest) XXX_Merge(src proto.Message)

func (*WatcherEventRequest) XXX_Size 

func (m *WatcherEventRequest) XXX_Size() int

func (*WatcherEventRequest) XXX_Unmarshal 

func (m *WatcherEventRequest) XXX_Unmarshal(b []byte) error

type WatcherEventResponse 

type WatcherEventResponse struct {
	Header               *ResponseHeader        `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Events               []*basepb.WatcherEvent `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*WatcherEventResponse) Descriptor 

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

func (*WatcherEventResponse) GetEvents 

func (m *WatcherEventResponse) GetEvents() []*basepb.WatcherEvent

func (*WatcherEventResponse) GetHeader 

func (m *WatcherEventResponse) GetHeader() *ResponseHeader

func (*WatcherEventResponse) Marshal 

func (m *WatcherEventResponse) Marshal() (dAtA []byte, err error)

func (*WatcherEventResponse) MarshalTo 

func (m *WatcherEventResponse) MarshalTo(dAtA []byte) (int, error)

func (*WatcherEventResponse) MarshalToSizedBuffer 

func (m *WatcherEventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*WatcherEventResponse) ProtoMessage 

func (*WatcherEventResponse) ProtoMessage()

func (*WatcherEventResponse) Reset 

func (m *WatcherEventResponse) Reset()

func (*WatcherEventResponse) Size 

func (m *WatcherEventResponse) Size() (n int)

func (*WatcherEventResponse) String 

func (m *WatcherEventResponse) String() string

func (*WatcherEventResponse) Unmarshal 

func (m *WatcherEventResponse) Unmarshal(dAtA []byte) error

func (*WatcherEventResponse) XXX_DiscardUnknown 

func (m *WatcherEventResponse) XXX_DiscardUnknown()

func (*WatcherEventResponse) XXX_Marshal 

func (m *WatcherEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatcherEventResponse) XXX_Merge 

func (m *WatcherEventResponse) XXX_Merge(src proto.Message)

func (*WatcherEventResponse) XXX_Size 

func (m *WatcherEventResponse) XXX_Size() int

func (*WatcherEventResponse) XXX_Unmarshal 

func (m *WatcherEventResponse) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.