mspb

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

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

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

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type AskSplitRequest

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

func (*AskSplitRequest) Descriptor

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

func (*AskSplitRequest) GetForce

func (m *AskSplitRequest) GetForce() bool

func (*AskSplitRequest) GetHeader

func (m *AskSplitRequest) GetHeader() *RequestHeader

func (*AskSplitRequest) GetRange

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

func (*AskSplitRequest) GetSplitKey

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

func (*AskSplitRequest) Marshal

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

func (*AskSplitRequest) MarshalTo

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

func (*AskSplitRequest) MarshalToSizedBuffer

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

func (*AskSplitRequest) ProtoMessage

func (*AskSplitRequest) ProtoMessage()

func (*AskSplitRequest) Reset

func (m *AskSplitRequest) Reset()

func (*AskSplitRequest) Size

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

func (*AskSplitRequest) String

func (m *AskSplitRequest) String() string

func (*AskSplitRequest) Unmarshal

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

func (*AskSplitRequest) XXX_DiscardUnknown

func (m *AskSplitRequest) XXX_DiscardUnknown()

func (*AskSplitRequest) XXX_Marshal

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

func (*AskSplitRequest) XXX_Merge

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

func (*AskSplitRequest) XXX_Size

func (m *AskSplitRequest) XXX_Size() int

func (*AskSplitRequest) XXX_Unmarshal

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

type AskSplitResponse

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

func (*AskSplitResponse) Descriptor

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

func (*AskSplitResponse) GetHeader

func (m *AskSplitResponse) GetHeader() *ResponseHeader

func (*AskSplitResponse) GetNewPeerIds

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

func (*AskSplitResponse) GetNewRangeId

func (m *AskSplitResponse) GetNewRangeId() uint64

func (*AskSplitResponse) GetRange

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

func (*AskSplitResponse) GetSplitKey

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

func (*AskSplitResponse) Marshal

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

func (*AskSplitResponse) MarshalTo

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

func (*AskSplitResponse) MarshalToSizedBuffer

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

func (*AskSplitResponse) ProtoMessage

func (*AskSplitResponse) ProtoMessage()

func (*AskSplitResponse) Reset

func (m *AskSplitResponse) Reset()

func (*AskSplitResponse) Size

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

func (*AskSplitResponse) String

func (m *AskSplitResponse) String() string

func (*AskSplitResponse) Unmarshal

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

func (*AskSplitResponse) XXX_DiscardUnknown

func (m *AskSplitResponse) XXX_DiscardUnknown()

func (*AskSplitResponse) XXX_Marshal

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

func (*AskSplitResponse) XXX_Merge

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

func (*AskSplitResponse) XXX_Size

func (m *AskSplitResponse) XXX_Size() int

func (*AskSplitResponse) XXX_Unmarshal

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

type ChangeNodeStateRequest

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

func (*ChangeNodeStateRequest) Descriptor

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

func (*ChangeNodeStateRequest) GetHeader

func (m *ChangeNodeStateRequest) GetHeader() *RequestHeader

func (*ChangeNodeStateRequest) GetId

func (m *ChangeNodeStateRequest) GetId() uint64

func (*ChangeNodeStateRequest) GetState

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

func (*ChangeNodeStateRequest) Marshal

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

func (*ChangeNodeStateRequest) MarshalTo

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

func (*ChangeNodeStateRequest) MarshalToSizedBuffer

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

func (*ChangeNodeStateRequest) ProtoMessage

func (*ChangeNodeStateRequest) ProtoMessage()

func (*ChangeNodeStateRequest) Reset

func (m *ChangeNodeStateRequest) Reset()

func (*ChangeNodeStateRequest) Size

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

func (*ChangeNodeStateRequest) String

func (m *ChangeNodeStateRequest) String() string

func (*ChangeNodeStateRequest) Unmarshal

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

func (*ChangeNodeStateRequest) XXX_DiscardUnknown

func (m *ChangeNodeStateRequest) XXX_DiscardUnknown()

func (*ChangeNodeStateRequest) XXX_Marshal

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

func (*ChangeNodeStateRequest) XXX_Merge

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

func (*ChangeNodeStateRequest) XXX_Size

func (m *ChangeNodeStateRequest) XXX_Size() int

func (*ChangeNodeStateRequest) XXX_Unmarshal

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

type ChangeNodeStateResponse

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

func (*ChangeNodeStateResponse) Descriptor

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

func (*ChangeNodeStateResponse) GetHeader

func (m *ChangeNodeStateResponse) GetHeader() *ResponseHeader

func (*ChangeNodeStateResponse) GetNode

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

func (*ChangeNodeStateResponse) Marshal

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

func (*ChangeNodeStateResponse) MarshalTo

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

func (*ChangeNodeStateResponse) MarshalToSizedBuffer

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

func (*ChangeNodeStateResponse) ProtoMessage

func (*ChangeNodeStateResponse) ProtoMessage()

func (*ChangeNodeStateResponse) Reset

func (m *ChangeNodeStateResponse) Reset()

func (*ChangeNodeStateResponse) Size

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

func (*ChangeNodeStateResponse) String

func (m *ChangeNodeStateResponse) String() string

func (*ChangeNodeStateResponse) Unmarshal

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

func (*ChangeNodeStateResponse) XXX_DiscardUnknown

func (m *ChangeNodeStateResponse) XXX_DiscardUnknown()

func (*ChangeNodeStateResponse) XXX_Marshal

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

func (*ChangeNodeStateResponse) XXX_Merge

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

func (*ChangeNodeStateResponse) XXX_Size

func (m *ChangeNodeStateResponse) XXX_Size() int

func (*ChangeNodeStateResponse) XXX_Unmarshal

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

type ChangeRangeStoreTypeRequest

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

func (*ChangeRangeStoreTypeRequest) Descriptor

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

func (*ChangeRangeStoreTypeRequest) GetHeader

func (*ChangeRangeStoreTypeRequest) GetRangeId

func (m *ChangeRangeStoreTypeRequest) GetRangeId() uint64

func (*ChangeRangeStoreTypeRequest) GetStoreType

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

func (*ChangeRangeStoreTypeRequest) GetTableId

func (m *ChangeRangeStoreTypeRequest) GetTableId() int32

func (*ChangeRangeStoreTypeRequest) Marshal

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

func (*ChangeRangeStoreTypeRequest) MarshalTo

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

func (*ChangeRangeStoreTypeRequest) MarshalToSizedBuffer

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

func (*ChangeRangeStoreTypeRequest) ProtoMessage

func (*ChangeRangeStoreTypeRequest) ProtoMessage()

func (*ChangeRangeStoreTypeRequest) Reset

func (m *ChangeRangeStoreTypeRequest) Reset()

func (*ChangeRangeStoreTypeRequest) Size

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

