pb

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: May 5, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpc        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Group_name = map[int32]string{
	0: "KVGroup",
	1: "AOEGroup",
}
View Source 
var Group_value = map[string]int32{
	"KVGroup":  0,
	"AOEGroup": 1,
}
View Source 
var Type_name = map[int32]string{
	0:   "Set",
	1:   "Del",
	2:   "Get",
	3:   "PrefixScan",
	4:   "Scan",
	5:   "Incr",
	6:   "SetIfNotExist",
	7:   "DelIfNotExist",
	8:   "TpePrefixScan",
	9:   "TpeScan",
	10:  "TpeDeleteBatch",
	11:  "TpeCheckKeysExistInBatch",
	12:  "TpeSetBatch",
	100: "Append",
	101: "GetSnapshot",
	102: "CreateTablet",
	103: "DropTablet",
	104: "Relation",
	105: "TabletIds",
	106: "TabletNames",
	107: "GetSegmentIds",
	108: "GetSegmentedId",
	109: "CreateIndex",
	110: "DropIndex",
}
View Source 
var Type_value = map[string]int32{
	"Set":                      0,
	"Del":                      1,
	"Get":                      2,
	"PrefixScan":               3,
	"Scan":                     4,
	"Incr":                     5,
	"SetIfNotExist":            6,
	"DelIfNotExist":            7,
	"TpePrefixScan":            8,
	"TpeScan":                  9,
	"TpeDeleteBatch":           10,
	"TpeCheckKeysExistInBatch": 11,
	"TpeSetBatch":              12,
	"Append":                   100,
	"GetSnapshot":              101,
	"CreateTablet":             102,
	"DropTablet":               103,
	"Relation":                 104,
	"TabletIds":                105,
	"TabletNames":              106,
	"GetSegmentIds":            107,
	"GetSegmentedId":           108,
	"CreateIndex":              109,
	"DropIndex":                110,
}

Functions

This section is empty.

Types

type AllocIDRequest 

type AllocIDRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Batch                uint64   `protobuf:"varint,2,opt,name=batch,proto3" json:"batch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AllocIDRequest alloc id request

func (*AllocIDRequest) Descriptor 

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

func (*AllocIDRequest) GetBatch 

func (m *AllocIDRequest) GetBatch() uint64

func (*AllocIDRequest) GetKey 

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

func (*AllocIDRequest) Marshal 

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

func (*AllocIDRequest) MarshalTo 

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

func (*AllocIDRequest) MarshalToSizedBuffer 

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

func (*AllocIDRequest) ProtoMessage 

func (*AllocIDRequest) ProtoMessage()

func (*AllocIDRequest) Reset 

func (m *AllocIDRequest) Reset()

func (*AllocIDRequest) Size 

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

func (*AllocIDRequest) String 

func (m *AllocIDRequest) String() string

func (*AllocIDRequest) Unmarshal 

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

func (*AllocIDRequest) XXX_DiscardUnknown 

func (m *AllocIDRequest) XXX_DiscardUnknown()

func (*AllocIDRequest) XXX_Marshal 

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

func (*AllocIDRequest) XXX_Merge 

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

func (*AllocIDRequest) XXX_Size 

func (m *AllocIDRequest) XXX_Size() int

func (*AllocIDRequest) XXX_Unmarshal 

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

type AppendRequest 

type AppendRequest struct {
	TabletName           string   `protobuf:"bytes,1,opt,name=tabletName,proto3" json:"tabletName,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

AppendRequest appends data in the table.

func (*AppendRequest) Descriptor 

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

func (*AppendRequest) GetData 

func (m *AppendRequest) GetData() []byte

func (*AppendRequest) GetTabletName 

func (m *AppendRequest) GetTabletName() string

func (*AppendRequest) Marshal 

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

func (*AppendRequest) MarshalTo 

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

func (*AppendRequest) MarshalToSizedBuffer 

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

func (*AppendRequest) ProtoMessage 

func (*AppendRequest) ProtoMessage()

func (*AppendRequest) Reset 

func (m *AppendRequest) Reset()

func (*AppendRequest) Size 

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

func (*AppendRequest) String 

func (m *AppendRequest) String() string

func (*AppendRequest) Unmarshal 

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

func (*AppendRequest) XXX_DiscardUnknown 

func (m *AppendRequest) XXX_DiscardUnknown()

func (*AppendRequest) XXX_Marshal 

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

func (*AppendRequest) XXX_Merge 

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

func (*AppendRequest) XXX_Size 

func (m *AppendRequest) XXX_Size() int

func (*AppendRequest) XXX_Unmarshal 

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

type BoolResponse 

