mspb

package
v0.0.0-...-e215c4f Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2019 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              uint64           `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() uint64

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 CountTableRequest 

type CountTableRequest 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 (*CountTableRequest) Descriptor 

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

func (*CountTableRequest) GetHeader 

func (m *CountTableRequest) GetHeader() *RequestHeader

func (*CountTableRequest) Marshal 

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

func (*CountTableRequest) MarshalTo 

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

func (*CountTableRequest) MarshalToSizedBuffer 

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

func (*CountTableRequest) ProtoMessage 

func (*CountTableRequest) ProtoMessage()

func (*CountTableRequest) Reset 

func (m *CountTableRequest) Reset()

func (*CountTableRequest) Size 

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

func (*CountTableRequest) String 

func (m *CountTableRequest) String() string

func (*CountTableRequest) Unmarshal 

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

func (*CountTableRequest) XXX_DiscardUnknown 

func (m *CountTableRequest) XXX_DiscardUnknown()

func (*CountTableRequest) XXX_Marshal 

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

func (*CountTableRequest) XXX_Merge 

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

func (*CountTableRequest) XXX_Size 

func (m *CountTableRequest) XXX_Size() int

func (*CountTableRequest) XXX_Unmarshal 

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

type CountTableResponse 

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

func (*CountTableResponse) Descriptor 

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

func (*CountTableResponse) GetHeader 

func (m *CountTableResponse) GetHeader() *ResponseHeader

func (*CountTableResponse) GetList 

func (m *CountTableResponse) GetList() []*Counter

func (*CountTableResponse) Marshal 

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

func (*CountTableResponse) MarshalTo 

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

func (*CountTableResponse) MarshalToSizedBuffer 

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

func (*CountTableResponse) ProtoMessage 

func (*CountTableResponse) ProtoMessage()

func (*CountTableResponse) Reset 

func (m *CountTableResponse) Reset()

func (*CountTableResponse) Size 

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

func (*CountTableResponse) String 

func (m *CountTableResponse) String() string

func (*CountTableResponse) Unmarshal 

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

func (*CountTableResponse) XXX_DiscardUnknown 

func (m *CountTableResponse) XXX_DiscardUnknown()

func (*CountTableResponse) XXX_Marshal 

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

func (*CountTableResponse) XXX_Merge 

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

func (*CountTableResponse) XXX_Size 

func (m *CountTableResponse) XXX_Size() int

func (*CountTableResponse) XXX_Unmarshal 

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

type Counter 

type Counter struct {
	DbId                 uint64   `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64   `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"`
	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() uint64

func (*Counter) GetTableId 

func (m *Counter) GetTableId() uint64

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 CreateDatabaseRequest 

type CreateDatabaseRequest 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 (*CreateDatabaseRequest) Descriptor 

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

func (*CreateDatabaseRequest) GetHeader 

func (m *CreateDatabaseRequest) GetHeader() *RequestHeader

func (*CreateDatabaseRequest) GetName 

func (m *CreateDatabaseRequest) GetName() string

func (*CreateDatabaseRequest) Marshal 

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

func (*CreateDatabaseRequest) MarshalTo 

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

func (*CreateDatabaseRequest) MarshalToSizedBuffer 

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

func (*CreateDatabaseRequest) ProtoMessage 

func (*CreateDatabaseRequest) ProtoMessage()

func (*CreateDatabaseRequest) Reset 

func (m *CreateDatabaseRequest) Reset()

func (*CreateDatabaseRequest) Size 

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

func (*CreateDatabaseRequest) String 

func (m *CreateDatabaseRequest) String() string

func (*CreateDatabaseRequest) Unmarshal 

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

func (*CreateDatabaseRequest) XXX_DiscardUnknown 

func (m *CreateDatabaseRequest) XXX_DiscardUnknown()

func (*CreateDatabaseRequest) XXX_Marshal 

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

func (*CreateDatabaseRequest) XXX_Merge 

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

func (*CreateDatabaseRequest) XXX_Size 