func (*ChangeRangeStoreTypeRequest) String

func (m *ChangeRangeStoreTypeRequest) String() string

func (*ChangeRangeStoreTypeRequest) Unmarshal

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

func (*ChangeRangeStoreTypeRequest) XXX_DiscardUnknown

func (m *ChangeRangeStoreTypeRequest) XXX_DiscardUnknown()

func (*ChangeRangeStoreTypeRequest) XXX_Marshal

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

func (*ChangeRangeStoreTypeRequest) XXX_Merge

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

func (*ChangeRangeStoreTypeRequest) XXX_Size

func (m *ChangeRangeStoreTypeRequest) XXX_Size() int

func (*ChangeRangeStoreTypeRequest) XXX_Unmarshal

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

type ChangeRangeStoreTypeResponse

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

func (*ChangeRangeStoreTypeResponse) Descriptor

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

func (*ChangeRangeStoreTypeResponse) GetHeader

func (*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 (*ChangeRangeStoreTypeResponse) Unmarshal

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

func (*ChangeRangeStoreTypeResponse) XXX_DiscardUnknown

func (m *ChangeRangeStoreTypeResponse) XXX_DiscardUnknown()

func (*ChangeRangeStoreTypeResponse) XXX_Marshal

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

func (*ChangeRangeStoreTypeResponse) XXX_Merge

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

func (*ChangeRangeStoreTypeResponse) XXX_Size

func (m *ChangeRangeStoreTypeResponse) XXX_Size() int

func (*ChangeRangeStoreTypeResponse) XXX_Unmarshal

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

type CheckNodeStateRequest

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

func (*CheckNodeStateRequest) Descriptor

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

func (*CheckNodeStateRequest) GetHeader

func (m *CheckNodeStateRequest) GetHeader() *RequestHeader

func (*CheckNodeStateRequest) GetId

func (m *CheckNodeStateRequest) GetId() uint64

func (*CheckNodeStateRequest) Marshal

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

func (*CheckNodeStateRequest) MarshalTo

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

func (*CheckNodeStateRequest) MarshalToSizedBuffer

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

func (*CheckNodeStateRequest) ProtoMessage

func (*CheckNodeStateRequest) ProtoMessage()

func (*CheckNodeStateRequest) Reset

func (m *CheckNodeStateRequest) Reset()

func (*CheckNodeStateRequest) Size

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

func (*CheckNodeStateRequest) String

func (m *CheckNodeStateRequest) String() string

func (*CheckNodeStateRequest) Unmarshal

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

func (*CheckNodeStateRequest) XXX_DiscardUnknown

func (m *CheckNodeStateRequest) XXX_DiscardUnknown()

func (*CheckNodeStateRequest) XXX_Marshal

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

func (*CheckNodeStateRequest) XXX_Merge

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

func (*CheckNodeStateRequest) XXX_Size

func (m *CheckNodeStateRequest) XXX_Size() int

func (*CheckNodeStateRequest) XXX_Unmarshal

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

type CheckNodeStateResponse

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

func (*CheckNodeStateResponse) Descriptor

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

func (*CheckNodeStateResponse) GetHeader

func (m *CheckNodeStateResponse) GetHeader() *ResponseHeader

func (*CheckNodeStateResponse) GetLeaderNum

func (m *CheckNodeStateResponse) GetLeaderNum() uint64

func (*CheckNodeStateResponse) GetRangeNum

func (m *CheckNodeStateResponse) GetRangeNum() uint64

func (*CheckNodeStateResponse) GetState

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

func (*CheckNodeStateResponse) Marshal

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

func (*CheckNodeStateResponse) MarshalTo

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

func (*CheckNodeStateResponse) MarshalToSizedBuffer

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

func (*CheckNodeStateResponse) ProtoMessage

func (*CheckNodeStateResponse) ProtoMessage()

func (*CheckNodeStateResponse) Reset

func (m *CheckNodeStateResponse) Reset()

func (*CheckNodeStateResponse) Size

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

func (*CheckNodeStateResponse) String

func (m *CheckNodeStateResponse) String() string

func (*CheckNodeStateResponse) Unmarshal

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

func (*CheckNodeStateResponse) XXX_DiscardUnknown

func (m *CheckNodeStateResponse) XXX_DiscardUnknown()

func (*CheckNodeStateResponse) XXX_Marshal

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

func (*CheckNodeStateResponse) XXX_Merge

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

func (*CheckNodeStateResponse) XXX_Size

func (m *CheckNodeStateResponse) XXX_Size() int

func (*CheckNodeStateResponse) XXX_Unmarshal

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

type ClusterInfoRequest

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

func (*ClusterInfoRequest) Descriptor

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

func (*ClusterInfoRequest) GetHeader

func (m *ClusterInfoRequest) GetHeader() *RequestHeader

func (*ClusterInfoRequest) Marshal

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

func (*ClusterInfoRequest) MarshalTo

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

func (*ClusterInfoRequest) MarshalToSizedBuffer

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

func (*ClusterInfoRequest) ProtoMessage

func (*ClusterInfoRequest) ProtoMessage()

func (*ClusterInfoRequest) Reset

func (m *ClusterInfoRequest) Reset()

func (*ClusterInfoRequest) Size

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

func (*ClusterInfoRequest) String

func (m *ClusterInfoRequest) String() string

func (*ClusterInfoRequest) Unmarshal

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

func (*ClusterInfoRequest) XXX_DiscardUnknown

func (m *ClusterInfoRequest) XXX_DiscardUnknown()

func (*ClusterInfoRequest) XXX_Marshal

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

func (*ClusterInfoRequest) XXX_Merge

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

func (*ClusterInfoRequest) XXX_Size

func (m *ClusterInfoRequest) XXX_Size() int

func (*ClusterInfoRequest) XXX_Unmarshal

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

type ClusterInfoResponse

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

func (*ClusterInfoResponse) Descriptor

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

func (*ClusterInfoResponse) GetBuildTime

func (m *ClusterInfoResponse) GetBuildTime() string

func (*ClusterInfoResponse) GetBuildVersion

func (m *ClusterInfoResponse) GetBuildVersion() string

func (*ClusterInfoResponse) GetCommitId

func (m *ClusterInfoResponse) GetCommitId() string

func (*ClusterInfoResponse) GetHeader

func (m *ClusterInfoResponse) GetHeader() *ResponseHeader

func (*ClusterInfoResponse) Marshal

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

func (*ClusterInfoResponse) MarshalTo

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

func (*ClusterInfoResponse) MarshalToSizedBuffer

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

func (*ClusterInfoResponse) ProtoMessage

func (*ClusterInfoResponse) ProtoMessage()

func (*ClusterInfoResponse) Reset

func (m *ClusterInfoResponse) Reset()

func (*ClusterInfoResponse) Size

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

func (*ClusterInfoResponse) String

func (m *ClusterInfoResponse) String() string

func (*ClusterInfoResponse) Unmarshal

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

func (*ClusterInfoResponse) XXX_DiscardUnknown

func (m *ClusterInfoResponse) XXX_DiscardUnknown()

func (*ClusterInfoResponse) XXX_Marshal

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

func (*ClusterInfoResponse) XXX_Merge

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

func (*ClusterInfoResponse) XXX_Size

func (m *ClusterInfoResponse) XXX_Size() int

func (*ClusterInfoResponse) XXX_Unmarshal

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

type Counter

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

func (*Counter) Descriptor

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

func (*Counter) GetCount

func (m *Counter) GetCount() uint64

func (*Counter) GetDbId

func (m *Counter) GetDbId() int32

func (*Counter) GetDbName

func (m *Counter) GetDbName() string

func (*Counter) GetTableId

func (m *Counter) GetTableId() int32

func (*Counter) GetTableName

func (m *Counter) GetTableName() string

func (*Counter) Marshal

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

func (*Counter) MarshalTo

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

func (*Counter) MarshalToSizedBuffer

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

func (*Counter) ProtoMessage

func (*Counter) ProtoMessage()

func (*Counter) Reset

func (m *Counter) Reset()

func (*Counter) Size

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

func (*Counter) String

func (m *Counter) String() string

func (*Counter) Unmarshal

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

func (*Counter) XXX_DiscardUnknown

func (m *Counter) XXX_DiscardUnknown()

func (*Counter) XXX_Marshal

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

func (*Counter) XXX_Merge

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

func (*Counter) XXX_Size

func (m *Counter) XXX_Size() int

func (*Counter) XXX_Unmarshal

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

type CreateRangesRequest

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

func (*CreateRangesRequest) Descriptor

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

func (*CreateRangesRequest) GetDbId

func (m *CreateRangesRequest) GetDbId() int32

func (*CreateRangesRequest) GetHeader

func (m *CreateRangesRequest) GetHeader() *RequestHeader

func (*CreateRangesRequest) GetRanges

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

func (*CreateRangesRequest) GetReplicas

func (m *CreateRangesRequest) GetReplicas() int32

func (*CreateRangesRequest) GetTableId

func (m *CreateRangesRequest) GetTableId() int32

func (*CreateRangesRequest) Marshal

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

func (*CreateRangesRequest) MarshalTo

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

func (*CreateRangesRequest) MarshalToSizedBuffer

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

func (*CreateRangesRequest) ProtoMessage

func (*CreateRangesRequest) ProtoMessage()

func (*CreateRangesRequest) Reset

func (m *CreateRangesRequest) Reset()

func (*CreateRangesRequest) Size

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

func (*CreateRangesRequest) String

func (m *CreateRangesRequest) String() string

func (*CreateRangesRequest) Unmarshal

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

func (*CreateRangesRequest) XXX_DiscardUnknown

func (m *CreateRangesRequest) XXX_DiscardUnknown()

func (*CreateRangesRequest) XXX_Marshal

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

func (*CreateRangesRequest) XXX_Merge

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

func (*CreateRangesRequest) XXX_Size

func (m *CreateRangesRequest) XXX_Size() int

func (*CreateRangesRequest) XXX_Unmarshal

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

type DeleteRangesRequest

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

func (*DeleteRangesRequest) Descriptor

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

func (*DeleteRangesRequest) GetDbId

func (m *DeleteRangesRequest) GetDbId() int32

func (*DeleteRangesRequest) GetHeader

func (m *DeleteRangesRequest) GetHeader() *RequestHeader

func (*DeleteRangesRequest) GetIndexId

func (m *DeleteRangesRequest) GetIndexId() int32

func (*DeleteRangesRequest) GetRangeType

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

func (*DeleteRangesRequest) GetTableId

func (m *DeleteRangesRequest) GetTableId() int32

func (*DeleteRangesRequest) Marshal

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

func (*DeleteRangesRequest) MarshalTo

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

func (*DeleteRangesRequest) MarshalToSizedBuffer

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

func (*DeleteRangesRequest) ProtoMessage

func (*DeleteRangesRequest) ProtoMessage()

func (*DeleteRangesRequest) Reset

func (m *DeleteRangesRequest) Reset()

func (*DeleteRangesRequest) Size

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

func (*DeleteRangesRequest) String

func (m *DeleteRangesRequest) String() string

func (*DeleteRangesRequest) Unmarshal

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

func (*DeleteRangesRequest) XXX_DiscardUnknown

func (m *DeleteRangesRequest) XXX_DiscardUnknown()

func (*DeleteRangesRequest) XXX_Marshal

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

func (*DeleteRangesRequest) XXX_Merge

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

func (*DeleteRangesRequest) XXX_Size

func (m *DeleteRangesRequest) XXX_Size() int

func (*DeleteRangesRequest) XXX_Unmarshal

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

type Error

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

func (*Error) Descriptor

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

func (*Error) GetCode

func (m *Error) GetCode() uint32

func (*Error) GetMessage

func (m *Error) GetMessage() string

func (*Error) Marshal

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

func (*Error) MarshalTo

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

func (*Error) MarshalToSizedBuffer

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

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

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

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

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

func (*Error) XXX_DiscardUnknown

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal

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

func (*Error) XXX_Merge

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

func (*Error) XXX_Size

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal

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

type ErrorType

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

func (ErrorType) EnumDescriptor

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

func (ErrorType) String

func (x ErrorType) String() string

type GeneralResponse

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

func (*GeneralResponse) Descriptor

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

func (*GeneralResponse) GetHeader

func (m *GeneralResponse) GetHeader() *ResponseHeader

func (*GeneralResponse) Marshal

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

func (*GeneralResponse) MarshalTo

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

func (*GeneralResponse) MarshalToSizedBuffer

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

func (*GeneralResponse) ProtoMessage

func (*GeneralResponse) ProtoMessage()

func (*GeneralResponse) Reset

func (m *GeneralResponse) Reset()

func (*GeneralResponse) Size

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

func (*GeneralResponse) String

func (m *GeneralResponse) String() string

func (*GeneralResponse) Unmarshal

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

func (*GeneralResponse) XXX_DiscardUnknown

func (m *GeneralResponse) XXX_DiscardUnknown()

func (*GeneralResponse) XXX_Marshal

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

func (*GeneralResponse) XXX_Merge

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

func (*GeneralResponse) XXX_Size

func (m *GeneralResponse) XXX_Size() int

func (*GeneralResponse) XXX_Unmarshal

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

type GetColumnRequest

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

func (*GetColumnRequest) Descriptor

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

func (*GetColumnRequest) GetColId

func (m *GetColumnRequest) GetColId() uint64

func (*GetColumnRequest) GetColName

func (m *GetColumnRequest) GetColName() string

func (*GetColumnRequest) GetDbId

func (m *GetColumnRequest) GetDbId() int32

func (*GetColumnRequest) GetHeader

func (m *GetColumnRequest) GetHeader() *RequestHeader

func (*GetColumnRequest) GetTableId

func (m *GetColumnRequest) GetTableId() int32

func (*GetColumnRequest) Marshal

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

func (*GetColumnRequest) MarshalTo

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

func (*GetColumnRequest) MarshalToSizedBuffer

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

func (*GetColumnRequest) ProtoMessage

func (*GetColumnRequest) ProtoMessage()

func (*GetColumnRequest) Reset

func (m *GetColumnRequest) Reset()

func (*GetColumnRequest) Size

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

func (*GetColumnRequest) String

func (m *GetColumnRequest) String() string

func (*GetColumnRequest) Unmarshal

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

func (*GetColumnRequest) XXX_DiscardUnknown

func (m *GetColumnRequest) XXX_DiscardUnknown()

func (*GetColumnRequest) XXX_Marshal

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

func (*GetColumnRequest) XXX_Merge

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

func (*GetColumnRequest) XXX_Size

func (m *GetColumnRequest) XXX_Size() int

func (*GetColumnRequest) XXX_Unmarshal

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

type GetDBRequest

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

func (*GetDBRequest) Descriptor

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

func (*GetDBRequest) GetHeader

func (m *GetDBRequest) GetHeader() *RequestHeader

func (*GetDBRequest) GetName

func (m *GetDBRequest) GetName() string

func (*GetDBRequest) Marshal

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

func (*GetDBRequest) MarshalTo

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

func (*GetDBRequest) MarshalToSizedBuffer

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

func (*GetDBRequest) ProtoMessage

func (*GetDBRequest) ProtoMessage()

func (*GetDBRequest) Reset

func (m *GetDBRequest) Reset()

func (*GetDBRequest) Size

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

func (*GetDBRequest) String

func (m *GetDBRequest) String() string

func (*GetDBRequest) Unmarshal

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

func (*GetDBRequest) XXX_DiscardUnknown

func (m *GetDBRequest) XXX_DiscardUnknown()

func (*GetDBRequest) XXX_Marshal

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

func (*GetDBRequest) XXX_Merge

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

func (*GetDBRequest) XXX_Size

func (m *GetDBRequest) XXX_Size() int

func (*GetDBRequest) XXX_Unmarshal

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

type GetNodeInfo

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

func (*GetNodeInfo) Descriptor

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

func (*GetNodeInfo) GetErr

func (m *GetNodeInfo) GetErr() string

func (*GetNodeInfo) GetInfo

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

func (*GetNodeInfo) GetNode

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

func (*GetNodeInfo) Marshal

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

func (*GetNodeInfo) MarshalTo

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

func (*GetNodeInfo) MarshalToSizedBuffer

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

func (*GetNodeInfo) ProtoMessage

func (*GetNodeInfo) ProtoMessage()

func (*GetNodeInfo) Reset

func (m *GetNodeInfo) Reset()

func (*GetNodeInfo) Size

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

func (*GetNodeInfo) String

func (m *GetNodeInfo) String() string

func (*GetNodeInfo) Unmarshal

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

func (*GetNodeInfo) XXX_DiscardUnknown

func (m *GetNodeInfo) XXX_DiscardUnknown()

func (*GetNodeInfo) XXX_Marshal

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

func (*GetNodeInfo) XXX_Merge

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

func (*GetNodeInfo) XXX_Size

func (m *GetNodeInfo) XXX_Size() int

func (*GetNodeInfo) XXX_Unmarshal

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

type GetNodeInfoRequest

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

func (*GetNodeInfoRequest) Descriptor

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

func (*GetNodeInfoRequest) GetHeader

func (m *GetNodeInfoRequest) GetHeader() *RequestHeader

func (*GetNodeInfoRequest) Marshal

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

func (*GetNodeInfoRequest) MarshalTo

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

func (*GetNodeInfoRequest) MarshalToSizedBuffer

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

func (*GetNodeInfoRequest) ProtoMessage

func (*GetNodeInfoRequest) ProtoMessage()

func (*GetNodeInfoRequest) Reset

func (m *GetNodeInfoRequest) Reset()

func (*GetNodeInfoRequest) Size

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

func (*GetNodeInfoRequest) String

func (m *GetNodeInfoRequest) String() string

func (*GetNodeInfoRequest) Unmarshal

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

func (*GetNodeInfoRequest) XXX_DiscardUnknown

func (m *GetNodeInfoRequest) XXX_DiscardUnknown()

func (*GetNodeInfoRequest) XXX_Marshal

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

func (*GetNodeInfoRequest) XXX_Merge

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

func (*GetNodeInfoRequest) XXX_Size

func (m *GetNodeInfoRequest) XXX_Size() int

func (*GetNodeInfoRequest) XXX_Unmarshal

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

type GetNodeInfoResponse

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

func (*GetNodeInfoResponse) Descriptor

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

func (*GetNodeInfoResponse) GetHeader

func (m *GetNodeInfoResponse) GetHeader() *ResponseHeader

func (*GetNodeInfoResponse) GetNodeInfos

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

func (*GetNodeInfoResponse) Marshal

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

func (*GetNodeInfoResponse) MarshalTo

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

func (*GetNodeInfoResponse) MarshalToSizedBuffer

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

func (*GetNodeInfoResponse) ProtoMessage

func (*GetNodeInfoResponse) ProtoMessage()

func (*GetNodeInfoResponse) Reset

func (m *GetNodeInfoResponse) Reset()

func (*GetNodeInfoResponse) Size

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

func (*GetNodeInfoResponse) String

func (m *GetNodeInfoResponse) String() string

func (*GetNodeInfoResponse) Unmarshal

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

func (*GetNodeInfoResponse) XXX_DiscardUnknown

func (m *GetNodeInfoResponse) XXX_DiscardUnknown()

func (*GetNodeInfoResponse) XXX_Marshal

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

func (*GetNodeInfoResponse) XXX_Merge

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

func (*GetNodeInfoResponse) XXX_Size

func (m *GetNodeInfoResponse) XXX_Size() int

func (*GetNodeInfoResponse) XXX_Unmarshal

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

type GetNodeRequest

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

func (*GetNodeRequest) Descriptor

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

func (*GetNodeRequest) GetHeader

func (m *GetNodeRequest) GetHeader() *RequestHeader

func (*GetNodeRequest) GetId

func (m *GetNodeRequest) GetId() uint64

func (*GetNodeRequest) Marshal

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

func (*GetNodeRequest) MarshalTo

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

func (*GetNodeRequest) MarshalToSizedBuffer

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

func (*GetNodeRequest) ProtoMessage

func (*GetNodeRequest) ProtoMessage()

func (*GetNodeRequest) Reset

func (m *GetNodeRequest) Reset()

func (*GetNodeRequest) Size

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

func (*GetNodeRequest) String

func (m *GetNodeRequest) String() string

func (*GetNodeRequest) Unmarshal

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

func (*GetNodeRequest) XXX_DiscardUnknown

func (m *GetNodeRequest) XXX_DiscardUnknown()

func (*GetNodeRequest) XXX_Marshal

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

func (*GetNodeRequest) XXX_Merge

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

func (*GetNodeRequest) XXX_Size

func (m *GetNodeRequest) XXX_Size() int

func (*GetNodeRequest) XXX_Unmarshal

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

type GetNodeResponse

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

func (*GetNodeResponse) Descriptor

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

func (*GetNodeResponse) GetHeader

func (m *GetNodeResponse) GetHeader() *ResponseHeader

func (*GetNodeResponse) GetNode

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

func (*GetNodeResponse) Marshal

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

func (*GetNodeResponse) MarshalTo

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

func (*GetNodeResponse) MarshalToSizedBuffer

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

func (*GetNodeResponse) ProtoMessage

func (*GetNodeResponse) ProtoMessage()

func (*GetNodeResponse) Reset

func (m *GetNodeResponse) Reset()

func (*GetNodeResponse) Size

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

func (*GetNodeResponse) String

func (m *GetNodeResponse) String() string

func (*GetNodeResponse) Unmarshal

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

func (*GetNodeResponse) XXX_DiscardUnknown

func (m *GetNodeResponse) XXX_DiscardUnknown()

func (*GetNodeResponse) XXX_Marshal

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

func (*GetNodeResponse) XXX_Merge

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

func (*GetNodeResponse) XXX_Size

func (m *GetNodeResponse) XXX_Size() int

func (*GetNodeResponse) XXX_Unmarshal

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

type GetNodesRequest

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

func (*GetNodesRequest) Descriptor

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

func (*GetNodesRequest) GetHeader

func (m *GetNodesRequest) GetHeader() *RequestHeader

func (*GetNodesRequest) Marshal

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

func (*GetNodesRequest) MarshalTo

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

func (*GetNodesRequest) MarshalToSizedBuffer

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

func (*GetNodesRequest) ProtoMessage

func (*GetNodesRequest) ProtoMessage()

func (*GetNodesRequest) Reset

func (m *GetNodesRequest) Reset()

func (*GetNodesRequest) Size

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

func (*GetNodesRequest) String

func (m *GetNodesRequest) String() string

func (*GetNodesRequest) Unmarshal

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

func (*GetNodesRequest) XXX_DiscardUnknown

func (m *GetNodesRequest) XXX_DiscardUnknown()

func (*GetNodesRequest) XXX_Marshal

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

func (*GetNodesRequest) XXX_Merge

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

func (*GetNodesRequest) XXX_Size

func (m *GetNodesRequest) XXX_Size() int

func (*GetNodesRequest) XXX_Unmarshal

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

type GetNodesResponse

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

func (*GetNodesResponse) Descriptor

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

func (*GetNodesResponse) GetHeader

func (m *GetNodesResponse) GetHeader() *ResponseHeader

func (*GetNodesResponse) GetNodes

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

func (*GetNodesResponse) Marshal

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

func (*GetNodesResponse) MarshalTo

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

func (*GetNodesResponse) MarshalToSizedBuffer

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

func (*GetNodesResponse) ProtoMessage

func (*GetNodesResponse) ProtoMessage()

func (*GetNodesResponse) Reset

func (m *GetNodesResponse) Reset()

func (*GetNodesResponse) Size

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

func (*GetNodesResponse) String

func (m *GetNodesResponse) String() string

func (*GetNodesResponse) Unmarshal

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

func (*GetNodesResponse) XXX_DiscardUnknown

func (m *GetNodesResponse) XXX_DiscardUnknown()

func (*GetNodesResponse) XXX_Marshal

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

func (*GetNodesResponse) XXX_Merge

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

func (*GetNodesResponse) XXX_Size

func (m *GetNodesResponse) XXX_Size() int

func (*GetNodesResponse) XXX_Unmarshal

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

type GetRouteRequest

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

func (*GetRouteRequest) Descriptor

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

func (*GetRouteRequest) GetDbId

func (m *GetRouteRequest) GetDbId() int32

func (*GetRouteRequest) GetHasAll

func (m *GetRouteRequest) GetHasAll() bool

func (*GetRouteRequest) GetHeader

func (m *GetRouteRequest) GetHeader() *RequestHeader

func (*GetRouteRequest) GetKey

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

func (*GetRouteRequest) GetMax

func (m *GetRouteRequest) GetMax() uint32

func (*GetRouteRequest) GetRangeType

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

func (*GetRouteRequest) GetTableId

func (m *GetRouteRequest) GetTableId() int32

func (*GetRouteRequest) Marshal

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

func (*GetRouteRequest) MarshalTo

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

func (*GetRouteRequest) MarshalToSizedBuffer

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

func (*GetRouteRequest) ProtoMessage

func (*GetRouteRequest) ProtoMessage()

func (*GetRouteRequest) Reset

func (m *GetRouteRequest) Reset()

func (*GetRouteRequest) Size

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

func (*GetRouteRequest) String

func (m *GetRouteRequest) String() string

func (*GetRouteRequest) Unmarshal

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

func (*GetRouteRequest) XXX_DiscardUnknown

func (m *GetRouteRequest) XXX_DiscardUnknown()

func (*GetRouteRequest) XXX_Marshal

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

func (*GetRouteRequest) XXX_Merge

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

func (*GetRouteRequest) XXX_Size

func (m *GetRouteRequest) XXX_Size() int

func (*GetRouteRequest) XXX_Unmarshal

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

type GetRouteResponse

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

func (*GetRouteResponse) Descriptor

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

func (*GetRouteResponse) GetHeader

func (m *GetRouteResponse) GetHeader() *ResponseHeader

func (*GetRouteResponse) GetMaster

func (m *GetRouteResponse) GetMaster() string

func (*GetRouteResponse) GetRoutes

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

func (*GetRouteResponse) GetVersion

func (m *GetRouteResponse) GetVersion() uint64

func (*GetRouteResponse) Marshal

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

func (*GetRouteResponse) MarshalTo

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

func (*GetRouteResponse) MarshalToSizedBuffer

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

func (*GetRouteResponse) ProtoMessage

func (*GetRouteResponse) ProtoMessage()

func (*GetRouteResponse) Reset

func (m *GetRouteResponse) Reset()

func (*GetRouteResponse) Size

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

func (*GetRouteResponse) String

func (m *GetRouteResponse) String() string

func (*GetRouteResponse) Unmarshal

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

func (*GetRouteResponse) XXX_DiscardUnknown

func (m *GetRouteResponse) XXX_DiscardUnknown()

func (*GetRouteResponse) XXX_Marshal

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

func (*GetRouteResponse) XXX_Merge

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

func (*GetRouteResponse) XXX_Size

func (m *GetRouteResponse) XXX_Size() int

func (*GetRouteResponse) XXX_Unmarshal

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

type GetTableRequest

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

func (*GetTableRequest) Descriptor

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

func (*GetTableRequest) GetDbId

func (m *GetTableRequest) GetDbId() int32

func (*GetTableRequest) GetDbName

func (m *GetTableRequest) GetDbName() string

func (*GetTableRequest) GetHeader

func (m *GetTableRequest) GetHeader() *RequestHeader

func (*GetTableRequest) GetTableId

func (m *GetTableRequest) GetTableId() int32

func (*GetTableRequest) GetTableName

func (m *GetTableRequest) GetTableName() string

func (*GetTableRequest) Marshal

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

func (*GetTableRequest) MarshalTo

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

func (*GetTableRequest) MarshalToSizedBuffer

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

func (*GetTableRequest) ProtoMessage

func (*GetTableRequest) ProtoMessage()

func (*GetTableRequest) Reset

func (m *GetTableRequest) Reset()

func (*GetTableRequest) Size

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

func (*GetTableRequest) String

func (m *GetTableRequest) String() string

func (*GetTableRequest) Unmarshal

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

func (*GetTableRequest) XXX_DiscardUnknown

func (m *GetTableRequest) XXX_DiscardUnknown()

func (*GetTableRequest) XXX_Marshal

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

func (*GetTableRequest) XXX_Merge

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

func (*GetTableRequest) XXX_Size

func (m *GetTableRequest) XXX_Size() int

func (*GetTableRequest) XXX_Unmarshal

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

type NodeHeartbeatRequest

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

func (*NodeHeartbeatRequest) Descriptor

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

func (*NodeHeartbeatRequest) GetHeader

func (m *NodeHeartbeatRequest) GetHeader() *RequestHeader

func (*NodeHeartbeatRequest) GetNodeId

func (m *NodeHeartbeatRequest) GetNodeId() uint64

func (*NodeHeartbeatRequest) Marshal

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

func (*NodeHeartbeatRequest) MarshalTo

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

func (*NodeHeartbeatRequest) MarshalToSizedBuffer

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

func (*NodeHeartbeatRequest) ProtoMessage

func (*NodeHeartbeatRequest) ProtoMessage()

func (*NodeHeartbeatRequest) Reset

func (m *NodeHeartbeatRequest) Reset()

func (*NodeHeartbeatRequest) Size

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

func (*NodeHeartbeatRequest) String

func (m *NodeHeartbeatRequest) String() string

func (*NodeHeartbeatRequest) Unmarshal

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

func (*NodeHeartbeatRequest) XXX_DiscardUnknown

func (m *NodeHeartbeatRequest) XXX_DiscardUnknown()

func (*NodeHeartbeatRequest) XXX_Marshal

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

func (*NodeHeartbeatRequest) XXX_Merge

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

func (*NodeHeartbeatRequest) XXX_Size

func (m *NodeHeartbeatRequest) XXX_Size() int

func (*NodeHeartbeatRequest) XXX_Unmarshal

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

type NodeHeartbeatResponse

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

func (*NodeHeartbeatResponse) Descriptor

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

func (*NodeHeartbeatResponse) GetHeader

func (m *NodeHeartbeatResponse) GetHeader() *ResponseHeader

func (*NodeHeartbeatResponse) GetNodeId

func (m *NodeHeartbeatResponse) GetNodeId() uint64

func (*NodeHeartbeatResponse) Marshal

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

func (*NodeHeartbeatResponse) MarshalTo

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

func (*NodeHeartbeatResponse) MarshalToSizedBuffer

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

func (*NodeHeartbeatResponse) ProtoMessage

func (*NodeHeartbeatResponse) ProtoMessage()

func (*NodeHeartbeatResponse) Reset

func (m *NodeHeartbeatResponse) Reset()

func (*NodeHeartbeatResponse) Size

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

func (*NodeHeartbeatResponse) String

func (m *NodeHeartbeatResponse) String() string

func (*NodeHeartbeatResponse) Unmarshal

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

func (*NodeHeartbeatResponse) XXX_DiscardUnknown

func (m *NodeHeartbeatResponse) XXX_DiscardUnknown()

func (*NodeHeartbeatResponse) XXX_Marshal

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

func (*NodeHeartbeatResponse) XXX_Merge

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

func (*NodeHeartbeatResponse) XXX_Size

func (m *NodeHeartbeatResponse) XXX_Size() int

func (*NodeHeartbeatResponse) XXX_Unmarshal

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

type PeerMoveRequest

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

func (*PeerMoveRequest) Descriptor

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

func (*PeerMoveRequest) GetHeader

func (m *PeerMoveRequest) GetHeader() *RequestHeader

func (*PeerMoveRequest) GetRangeId

func (m *PeerMoveRequest) GetRangeId() uint64

func (*PeerMoveRequest) GetStoreType

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

func (*PeerMoveRequest) GetTableId

func (m *PeerMoveRequest) GetTableId() int32

func (*PeerMoveRequest) Marshal

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

func (*PeerMoveRequest) MarshalTo

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

func (*PeerMoveRequest) MarshalToSizedBuffer

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

func (*PeerMoveRequest) ProtoMessage

func (*PeerMoveRequest) ProtoMessage()

func (*PeerMoveRequest) Reset

func (m *PeerMoveRequest) Reset()

func (*PeerMoveRequest) Size

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

func (*PeerMoveRequest) String

func (m *PeerMoveRequest) String() string

func (*PeerMoveRequest) Unmarshal

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

func (*PeerMoveRequest) XXX_DiscardUnknown

func (m *PeerMoveRequest) XXX_DiscardUnknown()

func (*PeerMoveRequest) XXX_Marshal

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

func (*PeerMoveRequest) XXX_Merge

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

func (*PeerMoveRequest) XXX_Size

func (m *PeerMoveRequest) XXX_Size() int

func (*PeerMoveRequest) XXX_Unmarshal

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

type PeerMoveResponse

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

func (*PeerMoveResponse) Descriptor

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

func (*PeerMoveResponse) GetHeader

func (m *PeerMoveResponse) GetHeader() *ResponseHeader

func (*PeerMoveResponse) Marshal

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

func (*PeerMoveResponse) MarshalTo

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

func (*PeerMoveResponse) MarshalToSizedBuffer

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

func (*PeerMoveResponse) ProtoMessage

func (*PeerMoveResponse) ProtoMessage()

func (*PeerMoveResponse) Reset

func (m *PeerMoveResponse) Reset()

func (*PeerMoveResponse) Size

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

func (*PeerMoveResponse) String

func (m *PeerMoveResponse) String() string

func (*PeerMoveResponse) Unmarshal

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

func (*PeerMoveResponse) XXX_DiscardUnknown

func (m *PeerMoveResponse) XXX_DiscardUnknown()

func (*PeerMoveResponse) XXX_Marshal

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

func (*PeerMoveResponse) XXX_Merge

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

func (*PeerMoveResponse) XXX_Size

func (m *PeerMoveResponse) XXX_Size() int

func (*PeerMoveResponse) XXX_Unmarshal

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

type RangeFingerprint

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

Fingerprint is used to verfiy if range is valid

func (*RangeFingerprint) Descriptor

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

func (*RangeFingerprint) GetDbId

func (m *RangeFingerprint) GetDbId() int32

func (*RangeFingerprint) GetPeerId

func (m *RangeFingerprint) GetPeerId() uint64

func (*RangeFingerprint) GetRangeEpoch

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

func (*RangeFingerprint) GetRangeId

func (m *RangeFingerprint) GetRangeId() uint64

func (*RangeFingerprint) GetTableId

func (m *RangeFingerprint) GetTableId() int32

func (*RangeFingerprint) Marshal

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

func (*RangeFingerprint) MarshalTo

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

func (*RangeFingerprint) MarshalToSizedBuffer

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

func (*RangeFingerprint) ProtoMessage

func (*RangeFingerprint) ProtoMessage()

func (*RangeFingerprint) Reset

func (m *RangeFingerprint) Reset()

func (*RangeFingerprint) Size

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

func (*RangeFingerprint) String

func (m *RangeFingerprint) String() string

func (*RangeFingerprint) Unmarshal

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

func (*RangeFingerprint) XXX_DiscardUnknown

func (m *RangeFingerprint) XXX_DiscardUnknown()

func (*RangeFingerprint) XXX_Marshal

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

func (*RangeFingerprint) XXX_Merge

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

func (*RangeFingerprint) XXX_Size

func (m *RangeFingerprint) XXX_Size() int

func (*RangeFingerprint) XXX_Unmarshal

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

type RangeHeartbeatRequest

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

func (*RangeHeartbeatRequest) Descriptor

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

func (*RangeHeartbeatRequest) GetHeader

func (m *RangeHeartbeatRequest) GetHeader() *RequestHeader

func (*RangeHeartbeatRequest) GetPeersStatus

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

func (*RangeHeartbeatRequest) GetRange

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

func (*RangeHeartbeatRequest) GetTerm

func (m *RangeHeartbeatRequest) GetTerm() uint64

func (*RangeHeartbeatRequest) Marshal

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

func (*RangeHeartbeatRequest) MarshalTo

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

func (*RangeHeartbeatRequest) MarshalToSizedBuffer

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

func (*RangeHeartbeatRequest) ProtoMessage

func (*RangeHeartbeatRequest) ProtoMessage()

func (*RangeHeartbeatRequest) Reset

func (m *RangeHeartbeatRequest) Reset()

func (*RangeHeartbeatRequest) Size

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

func (*RangeHeartbeatRequest) String

func (m *RangeHeartbeatRequest) String() string

func (*RangeHeartbeatRequest) Unmarshal

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

func (*RangeHeartbeatRequest) XXX_DiscardUnknown

func (m *RangeHeartbeatRequest) XXX_DiscardUnknown()

func (*RangeHeartbeatRequest) XXX_Marshal

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

func (*RangeHeartbeatRequest) XXX_Merge

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

func (*RangeHeartbeatRequest) XXX_Size

func (m *RangeHeartbeatRequest) XXX_Size() int

func (*RangeHeartbeatRequest) XXX_Unmarshal

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

type RangeHeartbeatResponse

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

func (*RangeHeartbeatResponse) Descriptor

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

func (*RangeHeartbeatResponse) GetEpoch

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

func (*RangeHeartbeatResponse) GetHeader

func (m *RangeHeartbeatResponse) GetHeader() *ResponseHeader

func (*RangeHeartbeatResponse) GetRangeId

func (m *RangeHeartbeatResponse) GetRangeId() uint64

func (*RangeHeartbeatResponse) Marshal

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

func (*RangeHeartbeatResponse) MarshalTo

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

func (*RangeHeartbeatResponse) MarshalToSizedBuffer

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

func (*RangeHeartbeatResponse) ProtoMessage

func (*RangeHeartbeatResponse) ProtoMessage()

func (*RangeHeartbeatResponse) Reset

func (m *RangeHeartbeatResponse) Reset()

func (*RangeHeartbeatResponse) Size

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

func (*RangeHeartbeatResponse) String

func (m *RangeHeartbeatResponse) String() string

func (*RangeHeartbeatResponse) Unmarshal

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

func (*RangeHeartbeatResponse) XXX_DiscardUnknown

func (m *RangeHeartbeatResponse) XXX_DiscardUnknown()

func (*RangeHeartbeatResponse) XXX_Marshal

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

func (*RangeHeartbeatResponse) XXX_Merge

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

func (*RangeHeartbeatResponse) XXX_Size

func (m *RangeHeartbeatResponse) XXX_Size() int

func (*RangeHeartbeatResponse) XXX_Unmarshal

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

type RegisterNodeRequest

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

func (*RegisterNodeRequest) Descriptor

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

func (*RegisterNodeRequest) GetAdminPort

func (m *RegisterNodeRequest) GetAdminPort() uint32

func (*RegisterNodeRequest) GetHeader

func (m *RegisterNodeRequest) GetHeader() *RequestHeader

func (*RegisterNodeRequest) GetRaftPort

func (m *RegisterNodeRequest) GetRaftPort() uint32

func (*RegisterNodeRequest) GetRanges

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

func (*RegisterNodeRequest) GetServerPort

func (m *RegisterNodeRequest) GetServerPort() uint32

func (*RegisterNodeRequest) GetStEngine

func (m *RegisterNodeRequest) GetStEngine() StorageEngine

func (*RegisterNodeRequest) GetVersion

func (m *RegisterNodeRequest) GetVersion() string

func (*RegisterNodeRequest) Marshal

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

func (*RegisterNodeRequest) MarshalTo

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

func (*RegisterNodeRequest) MarshalToSizedBuffer

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

func (*RegisterNodeRequest) ProtoMessage

func (*RegisterNodeRequest) ProtoMessage()

func (*RegisterNodeRequest) Reset

func (m *RegisterNodeRequest) Reset()

func (*RegisterNodeRequest) Size

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

func (*RegisterNodeRequest) String

func (m *RegisterNodeRequest) String() string

func (*RegisterNodeRequest) Unmarshal

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

func (*RegisterNodeRequest) XXX_DiscardUnknown

func (m *RegisterNodeRequest) XXX_DiscardUnknown()

func (*RegisterNodeRequest) XXX_Marshal

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

func (*RegisterNodeRequest) XXX_Merge

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

func (*RegisterNodeRequest) XXX_Size

func (m *RegisterNodeRequest) XXX_Size() int

func (*RegisterNodeRequest) XXX_Unmarshal

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

type RegisterNodeResponse

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

func (*RegisterNodeResponse) Descriptor

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

func (*RegisterNodeResponse) GetHeader

func (m *RegisterNodeResponse) GetHeader() *ResponseHeader

func (*RegisterNodeResponse) GetInvalidRanges

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

func (*RegisterNodeResponse) GetNodeId

func (m *RegisterNodeResponse) GetNodeId() uint64

func (*RegisterNodeResponse) Marshal

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

func (*RegisterNodeResponse) MarshalTo

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

func (*RegisterNodeResponse) MarshalToSizedBuffer

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

func (*RegisterNodeResponse) ProtoMessage

func (*RegisterNodeResponse) ProtoMessage()

func (*RegisterNodeResponse) Reset

func (m *RegisterNodeResponse) Reset()

func (*RegisterNodeResponse) Size

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

func (*RegisterNodeResponse) String

func (m *RegisterNodeResponse) String() string

func (*RegisterNodeResponse) Unmarshal

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

func (*RegisterNodeResponse) XXX_DiscardUnknown

func (m *RegisterNodeResponse) XXX_DiscardUnknown()

func (*RegisterNodeResponse) XXX_Marshal

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

func (*RegisterNodeResponse) XXX_Merge

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

func (*RegisterNodeResponse) XXX_Size

func (m *RegisterNodeResponse) XXX_Size() int

func (*RegisterNodeResponse) XXX_Unmarshal

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

type RequestHeader

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

func (*RequestHeader) Descriptor

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

func (*RequestHeader) GetClusterId

func (m *RequestHeader) GetClusterId() uint64

func (*RequestHeader) Marshal

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

func (*RequestHeader) MarshalTo

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

func (*RequestHeader) MarshalToSizedBuffer

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

func (*RequestHeader) ProtoMessage

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) Reset