type BoolResponse struct {
	Value                bool     `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BoolResponse response

func (*BoolResponse) Descriptor 

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

func (*BoolResponse) GetValue 

func (m *BoolResponse) GetValue() bool

func (*BoolResponse) Marshal 

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

func (*BoolResponse) MarshalTo 

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

func (*BoolResponse) MarshalToSizedBuffer 

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

func (*BoolResponse) ProtoMessage 

func (*BoolResponse) ProtoMessage()

func (*BoolResponse) Reset 

func (m *BoolResponse) Reset()

func (*BoolResponse) Size 

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

func (*BoolResponse) String 

func (m *BoolResponse) String() string

func (*BoolResponse) Unmarshal 

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

func (*BoolResponse) XXX_DiscardUnknown 

func (m *BoolResponse) XXX_DiscardUnknown()

func (*BoolResponse) XXX_Marshal 

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

func (*BoolResponse) XXX_Merge 

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

func (*BoolResponse) XXX_Size 

func (m *BoolResponse) XXX_Size() int

func (*BoolResponse) XXX_Unmarshal 

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

type BytesResponse 

type BytesResponse struct {
	Value                []byte   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BytesResponse response

func (*BytesResponse) Descriptor 

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

func (*BytesResponse) GetValue 

func (m *BytesResponse) GetValue() []byte

func (*BytesResponse) Marshal 

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

func (*BytesResponse) MarshalTo 

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

func (*BytesResponse) MarshalToSizedBuffer 

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

func (*BytesResponse) ProtoMessage 

func (*BytesResponse) ProtoMessage()

func (*BytesResponse) Reset 

func (m *BytesResponse) Reset()

func (*BytesResponse) Size 

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

func (*BytesResponse) String 

func (m *BytesResponse) String() string

func (*BytesResponse) Unmarshal 

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

func (*BytesResponse) XXX_DiscardUnknown 

func (m *BytesResponse) XXX_DiscardUnknown()

func (*BytesResponse) XXX_Marshal 

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

func (*BytesResponse) XXX_Merge 

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

func (*BytesResponse) XXX_Size 

func (m *BytesResponse) XXX_Size() int

func (*BytesResponse) XXX_Unmarshal 

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

type BytesSliceResponse 

type BytesSliceResponse struct {
	Keys                 [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values               [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	LastValue            uint64   `protobuf:"varint,3,opt,name=lastValue,proto3" json:"lastValue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

BytesSliceResponse response

func (*BytesSliceResponse) Descriptor 

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

func (*BytesSliceResponse) GetKeys 

func (m *BytesSliceResponse) GetKeys() [][]byte

func (*BytesSliceResponse) GetLastValue 

func (m *BytesSliceResponse) GetLastValue() uint64

func (*BytesSliceResponse) GetValues 

func (m *BytesSliceResponse) GetValues() [][]byte

func (*BytesSliceResponse) Marshal 

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

func (*BytesSliceResponse) MarshalTo 

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

func (*BytesSliceResponse) MarshalToSizedBuffer 

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

func (*BytesSliceResponse) ProtoMessage 

func (*BytesSliceResponse) ProtoMessage()

func (*BytesSliceResponse) Reset 

func (m *BytesSliceResponse) Reset()

func (*BytesSliceResponse) Size 

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

func (*BytesSliceResponse) String 

func (m *BytesSliceResponse) String() string

func (*BytesSliceResponse) Unmarshal 

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

func (*BytesSliceResponse) XXX_DiscardUnknown 

func (m *BytesSliceResponse) XXX_DiscardUnknown()

func (*BytesSliceResponse) XXX_Marshal 

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

func (*BytesSliceResponse) XXX_Merge 

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

func (*BytesSliceResponse) XXX_Size 

func (m *BytesSliceResponse) XXX_Size() int

func (*BytesSliceResponse) XXX_Unmarshal 

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

type CreateIndexRequest 

type CreateIndexRequest struct {
	TableName            string   `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	Indices              []byte   `protobuf:"bytes,2,opt,name=indices,proto3" json:"indices,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateIndexRequest create an index

func (*CreateIndexRequest) Descriptor 

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

func (*CreateIndexRequest) GetIndices 

func (m *CreateIndexRequest) GetIndices() []byte

func (*CreateIndexRequest) GetTableName 

func (m *CreateIndexRequest) GetTableName() string

func (*CreateIndexRequest) Marshal 

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

func (*CreateIndexRequest) MarshalTo 

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

func (*CreateIndexRequest) MarshalToSizedBuffer 

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

func (*CreateIndexRequest) ProtoMessage 

func (*CreateIndexRequest) ProtoMessage()

func (*CreateIndexRequest) Reset 

func (m *CreateIndexRequest) Reset()

func (*CreateIndexRequest) Size 

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

func (*CreateIndexRequest) String 

func (m *CreateIndexRequest) String() string

func (*CreateIndexRequest) Unmarshal 

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

func (*CreateIndexRequest) XXX_DiscardUnknown 

func (m *CreateIndexRequest) XXX_DiscardUnknown()

func (*CreateIndexRequest) XXX_Marshal 

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

func (*CreateIndexRequest) XXX_Merge 

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

func (*CreateIndexRequest) XXX_Size 

func (m *CreateIndexRequest) XXX_Size() int

func (*CreateIndexRequest) XXX_Unmarshal 

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

type CreateTabletRequest 

type CreateTabletRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TableInfo            []byte   `protobuf:"bytes,2,opt,name=tableInfo,proto3" json:"tableInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateTabletRequest create a tablet for the table.

func (*CreateTabletRequest) Descriptor 

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

func (*CreateTabletRequest) GetName 

func (m *CreateTabletRequest) GetName() string

func (*CreateTabletRequest) GetTableInfo 

func (m *CreateTabletRequest) GetTableInfo() []byte

func (*CreateTabletRequest) Marshal 

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

func (*CreateTabletRequest) MarshalTo 

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

func (*CreateTabletRequest) MarshalToSizedBuffer 

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

func (*CreateTabletRequest) ProtoMessage 

func (*CreateTabletRequest) ProtoMessage()

func (*CreateTabletRequest) Reset 

func (m *CreateTabletRequest) Reset()

func (*CreateTabletRequest) Size 

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

func (*CreateTabletRequest) String 

func (m *CreateTabletRequest) String() string

func (*CreateTabletRequest) Unmarshal 

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

func (*CreateTabletRequest) XXX_DiscardUnknown 

func (m *CreateTabletRequest) XXX_DiscardUnknown()

func (*CreateTabletRequest) XXX_Marshal 

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

func (*CreateTabletRequest) XXX_Merge 

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

func (*CreateTabletRequest) XXX_Size 

func (m *CreateTabletRequest) XXX_Size() int

func (*CreateTabletRequest) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DeleteRequest remove a key value pair

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) MarshalToSizedBuffer 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DropIndexRequest 

type DropIndexRequest struct {
	TableName            string   `protobuf:"bytes,1,opt,name=tableName,proto3" json:"tableName,omitempty"`
	IndexName            string   `protobuf:"bytes,2,opt,name=indexName,proto3" json:"indexName,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DropIndexRequest drops an index

func (*DropIndexRequest) Descriptor 

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

func (*DropIndexRequest) GetIndexName 

func (m *DropIndexRequest) GetIndexName() string

func (*DropIndexRequest) GetTableName 

func (m *DropIndexRequest) GetTableName() string

func (*DropIndexRequest) Marshal 

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

func (*DropIndexRequest) MarshalTo 

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

func (*DropIndexRequest) MarshalToSizedBuffer 

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

func (*DropIndexRequest) ProtoMessage 

func (*DropIndexRequest) ProtoMessage()

func (*DropIndexRequest) Reset 

func (m *DropIndexRequest) Reset()

func (*DropIndexRequest) Size 

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

func (*DropIndexRequest) String 

func (m *DropIndexRequest) String() string

func (*DropIndexRequest) Unmarshal 

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

func (*DropIndexRequest) XXX_DiscardUnknown 

func (m *DropIndexRequest) XXX_DiscardUnknown()

func (*DropIndexRequest) XXX_Marshal 

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

func (*DropIndexRequest) XXX_Merge 

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

func (*DropIndexRequest) XXX_Size 

func (m *DropIndexRequest) XXX_Size() int

func (*DropIndexRequest) XXX_Unmarshal 

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

type DropTabletRequest 

type DropTabletRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

DropTabletRequest drop all the tablets of the table.

func (*DropTabletRequest) Descriptor 

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

func (*DropTabletRequest) GetName 

func (m *DropTabletRequest) GetName() string

func (*DropTabletRequest) Marshal 

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

func (*DropTabletRequest) MarshalTo 

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

func (*DropTabletRequest) MarshalToSizedBuffer 

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

func (*DropTabletRequest) ProtoMessage 

func (*DropTabletRequest) ProtoMessage()

func (*DropTabletRequest) Reset 

func (m *DropTabletRequest) Reset()

func (*DropTabletRequest) Size 

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

func (*DropTabletRequest) String 

func (m *DropTabletRequest) String() string

func (*DropTabletRequest) Unmarshal 

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

func (*DropTabletRequest) XXX_DiscardUnknown 

func (m *DropTabletRequest) XXX_DiscardUnknown()

func (*DropTabletRequest) XXX_Marshal 

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

func (*DropTabletRequest) XXX_Merge 

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

func (*DropTabletRequest) XXX_Size 

func (m *DropTabletRequest) XXX_Size() int

func (*DropTabletRequest) XXX_Unmarshal 

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

type EmptyResponse 

type EmptyResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EmptyResponse empty response

func (*EmptyResponse) Descriptor 

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

func (*EmptyResponse) Marshal 

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

func (*EmptyResponse) MarshalTo 

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

func (*EmptyResponse) MarshalToSizedBuffer 

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

func (*EmptyResponse) ProtoMessage 

func (*EmptyResponse) ProtoMessage()

func (*EmptyResponse) Reset 

func (m *EmptyResponse) Reset()

func (*EmptyResponse) Size 

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

func (*EmptyResponse) String 

func (m *EmptyResponse) String() string

func (*EmptyResponse) Unmarshal 

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

func (*EmptyResponse) XXX_DiscardUnknown 

func (m *EmptyResponse) XXX_DiscardUnknown()

func (*EmptyResponse) XXX_Marshal 

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

func (*EmptyResponse) XXX_Merge 

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

func (*EmptyResponse) XXX_Size 

func (m *EmptyResponse) XXX_Size() int

func (*EmptyResponse) XXX_Unmarshal 

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

type ErrorResponse 

type ErrorResponse struct {
	Error                string   `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ErrorResponse error response

func (*ErrorResponse) Descriptor 

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

func (*ErrorResponse) GetError 

func (m *ErrorResponse) GetError() string

func (*ErrorResponse) Marshal 

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

func (*ErrorResponse) MarshalTo 

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

func (*ErrorResponse) MarshalToSizedBuffer 

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

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) Reset 

func (m *ErrorResponse) Reset()

func (*ErrorResponse) Size 

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

func (*ErrorResponse) String 

func (m *ErrorResponse) String() string

func (*ErrorResponse) Unmarshal 

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

func (*ErrorResponse) XXX_DiscardUnknown 

func (m *ErrorResponse) XXX_DiscardUnknown()

func (*ErrorResponse) XXX_Marshal 

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

func (*ErrorResponse) XXX_Merge 

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

func (*ErrorResponse) XXX_Size 

func (m *ErrorResponse) XXX_Size() int

func (*ErrorResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetRequest get value by key

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

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

func (*GetRequest) Marshal 

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

func (*GetRequest) MarshalTo 

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

func (*GetRequest) MarshalToSizedBuffer 

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

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) Size 

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

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal 

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

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

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

func (*GetRequest) XXX_Merge 

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

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

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

type GetSegmentIdsRequest 

type GetSegmentIdsRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetSegmentIdsRequest gets the id of all the segments.

func (*GetSegmentIdsRequest) Descriptor 

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

func (*GetSegmentIdsRequest) GetName 

func (m *GetSegmentIdsRequest) GetName() string

func (*GetSegmentIdsRequest) Marshal 

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

func (*GetSegmentIdsRequest) MarshalTo 

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

func (*GetSegmentIdsRequest) MarshalToSizedBuffer 

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

func (*GetSegmentIdsRequest) ProtoMessage 

func (*GetSegmentIdsRequest) ProtoMessage()

func (*GetSegmentIdsRequest) Reset 

func (m *GetSegmentIdsRequest) Reset()

func (*GetSegmentIdsRequest) Size 

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

func (*GetSegmentIdsRequest) String 

func (m *GetSegmentIdsRequest) String() string

func (*GetSegmentIdsRequest) Unmarshal 

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

func (*GetSegmentIdsRequest) XXX_DiscardUnknown 

func (m *GetSegmentIdsRequest) XXX_DiscardUnknown()

func (*GetSegmentIdsRequest) XXX_Marshal 

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

func (*GetSegmentIdsRequest) XXX_Merge 

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

func (*GetSegmentIdsRequest) XXX_Size 

func (m *GetSegmentIdsRequest) XXX_Size() int

func (*GetSegmentIdsRequest) XXX_Unmarshal 

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

type GetSegmentedIdRequest 

type GetSegmentedIdRequest struct {
	ShardId              uint64   `protobuf:"varint,1,opt,name=shardId,proto3" json:"shardId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetSegmentedIdRequest gets id of one of the segments of the table.

func (*GetSegmentedIdRequest) Descriptor 

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

func (*GetSegmentedIdRequest) GetShardId 

func (m *GetSegmentedIdRequest) GetShardId() uint64

func (*GetSegmentedIdRequest) Marshal 

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

func (*GetSegmentedIdRequest) MarshalTo 

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

func (*GetSegmentedIdRequest) MarshalToSizedBuffer 

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

func (*GetSegmentedIdRequest) ProtoMessage 

func (*GetSegmentedIdRequest) ProtoMessage()

func (*GetSegmentedIdRequest) Reset 

func (m *GetSegmentedIdRequest) Reset()

func (*GetSegmentedIdRequest) Size 

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

func (*GetSegmentedIdRequest) String 

func (m *GetSegmentedIdRequest) String() string

func (*GetSegmentedIdRequest) Unmarshal 

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

func (*GetSegmentedIdRequest) XXX_DiscardUnknown 

func (m *GetSegmentedIdRequest) XXX_DiscardUnknown()

func (*GetSegmentedIdRequest) XXX_Marshal 

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

func (*GetSegmentedIdRequest) XXX_Merge 

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

func (*GetSegmentedIdRequest) XXX_Size 

func (m *GetSegmentedIdRequest) XXX_Size() int

func (*GetSegmentedIdRequest) XXX_Unmarshal 

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

type GetSnapshotRequest 

type GetSnapshotRequest struct {
	Ctx                  []byte   `protobuf:"bytes,1,opt,name=ctx,proto3" json:"ctx,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetSnapshotRequest gets a snapshot for the table.

func (*GetSnapshotRequest) Descriptor 

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

func (*GetSnapshotRequest) GetCtx 

func (m *GetSnapshotRequest) GetCtx() []byte

func (*GetSnapshotRequest) Marshal 

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

func (*GetSnapshotRequest) MarshalTo 

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

func (*GetSnapshotRequest) MarshalToSizedBuffer 

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

func (*GetSnapshotRequest) ProtoMessage 

func (*GetSnapshotRequest) ProtoMessage()

func (*GetSnapshotRequest) Reset 

func (m *GetSnapshotRequest) Reset()

func (*GetSnapshotRequest) Size 

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

func (*GetSnapshotRequest) String 

func (m *GetSnapshotRequest) String() string

func (*GetSnapshotRequest) Unmarshal 

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

func (*GetSnapshotRequest) XXX_DiscardUnknown 

func (m *GetSnapshotRequest) XXX_DiscardUnknown()

func (*GetSnapshotRequest) XXX_Marshal 

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

func (*GetSnapshotRequest) XXX_Merge 

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

func (*GetSnapshotRequest) XXX_Size 

func (m *GetSnapshotRequest) XXX_Size() int

func (*GetSnapshotRequest) XXX_Unmarshal 

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

type Group 

type Group int32

Group shard group 

const (
	KVGroup  Group = 0
	AOEGroup Group = 1
)

func (Group) EnumDescriptor 

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

func (Group) String 

func (x Group) String() string

type PrefixScanRequest 

type PrefixScanRequest struct {
	Prefix               []byte   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	StartKey             []byte   `protobuf:"bytes,2,opt,name=startKey,proto3" json:"startKey,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PrefixScanRequest scan request

func (*PrefixScanRequest) Descriptor 

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

func (*PrefixScanRequest) GetLimit 

func (m *PrefixScanRequest) GetLimit() uint64

func (*PrefixScanRequest) GetPrefix 

func (m *PrefixScanRequest) GetPrefix() []byte

func (*PrefixScanRequest) GetStartKey 

func (m *PrefixScanRequest) GetStartKey() []byte

func (*PrefixScanRequest) Marshal 

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

func (*PrefixScanRequest) MarshalTo 

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

func (*PrefixScanRequest) MarshalToSizedBuffer 

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

func (*PrefixScanRequest) ProtoMessage 

func (*PrefixScanRequest) ProtoMessage()

func (*PrefixScanRequest) Reset 

func (m *PrefixScanRequest) Reset()

func (*PrefixScanRequest) Size 

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

func (*PrefixScanRequest) String 

func (m *PrefixScanRequest) String() string

func (*PrefixScanRequest) Unmarshal 

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

func (*PrefixScanRequest) XXX_DiscardUnknown 

func (m *PrefixScanRequest) XXX_DiscardUnknown()

func (*PrefixScanRequest) XXX_Marshal 

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

func (*PrefixScanRequest) XXX_Merge 

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

func (*PrefixScanRequest) XXX_Size 

func (m *PrefixScanRequest) XXX_Size() int

func (*PrefixScanRequest) XXX_Unmarshal 

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

type Request 

type Request struct {
	ID                       uint64                          `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                     Type                            `protobuf:"varint,2,opt,name=type,proto3,enum=pb.Type" json:"type,omitempty"`
	Group                    Group                           `protobuf:"varint,3,opt,name=group,proto3,enum=pb.Group" json:"group,omitempty"`
	Shard                    uint64                          `protobuf:"varint,4,opt,name=shard,proto3" json:"shard,omitempty"`
	Set                      SetRequest                      `protobuf:"bytes,5,opt,name=set,proto3" json:"set"`
	Get                      GetRequest                      `protobuf:"bytes,6,opt,name=get,proto3" json:"get"`
	Delete                   DeleteRequest                   `protobuf:"bytes,7,opt,name=delete,proto3" json:"delete"`
	Scan                     ScanRequest                     `protobuf:"bytes,8,opt,name=scan,proto3" json:"scan"`
	PrefixScan               PrefixScanRequest               `protobuf:"bytes,9,opt,name=prefixScan,proto3" json:"prefixScan"`
	AllocID                  AllocIDRequest                  `protobuf:"bytes,10,opt,name=allocID,proto3" json:"allocID"`
	TpePrefixScan            TpePrefixScanRequest            `protobuf:"bytes,11,opt,name=tpePrefixScan,proto3" json:"tpePrefixScan"`
	TpeScan                  TpeScanRequest                  `protobuf:"bytes,12,opt,name=tpeScan,proto3" json:"tpeScan"`
	TpeDeleteBatch           TpeDeleteBatchRequest           `protobuf:"bytes,13,opt,name=tpeDeleteBatch,proto3" json:"tpeDeleteBatch"`
	TpeCheckKeysExistInBatch TpeCheckKeysExistInBatchRequest `protobuf:"bytes,14,opt,name=tpeCheckKeysExistInBatch,proto3" json:"tpeCheckKeysExistInBatch"`
	TpeSetBatch              TpeSetBatchRequest              `protobuf:"bytes,15,opt,name=tpeSetBatch,proto3" json:"tpeSetBatch"`
	Append                   AppendRequest                   `protobuf:"bytes,100,opt,name=append,proto3" json:"append"`
	GetSnapshot              GetSnapshotRequest              `protobuf:"bytes,101,opt,name=getSnapshot,proto3" json:"getSnapshot"`
	TabletIds                TabletIDsRequest                `protobuf:"bytes,102,opt,name=tabletIds,proto3" json:"tabletIds"`
	CreateTablet             CreateTabletRequest             `protobuf:"bytes,103,opt,name=createTablet,proto3" json:"createTablet"`
	DropTablet               DropTabletRequest               `protobuf:"bytes,104,opt,name=dropTablet,proto3" json:"dropTablet"`
	GetSegmentIds            GetSegmentIdsRequest            `protobuf:"bytes,105,opt,name=getSegmentIds,proto3" json:"getSegmentIds"`
	GetSegmentedId           GetSegmentedIdRequest           `protobuf:"bytes,106,opt,name=getSegmentedId,proto3" json:"getSegmentedId"`
	CreateIndex              CreateIndexRequest              `protobuf:"bytes,107,opt,name=createIndex,proto3" json:"createIndex"`
	DropIndex                DropIndexRequest                `protobuf:"bytes,108,opt,name=dropIndex,proto3" json:"dropIndex"`
	XXX_NoUnkeyedLiteral     struct{}                        `json:"-"`
	XXX_unrecognized         []byte                          `json:"-"`
	XXX_sizecache            int32                           `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetAllocID 

func (m *Request) GetAllocID() AllocIDRequest

func (*Request) GetAppend 

func (m *Request) GetAppend() AppendRequest

func (*Request) GetCreateIndex 

func (m *Request) GetCreateIndex() CreateIndexRequest

func (*Request) GetCreateTablet 

func (m *Request) GetCreateTablet() CreateTabletRequest

func (*Request) GetDelete 

func (m *Request) GetDelete() DeleteRequest

func (*Request) GetDropIndex 

func (m *Request) GetDropIndex() DropIndexRequest

func (*Request) GetDropTablet 

func (m *Request) GetDropTablet() DropTabletRequest

func (*Request) GetGet 

func (m *Request) GetGet() GetRequest

func (*Request) GetGetSegmentIds 

func (m *Request) GetGetSegmentIds() GetSegmentIdsRequest

func (*Request) GetGetSegmentedId 

func (m *Request) GetGetSegmentedId() GetSegmentedIdRequest

func (*Request) GetGetSnapshot 

func (m *Request) GetGetSnapshot() GetSnapshotRequest

func (*Request) GetGroup 

func (m *Request) GetGroup() Group

func (*Request) GetID 

func (m *Request) GetID() uint64

func (*Request) GetPrefixScan 

func (m *Request) GetPrefixScan() PrefixScanRequest

func (*Request) GetScan 

func (m *Request) GetScan() ScanRequest

func (*Request) GetSet 

func (m *Request) GetSet() SetRequest

func (*Request) GetShard 

func (m *Request) GetShard() uint64

func (*Request) GetTabletIds 

func (m *Request) GetTabletIds() TabletIDsRequest

func (*Request) GetTpeCheckKeysExistInBatch 

func (m *Request) GetTpeCheckKeysExistInBatch() TpeCheckKeysExistInBatchRequest

func (*Request) GetTpeDeleteBatch 

func (m *Request) GetTpeDeleteBatch() TpeDeleteBatchRequest

func (*Request) GetTpePrefixScan 

func (m *Request) GetTpePrefixScan() TpePrefixScanRequest

func (*Request) GetTpeScan 

func (m *Request) GetTpeScan() TpeScanRequest

func (*Request) GetTpeSetBatch 

func (m *Request) GetTpeSetBatch() TpeSetBatchRequest

func (*Request) GetType 

func (m *Request) GetType() Type

func (*Request) Marshal 

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

func (*Request) MarshalTo 

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

func (*Request) MarshalToSizedBuffer 

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

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

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

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

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

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type Response 

type Response struct {
	ID                   uint64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 Type               `protobuf:"varint,2,opt,name=type,proto3,enum=pb.Type" json:"type,omitempty"`
	Error                ErrorResponse      `protobuf:"bytes,3,opt,name=error,proto3" json:"error"`
	BytesResp            BytesResponse      `protobuf:"bytes,4,opt,name=bytesResp,proto3" json:"bytesResp"`
	BoolResp             BoolResponse       `protobuf:"bytes,5,opt,name=boolResp,proto3" json:"boolResp"`
	Uint64Resp           Uint64Response     `protobuf:"bytes,6,opt,name=uint64Resp,proto3" json:"uint64Resp"`
	Uint32Resp           Uint32Response     `protobuf:"bytes,7,opt,name=uint32Resp,proto3" json:"uint32Resp"`
	BytesSliceResp       BytesSliceResponse `protobuf:"bytes,8,opt,name=bytesSliceResp,proto3" json:"bytesSliceResp"`
	StringResp           StringResponse     `protobuf:"bytes,9,opt,name=stringResp,proto3" json:"stringResp"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetBoolResp 

func (m *Response) GetBoolResp() BoolResponse

func (*Response) GetBytesResp 

func (m *Response) GetBytesResp() BytesResponse

func (*Response) GetBytesSliceResp 

func (m *Response) GetBytesSliceResp() BytesSliceResponse

func (*Response) GetError 

func (m *Response) GetError() ErrorResponse

func (*Response) GetID 

func (m *Response) GetID() uint64

func (*Response) GetStringResp 

func (m *Response) GetStringResp() StringResponse

func (*Response) GetType 

func (m *Response) GetType() Type

func (*Response) GetUint32Resp 

func (m *Response) GetUint32Resp() Uint32Response

func (*Response) GetUint64Resp 

func (m *Response) GetUint64Resp() Uint64Response

func (*Response) Marshal 

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

func (*Response) MarshalTo 

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

func (*Response) MarshalToSizedBuffer 

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

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

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

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

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

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type ScanRequest 

type ScanRequest struct {
	Start                []byte   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  []byte   `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	Limit                uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ScanRequest scan request

func (*ScanRequest) Descriptor 

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

func (*ScanRequest) GetEnd 

func (m *ScanRequest) GetEnd() []byte

func (*ScanRequest) GetLimit 

func (m *ScanRequest) GetLimit() uint64

func (*ScanRequest) GetStart 

func (m *ScanRequest) GetStart() []byte

func (*ScanRequest) Marshal 

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

func (*ScanRequest) MarshalTo 

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

func (*ScanRequest) MarshalToSizedBuffer 

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

func (*ScanRequest) ProtoMessage 

func (*ScanRequest) ProtoMessage()

func (*ScanRequest) Reset 

func (m *ScanRequest) Reset()

func (*ScanRequest) Size 

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

func (*ScanRequest) String 

func (m *ScanRequest) String() string

func (*ScanRequest) Unmarshal 

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

func (*ScanRequest) XXX_DiscardUnknown 

func (m *ScanRequest) XXX_DiscardUnknown()

func (*ScanRequest) XXX_Marshal 

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

func (*ScanRequest) XXX_Merge 

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

func (*ScanRequest) XXX_Size 

func (m *ScanRequest) XXX_Size() int

func (*ScanRequest) XXX_Unmarshal 

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

type SetRequest 

type SetRequest struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	TTL                  int64    `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	KeyIndex             int32    `protobuf:"varint,4,opt,name=keyIndex,proto3" json:"keyIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SetRequest set a key value pair

func (*SetRequest) Descriptor 

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

func (*SetRequest) GetKey 

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

func (*SetRequest) GetKeyIndex 

func (m *SetRequest) GetKeyIndex() int32

func (*SetRequest) GetTTL 

func (m *SetRequest) GetTTL() int64

func (*SetRequest) GetValue 

func (m *SetRequest) GetValue() []byte

func (*SetRequest) Marshal 

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

func (*SetRequest) MarshalTo 

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

func (*SetRequest) MarshalToSizedBuffer 

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

func (*SetRequest) ProtoMessage 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset 

func (m *SetRequest) Reset()

func (*SetRequest) Size 

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

func (*SetRequest) String 

func (m *SetRequest) String() string

func (*SetRequest) Unmarshal 

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

func (*SetRequest) XXX_DiscardUnknown 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal 

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

func (*SetRequest) XXX_Merge 

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

func (*SetRequest) XXX_Size 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal 

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

type StringResponse 

type StringResponse struct {
	Value                string   `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

StringResponse response

func (*StringResponse) Descriptor 

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

func (*StringResponse) GetValue 

func (m *StringResponse) GetValue() string

func (*StringResponse) Marshal 

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

func (*StringResponse) MarshalTo 

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

func (*StringResponse) MarshalToSizedBuffer 

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

func (*StringResponse) ProtoMessage 

func (*StringResponse) ProtoMessage()

func (*StringResponse) Reset 

func (m *StringResponse) Reset()

func (*StringResponse) Size 

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

func (*StringResponse) String 

func (m *StringResponse) String() string

func (*StringResponse) Unmarshal 

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

func (*StringResponse) XXX_DiscardUnknown 

func (m *StringResponse) XXX_DiscardUnknown()

func (*StringResponse) XXX_Marshal 

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

func (*StringResponse) XXX_Merge 

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

func (*StringResponse) XXX_Size 

func (m *StringResponse) XXX_Size() int

func (*StringResponse) XXX_Unmarshal 

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

type TabletIDsRequest 

type TabletIDsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TabletIDsRequest gets the ids of all the tablets of the table.

func (*TabletIDsRequest) Descriptor 

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

func (*TabletIDsRequest) Marshal 

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

func (*TabletIDsRequest) MarshalTo 

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

func (*TabletIDsRequest) MarshalToSizedBuffer 

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

func (*TabletIDsRequest) ProtoMessage 

func (*TabletIDsRequest) ProtoMessage()

func (*TabletIDsRequest) Reset 

func (m *TabletIDsRequest) Reset()

func (*TabletIDsRequest) Size 

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

func (*TabletIDsRequest) String 

func (m *TabletIDsRequest) String() string

func (*TabletIDsRequest) Unmarshal 

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

func (*TabletIDsRequest) XXX_DiscardUnknown 

func (m *TabletIDsRequest) XXX_DiscardUnknown()

func (*TabletIDsRequest) XXX_Marshal 

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

func (*TabletIDsRequest) XXX_Merge 

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

func (*TabletIDsRequest) XXX_Size 

func (m *TabletIDsRequest) XXX_Size() int

func (*TabletIDsRequest) XXX_Unmarshal 

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

type TpeCheckKeysExistInBatchRequest 

type TpeCheckKeysExistInBatchRequest struct {
	//the keys from the same shard
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	//the shardID
	ShardID              uint64   `protobuf:"varint,2,opt,name=shardID,proto3" json:"shardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TpeCheckKeysExistInBatchRequest) Descriptor 

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

func (*TpeCheckKeysExistInBatchRequest) GetKeys 

func (m *TpeCheckKeysExistInBatchRequest) GetKeys() [][]byte

func (*TpeCheckKeysExistInBatchRequest) GetShardID 

func (m *TpeCheckKeysExistInBatchRequest) GetShardID() uint64

func (*TpeCheckKeysExistInBatchRequest) Marshal 

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

func (*TpeCheckKeysExistInBatchRequest) MarshalTo 

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

func (*TpeCheckKeysExistInBatchRequest) MarshalToSizedBuffer 

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

func (*TpeCheckKeysExistInBatchRequest) ProtoMessage 

func (*TpeCheckKeysExistInBatchRequest) ProtoMessage()

func (*TpeCheckKeysExistInBatchRequest) Reset 

func (m *TpeCheckKeysExistInBatchRequest) Reset()

func (*TpeCheckKeysExistInBatchRequest) Size 

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

func (*TpeCheckKeysExistInBatchRequest) String 

func (m *TpeCheckKeysExistInBatchRequest) String() string

func (*TpeCheckKeysExistInBatchRequest) Unmarshal 

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

func (*TpeCheckKeysExistInBatchRequest) XXX_DiscardUnknown 

func (m *TpeCheckKeysExistInBatchRequest) XXX_DiscardUnknown()

func (*TpeCheckKeysExistInBatchRequest) XXX_Marshal 

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

func (*TpeCheckKeysExistInBatchRequest) XXX_Merge 

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

func (*TpeCheckKeysExistInBatchRequest) XXX_Size 

func (m *TpeCheckKeysExistInBatchRequest) XXX_Size() int

func (*TpeCheckKeysExistInBatchRequest) XXX_Unmarshal 

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

type TpeCheckKeysExistInBatchResponse 

type TpeCheckKeysExistInBatchResponse struct {
	ExistedKeyIndex      int32    `protobuf:"varint,1,opt,name=existedKeyIndex,proto3" json:"existedKeyIndex,omitempty"`
	ShardID              uint64   `protobuf:"varint,2,opt,name=shardID,proto3" json:"shardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TpeCheckKeysExistInBatchResponse) Descriptor 

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

func (*TpeCheckKeysExistInBatchResponse) GetExistedKeyIndex 

func (m *TpeCheckKeysExistInBatchResponse) GetExistedKeyIndex() int32

func (*TpeCheckKeysExistInBatchResponse) GetShardID 

func (m *TpeCheckKeysExistInBatchResponse) GetShardID() uint64

func (*TpeCheckKeysExistInBatchResponse) Marshal 

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

func (*TpeCheckKeysExistInBatchResponse) MarshalTo 

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

func (*TpeCheckKeysExistInBatchResponse) MarshalToSizedBuffer 

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

func (*TpeCheckKeysExistInBatchResponse) ProtoMessage 

func (*TpeCheckKeysExistInBatchResponse) ProtoMessage()

func (*TpeCheckKeysExistInBatchResponse) Reset 

func (m *TpeCheckKeysExistInBatchResponse) Reset()

func (*TpeCheckKeysExistInBatchResponse) Size 

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

func (*TpeCheckKeysExistInBatchResponse) String 

func (m *TpeCheckKeysExistInBatchResponse) String() string

func (*TpeCheckKeysExistInBatchResponse) Unmarshal 

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

func (*TpeCheckKeysExistInBatchResponse) XXX_DiscardUnknown 

func (m *TpeCheckKeysExistInBatchResponse) XXX_DiscardUnknown()

func (*TpeCheckKeysExistInBatchResponse) XXX_Marshal 

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

func (*TpeCheckKeysExistInBatchResponse) XXX_Merge 

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

func (*TpeCheckKeysExistInBatchResponse) XXX_Size 

func (m *TpeCheckKeysExistInBatchResponse) XXX_Size() int

func (*TpeCheckKeysExistInBatchResponse) XXX_Unmarshal 

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

type TpeDeleteBatchRequest 

type TpeDeleteBatchRequest struct {
	//the keys wanted to be deleted
	//if the keys is null,then use the range follow
	Keys [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	//the range [start,end)
	Start                []byte   `protobuf:"bytes,3,opt,name=start,proto3" json:"start,omitempty"`
	End                  []byte   `protobuf:"bytes,4,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TpeDeleteBatchRequest) Descriptor 

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

func (*TpeDeleteBatchRequest) GetEnd 

func (m *TpeDeleteBatchRequest) GetEnd() []byte

func (*TpeDeleteBatchRequest) GetKeys 

func (m *TpeDeleteBatchRequest) GetKeys() [][]byte

func (*TpeDeleteBatchRequest) GetStart 

func (m *TpeDeleteBatchRequest) GetStart() []byte

func (*TpeDeleteBatchRequest) Marshal 

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

func (*TpeDeleteBatchRequest) MarshalTo 

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

func (*TpeDeleteBatchRequest) MarshalToSizedBuffer 

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

func (*TpeDeleteBatchRequest) ProtoMessage 

func (*TpeDeleteBatchRequest) ProtoMessage()

func (*TpeDeleteBatchRequest) Reset 

func (m *TpeDeleteBatchRequest) Reset()

func (*TpeDeleteBatchRequest) Size 

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

func (*TpeDeleteBatchRequest) String 

func (m *TpeDeleteBatchRequest) String() string

func (*TpeDeleteBatchRequest) Unmarshal 

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

func (*TpeDeleteBatchRequest) XXX_DiscardUnknown 

func (m *TpeDeleteBatchRequest) XXX_DiscardUnknown()

func (*TpeDeleteBatchRequest) XXX_Marshal 

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

func (*TpeDeleteBatchRequest) XXX_Merge 

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

func (*TpeDeleteBatchRequest) XXX_Size 

func (m *TpeDeleteBatchRequest) XXX_Size() int

func (*TpeDeleteBatchRequest) XXX_Unmarshal 

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

type TpePrefixScanRequest 

type TpePrefixScanRequest struct {
	//the startKey for the scan
	PrefixOrStartKey []byte `protobuf:"bytes,1,opt,name=prefixOrStartKey,proto3" json:"prefixOrStartKey,omitempty"`
	//the prefixOrStartKey[:prefixLength] is the prefix
	PrefixLength int64 `protobuf:"varint,2,opt,name=prefixLength,proto3" json:"prefixLength,omitempty"`
	//the endKey of the range denoted by the prefix
	PrefixEnd []byte `protobuf:"bytes,3,opt,name=prefixEnd,proto3" json:"prefixEnd,omitempty"`
	//return the keys without their values
	NeedKeyOnly bool `protobuf:"varint,4,opt,name=needKeyOnly,proto3" json:"needKeyOnly,omitempty"`
	//the count of key/value wanted at most in the reqeust
	Limit                uint64   `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TpePrefixScanRequest scan request

func (*TpePrefixScanRequest) Descriptor 

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

func (*TpePrefixScanRequest) GetLimit 

func (m *TpePrefixScanRequest) GetLimit() uint64

func (*TpePrefixScanRequest) GetNeedKeyOnly 

func (m *TpePrefixScanRequest) GetNeedKeyOnly() bool

func (*TpePrefixScanRequest) GetPrefixEnd 

func (m *TpePrefixScanRequest) GetPrefixEnd() []byte

func (*TpePrefixScanRequest) GetPrefixLength 

func (m *TpePrefixScanRequest) GetPrefixLength() int64

func (*TpePrefixScanRequest) GetPrefixOrStartKey 

func (m *TpePrefixScanRequest) GetPrefixOrStartKey() []byte

func (*TpePrefixScanRequest) Marshal 

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

func (*TpePrefixScanRequest) MarshalTo 

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

func (*TpePrefixScanRequest) MarshalToSizedBuffer 

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

func (*TpePrefixScanRequest) ProtoMessage 

func (*TpePrefixScanRequest) ProtoMessage()

func (*TpePrefixScanRequest) Reset 

func (m *TpePrefixScanRequest) Reset()

func (*TpePrefixScanRequest) Size 

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

func (*TpePrefixScanRequest) String 

func (m *TpePrefixScanRequest) String() string

func (*TpePrefixScanRequest) Unmarshal 

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

func (*TpePrefixScanRequest) XXX_DiscardUnknown 

func (m *TpePrefixScanRequest) XXX_DiscardUnknown()

func (*TpePrefixScanRequest) XXX_Marshal 

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

func (*TpePrefixScanRequest) XXX_Merge 

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

func (*TpePrefixScanRequest) XXX_Size 

func (m *TpePrefixScanRequest) XXX_Size() int

func (*TpePrefixScanRequest) XXX_Unmarshal 

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

type TpeScanRequest 

type TpeScanRequest struct {
	//the range [start,end)
	Start  []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End    []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	Prefix []byte `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	//the count of key/value wanted at most in the request
	Limit uint64 `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	//the key needed to be returned
	NeedKey              bool     `protobuf:"varint,5,opt,name=needKey,proto3" json:"needKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TpeScanRequest scan request

func (*TpeScanRequest) Descriptor 

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

func (*TpeScanRequest) GetEnd 

func (m *TpeScanRequest) GetEnd() []byte

func (*TpeScanRequest) GetLimit 

func (m *TpeScanRequest) GetLimit() uint64

func (*TpeScanRequest) GetNeedKey 

func (m *TpeScanRequest) GetNeedKey() bool

func (*TpeScanRequest) GetPrefix 

func (m *TpeScanRequest) GetPrefix() []byte

func (*TpeScanRequest) GetStart 

func (m *TpeScanRequest) GetStart() []byte

func (*TpeScanRequest) Marshal 

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

func (*TpeScanRequest) MarshalTo 

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

func (*TpeScanRequest) MarshalToSizedBuffer 

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

func (*TpeScanRequest) ProtoMessage 

func (*TpeScanRequest) ProtoMessage()

func (*TpeScanRequest) Reset 

func (m *TpeScanRequest) Reset()

func (*TpeScanRequest) Size 

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

func (*TpeScanRequest) String 

func (m *TpeScanRequest) String() string

func (*TpeScanRequest) Unmarshal 

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

func (*TpeScanRequest) XXX_DiscardUnknown 

func (m *TpeScanRequest) XXX_DiscardUnknown()

func (*TpeScanRequest) XXX_Marshal 

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

func (*TpeScanRequest) XXX_Merge 

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

func (*TpeScanRequest) XXX_Size 

func (m *TpeScanRequest) XXX_Size() int

func (*TpeScanRequest) XXX_Unmarshal 

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

type TpeScanResponse 

type TpeScanResponse struct {
	Keys                 [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values               [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	CompleteInAllShards  bool     `protobuf:"varint,3,opt,name=completeInAllShards,proto3" json:"completeInAllShards,omitempty"`
	NextScanKey          []byte   `protobuf:"bytes,4,opt,name=nextScanKey,proto3" json:"nextScanKey,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TpeScanResponse) Descriptor 

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

func (*TpeScanResponse) GetCompleteInAllShards 

func (m *TpeScanResponse) GetCompleteInAllShards() bool

func (*TpeScanResponse) GetKeys 

func (m *TpeScanResponse) GetKeys() [][]byte

func (*TpeScanResponse) GetNextScanKey 

func (m *TpeScanResponse) GetNextScanKey() []byte

func (*TpeScanResponse) GetValues 

func (m *TpeScanResponse) GetValues() [][]byte

func (*TpeScanResponse) Marshal 

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

func (*TpeScanResponse) MarshalTo 

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

func (*TpeScanResponse) MarshalToSizedBuffer 

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

func (*TpeScanResponse) ProtoMessage 

func (*TpeScanResponse) ProtoMessage()

func (*TpeScanResponse) Reset 

func (m *TpeScanResponse) Reset()

func (*TpeScanResponse) Size 

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

func (*TpeScanResponse) String 

func (m *TpeScanResponse) String() string

func (*TpeScanResponse) Unmarshal 

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

func (*TpeScanResponse) XXX_DiscardUnknown 

func (m *TpeScanResponse) XXX_DiscardUnknown()

func (*TpeScanResponse) XXX_Marshal 

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

func (*TpeScanResponse) XXX_Merge 

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

func (*TpeScanResponse) XXX_Size 

func (m *TpeScanResponse) XXX_Size() int

func (*TpeScanResponse) XXX_Unmarshal 

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

type TpeSetBatchRequest 

type TpeSetBatchRequest struct {
	//the keys/values need to be set
	Keys   [][]byte `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	//the shardID
	ShardID              uint64   `protobuf:"varint,3,opt,name=shardID,proto3" json:"shardID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TpeSetBatchRequest) Descriptor 

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

func (*TpeSetBatchRequest) GetKeys 

func (m *TpeSetBatchRequest) GetKeys() [][]byte

func (*TpeSetBatchRequest) GetShardID 

func (m *TpeSetBatchRequest) GetShardID() uint64

func (*TpeSetBatchRequest) GetValues 

func (m *TpeSetBatchRequest) GetValues() [][]byte

func (*TpeSetBatchRequest) Marshal 

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

func (*TpeSetBatchRequest) MarshalTo 

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

func (*TpeSetBatchRequest) MarshalToSizedBuffer 

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

func (*TpeSetBatchRequest) ProtoMessage 

func (*TpeSetBatchRequest) ProtoMessage()

func (*TpeSetBatchRequest) Reset 

func (m *TpeSetBatchRequest) Reset()

func (*TpeSetBatchRequest) Size 

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

func (*TpeSetBatchRequest) String 

func (m *TpeSetBatchRequest) String() string

func (*TpeSetBatchRequest) Unmarshal 

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

func (*TpeSetBatchRequest) XXX_DiscardUnknown 

func (m *TpeSetBatchRequest) XXX_DiscardUnknown()

func (*TpeSetBatchRequest) XXX_Marshal 

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

func (*TpeSetBatchRequest) XXX_Merge 

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

func (*TpeSetBatchRequest) XXX_Size 

func (m *TpeSetBatchRequest) XXX_Size() int

func (*TpeSetBatchRequest) XXX_Unmarshal 

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

type Type 

type Type int32
const (
	Set                      Type = 0
	Del                      Type = 1
	Get                      Type = 2
	PrefixScan               Type = 3
	Scan                     Type = 4
	Incr                     Type = 5
	SetIfNotExist            Type = 6
	DelIfNotExist            Type = 7
	TpePrefixScan            Type = 8
	TpeScan                  Type = 9
	TpeDeleteBatch           Type = 10
	TpeCheckKeysExistInBatch Type = 11
	TpeSetBatch              Type = 12
	Append                   Type = 100
	GetSnapshot              Type = 101
	CreateTablet             Type = 102
	DropTablet               Type = 103
	Relation                 Type = 104
	TabletIds                Type = 105
	TabletNames              Type = 106
	GetSegmentIds            Type = 107
	GetSegmentedId           Type = 108
	CreateIndex              Type = 109
	DropIndex                Type = 110
)

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

type Uint32Response 

type Uint32Response struct {
	Value                uint32   `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Uint32Response uint32 response

func (*Uint32Response) Descriptor 

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

func (*Uint32Response) GetValue 

func (m *Uint32Response) GetValue() uint32

func (*Uint32Response) Marshal 

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

func (*Uint32Response) MarshalTo 

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

func (*Uint32Response) MarshalToSizedBuffer 

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

func (*Uint32Response) ProtoMessage 

func (*Uint32Response) ProtoMessage()

func (*Uint32Response) Reset 

func (m *Uint32Response) Reset()

func (*Uint32Response) Size 

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

func (*Uint32Response) String 

func (m *Uint32Response) String() string

func (*Uint32Response) Unmarshal 

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

func (*Uint32Response) XXX_DiscardUnknown 

func (m *Uint32Response) XXX_DiscardUnknown()

func (*Uint32Response) XXX_Marshal 

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

func (*Uint32Response) XXX_Merge 

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

func (*Uint32Response) XXX_Size 

func (m *Uint32Response) XXX_Size() int

func (*Uint32Response) XXX_Unmarshal 

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

type Uint64Response 

type Uint64Response struct {
	Value                uint64   `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Uint64Response response

func (*Uint64Response) Descriptor 

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

func (*Uint64Response) GetValue 

func (m *Uint64Response) GetValue() uint64

func (*Uint64Response) Marshal 

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

func (*Uint64Response) MarshalTo 

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

func (*Uint64Response) MarshalToSizedBuffer 

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

func (*Uint64Response) ProtoMessage 

func (*Uint64Response) ProtoMessage()

func (*Uint64Response) Reset 

func (m *Uint64Response) Reset()

func (*Uint64Response) Size 

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

func (*Uint64Response) String 

func (m *Uint64Response) String() string

func (*Uint64Response) Unmarshal 

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

func (*Uint64Response) XXX_DiscardUnknown 

func (m *Uint64Response) XXX_DiscardUnknown()

func (*Uint64Response) XXX_Marshal 

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

func (*Uint64Response) XXX_Merge 

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

func (*Uint64Response) XXX_Size 

func (m *Uint64Response) XXX_Size() int

func (*Uint64Response) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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