Documentation ¶
Index ¶
- Variables
- type AskSplitRequest
- func (*AskSplitRequest) Descriptor() ([]byte, []int)
- func (m *AskSplitRequest) GetForce() bool
- func (m *AskSplitRequest) GetHeader() *RequestHeader
- func (m *AskSplitRequest) GetRange() *basepb.Range
- func (m *AskSplitRequest) GetSplitKey() []byte
- func (m *AskSplitRequest) Marshal() (dAtA []byte, err error)
- func (m *AskSplitRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *AskSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AskSplitRequest) ProtoMessage()
- func (m *AskSplitRequest) Reset()
- func (m *AskSplitRequest) Size() (n int)
- func (m *AskSplitRequest) String() string
- func (m *AskSplitRequest) Unmarshal(dAtA []byte) error
- func (m *AskSplitRequest) XXX_DiscardUnknown()
- func (m *AskSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AskSplitRequest) XXX_Merge(src proto.Message)
- func (m *AskSplitRequest) XXX_Size() int
- func (m *AskSplitRequest) XXX_Unmarshal(b []byte) error
- type AskSplitResponse
- func (*AskSplitResponse) Descriptor() ([]byte, []int)
- func (m *AskSplitResponse) GetHeader() *ResponseHeader
- func (m *AskSplitResponse) GetNewPeerIds() []uint64
- func (m *AskSplitResponse) GetNewRangeId() uint64
- func (m *AskSplitResponse) GetRange() *basepb.Range
- func (m *AskSplitResponse) GetSplitKey() []byte
- func (m *AskSplitResponse) Marshal() (dAtA []byte, err error)
- func (m *AskSplitResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *AskSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AskSplitResponse) ProtoMessage()
- func (m *AskSplitResponse) Reset()
- func (m *AskSplitResponse) Size() (n int)
- func (m *AskSplitResponse) String() string
- func (m *AskSplitResponse) Unmarshal(dAtA []byte) error
- func (m *AskSplitResponse) XXX_DiscardUnknown()
- func (m *AskSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AskSplitResponse) XXX_Merge(src proto.Message)
- func (m *AskSplitResponse) XXX_Size() int
- func (m *AskSplitResponse) XXX_Unmarshal(b []byte) error
- type ChangeNodeStateRequest
- func (*ChangeNodeStateRequest) Descriptor() ([]byte, []int)
- func (m *ChangeNodeStateRequest) GetHeader() *RequestHeader
- func (m *ChangeNodeStateRequest) GetId() uint64
- func (m *ChangeNodeStateRequest) GetState() basepb.NodeState
- func (m *ChangeNodeStateRequest) Marshal() (dAtA []byte, err error)
- func (m *ChangeNodeStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ChangeNodeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChangeNodeStateRequest) ProtoMessage()
- func (m *ChangeNodeStateRequest) Reset()
- func (m *ChangeNodeStateRequest) Size() (n int)
- func (m *ChangeNodeStateRequest) String() string
- func (m *ChangeNodeStateRequest) Unmarshal(dAtA []byte) error
- func (m *ChangeNodeStateRequest) XXX_DiscardUnknown()
- func (m *ChangeNodeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChangeNodeStateRequest) XXX_Merge(src proto.Message)
- func (m *ChangeNodeStateRequest) XXX_Size() int
- func (m *ChangeNodeStateRequest) XXX_Unmarshal(b []byte) error
- type ChangeNodeStateResponse
- func (*ChangeNodeStateResponse) Descriptor() ([]byte, []int)
- func (m *ChangeNodeStateResponse) GetHeader() *ResponseHeader
- func (m *ChangeNodeStateResponse) GetNode() *basepb.Node
- func (m *ChangeNodeStateResponse) Marshal() (dAtA []byte, err error)
- func (m *ChangeNodeStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ChangeNodeStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChangeNodeStateResponse) ProtoMessage()
- func (m *ChangeNodeStateResponse) Reset()
- func (m *ChangeNodeStateResponse) Size() (n int)
- func (m *ChangeNodeStateResponse) String() string
- func (m *ChangeNodeStateResponse) Unmarshal(dAtA []byte) error
- func (m *ChangeNodeStateResponse) XXX_DiscardUnknown()
- func (m *ChangeNodeStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChangeNodeStateResponse) XXX_Merge(src proto.Message)
- func (m *ChangeNodeStateResponse) XXX_Size() int
- func (m *ChangeNodeStateResponse) XXX_Unmarshal(b []byte) error
- type ChangeRangeStoreTypeRequest
- func (*ChangeRangeStoreTypeRequest) Descriptor() ([]byte, []int)
- func (m *ChangeRangeStoreTypeRequest) GetHeader() *RequestHeader
- func (m *ChangeRangeStoreTypeRequest) GetRangeId() uint64
- func (m *ChangeRangeStoreTypeRequest) GetStoreType() basepb.StoreType
- func (m *ChangeRangeStoreTypeRequest) GetTableId() uint64
- func (m *ChangeRangeStoreTypeRequest) Marshal() (dAtA []byte, err error)
- func (m *ChangeRangeStoreTypeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ChangeRangeStoreTypeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChangeRangeStoreTypeRequest) ProtoMessage()
- func (m *ChangeRangeStoreTypeRequest) Reset()
- func (m *ChangeRangeStoreTypeRequest) Size() (n int)
- func (m *ChangeRangeStoreTypeRequest) String() string
- func (m *ChangeRangeStoreTypeRequest) Unmarshal(dAtA []byte) error
- func (m *ChangeRangeStoreTypeRequest) XXX_DiscardUnknown()
- func (m *ChangeRangeStoreTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChangeRangeStoreTypeRequest) XXX_Merge(src proto.Message)
- func (m *ChangeRangeStoreTypeRequest) XXX_Size() int
- func (m *ChangeRangeStoreTypeRequest) XXX_Unmarshal(b []byte) error
- type ChangeRangeStoreTypeResponse
- func (*ChangeRangeStoreTypeResponse) Descriptor() ([]byte, []int)
- func (m *ChangeRangeStoreTypeResponse) GetHeader() *ResponseHeader
- func (m *ChangeRangeStoreTypeResponse) Marshal() (dAtA []byte, err error)
- func (m *ChangeRangeStoreTypeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ChangeRangeStoreTypeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ChangeRangeStoreTypeResponse) ProtoMessage()
- func (m *ChangeRangeStoreTypeResponse) Reset()
- func (m *ChangeRangeStoreTypeResponse) Size() (n int)
- func (m *ChangeRangeStoreTypeResponse) String() string
- func (m *ChangeRangeStoreTypeResponse) Unmarshal(dAtA []byte) error
- func (m *ChangeRangeStoreTypeResponse) XXX_DiscardUnknown()
- func (m *ChangeRangeStoreTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ChangeRangeStoreTypeResponse) XXX_Merge(src proto.Message)
- func (m *ChangeRangeStoreTypeResponse) XXX_Size() int
- func (m *ChangeRangeStoreTypeResponse) XXX_Unmarshal(b []byte) error
- type CheckNodeStateRequest
- func (*CheckNodeStateRequest) Descriptor() ([]byte, []int)
- func (m *CheckNodeStateRequest) GetHeader() *RequestHeader
- func (m *CheckNodeStateRequest) GetId() uint64
- func (m *CheckNodeStateRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckNodeStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckNodeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckNodeStateRequest) ProtoMessage()
- func (m *CheckNodeStateRequest) Reset()
- func (m *CheckNodeStateRequest) Size() (n int)
- func (m *CheckNodeStateRequest) String() string
- func (m *CheckNodeStateRequest) Unmarshal(dAtA []byte) error
- func (m *CheckNodeStateRequest) XXX_DiscardUnknown()
- func (m *CheckNodeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckNodeStateRequest) XXX_Merge(src proto.Message)
- func (m *CheckNodeStateRequest) XXX_Size() int
- func (m *CheckNodeStateRequest) XXX_Unmarshal(b []byte) error
- type CheckNodeStateResponse
- func (*CheckNodeStateResponse) Descriptor() ([]byte, []int)
- func (m *CheckNodeStateResponse) GetHeader() *ResponseHeader
- func (m *CheckNodeStateResponse) GetLeaderNum() uint64
- func (m *CheckNodeStateResponse) GetRangeNum() uint64
- func (m *CheckNodeStateResponse) GetState() basepb.NodeState
- func (m *CheckNodeStateResponse) Marshal() (dAtA []byte, err error)
- func (m *CheckNodeStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckNodeStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckNodeStateResponse) ProtoMessage()
- func (m *CheckNodeStateResponse) Reset()
- func (m *CheckNodeStateResponse) Size() (n int)
- func (m *CheckNodeStateResponse) String() string
- func (m *CheckNodeStateResponse) Unmarshal(dAtA []byte) error
- func (m *CheckNodeStateResponse) XXX_DiscardUnknown()
- func (m *CheckNodeStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckNodeStateResponse) XXX_Merge(src proto.Message)
- func (m *CheckNodeStateResponse) XXX_Size() int
- func (m *CheckNodeStateResponse) XXX_Unmarshal(b []byte) error
- type ClusterInfoRequest
- func (*ClusterInfoRequest) Descriptor() ([]byte, []int)
- func (m *ClusterInfoRequest) GetHeader() *RequestHeader
- func (m *ClusterInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *ClusterInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterInfoRequest) ProtoMessage()
- func (m *ClusterInfoRequest) Reset()
- func (m *ClusterInfoRequest) Size() (n int)
- func (m *ClusterInfoRequest) String() string
- func (m *ClusterInfoRequest) Unmarshal(dAtA []byte) error
- func (m *ClusterInfoRequest) XXX_DiscardUnknown()
- func (m *ClusterInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterInfoRequest) XXX_Merge(src proto.Message)
- func (m *ClusterInfoRequest) XXX_Size() int
- func (m *ClusterInfoRequest) XXX_Unmarshal(b []byte) error
- type ClusterInfoResponse
- func (*ClusterInfoResponse) Descriptor() ([]byte, []int)
- func (m *ClusterInfoResponse) GetBuildTime() string
- func (m *ClusterInfoResponse) GetBuildVersion() string
- func (m *ClusterInfoResponse) GetCommitId() string
- func (m *ClusterInfoResponse) GetHeader() *ResponseHeader
- func (m *ClusterInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *ClusterInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterInfoResponse) ProtoMessage()
- func (m *ClusterInfoResponse) Reset()
- func (m *ClusterInfoResponse) Size() (n int)
- func (m *ClusterInfoResponse) String() string
- func (m *ClusterInfoResponse) Unmarshal(dAtA []byte) error
- func (m *ClusterInfoResponse) XXX_DiscardUnknown()
- func (m *ClusterInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterInfoResponse) XXX_Merge(src proto.Message)
- func (m *ClusterInfoResponse) XXX_Size() int
- func (m *ClusterInfoResponse) XXX_Unmarshal(b []byte) error
- type CountTableRequest
- func (*CountTableRequest) Descriptor() ([]byte, []int)
- func (m *CountTableRequest) GetHeader() *RequestHeader
- func (m *CountTableRequest) Marshal() (dAtA []byte, err error)
- func (m *CountTableRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CountTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CountTableRequest) ProtoMessage()
- func (m *CountTableRequest) Reset()
- func (m *CountTableRequest) Size() (n int)
- func (m *CountTableRequest) String() string
- func (m *CountTableRequest) Unmarshal(dAtA []byte) error
- func (m *CountTableRequest) XXX_DiscardUnknown()
- func (m *CountTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CountTableRequest) XXX_Merge(src proto.Message)
- func (m *CountTableRequest) XXX_Size() int
- func (m *CountTableRequest) XXX_Unmarshal(b []byte) error
- type CountTableResponse
- func (*CountTableResponse) Descriptor() ([]byte, []int)
- func (m *CountTableResponse) GetHeader() *ResponseHeader
- func (m *CountTableResponse) GetList() []*Counter
- func (m *CountTableResponse) Marshal() (dAtA []byte, err error)
- func (m *CountTableResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CountTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CountTableResponse) ProtoMessage()
- func (m *CountTableResponse) Reset()
- func (m *CountTableResponse) Size() (n int)
- func (m *CountTableResponse) String() string
- func (m *CountTableResponse) Unmarshal(dAtA []byte) error
- func (m *CountTableResponse) XXX_DiscardUnknown()
- func (m *CountTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CountTableResponse) XXX_Merge(src proto.Message)
- func (m *CountTableResponse) XXX_Size() int
- func (m *CountTableResponse) XXX_Unmarshal(b []byte) error
- type Counter
- func (*Counter) Descriptor() ([]byte, []int)
- func (m *Counter) GetCount() uint64
- func (m *Counter) GetDbId() uint64
- func (m *Counter) GetTableId() uint64
- func (m *Counter) Marshal() (dAtA []byte, err error)
- func (m *Counter) MarshalTo(dAtA []byte) (int, error)
- func (m *Counter) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Counter) ProtoMessage()
- func (m *Counter) Reset()
- func (m *Counter) Size() (n int)
- func (m *Counter) String() string
- func (m *Counter) Unmarshal(dAtA []byte) error
- func (m *Counter) XXX_DiscardUnknown()
- func (m *Counter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Counter) XXX_Merge(src proto.Message)
- func (m *Counter) XXX_Size() int
- func (m *Counter) XXX_Unmarshal(b []byte) error
- type CreateDatabaseRequest
- func (*CreateDatabaseRequest) Descriptor() ([]byte, []int)
- func (m *CreateDatabaseRequest) GetHeader() *RequestHeader
- func (m *CreateDatabaseRequest) GetName() string
- func (m *CreateDatabaseRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateDatabaseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateDatabaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateDatabaseRequest) ProtoMessage()
- func (m *CreateDatabaseRequest) Reset()
- func (m *CreateDatabaseRequest) Size() (n int)
- func (m *CreateDatabaseRequest) String() string
- func (m *CreateDatabaseRequest) Unmarshal(dAtA []byte) error
- func (m *CreateDatabaseRequest) XXX_DiscardUnknown()
- func (m *CreateDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateDatabaseRequest) XXX_Merge(src proto.Message)
- func (m *CreateDatabaseRequest) XXX_Size() int
- func (m *CreateDatabaseRequest) XXX_Unmarshal(b []byte) error
- type CreateDatabaseResponse
- func (*CreateDatabaseResponse) Descriptor() ([]byte, []int)
- func (m *CreateDatabaseResponse) GetDatabase() *basepb.DataBase
- func (m *CreateDatabaseResponse) GetHeader() *ResponseHeader
- func (m *CreateDatabaseResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateDatabaseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateDatabaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateDatabaseResponse) ProtoMessage()
- func (m *CreateDatabaseResponse) Reset()
- func (m *CreateDatabaseResponse) Size() (n int)
- func (m *CreateDatabaseResponse) String() string
- func (m *CreateDatabaseResponse) Unmarshal(dAtA []byte) error
- func (m *CreateDatabaseResponse) XXX_DiscardUnknown()
- func (m *CreateDatabaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateDatabaseResponse) XXX_Merge(src proto.Message)
- func (m *CreateDatabaseResponse) XXX_Size() int
- func (m *CreateDatabaseResponse) XXX_Unmarshal(b []byte) error
- type CreateTableRequest
- func (*CreateTableRequest) Descriptor() ([]byte, []int)
- func (m *CreateTableRequest) GetDataRangeNum() uint64
- func (m *CreateTableRequest) GetDbName() string
- func (m *CreateTableRequest) GetHeader() *RequestHeader
- func (m *CreateTableRequest) GetProperties() string
- func (m *CreateTableRequest) GetRangeKeys() []string
- func (m *CreateTableRequest) GetReplicaNum() uint64
- func (m *CreateTableRequest) GetStoreType() string
- func (m *CreateTableRequest) GetTableName() string
- func (m *CreateTableRequest) Marshal() (dAtA []byte, err error)
- func (m *CreateTableRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateTableRequest) ProtoMessage()
- func (m *CreateTableRequest) Reset()
- func (m *CreateTableRequest) Size() (n int)
- func (m *CreateTableRequest) String() string
- func (m *CreateTableRequest) Unmarshal(dAtA []byte) error
- func (m *CreateTableRequest) XXX_DiscardUnknown()
- func (m *CreateTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateTableRequest) XXX_Merge(src proto.Message)
- func (m *CreateTableRequest) XXX_Size() int
- func (m *CreateTableRequest) XXX_Unmarshal(b []byte) error
- type CreateTableResponse
- func (*CreateTableResponse) Descriptor() ([]byte, []int)
- func (m *CreateTableResponse) GetHeader() *ResponseHeader
- func (m *CreateTableResponse) GetTable() *basepb.Table
- func (m *CreateTableResponse) Marshal() (dAtA []byte, err error)
- func (m *CreateTableResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CreateTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CreateTableResponse) ProtoMessage()
- func (m *CreateTableResponse) Reset()
- func (m *CreateTableResponse) Size() (n int)
- func (m *CreateTableResponse) String() string
- func (m *CreateTableResponse) Unmarshal(dAtA []byte) error
- func (m *CreateTableResponse) XXX_DiscardUnknown()
- func (m *CreateTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CreateTableResponse) XXX_Merge(src proto.Message)
- func (m *CreateTableResponse) XXX_Size() int
- func (m *CreateTableResponse) XXX_Unmarshal(b []byte) error
- type DelDatabaseRequest
- func (*DelDatabaseRequest) Descriptor() ([]byte, []int)
- func (m *DelDatabaseRequest) GetHeader() *RequestHeader
- func (m *DelDatabaseRequest) GetId() uint64
- func (m *DelDatabaseRequest) GetName() string
- func (m *DelDatabaseRequest) Marshal() (dAtA []byte, err error)
- func (m *DelDatabaseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DelDatabaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DelDatabaseRequest) ProtoMessage()
- func (m *DelDatabaseRequest) Reset()
- func (m *DelDatabaseRequest) Size() (n int)
- func (m *DelDatabaseRequest) String() string
- func (m *DelDatabaseRequest) Unmarshal(dAtA []byte) error
- func (m *DelDatabaseRequest) XXX_DiscardUnknown()
- func (m *DelDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelDatabaseRequest) XXX_Merge(src proto.Message)
- func (m *DelDatabaseRequest) XXX_Size() int
- func (m *DelDatabaseRequest) XXX_Unmarshal(b []byte) error
- type DelDatabaseResponse
- func (*DelDatabaseResponse) Descriptor() ([]byte, []int)
- func (m *DelDatabaseResponse) GetHeader() *ResponseHeader
- func (m *DelDatabaseResponse) Marshal() (dAtA []byte, err error)
- func (m *DelDatabaseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DelDatabaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DelDatabaseResponse) ProtoMessage()
- func (m *DelDatabaseResponse) Reset()
- func (m *DelDatabaseResponse) Size() (n int)
- func (m *DelDatabaseResponse) String() string
- func (m *DelDatabaseResponse) Unmarshal(dAtA []byte) error
- func (m *DelDatabaseResponse) XXX_DiscardUnknown()
- func (m *DelDatabaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelDatabaseResponse) XXX_Merge(src proto.Message)
- func (m *DelDatabaseResponse) XXX_Size() int
- func (m *DelDatabaseResponse) XXX_Unmarshal(b []byte) error
- type DelTableRequest
- func (*DelTableRequest) Descriptor() ([]byte, []int)
- func (m *DelTableRequest) GetDbId() uint64
- func (m *DelTableRequest) GetDbName() string
- func (m *DelTableRequest) GetHeader() *RequestHeader
- func (m *DelTableRequest) GetTableId() uint64
- func (m *DelTableRequest) GetTableName() string
- func (m *DelTableRequest) Marshal() (dAtA []byte, err error)
- func (m *DelTableRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *DelTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DelTableRequest) ProtoMessage()
- func (m *DelTableRequest) Reset()
- func (m *DelTableRequest) Size() (n int)
- func (m *DelTableRequest) String() string
- func (m *DelTableRequest) Unmarshal(dAtA []byte) error
- func (m *DelTableRequest) XXX_DiscardUnknown()
- func (m *DelTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelTableRequest) XXX_Merge(src proto.Message)
- func (m *DelTableRequest) XXX_Size() int
- func (m *DelTableRequest) XXX_Unmarshal(b []byte) error
- type DelTableResponse
- func (*DelTableResponse) Descriptor() ([]byte, []int)
- func (m *DelTableResponse) GetHeader() *ResponseHeader
- func (m *DelTableResponse) GetTable() *basepb.Table
- func (m *DelTableResponse) Marshal() (dAtA []byte, err error)
- func (m *DelTableResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *DelTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DelTableResponse) ProtoMessage()
- func (m *DelTableResponse) Reset()
- func (m *DelTableResponse) Size() (n int)
- func (m *DelTableResponse) String() string
- func (m *DelTableResponse) Unmarshal(dAtA []byte) error
- func (m *DelTableResponse) XXX_DiscardUnknown()
- func (m *DelTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DelTableResponse) XXX_Merge(src proto.Message)
- func (m *DelTableResponse) XXX_Size() int
- func (m *DelTableResponse) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetCode() uint32
- func (m *Error) GetMessage() string
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type ErrorType
- type GetAutoIncIdRequest
- func (*GetAutoIncIdRequest) Descriptor() ([]byte, []int)
- func (m *GetAutoIncIdRequest) GetDbId() uint64
- func (m *GetAutoIncIdRequest) GetHeader() *RequestHeader
- func (m *GetAutoIncIdRequest) GetSize_() uint32
- func (m *GetAutoIncIdRequest) GetTableId() uint64
- func (m *GetAutoIncIdRequest) Marshal() (dAtA []byte, err error)
- func (m *GetAutoIncIdRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetAutoIncIdRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetAutoIncIdRequest) ProtoMessage()
- func (m *GetAutoIncIdRequest) Reset()
- func (m *GetAutoIncIdRequest) Size() (n int)
- func (m *GetAutoIncIdRequest) String() string
- func (m *GetAutoIncIdRequest) Unmarshal(dAtA []byte) error
- func (m *GetAutoIncIdRequest) XXX_DiscardUnknown()
- func (m *GetAutoIncIdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAutoIncIdRequest) XXX_Merge(src proto.Message)
- func (m *GetAutoIncIdRequest) XXX_Size() int
- func (m *GetAutoIncIdRequest) XXX_Unmarshal(b []byte) error
- type GetAutoIncIdResponse
- func (*GetAutoIncIdResponse) Descriptor() ([]byte, []int)
- func (m *GetAutoIncIdResponse) GetHeader() *ResponseHeader
- func (m *GetAutoIncIdResponse) GetIdPairs() []*IdPair
- func (m *GetAutoIncIdResponse) Marshal() (dAtA []byte, err error)
- func (m *GetAutoIncIdResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetAutoIncIdResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetAutoIncIdResponse) ProtoMessage()
- func (m *GetAutoIncIdResponse) Reset()
- func (m *GetAutoIncIdResponse) Size() (n int)
- func (m *GetAutoIncIdResponse) String() string
- func (m *GetAutoIncIdResponse) Unmarshal(dAtA []byte) error
- func (m *GetAutoIncIdResponse) XXX_DiscardUnknown()
- func (m *GetAutoIncIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAutoIncIdResponse) XXX_Merge(src proto.Message)
- func (m *GetAutoIncIdResponse) XXX_Size() int
- func (m *GetAutoIncIdResponse) XXX_Unmarshal(b []byte) error
- type GetColumnRequest
- func (*GetColumnRequest) Descriptor() ([]byte, []int)
- func (m *GetColumnRequest) GetColId() uint64
- func (m *GetColumnRequest) GetColName() string
- func (m *GetColumnRequest) GetDbId() uint64
- func (m *GetColumnRequest) GetHeader() *RequestHeader
- func (m *GetColumnRequest) GetTableId() uint64
- func (m *GetColumnRequest) Marshal() (dAtA []byte, err error)
- func (m *GetColumnRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetColumnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetColumnRequest) ProtoMessage()
- func (m *GetColumnRequest) Reset()
- func (m *GetColumnRequest) Size() (n int)
- func (m *GetColumnRequest) String() string
- func (m *GetColumnRequest) Unmarshal(dAtA []byte) error
- func (m *GetColumnRequest) XXX_DiscardUnknown()
- func (m *GetColumnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetColumnRequest) XXX_Merge(src proto.Message)
- func (m *GetColumnRequest) XXX_Size() int
- func (m *GetColumnRequest) XXX_Unmarshal(b []byte) error
- type GetColumnResponse
- func (*GetColumnResponse) Descriptor() ([]byte, []int)
- func (m *GetColumnResponse) GetColumn() *basepb.Column
- func (m *GetColumnResponse) GetHeader() *ResponseHeader
- func (m *GetColumnResponse) Marshal() (dAtA []byte, err error)
- func (m *GetColumnResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetColumnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetColumnResponse) ProtoMessage()
- func (m *GetColumnResponse) Reset()
- func (m *GetColumnResponse) Size() (n int)
- func (m *GetColumnResponse) String() string
- func (m *GetColumnResponse) Unmarshal(dAtA []byte) error
- func (m *GetColumnResponse) XXX_DiscardUnknown()
- func (m *GetColumnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetColumnResponse) XXX_Merge(src proto.Message)
- func (m *GetColumnResponse) XXX_Size() int
- func (m *GetColumnResponse) XXX_Unmarshal(b []byte) error
- type GetColumnsRequest
- func (*GetColumnsRequest) Descriptor() ([]byte, []int)
- func (m *GetColumnsRequest) GetDbId() uint64
- func (m *GetColumnsRequest) GetHeader() *RequestHeader
- func (m *GetColumnsRequest) GetTableId() uint64
- func (m *GetColumnsRequest) Marshal() (dAtA []byte, err error)
- func (m *GetColumnsRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetColumnsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetColumnsRequest) ProtoMessage()
- func (m *GetColumnsRequest) Reset()
- func (m *GetColumnsRequest) Size() (n int)
- func (m *GetColumnsRequest) String() string
- func (m *GetColumnsRequest) Unmarshal(dAtA []byte) error
- func (m *GetColumnsRequest) XXX_DiscardUnknown()
- func (m *GetColumnsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetColumnsRequest) XXX_Merge(src proto.Message)
- func (m *GetColumnsRequest) XXX_Size() int
- func (m *GetColumnsRequest) XXX_Unmarshal(b []byte) error
- type GetColumnsResponse
- func (*GetColumnsResponse) Descriptor() ([]byte, []int)
- func (m *GetColumnsResponse) GetColumns() []*basepb.Column
- func (m *GetColumnsResponse) GetHeader() *ResponseHeader
- func (m *GetColumnsResponse) Marshal() (dAtA []byte, err error)
- func (m *GetColumnsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetColumnsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetColumnsResponse) ProtoMessage()
- func (m *GetColumnsResponse) Reset()
- func (m *GetColumnsResponse) Size() (n int)
- func (m *GetColumnsResponse) String() string
- func (m *GetColumnsResponse) Unmarshal(dAtA []byte) error
- func (m *GetColumnsResponse) XXX_DiscardUnknown()
- func (m *GetColumnsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetColumnsResponse) XXX_Merge(src proto.Message)
- func (m *GetColumnsResponse) XXX_Size() int
- func (m *GetColumnsResponse) XXX_Unmarshal(b []byte) error
- type GetDBRequest
- func (*GetDBRequest) Descriptor() ([]byte, []int)
- func (m *GetDBRequest) GetHeader() *RequestHeader
- func (m *GetDBRequest) GetName() string
- func (m *GetDBRequest) Marshal() (dAtA []byte, err error)
- func (m *GetDBRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDBRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDBRequest) ProtoMessage()
- func (m *GetDBRequest) Reset()
- func (m *GetDBRequest) Size() (n int)
- func (m *GetDBRequest) String() string
- func (m *GetDBRequest) Unmarshal(dAtA []byte) error
- func (m *GetDBRequest) XXX_DiscardUnknown()
- func (m *GetDBRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDBRequest) XXX_Merge(src proto.Message)
- func (m *GetDBRequest) XXX_Size() int
- func (m *GetDBRequest) XXX_Unmarshal(b []byte) error
- type GetDBResponse
- func (*GetDBResponse) Descriptor() ([]byte, []int)
- func (m *GetDBResponse) GetDb() *basepb.DataBase
- func (m *GetDBResponse) GetHeader() *ResponseHeader
- func (m *GetDBResponse) Marshal() (dAtA []byte, err error)
- func (m *GetDBResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDBResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDBResponse) ProtoMessage()
- func (m *GetDBResponse) Reset()
- func (m *GetDBResponse) Size() (n int)
- func (m *GetDBResponse) String() string
- func (m *GetDBResponse) Unmarshal(dAtA []byte) error
- func (m *GetDBResponse) XXX_DiscardUnknown()
- func (m *GetDBResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDBResponse) XXX_Merge(src proto.Message)
- func (m *GetDBResponse) XXX_Size() int
- func (m *GetDBResponse) XXX_Unmarshal(b []byte) error
- type GetDBsResponse
- func (*GetDBsResponse) Descriptor() ([]byte, []int)
- func (m *GetDBsResponse) GetDbs() []*basepb.DataBase
- func (m *GetDBsResponse) GetHeader() *ResponseHeader
- func (m *GetDBsResponse) Marshal() (dAtA []byte, err error)
- func (m *GetDBsResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDBsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDBsResponse) ProtoMessage()
- func (m *GetDBsResponse) Reset()
- func (m *GetDBsResponse) Size() (n int)
- func (m *GetDBsResponse) String() string
- func (m *GetDBsResponse) Unmarshal(dAtA []byte) error
- func (m *GetDBsResponse) XXX_DiscardUnknown()
- func (m *GetDBsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDBsResponse) XXX_Merge(src proto.Message)
- func (m *GetDBsResponse) XXX_Size() int
- func (m *GetDBsResponse) XXX_Unmarshal(b []byte) error
- type GetNodeInfo
- func (*GetNodeInfo) Descriptor() ([]byte, []int)
- func (m *GetNodeInfo) GetErr() string
- func (m *GetNodeInfo) GetInfo() *dspb.NodeInfoResponse
- func (m *GetNodeInfo) GetNode() *basepb.Node
- func (m *GetNodeInfo) Marshal() (dAtA []byte, err error)
- func (m *GetNodeInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *GetNodeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetNodeInfo) ProtoMessage()
- func (m *GetNodeInfo) Reset()
- func (m *GetNodeInfo) Size() (n int)
- func (m *GetNodeInfo) String() string
- func (m *GetNodeInfo) Unmarshal(dAtA []byte) error
- func (m *GetNodeInfo) XXX_DiscardUnknown()
- func (m *GetNodeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNodeInfo) XXX_Merge(src proto.Message)
- func (m *GetNodeInfo) XXX_Size() int
- func (m *GetNodeInfo) XXX_Unmarshal(b []byte) error
- type GetNodeInfoRequest
- func (*GetNodeInfoRequest) Descriptor() ([]byte, []int)
- func (m *GetNodeInfoRequest) GetHeader() *RequestHeader
- func (m *GetNodeInfoRequest) Marshal() (dAtA []byte, err error)
- func (m *GetNodeInfoRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetNodeInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetNodeInfoRequest) ProtoMessage()
- func (m *GetNodeInfoRequest) Reset()
- func (m *GetNodeInfoRequest) Size() (n int)
- func (m *GetNodeInfoRequest) String() string
- func (m *GetNodeInfoRequest) Unmarshal(dAtA []byte) error
- func (m *GetNodeInfoRequest) XXX_DiscardUnknown()
- func (m *GetNodeInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNodeInfoRequest) XXX_Merge(src proto.Message)
- func (m *GetNodeInfoRequest) XXX_Size() int
- func (m *GetNodeInfoRequest) XXX_Unmarshal(b []byte) error
- type GetNodeInfoResponse
- func (*GetNodeInfoResponse) Descriptor() ([]byte, []int)
- func (m *GetNodeInfoResponse) GetHeader() *ResponseHeader
- func (m *GetNodeInfoResponse) GetNodeInfos() []*GetNodeInfo
- func (m *GetNodeInfoResponse) Marshal() (dAtA []byte, err error)
- func (m *GetNodeInfoResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetNodeInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetNodeInfoResponse) ProtoMessage()
- func (m *GetNodeInfoResponse) Reset()
- func (m *GetNodeInfoResponse) Size() (n int)
- func (m *GetNodeInfoResponse) String() string
- func (m *GetNodeInfoResponse) Unmarshal(dAtA []byte) error
- func (m *GetNodeInfoResponse) XXX_DiscardUnknown()
- func (m *GetNodeInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNodeInfoResponse) XXX_Merge(src proto.Message)
- func (m *GetNodeInfoResponse) XXX_Size() int
- func (m *GetNodeInfoResponse) XXX_Unmarshal(b []byte) error
- type GetNodeRequest
- func (*GetNodeRequest) Descriptor() ([]byte, []int)
- func (m *GetNodeRequest) GetHeader() *RequestHeader
- func (m *GetNodeRequest) GetId() uint64
- func (m *GetNodeRequest) Marshal() (dAtA []byte, err error)
- func (m *GetNodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetNodeRequest) ProtoMessage()
- func (m *GetNodeRequest) Reset()
- func (m *GetNodeRequest) Size() (n int)
- func (m *GetNodeRequest) String() string
- func (m *GetNodeRequest) Unmarshal(dAtA []byte) error
- func (m *GetNodeRequest) XXX_DiscardUnknown()
- func (m *GetNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNodeRequest) XXX_Merge(src proto.Message)
- func (m *GetNodeRequest) XXX_Size() int
- func (m *GetNodeRequest) XXX_Unmarshal(b []byte) error
- type GetNodeResponse
- func (*GetNodeResponse) Descriptor() ([]byte, []int)
- func (m *GetNodeResponse) GetHeader() *ResponseHeader
- func (m *GetNodeResponse) GetNode() *basepb.Node
- func (m *GetNodeResponse) Marshal() (dAtA []byte, err error)
- func (m *GetNodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetNodeResponse) ProtoMessage()
- func (m *GetNodeResponse) Reset()
- func (m *GetNodeResponse) Size() (n int)
- func (m *GetNodeResponse) String() string
- func (m *GetNodeResponse) Unmarshal(dAtA []byte) error
- func (m *GetNodeResponse) XXX_DiscardUnknown()
- func (m *GetNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNodeResponse) XXX_Merge(src proto.Message)
- func (m *GetNodeResponse) XXX_Size() int
- func (m *GetNodeResponse) XXX_Unmarshal(b []byte) error
- type GetNodesRequest
- func (*GetNodesRequest) Descriptor() ([]byte, []int)
- func (m *GetNodesRequest) GetHeader() *RequestHeader
- func (m *GetNodesRequest) Marshal() (dAtA []byte, err error)
- func (m *GetNodesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetNodesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetNodesRequest) ProtoMessage()
- func (m *GetNodesRequest) Reset()
- func (m *GetNodesRequest) Size() (n int)
- func (m *GetNodesRequest) String() string
- func (m *GetNodesRequest) Unmarshal(dAtA []byte) error
- func (m *GetNodesRequest) XXX_DiscardUnknown()
- func (m *GetNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNodesRequest) XXX_Merge(src proto.Message)
- func (m *GetNodesRequest) XXX_Size() int
- func (m *GetNodesRequest) XXX_Unmarshal(b []byte) error
- type GetNodesResponse
- func (*GetNodesResponse) Descriptor() ([]byte, []int)
- func (m *GetNodesResponse) GetHeader() *ResponseHeader
- func (m *GetNodesResponse) GetNodes() []*basepb.Node
- func (m *GetNodesResponse) Marshal() (dAtA []byte, err error)
- func (m *GetNodesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetNodesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetNodesResponse) ProtoMessage()
- func (m *GetNodesResponse) Reset()
- func (m *GetNodesResponse) Size() (n int)
- func (m *GetNodesResponse) String() string
- func (m *GetNodesResponse) Unmarshal(dAtA []byte) error
- func (m *GetNodesResponse) XXX_DiscardUnknown()
- func (m *GetNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetNodesResponse) XXX_Merge(src proto.Message)
- func (m *GetNodesResponse) XXX_Size() int
- func (m *GetNodesResponse) XXX_Unmarshal(b []byte) error
- type GetRouteRequest
- func (*GetRouteRequest) Descriptor() ([]byte, []int)
- func (m *GetRouteRequest) GetDbId() uint64
- func (m *GetRouteRequest) GetHasAll() bool
- func (m *GetRouteRequest) GetHeader() *RequestHeader
- func (m *GetRouteRequest) GetKey() []byte
- func (m *GetRouteRequest) GetMax() uint32
- func (m *GetRouteRequest) GetRangeType() basepb.RangeType
- func (m *GetRouteRequest) GetTableId() uint64
- func (m *GetRouteRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRouteRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRouteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRouteRequest) ProtoMessage()
- func (m *GetRouteRequest) Reset()
- func (m *GetRouteRequest) Size() (n int)
- func (m *GetRouteRequest) String() string
- func (m *GetRouteRequest) Unmarshal(dAtA []byte) error
- func (m *GetRouteRequest) XXX_DiscardUnknown()
- func (m *GetRouteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRouteRequest) XXX_Merge(src proto.Message)
- func (m *GetRouteRequest) XXX_Size() int
- func (m *GetRouteRequest) XXX_Unmarshal(b []byte) error
- type GetRouteResponse
- func (*GetRouteResponse) Descriptor() ([]byte, []int)
- func (m *GetRouteResponse) GetHeader() *ResponseHeader
- func (m *GetRouteResponse) GetMaster() string
- func (m *GetRouteResponse) GetRoutes() []*basepb.Range
- func (m *GetRouteResponse) GetVersion() uint64
- func (m *GetRouteResponse) Marshal() (dAtA []byte, err error)
- func (m *GetRouteResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRouteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRouteResponse) ProtoMessage()
- func (m *GetRouteResponse) Reset()
- func (m *GetRouteResponse) Size() (n int)
- func (m *GetRouteResponse) String() string
- func (m *GetRouteResponse) Unmarshal(dAtA []byte) error
- func (m *GetRouteResponse) XXX_DiscardUnknown()
- func (m *GetRouteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRouteResponse) XXX_Merge(src proto.Message)
- func (m *GetRouteResponse) XXX_Size() int
- func (m *GetRouteResponse) XXX_Unmarshal(b []byte) error
- type GetTableRequest
- func (*GetTableRequest) Descriptor() ([]byte, []int)
- func (m *GetTableRequest) GetDbId() uint64
- func (m *GetTableRequest) GetDbName() string
- func (m *GetTableRequest) GetHeader() *RequestHeader
- func (m *GetTableRequest) GetTableId() uint64
- func (m *GetTableRequest) GetTableName() string
- func (m *GetTableRequest) Marshal() (dAtA []byte, err error)
- func (m *GetTableRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTableRequest) ProtoMessage()
- func (m *GetTableRequest) Reset()
- func (m *GetTableRequest) Size() (n int)
- func (m *GetTableRequest) String() string
- func (m *GetTableRequest) Unmarshal(dAtA []byte) error
- func (m *GetTableRequest) XXX_DiscardUnknown()
- func (m *GetTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTableRequest) XXX_Merge(src proto.Message)
- func (m *GetTableRequest) XXX_Size() int
- func (m *GetTableRequest) XXX_Unmarshal(b []byte) error
- type GetTableResponse
- func (*GetTableResponse) Descriptor() ([]byte, []int)
- func (m *GetTableResponse) GetHeader() *ResponseHeader
- func (m *GetTableResponse) GetTable() *basepb.Table
- func (m *GetTableResponse) Marshal() (dAtA []byte, err error)
- func (m *GetTableResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTableResponse) ProtoMessage()
- func (m *GetTableResponse) Reset()
- func (m *GetTableResponse) Size() (n int)
- func (m *GetTableResponse) String() string
- func (m *GetTableResponse) Unmarshal(dAtA []byte) error
- func (m *GetTableResponse) XXX_DiscardUnknown()
- func (m *GetTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTableResponse) XXX_Merge(src proto.Message)
- func (m *GetTableResponse) XXX_Size() int
- func (m *GetTableResponse) XXX_Unmarshal(b []byte) error
- type GetTablesRequest
- func (*GetTablesRequest) Descriptor() ([]byte, []int)
- func (m *GetTablesRequest) GetDbId() uint64
- func (m *GetTablesRequest) GetDbName() string
- func (m *GetTablesRequest) GetHeader() *RequestHeader
- func (m *GetTablesRequest) Marshal() (dAtA []byte, err error)
- func (m *GetTablesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTablesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTablesRequest) ProtoMessage()
- func (m *GetTablesRequest) Reset()
- func (m *GetTablesRequest) Size() (n int)
- func (m *GetTablesRequest) String() string
- func (m *GetTablesRequest) Unmarshal(dAtA []byte) error
- func (m *GetTablesRequest) XXX_DiscardUnknown()
- func (m *GetTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTablesRequest) XXX_Merge(src proto.Message)
- func (m *GetTablesRequest) XXX_Size() int
- func (m *GetTablesRequest) XXX_Unmarshal(b []byte) error
- type GetTablesResponse
- func (*GetTablesResponse) Descriptor() ([]byte, []int)
- func (m *GetTablesResponse) GetHeader() *ResponseHeader
- func (m *GetTablesResponse) GetTables() []*basepb.Table
- func (m *GetTablesResponse) Marshal() (dAtA []byte, err error)
- func (m *GetTablesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetTablesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetTablesResponse) ProtoMessage()
- func (m *GetTablesResponse) Reset()
- func (m *GetTablesResponse) Size() (n int)
- func (m *GetTablesResponse) String() string
- func (m *GetTablesResponse) Unmarshal(dAtA []byte) error
- func (m *GetTablesResponse) XXX_DiscardUnknown()
- func (m *GetTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetTablesResponse) XXX_Merge(src proto.Message)
- func (m *GetTablesResponse) XXX_Size() int
- func (m *GetTablesResponse) XXX_Unmarshal(b []byte) error
- type IdPair
- func (*IdPair) Descriptor() ([]byte, []int)
- func (m *IdPair) GetIdEnd() []byte
- func (m *IdPair) GetIdStart() []byte
- func (m *IdPair) Marshal() (dAtA []byte, err error)
- func (m *IdPair) MarshalTo(dAtA []byte) (int, error)
- func (m *IdPair) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IdPair) ProtoMessage()
- func (m *IdPair) Reset()
- func (m *IdPair) Size() (n int)
- func (m *IdPair) String() string
- func (m *IdPair) Unmarshal(dAtA []byte) error
- func (m *IdPair) XXX_DiscardUnknown()
- func (m *IdPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IdPair) XXX_Merge(src proto.Message)
- func (m *IdPair) XXX_Size() int
- func (m *IdPair) XXX_Unmarshal(b []byte) error
- type NodeHeartbeatRequest
- func (*NodeHeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *NodeHeartbeatRequest) GetHeader() *RequestHeader
- func (m *NodeHeartbeatRequest) GetNodeId() uint64
- func (m *NodeHeartbeatRequest) Marshal() (dAtA []byte, err error)
- func (m *NodeHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeHeartbeatRequest) ProtoMessage()
- func (m *NodeHeartbeatRequest) Reset()
- func (m *NodeHeartbeatRequest) Size() (n int)
- func (m *NodeHeartbeatRequest) String() string
- func (m *NodeHeartbeatRequest) Unmarshal(dAtA []byte) error
- func (m *NodeHeartbeatRequest) XXX_DiscardUnknown()
- func (m *NodeHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeHeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *NodeHeartbeatRequest) XXX_Size() int
- func (m *NodeHeartbeatRequest) XXX_Unmarshal(b []byte) error
- type NodeHeartbeatResponse
- func (*NodeHeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *NodeHeartbeatResponse) GetHeader() *ResponseHeader
- func (m *NodeHeartbeatResponse) GetNodeId() uint64
- func (m *NodeHeartbeatResponse) Marshal() (dAtA []byte, err error)
- func (m *NodeHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeHeartbeatResponse) ProtoMessage()
- func (m *NodeHeartbeatResponse) Reset()
- func (m *NodeHeartbeatResponse) Size() (n int)
- func (m *NodeHeartbeatResponse) String() string
- func (m *NodeHeartbeatResponse) Unmarshal(dAtA []byte) error
- func (m *NodeHeartbeatResponse) XXX_DiscardUnknown()
- func (m *NodeHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeHeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *NodeHeartbeatResponse) XXX_Size() int
- func (m *NodeHeartbeatResponse) XXX_Unmarshal(b []byte) error
- type PeerMoveRequest
- func (*PeerMoveRequest) Descriptor() ([]byte, []int)
- func (m *PeerMoveRequest) GetHeader() *RequestHeader
- func (m *PeerMoveRequest) GetRangeId() uint64
- func (m *PeerMoveRequest) GetStoreType() basepb.StoreType
- func (m *PeerMoveRequest) GetTableId() uint64
- func (m *PeerMoveRequest) Marshal() (dAtA []byte, err error)
- func (m *PeerMoveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PeerMoveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PeerMoveRequest) ProtoMessage()
- func (m *PeerMoveRequest) Reset()
- func (m *PeerMoveRequest) Size() (n int)
- func (m *PeerMoveRequest) String() string
- func (m *PeerMoveRequest) Unmarshal(dAtA []byte) error
- func (m *PeerMoveRequest) XXX_DiscardUnknown()
- func (m *PeerMoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerMoveRequest) XXX_Merge(src proto.Message)
- func (m *PeerMoveRequest) XXX_Size() int
- func (m *PeerMoveRequest) XXX_Unmarshal(b []byte) error
- type PeerMoveResponse
- func (*PeerMoveResponse) Descriptor() ([]byte, []int)
- func (m *PeerMoveResponse) GetHeader() *ResponseHeader
- func (m *PeerMoveResponse) Marshal() (dAtA []byte, err error)
- func (m *PeerMoveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PeerMoveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PeerMoveResponse) ProtoMessage()
- func (m *PeerMoveResponse) Reset()
- func (m *PeerMoveResponse) Size() (n int)
- func (m *PeerMoveResponse) String() string
- func (m *PeerMoveResponse) Unmarshal(dAtA []byte) error
- func (m *PeerMoveResponse) XXX_DiscardUnknown()
- func (m *PeerMoveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PeerMoveResponse) XXX_Merge(src proto.Message)
- func (m *PeerMoveResponse) XXX_Size() int
- func (m *PeerMoveResponse) XXX_Unmarshal(b []byte) error
- type RangeFingerprint
- func (*RangeFingerprint) Descriptor() ([]byte, []int)
- func (m *RangeFingerprint) GetDbId() uint64
- func (m *RangeFingerprint) GetPeerId() uint64
- func (m *RangeFingerprint) GetRangeEpoch() *basepb.RangeEpoch
- func (m *RangeFingerprint) GetRangeId() uint64
- func (m *RangeFingerprint) GetTableId() uint64
- func (m *RangeFingerprint) Marshal() (dAtA []byte, err error)
- func (m *RangeFingerprint) MarshalTo(dAtA []byte) (int, error)
- func (m *RangeFingerprint) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RangeFingerprint) ProtoMessage()
- func (m *RangeFingerprint) Reset()
- func (m *RangeFingerprint) Size() (n int)
- func (m *RangeFingerprint) String() string
- func (m *RangeFingerprint) Unmarshal(dAtA []byte) error
- func (m *RangeFingerprint) XXX_DiscardUnknown()
- func (m *RangeFingerprint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RangeFingerprint) XXX_Merge(src proto.Message)
- func (m *RangeFingerprint) XXX_Size() int
- func (m *RangeFingerprint) XXX_Unmarshal(b []byte) error
- type RangeHeartbeatRequest
- func (*RangeHeartbeatRequest) Descriptor() ([]byte, []int)
- func (m *RangeHeartbeatRequest) GetHeader() *RequestHeader
- func (m *RangeHeartbeatRequest) GetPeersStatus() []*basepb.PeerStatus
- func (m *RangeHeartbeatRequest) GetRange() *basepb.Range
- func (m *RangeHeartbeatRequest) GetTerm() uint64
- func (m *RangeHeartbeatRequest) Marshal() (dAtA []byte, err error)
- func (m *RangeHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RangeHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RangeHeartbeatRequest) ProtoMessage()
- func (m *RangeHeartbeatRequest) Reset()
- func (m *RangeHeartbeatRequest) Size() (n int)
- func (m *RangeHeartbeatRequest) String() string
- func (m *RangeHeartbeatRequest) Unmarshal(dAtA []byte) error
- func (m *RangeHeartbeatRequest) XXX_DiscardUnknown()
- func (m *RangeHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RangeHeartbeatRequest) XXX_Merge(src proto.Message)
- func (m *RangeHeartbeatRequest) XXX_Size() int
- func (m *RangeHeartbeatRequest) XXX_Unmarshal(b []byte) error
- type RangeHeartbeatResponse
- func (*RangeHeartbeatResponse) Descriptor() ([]byte, []int)
- func (m *RangeHeartbeatResponse) GetEpoch() *basepb.RangeEpoch
- func (m *RangeHeartbeatResponse) GetHeader() *ResponseHeader
- func (m *RangeHeartbeatResponse) GetRangeId() uint64
- func (m *RangeHeartbeatResponse) Marshal() (dAtA []byte, err error)
- func (m *RangeHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RangeHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RangeHeartbeatResponse) ProtoMessage()
- func (m *RangeHeartbeatResponse) Reset()
- func (m *RangeHeartbeatResponse) Size() (n int)
- func (m *RangeHeartbeatResponse) String() string
- func (m *RangeHeartbeatResponse) Unmarshal(dAtA []byte) error
- func (m *RangeHeartbeatResponse) XXX_DiscardUnknown()
- func (m *RangeHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RangeHeartbeatResponse) XXX_Merge(src proto.Message)
- func (m *RangeHeartbeatResponse) XXX_Size() int
- func (m *RangeHeartbeatResponse) XXX_Unmarshal(b []byte) error
- type RegisterNodeRequest
- func (*RegisterNodeRequest) Descriptor() ([]byte, []int)
- func (m *RegisterNodeRequest) GetAdminPort() uint32
- func (m *RegisterNodeRequest) GetHeader() *RequestHeader
- func (m *RegisterNodeRequest) GetRaftPort() uint32
- func (m *RegisterNodeRequest) GetRanges() []*RangeFingerprint
- func (m *RegisterNodeRequest) GetServerPort() uint32
- func (m *RegisterNodeRequest) GetStEngine() StorageEngine
- func (m *RegisterNodeRequest) GetVersion() string
- func (m *RegisterNodeRequest) Marshal() (dAtA []byte, err error)
- func (m *RegisterNodeRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterNodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterNodeRequest) ProtoMessage()
- func (m *RegisterNodeRequest) Reset()
- func (m *RegisterNodeRequest) Size() (n int)
- func (m *RegisterNodeRequest) String() string
- func (m *RegisterNodeRequest) Unmarshal(dAtA []byte) error
- func (m *RegisterNodeRequest) XXX_DiscardUnknown()
- func (m *RegisterNodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterNodeRequest) XXX_Merge(src proto.Message)
- func (m *RegisterNodeRequest) XXX_Size() int
- func (m *RegisterNodeRequest) XXX_Unmarshal(b []byte) error
- type RegisterNodeResponse
- func (*RegisterNodeResponse) Descriptor() ([]byte, []int)
- func (m *RegisterNodeResponse) GetHeader() *ResponseHeader
- func (m *RegisterNodeResponse) GetInvalidRanges() []uint64
- func (m *RegisterNodeResponse) GetNodeId() uint64
- func (m *RegisterNodeResponse) Marshal() (dAtA []byte, err error)
- func (m *RegisterNodeResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *RegisterNodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RegisterNodeResponse) ProtoMessage()
- func (m *RegisterNodeResponse) Reset()
- func (m *RegisterNodeResponse) Size() (n int)
- func (m *RegisterNodeResponse) String() string
- func (m *RegisterNodeResponse) Unmarshal(dAtA []byte) error
- func (m *RegisterNodeResponse) XXX_DiscardUnknown()
- func (m *RegisterNodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RegisterNodeResponse) XXX_Merge(src proto.Message)
- func (m *RegisterNodeResponse) XXX_Size() int
- func (m *RegisterNodeResponse) XXX_Unmarshal(b []byte) error
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)
- func (m *RequestHeader) GetClusterId() uint64
- func (m *RequestHeader) Marshal() (dAtA []byte, err error)
- func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequestHeader) ProtoMessage()
- func (m *RequestHeader) Reset()
- func (m *RequestHeader) Size() (n int)
- func (m *RequestHeader) String() string
- func (m *RequestHeader) Unmarshal(dAtA []byte) error
- func (m *RequestHeader) XXX_DiscardUnknown()
- func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestHeader) XXX_Merge(src proto.Message)
- func (m *RequestHeader) XXX_Size() int
- func (m *RequestHeader) XXX_Unmarshal(b []byte) error
- type ResponseHeader
- func (*ResponseHeader) Descriptor() ([]byte, []int)
- func (m *ResponseHeader) GetClusterId() uint64
- func (m *ResponseHeader) GetError() *Error
- func (m *ResponseHeader) Marshal() (dAtA []byte, err error)
- func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResponseHeader) ProtoMessage()
- func (m *ResponseHeader) Reset()
- func (m *ResponseHeader) Size() (n int)
- func (m *ResponseHeader) String() string
- func (m *ResponseHeader) Unmarshal(dAtA []byte) error
- func (m *ResponseHeader) XXX_DiscardUnknown()
- func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseHeader) XXX_Merge(src proto.Message)
- func (m *ResponseHeader) XXX_Size() int
- func (m *ResponseHeader) XXX_Unmarshal(b []byte) error
- type StorageEngine
- type WatcherEventRequest
- func (*WatcherEventRequest) Descriptor() ([]byte, []int)
- func (m *WatcherEventRequest) GetHeader() *RequestHeader
- func (m *WatcherEventRequest) GetMaster() string
- func (m *WatcherEventRequest) GetVersion() uint64
- func (m *WatcherEventRequest) Marshal() (dAtA []byte, err error)
- func (m *WatcherEventRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WatcherEventRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatcherEventRequest) ProtoMessage()
- func (m *WatcherEventRequest) Reset()
- func (m *WatcherEventRequest) Size() (n int)
- func (m *WatcherEventRequest) String() string
- func (m *WatcherEventRequest) Unmarshal(dAtA []byte) error
- func (m *WatcherEventRequest) XXX_DiscardUnknown()
- func (m *WatcherEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatcherEventRequest) XXX_Merge(src proto.Message)
- func (m *WatcherEventRequest) XXX_Size() int
- func (m *WatcherEventRequest) XXX_Unmarshal(b []byte) error
- type WatcherEventResponse
- func (*WatcherEventResponse) Descriptor() ([]byte, []int)
- func (m *WatcherEventResponse) GetEvents() []*basepb.WatcherEvent
- func (m *WatcherEventResponse) GetHeader() *ResponseHeader
- func (m *WatcherEventResponse) Marshal() (dAtA []byte, err error)
- func (m *WatcherEventResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *WatcherEventResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatcherEventResponse) ProtoMessage()
- func (m *WatcherEventResponse) Reset()
- func (m *WatcherEventResponse) Size() (n int)
- func (m *WatcherEventResponse) String() string
- func (m *WatcherEventResponse) Unmarshal(dAtA []byte) error
- func (m *WatcherEventResponse) XXX_DiscardUnknown()
- func (m *WatcherEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatcherEventResponse) XXX_Merge(src proto.Message)
- func (m *WatcherEventResponse) XXX_Size() int
- func (m *WatcherEventResponse) XXX_Unmarshal(b []byte) error
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) 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) MarshalToSizedBuffer ¶
func (m *AskSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*AskSplitResponse) ProtoMessage ¶
func (*AskSplitResponse) ProtoMessage()
func (*AskSplitResponse) Reset ¶
func (m *AskSplitResponse) Reset()
func (*AskSplitResponse) Size ¶
func (m *AskSplitResponse) Size() (n int)
func (*AskSplitResponse) String ¶
func (m *AskSplitResponse) String() string
func (*AskSplitResponse) Unmarshal ¶
func (m *AskSplitResponse) Unmarshal(dAtA []byte) error
func (*AskSplitResponse) XXX_DiscardUnknown ¶
func (m *AskSplitResponse) XXX_DiscardUnknown()
func (*AskSplitResponse) XXX_Marshal ¶
func (m *AskSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AskSplitResponse) XXX_Merge ¶
func (m *AskSplitResponse) XXX_Merge(src proto.Message)
func (*AskSplitResponse) XXX_Size ¶
func (m *AskSplitResponse) XXX_Size() int
func (*AskSplitResponse) XXX_Unmarshal ¶
func (m *AskSplitResponse) XXX_Unmarshal(b []byte) error
type ChangeNodeStateRequest ¶
type ChangeNodeStateRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` State basepb.NodeState `protobuf:"varint,3,opt,name=state,proto3,enum=basepb.NodeState" json:"state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChangeNodeStateRequest) Descriptor ¶
func (*ChangeNodeStateRequest) Descriptor() ([]byte, []int)
func (*ChangeNodeStateRequest) GetHeader ¶
func (m *ChangeNodeStateRequest) GetHeader() *RequestHeader
func (*ChangeNodeStateRequest) GetId ¶
func (m *ChangeNodeStateRequest) GetId() uint64
func (*ChangeNodeStateRequest) GetState ¶
func (m *ChangeNodeStateRequest) GetState() basepb.NodeState
func (*ChangeNodeStateRequest) Marshal ¶
func (m *ChangeNodeStateRequest) Marshal() (dAtA []byte, err error)
func (*ChangeNodeStateRequest) MarshalTo ¶
func (m *ChangeNodeStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*ChangeNodeStateRequest) MarshalToSizedBuffer ¶
func (m *ChangeNodeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangeNodeStateRequest) ProtoMessage ¶
func (*ChangeNodeStateRequest) ProtoMessage()
func (*ChangeNodeStateRequest) Reset ¶
func (m *ChangeNodeStateRequest) Reset()
func (*ChangeNodeStateRequest) Size ¶
func (m *ChangeNodeStateRequest) Size() (n int)
func (*ChangeNodeStateRequest) String ¶
func (m *ChangeNodeStateRequest) String() string
func (*ChangeNodeStateRequest) Unmarshal ¶
func (m *ChangeNodeStateRequest) Unmarshal(dAtA []byte) error
func (*ChangeNodeStateRequest) XXX_DiscardUnknown ¶
func (m *ChangeNodeStateRequest) XXX_DiscardUnknown()
func (*ChangeNodeStateRequest) XXX_Marshal ¶
func (m *ChangeNodeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangeNodeStateRequest) XXX_Merge ¶
func (m *ChangeNodeStateRequest) XXX_Merge(src proto.Message)
func (*ChangeNodeStateRequest) XXX_Size ¶
func (m *ChangeNodeStateRequest) XXX_Size() int
func (*ChangeNodeStateRequest) XXX_Unmarshal ¶
func (m *ChangeNodeStateRequest) XXX_Unmarshal(b []byte) error
type ChangeNodeStateResponse ¶
type ChangeNodeStateResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Node *basepb.Node `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChangeNodeStateResponse) Descriptor ¶
func (*ChangeNodeStateResponse) Descriptor() ([]byte, []int)
func (*ChangeNodeStateResponse) GetHeader ¶
func (m *ChangeNodeStateResponse) GetHeader() *ResponseHeader
func (*ChangeNodeStateResponse) GetNode ¶
func (m *ChangeNodeStateResponse) GetNode() *basepb.Node
func (*ChangeNodeStateResponse) Marshal ¶
func (m *ChangeNodeStateResponse) Marshal() (dAtA []byte, err error)
func (*ChangeNodeStateResponse) MarshalTo ¶
func (m *ChangeNodeStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*ChangeNodeStateResponse) MarshalToSizedBuffer ¶
func (m *ChangeNodeStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangeNodeStateResponse) ProtoMessage ¶
func (*ChangeNodeStateResponse) ProtoMessage()
func (*ChangeNodeStateResponse) Reset ¶
func (m *ChangeNodeStateResponse) Reset()
func (*ChangeNodeStateResponse) Size ¶
func (m *ChangeNodeStateResponse) Size() (n int)
func (*ChangeNodeStateResponse) String ¶
func (m *ChangeNodeStateResponse) String() string
func (*ChangeNodeStateResponse) Unmarshal ¶
func (m *ChangeNodeStateResponse) Unmarshal(dAtA []byte) error
func (*ChangeNodeStateResponse) XXX_DiscardUnknown ¶
func (m *ChangeNodeStateResponse) XXX_DiscardUnknown()
func (*ChangeNodeStateResponse) XXX_Marshal ¶
func (m *ChangeNodeStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangeNodeStateResponse) XXX_Merge ¶
func (m *ChangeNodeStateResponse) XXX_Merge(src proto.Message)
func (*ChangeNodeStateResponse) XXX_Size ¶
func (m *ChangeNodeStateResponse) XXX_Size() int
func (*ChangeNodeStateResponse) XXX_Unmarshal ¶
func (m *ChangeNodeStateResponse) XXX_Unmarshal(b []byte) error
type ChangeRangeStoreTypeRequest ¶
type ChangeRangeStoreTypeRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` TableId uint64 `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` RangeId uint64 `protobuf:"varint,3,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"` StoreType basepb.StoreType `protobuf:"varint,4,opt,name=store_type,json=storeType,proto3,enum=basepb.StoreType" json:"store_type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChangeRangeStoreTypeRequest) Descriptor ¶
func (*ChangeRangeStoreTypeRequest) Descriptor() ([]byte, []int)
func (*ChangeRangeStoreTypeRequest) GetHeader ¶
func (m *ChangeRangeStoreTypeRequest) GetHeader() *RequestHeader
func (*ChangeRangeStoreTypeRequest) GetRangeId ¶
func (m *ChangeRangeStoreTypeRequest) GetRangeId() uint64
func (*ChangeRangeStoreTypeRequest) GetStoreType ¶
func (m *ChangeRangeStoreTypeRequest) GetStoreType() basepb.StoreType
func (*ChangeRangeStoreTypeRequest) GetTableId ¶
func (m *ChangeRangeStoreTypeRequest) GetTableId() uint64
func (*ChangeRangeStoreTypeRequest) Marshal ¶
func (m *ChangeRangeStoreTypeRequest) Marshal() (dAtA []byte, err error)
func (*ChangeRangeStoreTypeRequest) MarshalTo ¶
func (m *ChangeRangeStoreTypeRequest) MarshalTo(dAtA []byte) (int, error)
func (*ChangeRangeStoreTypeRequest) MarshalToSizedBuffer ¶
func (m *ChangeRangeStoreTypeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangeRangeStoreTypeRequest) ProtoMessage ¶
func (*ChangeRangeStoreTypeRequest) ProtoMessage()
func (*ChangeRangeStoreTypeRequest) Reset ¶
func (m *ChangeRangeStoreTypeRequest) Reset()
func (*ChangeRangeStoreTypeRequest) Size ¶
func (m *ChangeRangeStoreTypeRequest) Size() (n int)
func (*ChangeRangeStoreTypeRequest) String ¶
func (m *ChangeRangeStoreTypeRequest) String() string
func (*ChangeRangeStoreTypeRequest) Unmarshal ¶
func (m *ChangeRangeStoreTypeRequest) Unmarshal(dAtA []byte) error
func (*ChangeRangeStoreTypeRequest) XXX_DiscardUnknown ¶
func (m *ChangeRangeStoreTypeRequest) XXX_DiscardUnknown()
func (*ChangeRangeStoreTypeRequest) XXX_Marshal ¶
func (m *ChangeRangeStoreTypeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangeRangeStoreTypeRequest) XXX_Merge ¶
func (m *ChangeRangeStoreTypeRequest) XXX_Merge(src proto.Message)
func (*ChangeRangeStoreTypeRequest) XXX_Size ¶
func (m *ChangeRangeStoreTypeRequest) XXX_Size() int
func (*ChangeRangeStoreTypeRequest) XXX_Unmarshal ¶
func (m *ChangeRangeStoreTypeRequest) XXX_Unmarshal(b []byte) error
type ChangeRangeStoreTypeResponse ¶
type ChangeRangeStoreTypeResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ChangeRangeStoreTypeResponse) Descriptor ¶
func (*ChangeRangeStoreTypeResponse) Descriptor() ([]byte, []int)
func (*ChangeRangeStoreTypeResponse) GetHeader ¶
func (m *ChangeRangeStoreTypeResponse) GetHeader() *ResponseHeader
func (*ChangeRangeStoreTypeResponse) Marshal ¶
func (m *ChangeRangeStoreTypeResponse) Marshal() (dAtA []byte, err error)
func (*ChangeRangeStoreTypeResponse) MarshalTo ¶
func (m *ChangeRangeStoreTypeResponse) MarshalTo(dAtA []byte) (int, error)
func (*ChangeRangeStoreTypeResponse) MarshalToSizedBuffer ¶
func (m *ChangeRangeStoreTypeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ChangeRangeStoreTypeResponse) ProtoMessage ¶
func (*ChangeRangeStoreTypeResponse) ProtoMessage()
func (*ChangeRangeStoreTypeResponse) Reset ¶
func (m *ChangeRangeStoreTypeResponse) Reset()
func (*ChangeRangeStoreTypeResponse) Size ¶
func (m *ChangeRangeStoreTypeResponse) Size() (n int)
func (*ChangeRangeStoreTypeResponse) String ¶
func (m *ChangeRangeStoreTypeResponse) String() string
func (*ChangeRangeStoreTypeResponse) Unmarshal ¶
func (m *ChangeRangeStoreTypeResponse) Unmarshal(dAtA []byte) error
func (*ChangeRangeStoreTypeResponse) XXX_DiscardUnknown ¶
func (m *ChangeRangeStoreTypeResponse) XXX_DiscardUnknown()
func (*ChangeRangeStoreTypeResponse) XXX_Marshal ¶
func (m *ChangeRangeStoreTypeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ChangeRangeStoreTypeResponse) XXX_Merge ¶
func (m *ChangeRangeStoreTypeResponse) XXX_Merge(src proto.Message)
func (*ChangeRangeStoreTypeResponse) XXX_Size ¶
func (m *ChangeRangeStoreTypeResponse) XXX_Size() int
func (*ChangeRangeStoreTypeResponse) XXX_Unmarshal ¶
func (m *ChangeRangeStoreTypeResponse) XXX_Unmarshal(b []byte) error
type CheckNodeStateRequest ¶
type CheckNodeStateRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CheckNodeStateRequest) Descriptor ¶
func (*CheckNodeStateRequest) Descriptor() ([]byte, []int)
func (*CheckNodeStateRequest) GetHeader ¶
func (m *CheckNodeStateRequest) GetHeader() *RequestHeader
func (*CheckNodeStateRequest) GetId ¶
func (m *CheckNodeStateRequest) GetId() uint64
func (*CheckNodeStateRequest) Marshal ¶
func (m *CheckNodeStateRequest) Marshal() (dAtA []byte, err error)
func (*CheckNodeStateRequest) MarshalTo ¶
func (m *CheckNodeStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*CheckNodeStateRequest) MarshalToSizedBuffer ¶
func (m *CheckNodeStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckNodeStateRequest) ProtoMessage ¶
func (*CheckNodeStateRequest) ProtoMessage()
func (*CheckNodeStateRequest) Reset ¶
func (m *CheckNodeStateRequest) Reset()
func (*CheckNodeStateRequest) Size ¶
func (m *CheckNodeStateRequest) Size() (n int)
func (*CheckNodeStateRequest) String ¶
func (m *CheckNodeStateRequest) String() string
func (*CheckNodeStateRequest) Unmarshal ¶
func (m *CheckNodeStateRequest) Unmarshal(dAtA []byte) error
func (*CheckNodeStateRequest) XXX_DiscardUnknown ¶
func (m *CheckNodeStateRequest) XXX_DiscardUnknown()
func (*CheckNodeStateRequest) XXX_Marshal ¶
func (m *CheckNodeStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckNodeStateRequest) XXX_Merge ¶
func (m *CheckNodeStateRequest) XXX_Merge(src proto.Message)
func (*CheckNodeStateRequest) XXX_Size ¶
func (m *CheckNodeStateRequest) XXX_Size() int
func (*CheckNodeStateRequest) XXX_Unmarshal ¶
func (m *CheckNodeStateRequest) XXX_Unmarshal(b []byte) error
type CheckNodeStateResponse ¶
type CheckNodeStateResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` RangeNum uint64 `protobuf:"varint,2,opt,name=range_num,json=rangeNum,proto3" json:"range_num,omitempty"` LeaderNum uint64 `protobuf:"varint,3,opt,name=leader_num,json=leaderNum,proto3" json:"leader_num,omitempty"` State basepb.NodeState `protobuf:"varint,4,opt,name=state,proto3,enum=basepb.NodeState" json:"state,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CheckNodeStateResponse) Descriptor ¶
func (*CheckNodeStateResponse) Descriptor() ([]byte, []int)
func (*CheckNodeStateResponse) GetHeader ¶
func (m *CheckNodeStateResponse) GetHeader() *ResponseHeader
func (*CheckNodeStateResponse) GetLeaderNum ¶
func (m *CheckNodeStateResponse) GetLeaderNum() uint64
func (*CheckNodeStateResponse) GetRangeNum ¶
func (m *CheckNodeStateResponse) GetRangeNum() uint64
func (*CheckNodeStateResponse) GetState ¶
func (m *CheckNodeStateResponse) GetState() basepb.NodeState
func (*CheckNodeStateResponse) Marshal ¶
func (m *CheckNodeStateResponse) Marshal() (dAtA []byte, err error)
func (*CheckNodeStateResponse) MarshalTo ¶
func (m *CheckNodeStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*CheckNodeStateResponse) MarshalToSizedBuffer ¶
func (m *CheckNodeStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CheckNodeStateResponse) ProtoMessage ¶
func (*CheckNodeStateResponse) ProtoMessage()
func (*CheckNodeStateResponse) Reset ¶
func (m *CheckNodeStateResponse) Reset()
func (*CheckNodeStateResponse) Size ¶
func (m *CheckNodeStateResponse) Size() (n int)
func (*CheckNodeStateResponse) String ¶
func (m *CheckNodeStateResponse) String() string
func (*CheckNodeStateResponse) Unmarshal ¶
func (m *CheckNodeStateResponse) Unmarshal(dAtA []byte) error
func (*CheckNodeStateResponse) XXX_DiscardUnknown ¶
func (m *CheckNodeStateResponse) XXX_DiscardUnknown()
func (*CheckNodeStateResponse) XXX_Marshal ¶
func (m *CheckNodeStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CheckNodeStateResponse) XXX_Merge ¶
func (m *CheckNodeStateResponse) XXX_Merge(src proto.Message)
func (*CheckNodeStateResponse) XXX_Size ¶
func (m *CheckNodeStateResponse) XXX_Size() int
func (*CheckNodeStateResponse) XXX_Unmarshal ¶
func (m *CheckNodeStateResponse) XXX_Unmarshal(b []byte) error
type ClusterInfoRequest ¶
type ClusterInfoRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterInfoRequest) Descriptor ¶
func (*ClusterInfoRequest) Descriptor() ([]byte, []int)
func (*ClusterInfoRequest) GetHeader ¶
func (m *ClusterInfoRequest) GetHeader() *RequestHeader
func (*ClusterInfoRequest) Marshal ¶
func (m *ClusterInfoRequest) Marshal() (dAtA []byte, err error)
func (*ClusterInfoRequest) MarshalTo ¶
func (m *ClusterInfoRequest) MarshalTo(dAtA []byte) (int, error)
func (*ClusterInfoRequest) MarshalToSizedBuffer ¶
func (m *ClusterInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterInfoRequest) ProtoMessage ¶
func (*ClusterInfoRequest) ProtoMessage()
func (*ClusterInfoRequest) Reset ¶
func (m *ClusterInfoRequest) Reset()
func (*ClusterInfoRequest) Size ¶
func (m *ClusterInfoRequest) Size() (n int)
func (*ClusterInfoRequest) String ¶
func (m *ClusterInfoRequest) String() string
func (*ClusterInfoRequest) Unmarshal ¶
func (m *ClusterInfoRequest) Unmarshal(dAtA []byte) error
func (*ClusterInfoRequest) XXX_DiscardUnknown ¶
func (m *ClusterInfoRequest) XXX_DiscardUnknown()
func (*ClusterInfoRequest) XXX_Marshal ¶
func (m *ClusterInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterInfoRequest) XXX_Merge ¶
func (m *ClusterInfoRequest) XXX_Merge(src proto.Message)
func (*ClusterInfoRequest) XXX_Size ¶
func (m *ClusterInfoRequest) XXX_Size() int
func (*ClusterInfoRequest) XXX_Unmarshal ¶
func (m *ClusterInfoRequest) XXX_Unmarshal(b []byte) error
type ClusterInfoResponse ¶
type ClusterInfoResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` BuildVersion string `protobuf:"bytes,2,opt,name=build_version,json=buildVersion,proto3" json:"build_version,omitempty"` BuildTime string `protobuf:"bytes,3,opt,name=build_time,json=buildTime,proto3" json:"build_time,omitempty"` CommitId string `protobuf:"bytes,4,opt,name=commit_id,json=commitId,proto3" json:"commit_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ClusterInfoResponse) Descriptor ¶
func (*ClusterInfoResponse) Descriptor() ([]byte, []int)
func (*ClusterInfoResponse) GetBuildTime ¶
func (m *ClusterInfoResponse) GetBuildTime() string
func (*ClusterInfoResponse) GetBuildVersion ¶
func (m *ClusterInfoResponse) GetBuildVersion() string
func (*ClusterInfoResponse) GetCommitId ¶
func (m *ClusterInfoResponse) GetCommitId() string
func (*ClusterInfoResponse) GetHeader ¶
func (m *ClusterInfoResponse) GetHeader() *ResponseHeader
func (*ClusterInfoResponse) Marshal ¶
func (m *ClusterInfoResponse) Marshal() (dAtA []byte, err error)
func (*ClusterInfoResponse) MarshalTo ¶
func (m *ClusterInfoResponse) MarshalTo(dAtA []byte) (int, error)
func (*ClusterInfoResponse) MarshalToSizedBuffer ¶
func (m *ClusterInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ClusterInfoResponse) ProtoMessage ¶
func (*ClusterInfoResponse) ProtoMessage()
func (*ClusterInfoResponse) Reset ¶
func (m *ClusterInfoResponse) Reset()
func (*ClusterInfoResponse) Size ¶
func (m *ClusterInfoResponse) Size() (n int)
func (*ClusterInfoResponse) String ¶
func (m *ClusterInfoResponse) String() string
func (*ClusterInfoResponse) Unmarshal ¶
func (m *ClusterInfoResponse) Unmarshal(dAtA []byte) error
func (*ClusterInfoResponse) XXX_DiscardUnknown ¶
func (m *ClusterInfoResponse) XXX_DiscardUnknown()
func (*ClusterInfoResponse) XXX_Marshal ¶
func (m *ClusterInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClusterInfoResponse) XXX_Merge ¶
func (m *ClusterInfoResponse) XXX_Merge(src proto.Message)
func (*ClusterInfoResponse) XXX_Size ¶
func (m *ClusterInfoResponse) XXX_Size() int
func (*ClusterInfoResponse) XXX_Unmarshal ¶
func (m *ClusterInfoResponse) XXX_Unmarshal(b []byte) error
type CountTableRequest ¶
type CountTableRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CountTableRequest) Descriptor ¶
func (*CountTableRequest) Descriptor() ([]byte, []int)
func (*CountTableRequest) GetHeader ¶
func (m *CountTableRequest) GetHeader() *RequestHeader
func (*CountTableRequest) Marshal ¶
func (m *CountTableRequest) Marshal() (dAtA []byte, err error)
func (*CountTableRequest) MarshalTo ¶
func (m *CountTableRequest) MarshalTo(dAtA []byte) (int, error)
func (*CountTableRequest) MarshalToSizedBuffer ¶
func (m *CountTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CountTableRequest) ProtoMessage ¶
func (*CountTableRequest) ProtoMessage()
func (*CountTableRequest) Reset ¶
func (m *CountTableRequest) Reset()
func (*CountTableRequest) Size ¶
func (m *CountTableRequest) Size() (n int)
func (*CountTableRequest) String ¶
func (m *CountTableRequest) String() string
func (*CountTableRequest) Unmarshal ¶
func (m *CountTableRequest) Unmarshal(dAtA []byte) error
func (*CountTableRequest) XXX_DiscardUnknown ¶
func (m *CountTableRequest) XXX_DiscardUnknown()
func (*CountTableRequest) XXX_Marshal ¶
func (m *CountTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CountTableRequest) XXX_Merge ¶
func (m *CountTableRequest) XXX_Merge(src proto.Message)
func (*CountTableRequest) XXX_Size ¶
func (m *CountTableRequest) XXX_Size() int
func (*CountTableRequest) XXX_Unmarshal ¶
func (m *CountTableRequest) XXX_Unmarshal(b []byte) error
type CountTableResponse ¶
type CountTableResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` List []*Counter `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CountTableResponse) Descriptor ¶
func (*CountTableResponse) Descriptor() ([]byte, []int)
func (*CountTableResponse) GetHeader ¶
func (m *CountTableResponse) GetHeader() *ResponseHeader
func (*CountTableResponse) GetList ¶
func (m *CountTableResponse) GetList() []*Counter
func (*CountTableResponse) Marshal ¶
func (m *CountTableResponse) Marshal() (dAtA []byte, err error)
func (*CountTableResponse) MarshalTo ¶
func (m *CountTableResponse) MarshalTo(dAtA []byte) (int, error)
func (*CountTableResponse) MarshalToSizedBuffer ¶
func (m *CountTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CountTableResponse) ProtoMessage ¶
func (*CountTableResponse) ProtoMessage()
func (*CountTableResponse) Reset ¶
func (m *CountTableResponse) Reset()
func (*CountTableResponse) Size ¶
func (m *CountTableResponse) Size() (n int)
func (*CountTableResponse) String ¶
func (m *CountTableResponse) String() string
func (*CountTableResponse) Unmarshal ¶
func (m *CountTableResponse) Unmarshal(dAtA []byte) error
func (*CountTableResponse) XXX_DiscardUnknown ¶
func (m *CountTableResponse) XXX_DiscardUnknown()
func (*CountTableResponse) XXX_Marshal ¶
func (m *CountTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CountTableResponse) XXX_Merge ¶
func (m *CountTableResponse) XXX_Merge(src proto.Message)
func (*CountTableResponse) XXX_Size ¶
func (m *CountTableResponse) XXX_Size() int
func (*CountTableResponse) XXX_Unmarshal ¶
func (m *CountTableResponse) XXX_Unmarshal(b []byte) error
type Counter ¶
type Counter struct { DbId uint64 `protobuf:"varint,1,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` TableId uint64 `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` Count uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Counter) Descriptor ¶
func (*Counter) GetTableId ¶
func (*Counter) MarshalToSizedBuffer ¶
func (*Counter) ProtoMessage ¶
func (*Counter) ProtoMessage()
func (*Counter) XXX_DiscardUnknown ¶
func (m *Counter) XXX_DiscardUnknown()
func (*Counter) XXX_Marshal ¶
func (*Counter) XXX_Unmarshal ¶
type CreateDatabaseRequest ¶
type CreateDatabaseRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateDatabaseRequest) Descriptor ¶
func (*CreateDatabaseRequest) Descriptor() ([]byte, []int)
func (*CreateDatabaseRequest) GetHeader ¶
func (m *CreateDatabaseRequest) GetHeader() *RequestHeader
func (*CreateDatabaseRequest) GetName ¶
func (m *CreateDatabaseRequest) GetName() string
func (*CreateDatabaseRequest) Marshal ¶
func (m *CreateDatabaseRequest) Marshal() (dAtA []byte, err error)
func (*CreateDatabaseRequest) MarshalTo ¶
func (m *CreateDatabaseRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateDatabaseRequest) MarshalToSizedBuffer ¶
func (m *CreateDatabaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateDatabaseRequest) ProtoMessage ¶
func (*CreateDatabaseRequest) ProtoMessage()
func (*CreateDatabaseRequest) Reset ¶
func (m *CreateDatabaseRequest) Reset()
func (*CreateDatabaseRequest) Size ¶
func (m *CreateDatabaseRequest) Size() (n int)
func (*CreateDatabaseRequest) String ¶
func (m *CreateDatabaseRequest) String() string
func (*CreateDatabaseRequest) Unmarshal ¶
func (m *CreateDatabaseRequest) Unmarshal(dAtA []byte) error
func (*CreateDatabaseRequest) XXX_DiscardUnknown ¶
func (m *CreateDatabaseRequest) XXX_DiscardUnknown()
func (*CreateDatabaseRequest) XXX_Marshal ¶
func (m *CreateDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateDatabaseRequest) XXX_Merge ¶
func (m *CreateDatabaseRequest) XXX_Merge(src proto.Message)
func (*CreateDatabaseRequest) XXX_Size ¶
func (m *CreateDatabaseRequest) XXX_Size() int
func (*CreateDatabaseRequest) XXX_Unmarshal ¶
func (m *CreateDatabaseRequest) XXX_Unmarshal(b []byte) error
type CreateDatabaseResponse ¶
type CreateDatabaseResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Database *basepb.DataBase `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateDatabaseResponse) Descriptor ¶
func (*CreateDatabaseResponse) Descriptor() ([]byte, []int)
func (*CreateDatabaseResponse) GetDatabase ¶
func (m *CreateDatabaseResponse) GetDatabase() *basepb.DataBase
func (*CreateDatabaseResponse) GetHeader ¶
func (m *CreateDatabaseResponse) GetHeader() *ResponseHeader
func (*CreateDatabaseResponse) Marshal ¶
func (m *CreateDatabaseResponse) Marshal() (dAtA []byte, err error)
func (*CreateDatabaseResponse) MarshalTo ¶
func (m *CreateDatabaseResponse) MarshalTo(dAtA []byte) (int, error)
func (*CreateDatabaseResponse) MarshalToSizedBuffer ¶
func (m *CreateDatabaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateDatabaseResponse) ProtoMessage ¶
func (*CreateDatabaseResponse) ProtoMessage()
func (*CreateDatabaseResponse) Reset ¶
func (m *CreateDatabaseResponse) Reset()
func (*CreateDatabaseResponse) Size ¶
func (m *CreateDatabaseResponse) Size() (n int)
func (*CreateDatabaseResponse) String ¶
func (m *CreateDatabaseResponse) String() string
func (*CreateDatabaseResponse) Unmarshal ¶
func (m *CreateDatabaseResponse) Unmarshal(dAtA []byte) error
func (*CreateDatabaseResponse) XXX_DiscardUnknown ¶
func (m *CreateDatabaseResponse) XXX_DiscardUnknown()
func (*CreateDatabaseResponse) XXX_Marshal ¶
func (m *CreateDatabaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateDatabaseResponse) XXX_Merge ¶
func (m *CreateDatabaseResponse) XXX_Merge(src proto.Message)
func (*CreateDatabaseResponse) XXX_Size ¶
func (m *CreateDatabaseResponse) XXX_Size() int
func (*CreateDatabaseResponse) XXX_Unmarshal ¶
func (m *CreateDatabaseResponse) XXX_Unmarshal(b []byte) error
type CreateTableRequest ¶
type CreateTableRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbName string `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"` TableName string `protobuf:"bytes,3,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` Properties string `protobuf:"bytes,4,opt,name=properties,proto3" json:"properties,omitempty"` RangeKeys []string `protobuf:"bytes,5,rep,name=range_keys,json=rangeKeys,proto3" json:"range_keys,omitempty"` //warm hot or mix default hot StoreType string `protobuf:"bytes,6,opt,name=store_type,json=storeType,proto3" json:"store_type,omitempty"` //replica num default is 3 ReplicaNum uint64 `protobuf:"varint,7,opt,name=replica_num,json=replicaNum,proto3" json:"replica_num,omitempty"` // how many date range live default 2 DataRangeNum uint64 `protobuf:"varint,8,opt,name=data_range_num,json=dataRangeNum,proto3" json:"data_range_num,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateTableRequest) Descriptor ¶
func (*CreateTableRequest) Descriptor() ([]byte, []int)
func (*CreateTableRequest) GetDataRangeNum ¶
func (m *CreateTableRequest) GetDataRangeNum() uint64
func (*CreateTableRequest) GetDbName ¶
func (m *CreateTableRequest) GetDbName() string
func (*CreateTableRequest) GetHeader ¶
func (m *CreateTableRequest) GetHeader() *RequestHeader
func (*CreateTableRequest) GetProperties ¶
func (m *CreateTableRequest) GetProperties() string
func (*CreateTableRequest) GetRangeKeys ¶
func (m *CreateTableRequest) GetRangeKeys() []string
func (*CreateTableRequest) GetReplicaNum ¶
func (m *CreateTableRequest) GetReplicaNum() uint64
func (*CreateTableRequest) GetStoreType ¶
func (m *CreateTableRequest) GetStoreType() string
func (*CreateTableRequest) GetTableName ¶
func (m *CreateTableRequest) GetTableName() string
func (*CreateTableRequest) Marshal ¶
func (m *CreateTableRequest) Marshal() (dAtA []byte, err error)
func (*CreateTableRequest) MarshalTo ¶
func (m *CreateTableRequest) MarshalTo(dAtA []byte) (int, error)
func (*CreateTableRequest) MarshalToSizedBuffer ¶
func (m *CreateTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateTableRequest) ProtoMessage ¶
func (*CreateTableRequest) ProtoMessage()
func (*CreateTableRequest) Reset ¶
func (m *CreateTableRequest) Reset()
func (*CreateTableRequest) Size ¶
func (m *CreateTableRequest) Size() (n int)
func (*CreateTableRequest) String ¶
func (m *CreateTableRequest) String() string
func (*CreateTableRequest) Unmarshal ¶
func (m *CreateTableRequest) Unmarshal(dAtA []byte) error
func (*CreateTableRequest) XXX_DiscardUnknown ¶
func (m *CreateTableRequest) XXX_DiscardUnknown()
func (*CreateTableRequest) XXX_Marshal ¶
func (m *CreateTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateTableRequest) XXX_Merge ¶
func (m *CreateTableRequest) XXX_Merge(src proto.Message)
func (*CreateTableRequest) XXX_Size ¶
func (m *CreateTableRequest) XXX_Size() int
func (*CreateTableRequest) XXX_Unmarshal ¶
func (m *CreateTableRequest) XXX_Unmarshal(b []byte) error
type CreateTableResponse ¶
type CreateTableResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Table *basepb.Table `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*CreateTableResponse) Descriptor ¶
func (*CreateTableResponse) Descriptor() ([]byte, []int)
func (*CreateTableResponse) GetHeader ¶
func (m *CreateTableResponse) GetHeader() *ResponseHeader
func (*CreateTableResponse) GetTable ¶
func (m *CreateTableResponse) GetTable() *basepb.Table
func (*CreateTableResponse) Marshal ¶
func (m *CreateTableResponse) Marshal() (dAtA []byte, err error)
func (*CreateTableResponse) MarshalTo ¶
func (m *CreateTableResponse) MarshalTo(dAtA []byte) (int, error)
func (*CreateTableResponse) MarshalToSizedBuffer ¶
func (m *CreateTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*CreateTableResponse) ProtoMessage ¶
func (*CreateTableResponse) ProtoMessage()
func (*CreateTableResponse) Reset ¶
func (m *CreateTableResponse) Reset()
func (*CreateTableResponse) Size ¶
func (m *CreateTableResponse) Size() (n int)
func (*CreateTableResponse) String ¶
func (m *CreateTableResponse) String() string
func (*CreateTableResponse) Unmarshal ¶
func (m *CreateTableResponse) Unmarshal(dAtA []byte) error
func (*CreateTableResponse) XXX_DiscardUnknown ¶
func (m *CreateTableResponse) XXX_DiscardUnknown()
func (*CreateTableResponse) XXX_Marshal ¶
func (m *CreateTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CreateTableResponse) XXX_Merge ¶
func (m *CreateTableResponse) XXX_Merge(src proto.Message)
func (*CreateTableResponse) XXX_Size ¶
func (m *CreateTableResponse) XXX_Size() int
func (*CreateTableResponse) XXX_Unmarshal ¶
func (m *CreateTableResponse) XXX_Unmarshal(b []byte) error
type DelDatabaseRequest ¶
type DelDatabaseRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DelDatabaseRequest) Descriptor ¶
func (*DelDatabaseRequest) Descriptor() ([]byte, []int)
func (*DelDatabaseRequest) GetHeader ¶
func (m *DelDatabaseRequest) GetHeader() *RequestHeader
func (*DelDatabaseRequest) GetId ¶
func (m *DelDatabaseRequest) GetId() uint64
func (*DelDatabaseRequest) GetName ¶
func (m *DelDatabaseRequest) GetName() string
func (*DelDatabaseRequest) Marshal ¶
func (m *DelDatabaseRequest) Marshal() (dAtA []byte, err error)
func (*DelDatabaseRequest) MarshalTo ¶
func (m *DelDatabaseRequest) MarshalTo(dAtA []byte) (int, error)
func (*DelDatabaseRequest) MarshalToSizedBuffer ¶
func (m *DelDatabaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DelDatabaseRequest) ProtoMessage ¶
func (*DelDatabaseRequest) ProtoMessage()
func (*DelDatabaseRequest) Reset ¶
func (m *DelDatabaseRequest) Reset()
func (*DelDatabaseRequest) Size ¶
func (m *DelDatabaseRequest) Size() (n int)
func (*DelDatabaseRequest) String ¶
func (m *DelDatabaseRequest) String() string
func (*DelDatabaseRequest) Unmarshal ¶
func (m *DelDatabaseRequest) Unmarshal(dAtA []byte) error
func (*DelDatabaseRequest) XXX_DiscardUnknown ¶
func (m *DelDatabaseRequest) XXX_DiscardUnknown()
func (*DelDatabaseRequest) XXX_Marshal ¶
func (m *DelDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelDatabaseRequest) XXX_Merge ¶
func (m *DelDatabaseRequest) XXX_Merge(src proto.Message)
func (*DelDatabaseRequest) XXX_Size ¶
func (m *DelDatabaseRequest) XXX_Size() int
func (*DelDatabaseRequest) XXX_Unmarshal ¶
func (m *DelDatabaseRequest) XXX_Unmarshal(b []byte) error
type DelDatabaseResponse ¶
type DelDatabaseResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DelDatabaseResponse) Descriptor ¶
func (*DelDatabaseResponse) Descriptor() ([]byte, []int)
func (*DelDatabaseResponse) GetHeader ¶
func (m *DelDatabaseResponse) GetHeader() *ResponseHeader
func (*DelDatabaseResponse) Marshal ¶
func (m *DelDatabaseResponse) Marshal() (dAtA []byte, err error)
func (*DelDatabaseResponse) MarshalTo ¶
func (m *DelDatabaseResponse) MarshalTo(dAtA []byte) (int, error)
func (*DelDatabaseResponse) MarshalToSizedBuffer ¶
func (m *DelDatabaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DelDatabaseResponse) ProtoMessage ¶
func (*DelDatabaseResponse) ProtoMessage()
func (*DelDatabaseResponse) Reset ¶
func (m *DelDatabaseResponse) Reset()
func (*DelDatabaseResponse) Size ¶
func (m *DelDatabaseResponse) Size() (n int)
func (*DelDatabaseResponse) String ¶
func (m *DelDatabaseResponse) String() string
func (*DelDatabaseResponse) Unmarshal ¶
func (m *DelDatabaseResponse) Unmarshal(dAtA []byte) error
func (*DelDatabaseResponse) XXX_DiscardUnknown ¶
func (m *DelDatabaseResponse) XXX_DiscardUnknown()
func (*DelDatabaseResponse) XXX_Marshal ¶
func (m *DelDatabaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelDatabaseResponse) XXX_Merge ¶
func (m *DelDatabaseResponse) XXX_Merge(src proto.Message)
func (*DelDatabaseResponse) XXX_Size ¶
func (m *DelDatabaseResponse) XXX_Size() int
func (*DelDatabaseResponse) XXX_Unmarshal ¶
func (m *DelDatabaseResponse) XXX_Unmarshal(b []byte) error
type DelTableRequest ¶
type DelTableRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbId uint64 `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` DbName string `protobuf:"bytes,3,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"` TableId uint64 `protobuf:"varint,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` TableName string `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DelTableRequest) Descriptor ¶
func (*DelTableRequest) Descriptor() ([]byte, []int)
func (*DelTableRequest) GetDbId ¶
func (m *DelTableRequest) GetDbId() uint64
func (*DelTableRequest) GetDbName ¶
func (m *DelTableRequest) GetDbName() string
func (*DelTableRequest) GetHeader ¶
func (m *DelTableRequest) GetHeader() *RequestHeader
func (*DelTableRequest) GetTableId ¶
func (m *DelTableRequest) GetTableId() uint64
func (*DelTableRequest) GetTableName ¶
func (m *DelTableRequest) GetTableName() string
func (*DelTableRequest) Marshal ¶
func (m *DelTableRequest) Marshal() (dAtA []byte, err error)
func (*DelTableRequest) MarshalToSizedBuffer ¶
func (m *DelTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DelTableRequest) ProtoMessage ¶
func (*DelTableRequest) ProtoMessage()
func (*DelTableRequest) Reset ¶
func (m *DelTableRequest) Reset()
func (*DelTableRequest) Size ¶
func (m *DelTableRequest) Size() (n int)
func (*DelTableRequest) String ¶
func (m *DelTableRequest) String() string
func (*DelTableRequest) Unmarshal ¶
func (m *DelTableRequest) Unmarshal(dAtA []byte) error
func (*DelTableRequest) XXX_DiscardUnknown ¶
func (m *DelTableRequest) XXX_DiscardUnknown()
func (*DelTableRequest) XXX_Marshal ¶
func (m *DelTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelTableRequest) XXX_Merge ¶
func (m *DelTableRequest) XXX_Merge(src proto.Message)
func (*DelTableRequest) XXX_Size ¶
func (m *DelTableRequest) XXX_Size() int
func (*DelTableRequest) XXX_Unmarshal ¶
func (m *DelTableRequest) XXX_Unmarshal(b []byte) error
type DelTableResponse ¶
type DelTableResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Table *basepb.Table `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DelTableResponse) Descriptor ¶
func (*DelTableResponse) Descriptor() ([]byte, []int)
func (*DelTableResponse) GetHeader ¶
func (m *DelTableResponse) GetHeader() *ResponseHeader
func (*DelTableResponse) GetTable ¶
func (m *DelTableResponse) GetTable() *basepb.Table
func (*DelTableResponse) Marshal ¶
func (m *DelTableResponse) Marshal() (dAtA []byte, err error)
func (*DelTableResponse) MarshalToSizedBuffer ¶
func (m *DelTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DelTableResponse) ProtoMessage ¶
func (*DelTableResponse) ProtoMessage()
func (*DelTableResponse) Reset ¶
func (m *DelTableResponse) Reset()
func (*DelTableResponse) Size ¶
func (m *DelTableResponse) Size() (n int)
func (*DelTableResponse) String ¶
func (m *DelTableResponse) String() string
func (*DelTableResponse) Unmarshal ¶
func (m *DelTableResponse) Unmarshal(dAtA []byte) error
func (*DelTableResponse) XXX_DiscardUnknown ¶
func (m *DelTableResponse) XXX_DiscardUnknown()
func (*DelTableResponse) XXX_Marshal ¶
func (m *DelTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DelTableResponse) XXX_Merge ¶
func (m *DelTableResponse) XXX_Merge(src proto.Message)
func (*DelTableResponse) XXX_Size ¶
func (m *DelTableResponse) XXX_Size() int
func (*DelTableResponse) XXX_Unmarshal ¶
func (m *DelTableResponse) XXX_Unmarshal(b []byte) error
type Error ¶
type Error struct { Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Error) Descriptor ¶
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶
func (*Error) XXX_Unmarshal ¶
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 ¶
type GetAutoIncIdRequest ¶
type GetAutoIncIdRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbId uint64 `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` TableId uint64 `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` Size_ uint32 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAutoIncIdRequest) Descriptor ¶
func (*GetAutoIncIdRequest) Descriptor() ([]byte, []int)
func (*GetAutoIncIdRequest) GetDbId ¶
func (m *GetAutoIncIdRequest) GetDbId() uint64
func (*GetAutoIncIdRequest) GetHeader ¶
func (m *GetAutoIncIdRequest) GetHeader() *RequestHeader
func (*GetAutoIncIdRequest) GetSize_ ¶
func (m *GetAutoIncIdRequest) GetSize_() uint32
func (*GetAutoIncIdRequest) GetTableId ¶
func (m *GetAutoIncIdRequest) GetTableId() uint64
func (*GetAutoIncIdRequest) Marshal ¶
func (m *GetAutoIncIdRequest) Marshal() (dAtA []byte, err error)
func (*GetAutoIncIdRequest) MarshalTo ¶
func (m *GetAutoIncIdRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetAutoIncIdRequest) MarshalToSizedBuffer ¶
func (m *GetAutoIncIdRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetAutoIncIdRequest) ProtoMessage ¶
func (*GetAutoIncIdRequest) ProtoMessage()
func (*GetAutoIncIdRequest) Reset ¶
func (m *GetAutoIncIdRequest) Reset()
func (*GetAutoIncIdRequest) Size ¶
func (m *GetAutoIncIdRequest) Size() (n int)
func (*GetAutoIncIdRequest) String ¶
func (m *GetAutoIncIdRequest) String() string
func (*GetAutoIncIdRequest) Unmarshal ¶
func (m *GetAutoIncIdRequest) Unmarshal(dAtA []byte) error
func (*GetAutoIncIdRequest) XXX_DiscardUnknown ¶
func (m *GetAutoIncIdRequest) XXX_DiscardUnknown()
func (*GetAutoIncIdRequest) XXX_Marshal ¶
func (m *GetAutoIncIdRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAutoIncIdRequest) XXX_Merge ¶
func (m *GetAutoIncIdRequest) XXX_Merge(src proto.Message)
func (*GetAutoIncIdRequest) XXX_Size ¶
func (m *GetAutoIncIdRequest) XXX_Size() int
func (*GetAutoIncIdRequest) XXX_Unmarshal ¶
func (m *GetAutoIncIdRequest) XXX_Unmarshal(b []byte) error
type GetAutoIncIdResponse ¶
type GetAutoIncIdResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` IdPairs []*IdPair `protobuf:"bytes,2,rep,name=id_pairs,json=idPairs,proto3" json:"id_pairs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAutoIncIdResponse) Descriptor ¶
func (*GetAutoIncIdResponse) Descriptor() ([]byte, []int)
func (*GetAutoIncIdResponse) GetHeader ¶
func (m *GetAutoIncIdResponse) GetHeader() *ResponseHeader
func (*GetAutoIncIdResponse) GetIdPairs ¶
func (m *GetAutoIncIdResponse) GetIdPairs() []*IdPair
func (*GetAutoIncIdResponse) Marshal ¶
func (m *GetAutoIncIdResponse) Marshal() (dAtA []byte, err error)
func (*GetAutoIncIdResponse) MarshalTo ¶
func (m *GetAutoIncIdResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetAutoIncIdResponse) MarshalToSizedBuffer ¶
func (m *GetAutoIncIdResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetAutoIncIdResponse) ProtoMessage ¶
func (*GetAutoIncIdResponse) ProtoMessage()
func (*GetAutoIncIdResponse) Reset ¶
func (m *GetAutoIncIdResponse) Reset()
func (*GetAutoIncIdResponse) Size ¶
func (m *GetAutoIncIdResponse) Size() (n int)
func (*GetAutoIncIdResponse) String ¶
func (m *GetAutoIncIdResponse) String() string
func (*GetAutoIncIdResponse) Unmarshal ¶
func (m *GetAutoIncIdResponse) Unmarshal(dAtA []byte) error
func (*GetAutoIncIdResponse) XXX_DiscardUnknown ¶
func (m *GetAutoIncIdResponse) XXX_DiscardUnknown()
func (*GetAutoIncIdResponse) XXX_Marshal ¶
func (m *GetAutoIncIdResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAutoIncIdResponse) XXX_Merge ¶
func (m *GetAutoIncIdResponse) XXX_Merge(src proto.Message)
func (*GetAutoIncIdResponse) XXX_Size ¶
func (m *GetAutoIncIdResponse) XXX_Size() int
func (*GetAutoIncIdResponse) XXX_Unmarshal ¶
func (m *GetAutoIncIdResponse) XXX_Unmarshal(b []byte) error
type GetColumnRequest ¶
type GetColumnRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbId uint64 `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` TableId uint64 `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` ColId uint64 `protobuf:"varint,4,opt,name=col_id,json=colId,proto3" json:"col_id,omitempty"` ColName string `protobuf:"bytes,5,opt,name=col_name,json=colName,proto3" json:"col_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetColumnRequest) Descriptor ¶
func (*GetColumnRequest) Descriptor() ([]byte, []int)
func (*GetColumnRequest) GetColId ¶
func (m *GetColumnRequest) GetColId() uint64
func (*GetColumnRequest) GetColName ¶
func (m *GetColumnRequest) GetColName() string
func (*GetColumnRequest) GetDbId ¶
func (m *GetColumnRequest) GetDbId() uint64
func (*GetColumnRequest) GetHeader ¶
func (m *GetColumnRequest) GetHeader() *RequestHeader
func (*GetColumnRequest) GetTableId ¶
func (m *GetColumnRequest) GetTableId() uint64
func (*GetColumnRequest) Marshal ¶
func (m *GetColumnRequest) Marshal() (dAtA []byte, err error)
func (*GetColumnRequest) MarshalToSizedBuffer ¶
func (m *GetColumnRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetColumnRequest) ProtoMessage ¶
func (*GetColumnRequest) ProtoMessage()
func (*GetColumnRequest) Reset ¶
func (m *GetColumnRequest) Reset()
func (*GetColumnRequest) Size ¶
func (m *GetColumnRequest) Size() (n int)
func (*GetColumnRequest) String ¶
func (m *GetColumnRequest) String() string
func (*GetColumnRequest) Unmarshal ¶
func (m *GetColumnRequest) Unmarshal(dAtA []byte) error
func (*GetColumnRequest) XXX_DiscardUnknown ¶
func (m *GetColumnRequest) XXX_DiscardUnknown()
func (*GetColumnRequest) XXX_Marshal ¶
func (m *GetColumnRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetColumnRequest) XXX_Merge ¶
func (m *GetColumnRequest) XXX_Merge(src proto.Message)
func (*GetColumnRequest) XXX_Size ¶
func (m *GetColumnRequest) XXX_Size() int
func (*GetColumnRequest) XXX_Unmarshal ¶
func (m *GetColumnRequest) XXX_Unmarshal(b []byte) error
type GetColumnResponse ¶
type GetColumnResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Column *basepb.Column `protobuf:"bytes,2,opt,name=column,proto3" json:"column,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetColumnResponse) Descriptor ¶
func (*GetColumnResponse) Descriptor() ([]byte, []int)
func (*GetColumnResponse) GetColumn ¶
func (m *GetColumnResponse) GetColumn() *basepb.Column
func (*GetColumnResponse) GetHeader ¶
func (m *GetColumnResponse) GetHeader() *ResponseHeader
func (*GetColumnResponse) Marshal ¶
func (m *GetColumnResponse) Marshal() (dAtA []byte, err error)
func (*GetColumnResponse) MarshalTo ¶
func (m *GetColumnResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetColumnResponse) MarshalToSizedBuffer ¶
func (m *GetColumnResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetColumnResponse) ProtoMessage ¶
func (*GetColumnResponse) ProtoMessage()
func (*GetColumnResponse) Reset ¶
func (m *GetColumnResponse) Reset()
func (*GetColumnResponse) Size ¶
func (m *GetColumnResponse) Size() (n int)
func (*GetColumnResponse) String ¶
func (m *GetColumnResponse) String() string
func (*GetColumnResponse) Unmarshal ¶
func (m *GetColumnResponse) Unmarshal(dAtA []byte) error
func (*GetColumnResponse) XXX_DiscardUnknown ¶
func (m *GetColumnResponse) XXX_DiscardUnknown()
func (*GetColumnResponse) XXX_Marshal ¶
func (m *GetColumnResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetColumnResponse) XXX_Merge ¶
func (m *GetColumnResponse) XXX_Merge(src proto.Message)
func (*GetColumnResponse) XXX_Size ¶
func (m *GetColumnResponse) XXX_Size() int
func (*GetColumnResponse) XXX_Unmarshal ¶
func (m *GetColumnResponse) XXX_Unmarshal(b []byte) error
type GetColumnsRequest ¶
type GetColumnsRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbId uint64 `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` TableId uint64 `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetColumnsRequest) Descriptor ¶
func (*GetColumnsRequest) Descriptor() ([]byte, []int)
func (*GetColumnsRequest) GetDbId ¶
func (m *GetColumnsRequest) GetDbId() uint64
func (*GetColumnsRequest) GetHeader ¶
func (m *GetColumnsRequest) GetHeader() *RequestHeader
func (*GetColumnsRequest) GetTableId ¶
func (m *GetColumnsRequest) GetTableId() uint64
func (*GetColumnsRequest) Marshal ¶
func (m *GetColumnsRequest) Marshal() (dAtA []byte, err error)
func (*GetColumnsRequest) MarshalTo ¶
func (m *GetColumnsRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetColumnsRequest) MarshalToSizedBuffer ¶
func (m *GetColumnsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetColumnsRequest) ProtoMessage ¶
func (*GetColumnsRequest) ProtoMessage()
func (*GetColumnsRequest) Reset ¶
func (m *GetColumnsRequest) Reset()
func (*GetColumnsRequest) Size ¶
func (m *GetColumnsRequest) Size() (n int)
func (*GetColumnsRequest) String ¶
func (m *GetColumnsRequest) String() string
func (*GetColumnsRequest) Unmarshal ¶
func (m *GetColumnsRequest) Unmarshal(dAtA []byte) error
func (*GetColumnsRequest) XXX_DiscardUnknown ¶
func (m *GetColumnsRequest) XXX_DiscardUnknown()
func (*GetColumnsRequest) XXX_Marshal ¶
func (m *GetColumnsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetColumnsRequest) XXX_Merge ¶
func (m *GetColumnsRequest) XXX_Merge(src proto.Message)
func (*GetColumnsRequest) XXX_Size ¶
func (m *GetColumnsRequest) XXX_Size() int
func (*GetColumnsRequest) XXX_Unmarshal ¶
func (m *GetColumnsRequest) XXX_Unmarshal(b []byte) error
type GetColumnsResponse ¶
type GetColumnsResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Columns []*basepb.Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetColumnsResponse) Descriptor ¶
func (*GetColumnsResponse) Descriptor() ([]byte, []int)
func (*GetColumnsResponse) GetColumns ¶
func (m *GetColumnsResponse) GetColumns() []*basepb.Column
func (*GetColumnsResponse) GetHeader ¶
func (m *GetColumnsResponse) GetHeader() *ResponseHeader
func (*GetColumnsResponse) Marshal ¶
func (m *GetColumnsResponse) Marshal() (dAtA []byte, err error)
func (*GetColumnsResponse) MarshalTo ¶
func (m *GetColumnsResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetColumnsResponse) MarshalToSizedBuffer ¶
func (m *GetColumnsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetColumnsResponse) ProtoMessage ¶
func (*GetColumnsResponse) ProtoMessage()
func (*GetColumnsResponse) Reset ¶
func (m *GetColumnsResponse) Reset()
func (*GetColumnsResponse) Size ¶
func (m *GetColumnsResponse) Size() (n int)
func (*GetColumnsResponse) String ¶
func (m *GetColumnsResponse) String() string
func (*GetColumnsResponse) Unmarshal ¶
func (m *GetColumnsResponse) Unmarshal(dAtA []byte) error
func (*GetColumnsResponse) XXX_DiscardUnknown ¶
func (m *GetColumnsResponse) XXX_DiscardUnknown()
func (*GetColumnsResponse) XXX_Marshal ¶
func (m *GetColumnsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetColumnsResponse) XXX_Merge ¶
func (m *GetColumnsResponse) XXX_Merge(src proto.Message)
func (*GetColumnsResponse) XXX_Size ¶
func (m *GetColumnsResponse) XXX_Size() int
func (*GetColumnsResponse) XXX_Unmarshal ¶
func (m *GetColumnsResponse) XXX_Unmarshal(b []byte) error
type GetDBRequest ¶
type GetDBRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetDBRequest) Descriptor ¶
func (*GetDBRequest) Descriptor() ([]byte, []int)
func (*GetDBRequest) GetHeader ¶
func (m *GetDBRequest) GetHeader() *RequestHeader
func (*GetDBRequest) GetName ¶
func (m *GetDBRequest) GetName() string
func (*GetDBRequest) Marshal ¶
func (m *GetDBRequest) Marshal() (dAtA []byte, err error)
func (*GetDBRequest) MarshalToSizedBuffer ¶
func (m *GetDBRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDBRequest) ProtoMessage ¶
func (*GetDBRequest) ProtoMessage()
func (*GetDBRequest) Reset ¶
func (m *GetDBRequest) Reset()
func (*GetDBRequest) Size ¶
func (m *GetDBRequest) Size() (n int)
func (*GetDBRequest) String ¶
func (m *GetDBRequest) String() string
func (*GetDBRequest) Unmarshal ¶
func (m *GetDBRequest) Unmarshal(dAtA []byte) error
func (*GetDBRequest) XXX_DiscardUnknown ¶
func (m *GetDBRequest) XXX_DiscardUnknown()
func (*GetDBRequest) XXX_Marshal ¶
func (m *GetDBRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDBRequest) XXX_Merge ¶
func (m *GetDBRequest) XXX_Merge(src proto.Message)
func (*GetDBRequest) XXX_Size ¶
func (m *GetDBRequest) XXX_Size() int
func (*GetDBRequest) XXX_Unmarshal ¶
func (m *GetDBRequest) XXX_Unmarshal(b []byte) error
type GetDBResponse ¶
type GetDBResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Db *basepb.DataBase `protobuf:"bytes,2,opt,name=db,proto3" json:"db,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetDBResponse) Descriptor ¶
func (*GetDBResponse) Descriptor() ([]byte, []int)
func (*GetDBResponse) GetDb ¶
func (m *GetDBResponse) GetDb() *basepb.DataBase
func (*GetDBResponse) GetHeader ¶
func (m *GetDBResponse) GetHeader() *ResponseHeader
func (*GetDBResponse) Marshal ¶
func (m *GetDBResponse) Marshal() (dAtA []byte, err error)
func (*GetDBResponse) MarshalToSizedBuffer ¶
func (m *GetDBResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDBResponse) ProtoMessage ¶
func (*GetDBResponse) ProtoMessage()
func (*GetDBResponse) Reset ¶
func (m *GetDBResponse) Reset()
func (*GetDBResponse) Size ¶
func (m *GetDBResponse) Size() (n int)
func (*GetDBResponse) String ¶
func (m *GetDBResponse) String() string
func (*GetDBResponse) Unmarshal ¶
func (m *GetDBResponse) Unmarshal(dAtA []byte) error
func (*GetDBResponse) XXX_DiscardUnknown ¶
func (m *GetDBResponse) XXX_DiscardUnknown()
func (*GetDBResponse) XXX_Marshal ¶
func (m *GetDBResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDBResponse) XXX_Merge ¶
func (m *GetDBResponse) XXX_Merge(src proto.Message)
func (*GetDBResponse) XXX_Size ¶
func (m *GetDBResponse) XXX_Size() int
func (*GetDBResponse) XXX_Unmarshal ¶
func (m *GetDBResponse) XXX_Unmarshal(b []byte) error
type GetDBsResponse ¶
type GetDBsResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Dbs []*basepb.DataBase `protobuf:"bytes,2,rep,name=dbs,proto3" json:"dbs,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetDBsResponse) Descriptor ¶
func (*GetDBsResponse) Descriptor() ([]byte, []int)
func (*GetDBsResponse) GetDbs ¶
func (m *GetDBsResponse) GetDbs() []*basepb.DataBase
func (*GetDBsResponse) GetHeader ¶
func (m *GetDBsResponse) GetHeader() *ResponseHeader
func (*GetDBsResponse) Marshal ¶
func (m *GetDBsResponse) Marshal() (dAtA []byte, err error)
func (*GetDBsResponse) MarshalToSizedBuffer ¶
func (m *GetDBsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDBsResponse) ProtoMessage ¶
func (*GetDBsResponse) ProtoMessage()
func (*GetDBsResponse) Reset ¶
func (m *GetDBsResponse) Reset()
func (*GetDBsResponse) Size ¶
func (m *GetDBsResponse) Size() (n int)
func (*GetDBsResponse) String ¶
func (m *GetDBsResponse) String() string
func (*GetDBsResponse) Unmarshal ¶
func (m *GetDBsResponse) Unmarshal(dAtA []byte) error
func (*GetDBsResponse) XXX_DiscardUnknown ¶
func (m *GetDBsResponse) XXX_DiscardUnknown()
func (*GetDBsResponse) XXX_Marshal ¶
func (m *GetDBsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDBsResponse) XXX_Merge ¶
func (m *GetDBsResponse) XXX_Merge(src proto.Message)
func (*GetDBsResponse) XXX_Size ¶
func (m *GetDBsResponse) XXX_Size() int
func (*GetDBsResponse) XXX_Unmarshal ¶
func (m *GetDBsResponse) XXX_Unmarshal(b []byte) error
type GetNodeInfo ¶
type GetNodeInfo struct { Err string `protobuf:"bytes,1,opt,name=err,proto3" json:"err,omitempty"` Node *basepb.Node `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"` Info *dspb.NodeInfoResponse `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetNodeInfo) Descriptor ¶
func (*GetNodeInfo) Descriptor() ([]byte, []int)
func (*GetNodeInfo) GetErr ¶
func (m *GetNodeInfo) GetErr() string
func (*GetNodeInfo) GetInfo ¶
func (m *GetNodeInfo) GetInfo() *dspb.NodeInfoResponse
func (*GetNodeInfo) GetNode ¶
func (m *GetNodeInfo) GetNode() *basepb.Node
func (*GetNodeInfo) Marshal ¶
func (m *GetNodeInfo) Marshal() (dAtA []byte, err error)
func (*GetNodeInfo) 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) 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) 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) 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) MarshalToSizedBuffer ¶
func (m *GetNodesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetNodesResponse) ProtoMessage ¶
func (*GetNodesResponse) ProtoMessage()
func (*GetNodesResponse) Reset ¶
func (m *GetNodesResponse) Reset()
func (*GetNodesResponse) Size ¶
func (m *GetNodesResponse) Size() (n int)
func (*GetNodesResponse) String ¶
func (m *GetNodesResponse) String() string
func (*GetNodesResponse) Unmarshal ¶
func (m *GetNodesResponse) Unmarshal(dAtA []byte) error
func (*GetNodesResponse) XXX_DiscardUnknown ¶
func (m *GetNodesResponse) XXX_DiscardUnknown()
func (*GetNodesResponse) XXX_Marshal ¶
func (m *GetNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetNodesResponse) XXX_Merge ¶
func (m *GetNodesResponse) XXX_Merge(src proto.Message)
func (*GetNodesResponse) XXX_Size ¶
func (m *GetNodesResponse) XXX_Size() int
func (*GetNodesResponse) XXX_Unmarshal ¶
func (m *GetNodesResponse) XXX_Unmarshal(b []byte) error
type GetRouteRequest ¶
type GetRouteRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbId uint64 `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` TableId uint64 `protobuf:"varint,3,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` Key []byte `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"` Max uint32 `protobuf:"varint,5,opt,name=max,proto3" json:"max,omitempty"` RangeType basepb.RangeType `protobuf:"varint,6,opt,name=rangeType,proto3,enum=basepb.RangeType" json:"rangeType,omitempty"` HasAll bool `protobuf:"varint,7,opt,name=has_all,json=hasAll,proto3" json:"has_all,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetRouteRequest) Descriptor ¶
func (*GetRouteRequest) Descriptor() ([]byte, []int)
func (*GetRouteRequest) GetDbId ¶
func (m *GetRouteRequest) GetDbId() uint64
func (*GetRouteRequest) GetHasAll ¶
func (m *GetRouteRequest) GetHasAll() bool
func (*GetRouteRequest) GetHeader ¶
func (m *GetRouteRequest) GetHeader() *RequestHeader
func (*GetRouteRequest) GetKey ¶
func (m *GetRouteRequest) GetKey() []byte
func (*GetRouteRequest) GetMax ¶
func (m *GetRouteRequest) GetMax() uint32
func (*GetRouteRequest) GetRangeType ¶
func (m *GetRouteRequest) GetRangeType() basepb.RangeType
func (*GetRouteRequest) GetTableId ¶
func (m *GetRouteRequest) GetTableId() uint64
func (*GetRouteRequest) Marshal ¶
func (m *GetRouteRequest) Marshal() (dAtA []byte, err error)
func (*GetRouteRequest) 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) MarshalToSizedBuffer ¶
func (m *GetRouteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRouteResponse) ProtoMessage ¶
func (*GetRouteResponse) ProtoMessage()
func (*GetRouteResponse) Reset ¶
func (m *GetRouteResponse) Reset()
func (*GetRouteResponse) Size ¶
func (m *GetRouteResponse) Size() (n int)
func (*GetRouteResponse) String ¶
func (m *GetRouteResponse) String() string
func (*GetRouteResponse) Unmarshal ¶
func (m *GetRouteResponse) Unmarshal(dAtA []byte) error
func (*GetRouteResponse) XXX_DiscardUnknown ¶
func (m *GetRouteResponse) XXX_DiscardUnknown()
func (*GetRouteResponse) XXX_Marshal ¶
func (m *GetRouteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRouteResponse) XXX_Merge ¶
func (m *GetRouteResponse) XXX_Merge(src proto.Message)
func (*GetRouteResponse) XXX_Size ¶
func (m *GetRouteResponse) XXX_Size() int
func (*GetRouteResponse) XXX_Unmarshal ¶
func (m *GetRouteResponse) XXX_Unmarshal(b []byte) error
type GetTableRequest ¶
type GetTableRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbId uint64 `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` DbName string `protobuf:"bytes,3,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"` TableId uint64 `protobuf:"varint,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` TableName string `protobuf:"bytes,5,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTableRequest) Descriptor ¶
func (*GetTableRequest) Descriptor() ([]byte, []int)
func (*GetTableRequest) GetDbId ¶
func (m *GetTableRequest) GetDbId() uint64
func (*GetTableRequest) GetDbName ¶
func (m *GetTableRequest) GetDbName() string
func (*GetTableRequest) GetHeader ¶
func (m *GetTableRequest) GetHeader() *RequestHeader
func (*GetTableRequest) GetTableId ¶
func (m *GetTableRequest) GetTableId() uint64
func (*GetTableRequest) GetTableName ¶
func (m *GetTableRequest) GetTableName() string
func (*GetTableRequest) Marshal ¶
func (m *GetTableRequest) Marshal() (dAtA []byte, err error)
func (*GetTableRequest) MarshalToSizedBuffer ¶
func (m *GetTableRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetTableRequest) ProtoMessage ¶
func (*GetTableRequest) ProtoMessage()
func (*GetTableRequest) Reset ¶
func (m *GetTableRequest) Reset()
func (*GetTableRequest) Size ¶
func (m *GetTableRequest) Size() (n int)
func (*GetTableRequest) String ¶
func (m *GetTableRequest) String() string
func (*GetTableRequest) Unmarshal ¶
func (m *GetTableRequest) Unmarshal(dAtA []byte) error
func (*GetTableRequest) XXX_DiscardUnknown ¶
func (m *GetTableRequest) XXX_DiscardUnknown()
func (*GetTableRequest) XXX_Marshal ¶
func (m *GetTableRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTableRequest) XXX_Merge ¶
func (m *GetTableRequest) XXX_Merge(src proto.Message)
func (*GetTableRequest) XXX_Size ¶
func (m *GetTableRequest) XXX_Size() int
func (*GetTableRequest) XXX_Unmarshal ¶
func (m *GetTableRequest) XXX_Unmarshal(b []byte) error
type GetTableResponse ¶
type GetTableResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Table *basepb.Table `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTableResponse) Descriptor ¶
func (*GetTableResponse) Descriptor() ([]byte, []int)
func (*GetTableResponse) GetHeader ¶
func (m *GetTableResponse) GetHeader() *ResponseHeader
func (*GetTableResponse) GetTable ¶
func (m *GetTableResponse) GetTable() *basepb.Table
func (*GetTableResponse) Marshal ¶
func (m *GetTableResponse) Marshal() (dAtA []byte, err error)
func (*GetTableResponse) MarshalToSizedBuffer ¶
func (m *GetTableResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetTableResponse) ProtoMessage ¶
func (*GetTableResponse) ProtoMessage()
func (*GetTableResponse) Reset ¶
func (m *GetTableResponse) Reset()
func (*GetTableResponse) Size ¶
func (m *GetTableResponse) Size() (n int)
func (*GetTableResponse) String ¶
func (m *GetTableResponse) String() string
func (*GetTableResponse) Unmarshal ¶
func (m *GetTableResponse) Unmarshal(dAtA []byte) error
func (*GetTableResponse) XXX_DiscardUnknown ¶
func (m *GetTableResponse) XXX_DiscardUnknown()
func (*GetTableResponse) XXX_Marshal ¶
func (m *GetTableResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTableResponse) XXX_Merge ¶
func (m *GetTableResponse) XXX_Merge(src proto.Message)
func (*GetTableResponse) XXX_Size ¶
func (m *GetTableResponse) XXX_Size() int
func (*GetTableResponse) XXX_Unmarshal ¶
func (m *GetTableResponse) XXX_Unmarshal(b []byte) error
type GetTablesRequest ¶
type GetTablesRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` DbId uint64 `protobuf:"varint,2,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` DbName string `protobuf:"bytes,3,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTablesRequest) Descriptor ¶
func (*GetTablesRequest) Descriptor() ([]byte, []int)
func (*GetTablesRequest) GetDbId ¶
func (m *GetTablesRequest) GetDbId() uint64
func (*GetTablesRequest) GetDbName ¶
func (m *GetTablesRequest) GetDbName() string
func (*GetTablesRequest) GetHeader ¶
func (m *GetTablesRequest) GetHeader() *RequestHeader
func (*GetTablesRequest) Marshal ¶
func (m *GetTablesRequest) Marshal() (dAtA []byte, err error)
func (*GetTablesRequest) MarshalToSizedBuffer ¶
func (m *GetTablesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetTablesRequest) ProtoMessage ¶
func (*GetTablesRequest) ProtoMessage()
func (*GetTablesRequest) Reset ¶
func (m *GetTablesRequest) Reset()
func (*GetTablesRequest) Size ¶
func (m *GetTablesRequest) Size() (n int)
func (*GetTablesRequest) String ¶
func (m *GetTablesRequest) String() string
func (*GetTablesRequest) Unmarshal ¶
func (m *GetTablesRequest) Unmarshal(dAtA []byte) error
func (*GetTablesRequest) XXX_DiscardUnknown ¶
func (m *GetTablesRequest) XXX_DiscardUnknown()
func (*GetTablesRequest) XXX_Marshal ¶
func (m *GetTablesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTablesRequest) XXX_Merge ¶
func (m *GetTablesRequest) XXX_Merge(src proto.Message)
func (*GetTablesRequest) XXX_Size ¶
func (m *GetTablesRequest) XXX_Size() int
func (*GetTablesRequest) XXX_Unmarshal ¶
func (m *GetTablesRequest) XXX_Unmarshal(b []byte) error
type GetTablesResponse ¶
type GetTablesResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` Tables []*basepb.Table `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetTablesResponse) Descriptor ¶
func (*GetTablesResponse) Descriptor() ([]byte, []int)
func (*GetTablesResponse) GetHeader ¶
func (m *GetTablesResponse) GetHeader() *ResponseHeader
func (*GetTablesResponse) GetTables ¶
func (m *GetTablesResponse) GetTables() []*basepb.Table
func (*GetTablesResponse) Marshal ¶
func (m *GetTablesResponse) Marshal() (dAtA []byte, err error)
func (*GetTablesResponse) MarshalTo ¶
func (m *GetTablesResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetTablesResponse) MarshalToSizedBuffer ¶
func (m *GetTablesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetTablesResponse) ProtoMessage ¶
func (*GetTablesResponse) ProtoMessage()
func (*GetTablesResponse) Reset ¶
func (m *GetTablesResponse) Reset()
func (*GetTablesResponse) Size ¶
func (m *GetTablesResponse) Size() (n int)
func (*GetTablesResponse) String ¶
func (m *GetTablesResponse) String() string
func (*GetTablesResponse) Unmarshal ¶
func (m *GetTablesResponse) Unmarshal(dAtA []byte) error
func (*GetTablesResponse) XXX_DiscardUnknown ¶
func (m *GetTablesResponse) XXX_DiscardUnknown()
func (*GetTablesResponse) XXX_Marshal ¶
func (m *GetTablesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetTablesResponse) XXX_Merge ¶
func (m *GetTablesResponse) XXX_Merge(src proto.Message)
func (*GetTablesResponse) XXX_Size ¶
func (m *GetTablesResponse) XXX_Size() int
func (*GetTablesResponse) XXX_Unmarshal ¶
func (m *GetTablesResponse) XXX_Unmarshal(b []byte) error
type IdPair ¶
type IdPair struct { IdStart []byte `protobuf:"bytes,1,opt,name=id_start,json=idStart,proto3" json:"id_start,omitempty"` IdEnd []byte `protobuf:"bytes,2,opt,name=id_end,json=idEnd,proto3" json:"id_end,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*IdPair) Descriptor ¶
func (*IdPair) GetIdStart ¶
func (*IdPair) MarshalToSizedBuffer ¶
func (*IdPair) ProtoMessage ¶
func (*IdPair) ProtoMessage()
func (*IdPair) XXX_DiscardUnknown ¶
func (m *IdPair) XXX_DiscardUnknown()
func (*IdPair) XXX_Marshal ¶
func (*IdPair) XXX_Unmarshal ¶
type NodeHeartbeatRequest ¶
type NodeHeartbeatRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` NodeId uint64 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeHeartbeatRequest) Descriptor ¶
func (*NodeHeartbeatRequest) Descriptor() ([]byte, []int)
func (*NodeHeartbeatRequest) GetHeader ¶
func (m *NodeHeartbeatRequest) GetHeader() *RequestHeader
func (*NodeHeartbeatRequest) GetNodeId ¶
func (m *NodeHeartbeatRequest) GetNodeId() uint64
func (*NodeHeartbeatRequest) Marshal ¶
func (m *NodeHeartbeatRequest) Marshal() (dAtA []byte, err error)
func (*NodeHeartbeatRequest) MarshalTo ¶
func (m *NodeHeartbeatRequest) MarshalTo(dAtA []byte) (int, error)
func (*NodeHeartbeatRequest) MarshalToSizedBuffer ¶
func (m *NodeHeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodeHeartbeatRequest) ProtoMessage ¶
func (*NodeHeartbeatRequest) ProtoMessage()
func (*NodeHeartbeatRequest) Reset ¶
func (m *NodeHeartbeatRequest) Reset()
func (*NodeHeartbeatRequest) Size ¶
func (m *NodeHeartbeatRequest) Size() (n int)
func (*NodeHeartbeatRequest) String ¶
func (m *NodeHeartbeatRequest) String() string
func (*NodeHeartbeatRequest) Unmarshal ¶
func (m *NodeHeartbeatRequest) Unmarshal(dAtA []byte) error
func (*NodeHeartbeatRequest) XXX_DiscardUnknown ¶
func (m *NodeHeartbeatRequest) XXX_DiscardUnknown()
func (*NodeHeartbeatRequest) XXX_Marshal ¶
func (m *NodeHeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeHeartbeatRequest) XXX_Merge ¶
func (m *NodeHeartbeatRequest) XXX_Merge(src proto.Message)
func (*NodeHeartbeatRequest) XXX_Size ¶
func (m *NodeHeartbeatRequest) XXX_Size() int
func (*NodeHeartbeatRequest) XXX_Unmarshal ¶
func (m *NodeHeartbeatRequest) XXX_Unmarshal(b []byte) error
type NodeHeartbeatResponse ¶
type NodeHeartbeatResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` NodeId uint64 `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*NodeHeartbeatResponse) Descriptor ¶
func (*NodeHeartbeatResponse) Descriptor() ([]byte, []int)
func (*NodeHeartbeatResponse) GetHeader ¶
func (m *NodeHeartbeatResponse) GetHeader() *ResponseHeader
func (*NodeHeartbeatResponse) GetNodeId ¶
func (m *NodeHeartbeatResponse) GetNodeId() uint64
func (*NodeHeartbeatResponse) Marshal ¶
func (m *NodeHeartbeatResponse) Marshal() (dAtA []byte, err error)
func (*NodeHeartbeatResponse) MarshalTo ¶
func (m *NodeHeartbeatResponse) MarshalTo(dAtA []byte) (int, error)
func (*NodeHeartbeatResponse) MarshalToSizedBuffer ¶
func (m *NodeHeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*NodeHeartbeatResponse) ProtoMessage ¶
func (*NodeHeartbeatResponse) ProtoMessage()
func (*NodeHeartbeatResponse) Reset ¶
func (m *NodeHeartbeatResponse) Reset()
func (*NodeHeartbeatResponse) Size ¶
func (m *NodeHeartbeatResponse) Size() (n int)
func (*NodeHeartbeatResponse) String ¶
func (m *NodeHeartbeatResponse) String() string
func (*NodeHeartbeatResponse) Unmarshal ¶
func (m *NodeHeartbeatResponse) Unmarshal(dAtA []byte) error
func (*NodeHeartbeatResponse) XXX_DiscardUnknown ¶
func (m *NodeHeartbeatResponse) XXX_DiscardUnknown()
func (*NodeHeartbeatResponse) XXX_Marshal ¶
func (m *NodeHeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*NodeHeartbeatResponse) XXX_Merge ¶
func (m *NodeHeartbeatResponse) XXX_Merge(src proto.Message)
func (*NodeHeartbeatResponse) XXX_Size ¶
func (m *NodeHeartbeatResponse) XXX_Size() int
func (*NodeHeartbeatResponse) XXX_Unmarshal ¶
func (m *NodeHeartbeatResponse) XXX_Unmarshal(b []byte) error
type PeerMoveRequest ¶
type PeerMoveRequest struct { Header *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` TableId uint64 `protobuf:"varint,2,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` RangeId uint64 `protobuf:"varint,3,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"` StoreType basepb.StoreType `protobuf:"varint,4,opt,name=store_type,json=storeType,proto3,enum=basepb.StoreType" json:"store_type,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*PeerMoveRequest) Descriptor ¶
func (*PeerMoveRequest) Descriptor() ([]byte, []int)
func (*PeerMoveRequest) GetHeader ¶
func (m *PeerMoveRequest) GetHeader() *RequestHeader
func (*PeerMoveRequest) GetRangeId ¶
func (m *PeerMoveRequest) GetRangeId() uint64
func (*PeerMoveRequest) GetStoreType ¶
func (m *PeerMoveRequest) GetStoreType() basepb.StoreType
func (*PeerMoveRequest) GetTableId ¶
func (m *PeerMoveRequest) GetTableId() uint64
func (*PeerMoveRequest) Marshal ¶
func (m *PeerMoveRequest) Marshal() (dAtA []byte, err error)
func (*PeerMoveRequest) 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) MarshalToSizedBuffer ¶
func (m *PeerMoveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PeerMoveResponse) ProtoMessage ¶
func (*PeerMoveResponse) ProtoMessage()
func (*PeerMoveResponse) Reset ¶
func (m *PeerMoveResponse) Reset()
func (*PeerMoveResponse) Size ¶
func (m *PeerMoveResponse) Size() (n int)
func (*PeerMoveResponse) String ¶
func (m *PeerMoveResponse) String() string
func (*PeerMoveResponse) Unmarshal ¶
func (m *PeerMoveResponse) Unmarshal(dAtA []byte) error
func (*PeerMoveResponse) XXX_DiscardUnknown ¶
func (m *PeerMoveResponse) XXX_DiscardUnknown()
func (*PeerMoveResponse) XXX_Marshal ¶
func (m *PeerMoveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PeerMoveResponse) XXX_Merge ¶
func (m *PeerMoveResponse) XXX_Merge(src proto.Message)
func (*PeerMoveResponse) XXX_Size ¶
func (m *PeerMoveResponse) XXX_Size() int
func (*PeerMoveResponse) XXX_Unmarshal ¶
func (m *PeerMoveResponse) XXX_Unmarshal(b []byte) error
type RangeFingerprint ¶
type RangeFingerprint struct { RangeId uint64 `protobuf:"varint,1,opt,name=range_id,json=rangeId,proto3" json:"range_id,omitempty"` RangeEpoch *basepb.RangeEpoch `protobuf:"bytes,2,opt,name=range_epoch,json=rangeEpoch,proto3" json:"range_epoch,omitempty"` DbId uint64 `protobuf:"varint,3,opt,name=db_id,json=dbId,proto3" json:"db_id,omitempty"` TableId uint64 `protobuf:"varint,4,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"` PeerId uint64 `protobuf:"varint,5,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Fingerprint is used to verfiy if range is valid
func (*RangeFingerprint) Descriptor ¶
func (*RangeFingerprint) Descriptor() ([]byte, []int)
func (*RangeFingerprint) GetDbId ¶
func (m *RangeFingerprint) GetDbId() uint64
func (*RangeFingerprint) GetPeerId ¶
func (m *RangeFingerprint) GetPeerId() uint64
func (*RangeFingerprint) GetRangeEpoch ¶
func (m *RangeFingerprint) GetRangeEpoch() *basepb.RangeEpoch
func (*RangeFingerprint) GetRangeId ¶
func (m *RangeFingerprint) GetRangeId() uint64
func (*RangeFingerprint) GetTableId ¶
func (m *RangeFingerprint) GetTableId() uint64
func (*RangeFingerprint) Marshal ¶
func (m *RangeFingerprint) Marshal() (dAtA []byte, err error)
func (*RangeFingerprint) 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) 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) 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
Click to show internal directories.
Click to hide internal directories.