func (m *RequestHeader) Reset()

func (*RequestHeader) Size

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

func (*RequestHeader) String

func (m *RequestHeader) String() string

func (*RequestHeader) Unmarshal

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

func (*RequestHeader) XXX_DiscardUnknown

func (m *RequestHeader) XXX_DiscardUnknown()

func (*RequestHeader) XXX_Marshal

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

func (*RequestHeader) XXX_Merge

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

func (*RequestHeader) XXX_Size

func (m *RequestHeader) XXX_Size() int

func (*RequestHeader) XXX_Unmarshal

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

type ResponseHeader

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

func (*ResponseHeader) Descriptor

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

func (*ResponseHeader) GetClusterId

func (m *ResponseHeader) GetClusterId() uint64

func (*ResponseHeader) GetError

func (m *ResponseHeader) GetError() *Error

func (*ResponseHeader) Marshal

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

func (*ResponseHeader) MarshalTo

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

func (*ResponseHeader) MarshalToSizedBuffer

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

func (*ResponseHeader) ProtoMessage

func (*ResponseHeader) ProtoMessage()

func (*ResponseHeader) Reset

func (m *ResponseHeader) Reset()

func (*ResponseHeader) Size

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

func (*ResponseHeader) String

func (m *ResponseHeader) String() string