func (m *CreateDatabaseRequest) XXX_Size() int

func (*CreateDatabaseRequest) XXX_Unmarshal 

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

type CreateDatabaseResponse 

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

func (*CreateDatabaseResponse) Descriptor 

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

func (*CreateDatabaseResponse) GetDatabase 

func (m *CreateDatabaseResponse) GetDatabase() *basepb.DataBase

func (*CreateDatabaseResponse) GetHeader 

func (m *CreateDatabaseResponse) GetHeader() *ResponseHeader

func (*CreateDatabaseResponse) Marshal 

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

func (*CreateDatabaseResponse) MarshalTo 

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

func (*CreateDatabaseResponse) MarshalToSizedBuffer 

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

func (*CreateDatabaseResponse) ProtoMessage 

func (*CreateDatabaseResponse) ProtoMessage()

func (*CreateDatabaseResponse) Reset 

func (m *CreateDatabaseResponse) Reset()

func (*CreateDatabaseResponse) Size 

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

func (*CreateDatabaseResponse) String 

func (m *CreateDatabaseResponse) String() string

func (*CreateDatabaseResponse) Unmarshal 

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

func (*CreateDatabaseResponse) XXX_DiscardUnknown 

func (m *CreateDatabaseResponse) XXX_DiscardUnknown()

func (*CreateDatabaseResponse) XXX_Marshal 

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

func (*CreateDatabaseResponse) XXX_Merge 

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

func (*CreateDatabaseResponse) XXX_Size 

func (m *CreateDatabaseResponse) XXX_Size() int

func (*CreateDatabaseResponse) XXX_Unmarshal 

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

type CreateTableRequest 

type CreateTableRequest struct {
	Header     *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbName     string         `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	TableName  string         `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Properties string         `protobuf:"bytes,4,opt,name=properties,proto3" json:"properties,omitempty"`
	RangeKeys  []string       `protobuf:"bytes,5,rep,name=range_keys,json=rangeKeys,proto3" json:"range_keys,omitempty"`
	//warm hot or mix default hot
	StoreType string `protobuf:"bytes,6,opt,name=store_type,json=storeType,proto3" json:"store_type,omitempty"`
	//replica num default is 3
	ReplicaNum uint64 `protobuf:"varint,7,opt,name=replica_num,json=replicaNum,proto3" json:"replica_num,omitempty"`
	// how many date range live default 2
	DataRangeNum         uint64   `protobuf:"varint,8,opt,name=data_range_num,json=dataRangeNum,proto3" json:"data_range_num,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateTableRequest) Descriptor 

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

func (*CreateTableRequest) GetDataRangeNum 

func (m *CreateTableRequest) GetDataRangeNum() uint64

func (*CreateTableRequest) GetDbName 

func (m *CreateTableRequest) GetDbName() string

func (*CreateTableRequest) GetHeader 

func (m *CreateTableRequest) GetHeader() *RequestHeader

func (*CreateTableRequest) GetProperties 

func (m *CreateTableRequest) GetProperties() string

func (*CreateTableRequest) GetRangeKeys 

func (m *CreateTableRequest) GetRangeKeys() []string

func (*CreateTableRequest) GetReplicaNum 

func (m *CreateTableRequest) GetReplicaNum() uint64

func (*CreateTableRequest) GetStoreType 

func (m *CreateTableRequest) GetStoreType() string

func (*CreateTableRequest) GetTableName 

func (m *CreateTableRequest) GetTableName() string

func (*CreateTableRequest) Marshal 

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

func (*CreateTableRequest) MarshalTo 

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

func (*CreateTableRequest) MarshalToSizedBuffer 

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

func (*CreateTableRequest) ProtoMessage 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) Reset 

func (m *CreateTableRequest) Reset()

func (*CreateTableRequest) Size 

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

func (*CreateTableRequest) String 

func (m *CreateTableRequest) String() string

func (*CreateTableRequest) Unmarshal 

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

func (*CreateTableRequest) XXX_DiscardUnknown 

func (m *CreateTableRequest) XXX_DiscardUnknown()

func (*CreateTableRequest) XXX_Marshal 

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

func (*CreateTableRequest) XXX_Merge 

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

func (*CreateTableRequest) XXX_Size 

func (m *CreateTableRequest) XXX_Size() int

func (*CreateTableRequest) XXX_Unmarshal 

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

type CreateTableResponse 

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

func (*CreateTableResponse) Descriptor 

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

func (*CreateTableResponse) GetHeader 

func (m *CreateTableResponse) GetHeader() *ResponseHeader

func (*CreateTableResponse) GetTable 

func (m *CreateTableResponse) GetTable() *basepb.Table

func (*CreateTableResponse) Marshal 

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

func (*CreateTableResponse) MarshalTo 

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

func (*CreateTableResponse) MarshalToSizedBuffer 

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

func (*CreateTableResponse) ProtoMessage 

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) Reset 

func (m *CreateTableResponse) Reset()

func (*CreateTableResponse) Size 

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

func (*CreateTableResponse) String 

func (m *CreateTableResponse) String() string

func (*CreateTableResponse) Unmarshal 

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

func (*CreateTableResponse) XXX_DiscardUnknown 

func (m *CreateTableResponse) XXX_DiscardUnknown()

func (*CreateTableResponse) XXX_Marshal 

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

func (*CreateTableResponse) XXX_Merge 

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

func (*CreateTableResponse) XXX_Size 

func (m *CreateTableResponse) XXX_Size() int

func (*CreateTableResponse) XXX_Unmarshal 

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

type DelDatabaseRequest 

type DelDatabaseRequest 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"`
	Name                 string         `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DelDatabaseRequest) Descriptor 

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

func (*DelDatabaseRequest) GetHeader 

func (m *DelDatabaseRequest) GetHeader() *RequestHeader

func (*DelDatabaseRequest) GetId 

func (m *DelDatabaseRequest) GetId() uint64

func (*DelDatabaseRequest) GetName 

func (m *DelDatabaseRequest) GetName() string

func (*DelDatabaseRequest) Marshal 

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

func (*DelDatabaseRequest) MarshalTo 

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

func (*DelDatabaseRequest) MarshalToSizedBuffer 

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

func (*DelDatabaseRequest) ProtoMessage 

func (*DelDatabaseRequest) ProtoMessage()

func (*DelDatabaseRequest) Reset 

func (m *DelDatabaseRequest) Reset()

func (*DelDatabaseRequest) Size 

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

func (*DelDatabaseRequest) String 

func (m *DelDatabaseRequest) String() string

func (*DelDatabaseRequest) Unmarshal 

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

func (*DelDatabaseRequest) XXX_DiscardUnknown 

func (m *DelDatabaseRequest) XXX_DiscardUnknown()

func (*DelDatabaseRequest) XXX_Marshal 

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

func (*DelDatabaseRequest) XXX_Merge 

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

func (*DelDatabaseRequest) XXX_Size 

func (m *DelDatabaseRequest) XXX_Size() int

func (*DelDatabaseRequest) XXX_Unmarshal 

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

type DelDatabaseResponse 

type DelDatabaseResponse 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 (*DelDatabaseResponse) Descriptor 

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

func (*DelDatabaseResponse) GetHeader 

func (m *DelDatabaseResponse) GetHeader() *ResponseHeader

func (*DelDatabaseResponse) Marshal 

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

func (*DelDatabaseResponse) MarshalTo 

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

func (*DelDatabaseResponse) MarshalToSizedBuffer 

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

func (*DelDatabaseResponse) ProtoMessage 

func (*DelDatabaseResponse) ProtoMessage()

func (*DelDatabaseResponse) Reset 

func (m *DelDatabaseResponse) Reset()

func (*DelDatabaseResponse) Size 

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

func (*DelDatabaseResponse) String 

func (m *DelDatabaseResponse) String() string

func (*DelDatabaseResponse) Unmarshal 

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

func (*DelDatabaseResponse) XXX_DiscardUnknown 

func (m *DelDatabaseResponse) XXX_DiscardUnknown()

func (*DelDatabaseResponse) XXX_Marshal 

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

func (*DelDatabaseResponse) XXX_Merge 

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

func (*DelDatabaseResponse) XXX_Size 

func (m *DelDatabaseResponse) XXX_Size() int

func (*DelDatabaseResponse) XXX_Unmarshal 

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

type DelTableRequest 

type DelTableRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 uint64         `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              uint64         `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 (*DelTableRequest) Descriptor 

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

func (*DelTableRequest) GetDbId 

func (m *DelTableRequest) GetDbId() uint64

func (*DelTableRequest) GetDbName 

func (m *DelTableRequest) GetDbName() string

func (*DelTableRequest) GetHeader 

func (m *DelTableRequest) GetHeader() *RequestHeader

func (*DelTableRequest) GetTableId 

func (m *DelTableRequest) GetTableId() uint64

func (*DelTableRequest) GetTableName 

func (m *DelTableRequest) GetTableName() string

func (*DelTableRequest) Marshal 

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

func (*DelTableRequest) MarshalTo 

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

func (*DelTableRequest) MarshalToSizedBuffer 

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

func (*DelTableRequest) ProtoMessage 

func (*DelTableRequest) ProtoMessage()

func (*DelTableRequest) Reset 

func (m *DelTableRequest) Reset()

func (*DelTableRequest) Size 

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

func (*DelTableRequest) String 

func (m *DelTableRequest) String() string

func (*DelTableRequest) Unmarshal 

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

func (*DelTableRequest) XXX_DiscardUnknown 

func (m *DelTableRequest) XXX_DiscardUnknown()

func (*DelTableRequest) XXX_Marshal 

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

func (*DelTableRequest) XXX_Merge 

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

func (*DelTableRequest) XXX_Size 

func (m *DelTableRequest) XXX_Size() int

func (*DelTableRequest) XXX_Unmarshal 

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

type DelTableResponse 

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

func (*DelTableResponse) Descriptor 

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

func (*DelTableResponse) GetHeader 

func (m *DelTableResponse) GetHeader() *ResponseHeader

func (*DelTableResponse) GetTable 

func (m *DelTableResponse) GetTable() *basepb.Table

func (*DelTableResponse) Marshal 

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

func (*DelTableResponse) MarshalTo 

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

func (*DelTableResponse) MarshalToSizedBuffer 

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

func (*DelTableResponse) ProtoMessage 

func (*DelTableResponse) ProtoMessage()

func (*DelTableResponse) Reset 

func (m *DelTableResponse) Reset()

func (*DelTableResponse) Size 

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

func (*DelTableResponse) String 

func (m *DelTableResponse) String() string

func (*DelTableResponse) Unmarshal 

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

func (*DelTableResponse) XXX_DiscardUnknown 

func (m *DelTableResponse) XXX_DiscardUnknown()

func (*DelTableResponse) XXX_Marshal 

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

func (*DelTableResponse) XXX_Merge 

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

func (*DelTableResponse) XXX_Size 

func (m *DelTableResponse) XXX_Size() int

func (*DelTableResponse) XXX_Unmarshal 

func (m *DelTableResponse) 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 GetAutoIncIdRequest 

type GetAutoIncIdRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Size_                uint32         `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetAutoIncIdRequest) Descriptor 

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

func (*GetAutoIncIdRequest) GetDbId 

func (m *GetAutoIncIdRequest) GetDbId() uint64

func (*GetAutoIncIdRequest) GetHeader 

func (m *GetAutoIncIdRequest) GetHeader() *RequestHeader

func (*GetAutoIncIdRequest) GetSize_ 

func (m *GetAutoIncIdRequest) GetSize_() uint32

func (*GetAutoIncIdRequest) GetTableId 

func (m *GetAutoIncIdRequest) GetTableId() uint64

func (*GetAutoIncIdRequest) Marshal 

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

func (*GetAutoIncIdRequest) MarshalTo 

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

func (*GetAutoIncIdRequest) MarshalToSizedBuffer 

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

func (*GetAutoIncIdRequest) ProtoMessage 

func (*GetAutoIncIdRequest) ProtoMessage()

func (*GetAutoIncIdRequest) Reset 

func (m *GetAutoIncIdRequest) Reset()

func (*GetAutoIncIdRequest) Size 

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

func (*GetAutoIncIdRequest) String 

func (m *GetAutoIncIdRequest) String() string

func (*GetAutoIncIdRequest) Unmarshal 

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

func (*GetAutoIncIdRequest) XXX_DiscardUnknown 

func (m *GetAutoIncIdRequest) XXX_DiscardUnknown()

func (*GetAutoIncIdRequest) XXX_Marshal 

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

func (*GetAutoIncIdRequest) XXX_Merge 

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

func (*GetAutoIncIdRequest) XXX_Size 

func (m *GetAutoIncIdRequest) XXX_Size() int

func (*GetAutoIncIdRequest) XXX_Unmarshal 

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

type GetAutoIncIdResponse 

type GetAutoIncIdResponse struct {
	Header               *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	IdPairs              []*IdPair       `protobuf:"bytes,2,rep,name=id_pairs,json=idPairs,proto3" json:"id_pairs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetAutoIncIdResponse) Descriptor 

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

func (*GetAutoIncIdResponse) GetHeader 

func (m *GetAutoIncIdResponse) GetHeader() *ResponseHeader

func (*GetAutoIncIdResponse) GetIdPairs 

func (m *GetAutoIncIdResponse) GetIdPairs() []*IdPair

func (*GetAutoIncIdResponse) Marshal 

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

func (*GetAutoIncIdResponse) MarshalTo 

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

func (*GetAutoIncIdResponse) MarshalToSizedBuffer 

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

func (*GetAutoIncIdResponse) ProtoMessage 

func (*GetAutoIncIdResponse) ProtoMessage()

func (*GetAutoIncIdResponse) Reset 

func (m *GetAutoIncIdResponse) Reset()

func (*GetAutoIncIdResponse) Size 

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

func (*GetAutoIncIdResponse) String 

func (m *GetAutoIncIdResponse) String() string

func (*GetAutoIncIdResponse) Unmarshal 

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

func (*GetAutoIncIdResponse) XXX_DiscardUnknown 

func (m *GetAutoIncIdResponse) XXX_DiscardUnknown()

func (*GetAutoIncIdResponse) XXX_Marshal 

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

func (*GetAutoIncIdResponse) XXX_Merge 

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

func (*GetAutoIncIdResponse) XXX_Size 

func (m *GetAutoIncIdResponse) XXX_Size() int

func (*GetAutoIncIdResponse) XXX_Unmarshal 

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

type GetColumnRequest 

type GetColumnRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64         `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() uint64

func (*GetColumnRequest) GetHeader 

func (m *GetColumnRequest) GetHeader() *RequestHeader

func (*GetColumnRequest) GetTableId 

func (m *GetColumnRequest) GetTableId() uint64

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 GetColumnResponse 

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

func (*GetColumnResponse) Descriptor 

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

func (*GetColumnResponse) GetColumn 

func (m *GetColumnResponse) GetColumn() *basepb.Column

func (*GetColumnResponse) GetHeader 

func (m *GetColumnResponse) GetHeader() *ResponseHeader

func (*GetColumnResponse) Marshal 

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

func (*GetColumnResponse) MarshalTo 

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

func (*GetColumnResponse) MarshalToSizedBuffer 

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

func (*GetColumnResponse) ProtoMessage 

func (*GetColumnResponse) ProtoMessage()

func (*GetColumnResponse) Reset 

func (m *GetColumnResponse) Reset()

func (*GetColumnResponse) Size 

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

func (*GetColumnResponse) String 

func (m *GetColumnResponse) String() string

func (*GetColumnResponse) Unmarshal 

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

func (*GetColumnResponse) XXX_DiscardUnknown 

func (m *GetColumnResponse) XXX_DiscardUnknown()

func (*GetColumnResponse) XXX_Marshal 

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

func (*GetColumnResponse) XXX_Merge 

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

func (*GetColumnResponse) XXX_Size 

func (m *GetColumnResponse) XXX_Size() int

func (*GetColumnResponse) XXX_Unmarshal 

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

type GetColumnsRequest 

type GetColumnsRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 uint64         `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64         `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetColumnsRequest) Descriptor 

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

func (*GetColumnsRequest) GetDbId 

func (m *GetColumnsRequest) GetDbId() uint64

func (*GetColumnsRequest) GetHeader 

func (m *GetColumnsRequest) GetHeader() *RequestHeader

func (*GetColumnsRequest) GetTableId 

func (m *GetColumnsRequest) GetTableId() uint64

func (*GetColumnsRequest) Marshal 

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

func (*GetColumnsRequest) MarshalTo 

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

func (*GetColumnsRequest) MarshalToSizedBuffer 

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

func (*GetColumnsRequest) ProtoMessage 

func (*GetColumnsRequest) ProtoMessage()

func (*GetColumnsRequest) Reset 

func (m *GetColumnsRequest) Reset()

func (*GetColumnsRequest) Size 

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

func (*GetColumnsRequest) String 

func (m *GetColumnsRequest) String() string

func (*GetColumnsRequest) Unmarshal 

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

func (*GetColumnsRequest) XXX_DiscardUnknown 

func (m *GetColumnsRequest) XXX_DiscardUnknown()

func (*GetColumnsRequest) XXX_Marshal 

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

func (*GetColumnsRequest) XXX_Merge 

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

func (*GetColumnsRequest) XXX_Size 

func (m *GetColumnsRequest) XXX_Size() int

func (*GetColumnsRequest) XXX_Unmarshal 

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

type GetColumnsResponse 

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

func (*GetColumnsResponse) Descriptor 

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

func (*GetColumnsResponse) GetColumns 

func (m *GetColumnsResponse) GetColumns() []*basepb.Column

func (*GetColumnsResponse) GetHeader 

func (m *GetColumnsResponse) GetHeader() *ResponseHeader

func (*GetColumnsResponse) Marshal 

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

func (*GetColumnsResponse) MarshalTo 

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

func (*GetColumnsResponse) MarshalToSizedBuffer 

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

func (*GetColumnsResponse) ProtoMessage 

func (*GetColumnsResponse) ProtoMessage()

func (*GetColumnsResponse) Reset 

func (m *GetColumnsResponse) Reset()

func (*GetColumnsResponse) Size 

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

func (*GetColumnsResponse) String 

func (m *GetColumnsResponse) String() string

func (*GetColumnsResponse) Unmarshal 

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

func (*GetColumnsResponse) XXX_DiscardUnknown 

func (m *GetColumnsResponse) XXX_DiscardUnknown()

func (*GetColumnsResponse) XXX_Marshal 

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

func (*GetColumnsResponse) XXX_Merge 

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

func (*GetColumnsResponse) XXX_Size 

func (m *GetColumnsResponse) XXX_Size() int

func (*GetColumnsResponse) XXX_Unmarshal 

func (m *GetColumnsResponse) 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 GetDBResponse 

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

func (*GetDBResponse) Descriptor 

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

func (*GetDBResponse) GetDb 

func (m *GetDBResponse) GetDb() *basepb.DataBase

func (*GetDBResponse) GetHeader 

func (m *GetDBResponse) GetHeader() *ResponseHeader

func (*GetDBResponse) Marshal 

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

func (*GetDBResponse) MarshalTo 

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

func (*GetDBResponse) MarshalToSizedBuffer 

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

func (*GetDBResponse) ProtoMessage 

func (*GetDBResponse) ProtoMessage()

func (*GetDBResponse) Reset 

func (m *GetDBResponse) Reset()

func (*GetDBResponse) Size 

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

func (*GetDBResponse) String 

func (m *GetDBResponse) String() string

func (*GetDBResponse) Unmarshal 

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

func (*GetDBResponse) XXX_DiscardUnknown 

func (m *GetDBResponse) XXX_DiscardUnknown()

func (*GetDBResponse) XXX_Marshal 

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

func (*GetDBResponse) XXX_Merge 

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

func (*GetDBResponse) XXX_Size 

func (m *GetDBResponse) XXX_Size() int

func (*GetDBResponse) XXX_Unmarshal 

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

type GetDBsResponse 

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

func (*GetDBsResponse) Descriptor 

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

func (*GetDBsResponse) GetDbs 

func (m *GetDBsResponse) GetDbs() []*basepb.DataBase

func (*GetDBsResponse) GetHeader 

func (m *GetDBsResponse) GetHeader() *ResponseHeader

func (*GetDBsResponse) Marshal 

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

func (*GetDBsResponse) MarshalTo 

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

func (*GetDBsResponse) MarshalToSizedBuffer 

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

func (*GetDBsResponse) ProtoMessage 

func (*GetDBsResponse) ProtoMessage()

func (*GetDBsResponse) Reset 

func (m *GetDBsResponse) Reset()

func (*GetDBsResponse) Size 

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

func (*GetDBsResponse) String 

func (m *GetDBsResponse) String() string

func (*GetDBsResponse) Unmarshal 

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

func (*GetDBsResponse) XXX_DiscardUnknown 

func (m *GetDBsResponse) XXX_DiscardUnknown()

func (*GetDBsResponse) XXX_Marshal 

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

func (*GetDBsResponse) XXX_Merge 

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

func (*GetDBsResponse) XXX_Size 

func (m *GetDBsResponse) XXX_Size() int

func (*GetDBsResponse) XXX_Unmarshal 

func (m *GetDBsResponse) 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                 uint64           `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64           `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() uint64

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() uint64

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                 uint64         `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              uint64         `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() uint64

func (*GetTableRequest) GetDbName 

func (m *GetTableRequest) GetDbName() string

func (*GetTableRequest) GetHeader 

func (m *GetTableRequest) GetHeader() *RequestHeader

func (*GetTableRequest) GetTableId 

func (m *GetTableRequest) GetTableId() uint64

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 GetTableResponse 

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

func (*GetTableResponse) Descriptor 

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

func (*GetTableResponse) GetHeader 

func (m *GetTableResponse) GetHeader() *ResponseHeader

func (*GetTableResponse) GetTable 

func (m *GetTableResponse) GetTable() *basepb.Table

func (*GetTableResponse) Marshal 

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

func (*GetTableResponse) MarshalTo 

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

func (*GetTableResponse) MarshalToSizedBuffer 

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

func (*GetTableResponse) ProtoMessage 

func (*GetTableResponse) ProtoMessage()

func (*GetTableResponse) Reset 

func (m *GetTableResponse) Reset()

func (*GetTableResponse) Size 

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

func (*GetTableResponse) String 

func (m *GetTableResponse) String() string

func (*GetTableResponse) Unmarshal 

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

func (*GetTableResponse) XXX_DiscardUnknown 

func (m *GetTableResponse) XXX_DiscardUnknown()

func (*GetTableResponse) XXX_Marshal 

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

func (*GetTableResponse) XXX_Merge 

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

func (*GetTableResponse) XXX_Size 

func (m *GetTableResponse) XXX_Size() int

func (*GetTableResponse) XXX_Unmarshal 

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

type GetTablesRequest 

type GetTablesRequest struct {
	Header               *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	DbId                 uint64         `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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetTablesRequest) Descriptor 

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

func (*GetTablesRequest) GetDbId 

func (m *GetTablesRequest) GetDbId() uint64

func (*GetTablesRequest) GetDbName 

func (m *GetTablesRequest) GetDbName() string

func (*GetTablesRequest) GetHeader 

func (m *GetTablesRequest) GetHeader() *RequestHeader

func (*GetTablesRequest) Marshal 

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

func (*GetTablesRequest) MarshalTo 

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

func (*GetTablesRequest) MarshalToSizedBuffer 

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

func (*GetTablesRequest) ProtoMessage 

func (*GetTablesRequest) ProtoMessage()

func (*GetTablesRequest) Reset 

func (m *GetTablesRequest) Reset()

func (*GetTablesRequest) Size 

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

func (*GetTablesRequest) String 

func (m *GetTablesRequest) String() string

func (*GetTablesRequest) Unmarshal 

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

func (*GetTablesRequest) XXX_DiscardUnknown 

func (m *GetTablesRequest) XXX_DiscardUnknown()

func (*GetTablesRequest) XXX_Marshal 

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

func (*GetTablesRequest) XXX_Merge 

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

func (*GetTablesRequest) XXX_Size 

func (m *GetTablesRequest) XXX_Size() int

func (*GetTablesRequest) XXX_Unmarshal 

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

type GetTablesResponse 

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

func (*GetTablesResponse) Descriptor 

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

func (*GetTablesResponse) GetHeader 

func (m *GetTablesResponse) GetHeader() *ResponseHeader

func (*GetTablesResponse) GetTables 

func (m *GetTablesResponse) GetTables() []*basepb.Table

func (*GetTablesResponse) Marshal 

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

func (*GetTablesResponse) MarshalTo 

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

func (*GetTablesResponse) MarshalToSizedBuffer 

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

func (*GetTablesResponse) ProtoMessage 

func (*GetTablesResponse) ProtoMessage()

func (*GetTablesResponse) Reset 

func (m *GetTablesResponse) Reset()

func (*GetTablesResponse) Size 

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

func (*GetTablesResponse) String 

func (m *GetTablesResponse) String() string

func (*GetTablesResponse) Unmarshal 

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

func (*GetTablesResponse) XXX_DiscardUnknown 

func (m *GetTablesResponse) XXX_DiscardUnknown()

func (*GetTablesResponse) XXX_Marshal 

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

func (*GetTablesResponse) XXX_Merge 

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

func (*GetTablesResponse) XXX_Size 

func (m *GetTablesResponse) XXX_Size() int

func (*GetTablesResponse) XXX_Unmarshal 

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

type IdPair 

type IdPair struct {
	IdStart              []byte   `protobuf:"bytes,1,opt,name=id_start,json=idStart,proto3" json:"id_start,omitempty"`
	IdEnd                []byte   `protobuf:"bytes,2,opt,name=id_end,json=idEnd,proto3" json:"id_end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IdPair) Descriptor 

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

func (*IdPair) GetIdEnd 

func (m *IdPair) GetIdEnd() []byte

func (*IdPair) GetIdStart 

func (m *IdPair) GetIdStart() []byte

func (*IdPair) Marshal 

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

func (*IdPair) MarshalTo 

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

func (*IdPair) MarshalToSizedBuffer 

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

func (*IdPair) ProtoMessage 

func (*IdPair) ProtoMessage()

func (*IdPair) Reset 

func (m *IdPair) Reset()

func (*IdPair) Size 

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

func (*IdPair) String 

func (m *IdPair) String() string

func (*IdPair) Unmarshal 

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

func (*IdPair) XXX_DiscardUnknown 

func (m *IdPair) XXX_DiscardUnknown()

func (*IdPair) XXX_Marshal 

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

func (*IdPair) XXX_Merge 

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

func (*IdPair) XXX_Size 

func (m *IdPair) XXX_Size() int

func (*IdPair) XXX_Unmarshal 

func (m *IdPair) 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              uint64           `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() uint64

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                 uint64             `protobuf:"varint,3,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"`
	TableId              uint64             `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() uint64

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() uint64

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.