func (*ResponseHeader) Unmarshal

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

func (*ResponseHeader) XXX_DiscardUnknown

func (m *ResponseHeader) XXX_DiscardUnknown()

func (*ResponseHeader) XXX_Marshal

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

func (*ResponseHeader) XXX_Merge

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

func (*ResponseHeader) XXX_Size

func (m *ResponseHeader) XXX_Size() int

func (*ResponseHeader) XXX_Unmarshal

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

type StorageEngine

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

func (StorageEngine) EnumDescriptor

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

func (StorageEngine) String

func (x StorageEngine) String() string

type WatcherEventRequest

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

func (*WatcherEventRequest) Descriptor

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

func (*WatcherEventRequest) GetHeader

func (m *WatcherEventRequest) GetHeader() *RequestHeader

func (*WatcherEventRequest) GetMaster

func (m *WatcherEventRequest) GetMaster() string

func (*WatcherEventRequest) GetVersion

func (m *WatcherEventRequest) GetVersion() uint64

func (*WatcherEventRequest) Marshal

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

func (*WatcherEventRequest) MarshalTo

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

func (*WatcherEventRequest) MarshalToSizedBuffer

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

func (*WatcherEventRequest) ProtoMessage

func (*WatcherEventRequest) ProtoMessage()

func (*WatcherEventRequest) Reset

func (m *WatcherEventRequest) Reset()

func (*WatcherEventRequest) Size

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

func (*WatcherEventRequest) String

func (m *WatcherEventRequest) String() string

func (*WatcherEventRequest) Unmarshal

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

func (*WatcherEventRequest) XXX_DiscardUnknown

func (m *WatcherEventRequest) XXX_DiscardUnknown()

func (*WatcherEventRequest) XXX_Marshal

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

func (*WatcherEventRequest) XXX_Merge

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

func (*WatcherEventRequest) XXX_Size

func (m *WatcherEventRequest) XXX_Size() int

func (*WatcherEventRequest) XXX_Unmarshal

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

type WatcherEventResponse

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

func (*WatcherEventResponse) Descriptor

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

func (*WatcherEventResponse) GetEvents

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

func (*WatcherEventResponse) GetHeader

func (m *WatcherEventResponse) GetHeader() *ResponseHeader

func (*WatcherEventResponse) Marshal

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

func (*WatcherEventResponse) MarshalTo

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

func (*WatcherEventResponse) MarshalToSizedBuffer

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

func (*WatcherEventResponse) ProtoMessage

func (*WatcherEventResponse) ProtoMessage()

func (*WatcherEventResponse) Reset

func (m *WatcherEventResponse) Reset()

func (*WatcherEventResponse) Size

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

func (*WatcherEventResponse) String

func (m *WatcherEventResponse) String() string

func (*WatcherEventResponse) Unmarshal

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

func (*WatcherEventResponse) XXX_DiscardUnknown

func (m *WatcherEventResponse) XXX_DiscardUnknown()

func (*WatcherEventResponse) XXX_Marshal

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

func (*WatcherEventResponse) XXX_Merge

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

func (*WatcherEventResponse) XXX_Size

func (m *WatcherEventResponse) XXX_Size() int

func (*WatcherEventResponse) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL