pspb

package
v0.0.0-...-6aa601a Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2021 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthPspb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPspb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPspb = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterPartitionKVServer 

func RegisterPartitionKVServer(s *grpc.Server, srv PartitionKVServer)

Types

type BatchRequest 

type BatchRequest struct {
	Req []*RequestOp `protobuf:"bytes,1,rep,name=req,proto3" json:"req,omitempty"`
}

func (*BatchRequest) Descriptor 

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

func (*BatchRequest) GetReq 

func (m *BatchRequest) GetReq() []*RequestOp

func (*BatchRequest) Marshal 

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

func (*BatchRequest) MarshalTo 

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

func (*BatchRequest) MarshalToSizedBuffer 

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

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) Reset 

func (m *BatchRequest) Reset()

func (*BatchRequest) Size 

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

func (*BatchRequest) String 

func (m *BatchRequest) String() string

func (*BatchRequest) Unmarshal 

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

func (*BatchRequest) XXX_DiscardUnknown 

func (m *BatchRequest) XXX_DiscardUnknown()

func (*BatchRequest) XXX_Marshal 

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

func (*BatchRequest) XXX_Merge 

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

func (*BatchRequest) XXX_Size 

func (m *BatchRequest) XXX_Size() int

func (*BatchRequest) XXX_Unmarshal 

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

type BatchResponse 

type BatchResponse struct {
	Res []*RequestOp `protobuf:"bytes,1,rep,name=res,proto3" json:"res,omitempty"`
}

func (*BatchResponse) Descriptor 

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

func (*BatchResponse) GetRes 

func (m *BatchResponse) GetRes() []*RequestOp

func (*BatchResponse) Marshal 

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

func (*BatchResponse) MarshalTo 

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

func (*BatchResponse) MarshalToSizedBuffer 

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

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) Reset 

func (m *BatchResponse) Reset()

func (*BatchResponse) Size 

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

func (*BatchResponse) String 

func (m *BatchResponse) String() string

func (*BatchResponse) Unmarshal 

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

func (*BatchResponse) XXX_DiscardUnknown 

func (m *BatchResponse) XXX_DiscardUnknown()

func (*BatchResponse) XXX_Marshal 

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

func (*BatchResponse) XXX_Merge 

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

func (*BatchResponse) XXX_Size 

func (m *BatchResponse) XXX_Size() int

func (*BatchResponse) XXX_Unmarshal 

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

type BlockMeta 

type BlockMeta struct {
	TableIndex       *TableIndex `protobuf:"bytes,1,opt,name=tableIndex,proto3" json:"tableIndex,omitempty"`
	CompressedSize   uint32      `protobuf:"varint,2,opt,name=CompressedSize,proto3" json:"CompressedSize,omitempty"`
	UnCompressedSize uint32      `protobuf:"varint,3,opt,name=UnCompressedSize,proto3" json:"UnCompressedSize,omitempty"`
	VpExtentID       uint64      `protobuf:"varint,4,opt,name=vpExtentID,proto3" json:"vpExtentID,omitempty"`
	VpOffset         uint32      `protobuf:"varint,5,opt,name=vpOffset,proto3" json:"vpOffset,omitempty"`
	SeqNum           uint64      `protobuf:"varint,6,opt,name=seqNum,proto3" json:"seqNum,omitempty"`
}

func (*BlockMeta) Descriptor 

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

func (*BlockMeta) GetCompressedSize 

func (m *BlockMeta) GetCompressedSize() uint32

func (*BlockMeta) GetSeqNum 

func (m *BlockMeta) GetSeqNum() uint64

func (*BlockMeta) GetTableIndex 

func (m *BlockMeta) GetTableIndex() *TableIndex

func (*BlockMeta) GetUnCompressedSize 

func (m *BlockMeta) GetUnCompressedSize() uint32

func (*BlockMeta) GetVpExtentID 

func (m *BlockMeta) GetVpExtentID() uint64

func (*BlockMeta) GetVpOffset 

func (m *BlockMeta) GetVpOffset() uint32

func (*BlockMeta) Marshal 

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

func (*BlockMeta) MarshalTo 

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

func (*BlockMeta) MarshalToSizedBuffer 

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

func (*BlockMeta) ProtoMessage 

func (*BlockMeta) ProtoMessage()

func (*BlockMeta) Reset 

func (m *BlockMeta) Reset()

func (*BlockMeta) Size 

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

func (*BlockMeta) String 

func (m *BlockMeta) String() string

func (*BlockMeta) Unmarshal 

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

func (*BlockMeta) XXX_DiscardUnknown 

func (m *BlockMeta) XXX_DiscardUnknown()

func (*BlockMeta) XXX_Marshal 

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

func (*BlockMeta) XXX_Merge 

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

func (*BlockMeta) XXX_Size 

func (m *BlockMeta) XXX_Size() int

func (*BlockMeta) XXX_Unmarshal 

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

type BlockOffset 

type BlockOffset struct {
	Key      []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ExtentID uint64 `protobuf:"varint,2,opt,name=extentID,proto3" json:"extentID,omitempty"`
	Offset   uint32 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
}

func (*BlockOffset) Descriptor 

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

func (*BlockOffset) GetExtentID 

func (m *BlockOffset) GetExtentID() uint64

func (*BlockOffset) GetKey 

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

func (*BlockOffset) GetOffset 

func (m *BlockOffset) GetOffset() uint32

func (*BlockOffset) Marshal 

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

func (*BlockOffset) MarshalTo 

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

func (*BlockOffset) MarshalToSizedBuffer 

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

func (*BlockOffset) ProtoMessage 

func (*BlockOffset) ProtoMessage()

func (*BlockOffset) Reset 

func (m *BlockOffset) Reset()

func (*BlockOffset) Size 

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

func (*BlockOffset) String 

func (m *BlockOffset) String() string

func (*BlockOffset) Unmarshal 

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

func (*BlockOffset) XXX_DiscardUnknown 

func (m *BlockOffset) XXX_DiscardUnknown()

func (*BlockOffset) XXX_Marshal 

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

func (*BlockOffset) XXX_Merge 

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

func (*BlockOffset) XXX_Size 

func (m *BlockOffset) XXX_Size() int

func (*BlockOffset) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Partid uint64 `protobuf:"varint,2,opt,name=partid,proto3" json:"partid,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetKey 

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

func (*DeleteRequest) GetPartid 

func (m *DeleteRequest) GetPartid() uint64

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 DeleteResponse 

type DeleteResponse struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) GetKey 

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

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) MarshalToSizedBuffer 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type GetRequest 

type GetRequest struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Partid uint64 `protobuf:"varint,2,opt,name=partid,proto3" json:"partid,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetKey 

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

func (*GetRequest) GetPartid 

func (m *GetRequest) GetPartid() uint64

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 GetResponse 

type GetResponse 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"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetKey 

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

func (*GetResponse) GetValue 

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

func (*GetResponse) Marshal 

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

func (*GetResponse) MarshalTo 

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

func (*GetResponse) MarshalToSizedBuffer 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) Size 

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

func (*GetResponse) String 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal 

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

func (*GetResponse) XXX_DiscardUnknown 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal 

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

func (*GetResponse) XXX_Merge 

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

func (*GetResponse) XXX_Size 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal 

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

type Location 

type Location struct {
	ExtentID uint64 `protobuf:"varint,1,opt,name=extentID,proto3" json:"extentID,omitempty"`
	Offset   uint32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
}

func (*Location) Descriptor 

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

func (*Location) GetExtentID 

func (m *Location) GetExtentID() uint64

func (*Location) GetOffset 

func (m *Location) GetOffset() uint32

func (*Location) Marshal 

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

func (*Location) MarshalTo 

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

func (*Location) MarshalToSizedBuffer 

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

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) Size 

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

func (*Location) String 

func (m *Location) String() string

func (*Location) Unmarshal 

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

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

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

func (*Location) XXX_Merge 

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

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

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

type PSDetail 

type PSDetail struct {
	PSID    uint64 `protobuf:"varint,1,opt,name=PSID,proto3" json:"PSID,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
}

func (*PSDetail) Descriptor 

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

func (*PSDetail) GetAddress 

func (m *PSDetail) GetAddress() string

func (*PSDetail) GetPSID 

func (m *PSDetail) GetPSID() uint64

func (*PSDetail) Marshal 

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

func (*PSDetail) MarshalTo 

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

func (*PSDetail) MarshalToSizedBuffer 

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

func (*PSDetail) ProtoMessage 

func (*PSDetail) ProtoMessage()

func (*PSDetail) Reset 

func (m *PSDetail) Reset()

func (*PSDetail) Size 

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

func (*PSDetail) String 

func (m *PSDetail) String() string

func (*PSDetail) Unmarshal 

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

func (*PSDetail) XXX_DiscardUnknown 

func (m *PSDetail) XXX_DiscardUnknown()

func (*PSDetail) XXX_Marshal 

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

func (*PSDetail) XXX_Merge 

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

func (*PSDetail) XXX_Size 

func (m *PSDetail) XXX_Size() int

func (*PSDetail) XXX_Unmarshal 

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

type PartitionKVClient 

type PartitionKVClient interface {
	//
	//option (google.api.http) = {
	//post: "/v3/kv/txn"
	//body: "*"
	//};
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error)
	//ps management API
	//system performace
	SplitPart(ctx context.Context, in *SplitPartRequest, opts ...grpc.CallOption) (*SplitPartResponse, error)
}

PartitionKVClient is the client API for PartitionKV service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPartitionKVClient 

func NewPartitionKVClient(cc *grpc.ClientConn) PartitionKVClient

type PartitionKVServer 

type PartitionKVServer interface {
	//
	//option (google.api.http) = {
	//post: "/v3/kv/txn"
	//body: "*"
	//};
	Batch(context.Context, *BatchRequest) (*BatchResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	//ps management API
	//system performace
	SplitPart(context.Context, *SplitPartRequest) (*SplitPartResponse, error)
}

PartitionKVServer is the server API for PartitionKV service.

type PartitionMeta 

type PartitionMeta struct {
	LogStream uint64 `protobuf:"varint,2,opt,name=logStream,proto3" json:"logStream,omitempty"`
	RowStream uint64 `protobuf:"varint,3,opt,name=rowStream,proto3" json:"rowStream,omitempty"`
	Rg        *Range `protobuf:"bytes,7,opt,name=rg,proto3" json:"rg,omitempty"`
	PartID    uint64 `protobuf:"varint,8,opt,name=PartID,proto3" json:"PartID,omitempty"`
}

func (*PartitionMeta) Descriptor 

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

func (*PartitionMeta) GetLogStream 

func (m *PartitionMeta) GetLogStream() uint64

func (*PartitionMeta) GetPartID 

func (m *PartitionMeta) GetPartID() uint64

func (*PartitionMeta) GetRg 

func (m *PartitionMeta) GetRg() *Range

func (*PartitionMeta) GetRowStream 

func (m *PartitionMeta) GetRowStream() uint64

func (*PartitionMeta) Marshal 

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

func (*PartitionMeta) MarshalTo 

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

func (*PartitionMeta) MarshalToSizedBuffer 

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

func (*PartitionMeta) ProtoMessage 

func (*PartitionMeta) ProtoMessage()

func (*PartitionMeta) Reset 

func (m *PartitionMeta) Reset()

func (*PartitionMeta) Size 

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

func (*PartitionMeta) String 

func (m *PartitionMeta) String() string

func (*PartitionMeta) Unmarshal 

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

func (*PartitionMeta) XXX_DiscardUnknown 

func (m *PartitionMeta) XXX_DiscardUnknown()

func (*PartitionMeta) XXX_Marshal 

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

func (*PartitionMeta) XXX_Merge 

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

func (*PartitionMeta) XXX_Size 

func (m *PartitionMeta) XXX_Size() int

func (*PartitionMeta) XXX_Unmarshal 

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

type PutRequest 

type PutRequest 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"`
	ExpiresAt uint64 `protobuf:"varint,3,opt,name=ExpiresAt,proto3" json:"ExpiresAt,omitempty"`
	Partid    uint64 `protobuf:"varint,4,opt,name=partid,proto3" json:"partid,omitempty"`
}

func (*PutRequest) Descriptor 

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

func (*PutRequest) GetExpiresAt 

func (m *PutRequest) GetExpiresAt() uint64

func (*PutRequest) GetKey 

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

func (*PutRequest) GetPartid 

func (m *PutRequest) GetPartid() uint64

func (*PutRequest) GetValue 

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

func (*PutRequest) Marshal 

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

func (*PutRequest) MarshalTo 

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

func (*PutRequest) MarshalToSizedBuffer 

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

func (*PutRequest) ProtoMessage 

func (*PutRequest) ProtoMessage()

func (*PutRequest) Reset 

func (m *PutRequest) Reset()

func (*PutRequest) Size 

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

func (*PutRequest) String 

func (m *PutRequest) String() string

func (*PutRequest) Unmarshal 

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

func (*PutRequest) XXX_DiscardUnknown 

func (m *PutRequest) XXX_DiscardUnknown()

func (*PutRequest) XXX_Marshal 

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

func (*PutRequest) XXX_Merge 

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

func (*PutRequest) XXX_Size 

func (m *PutRequest) XXX_Size() int

func (*PutRequest) XXX_Unmarshal 

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

type PutResponse 

type PutResponse struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*PutResponse) Descriptor 

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

func (*PutResponse) GetKey 

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

func (*PutResponse) Marshal 

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

func (*PutResponse) MarshalTo 

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

func (*PutResponse) MarshalToSizedBuffer 

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

func (*PutResponse) ProtoMessage 

func (*PutResponse) ProtoMessage()

func (*PutResponse) Reset 

func (m *PutResponse) Reset()

func (*PutResponse) Size 

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

func (*PutResponse) String 

func (m *PutResponse) String() string

func (*PutResponse) Unmarshal 

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

func (*PutResponse) XXX_DiscardUnknown 

func (m *PutResponse) XXX_DiscardUnknown()

func (*PutResponse) XXX_Marshal 

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

func (*PutResponse) XXX_Merge 

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

func (*PutResponse) XXX_Size 

func (m *PutResponse) XXX_Size() int

func (*PutResponse) XXX_Unmarshal 

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

type Range 

type Range struct {
	StartKey []byte `protobuf:"bytes,1,opt,name=startKey,proto3" json:"startKey,omitempty"`
	EndKey   []byte `protobuf:"bytes,2,opt,name=endKey,proto3" json:"endKey,omitempty"`
}

func (*Range) Descriptor 

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

func (*Range) GetEndKey 

func (m *Range) GetEndKey() []byte

func (*Range) GetStartKey 

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

func (*Range) Marshal 

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

func (*Range) MarshalTo 

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

func (*Range) MarshalToSizedBuffer 

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

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) Reset 

func (m *Range) Reset()

func (*Range) Size 

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

func (*Range) String 

func (m *Range) String() string

func (*Range) Unmarshal 

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

func (*Range) XXX_DiscardUnknown 

func (m *Range) XXX_DiscardUnknown()

func (*Range) XXX_Marshal 

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

func (*Range) XXX_Merge 

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

func (*Range) XXX_Size 

func (m *Range) XXX_Size() int

func (*Range) XXX_Unmarshal 

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

type RangeRequest 

type RangeRequest struct {
	Prefix []byte `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Start  []byte `protobuf:"bytes,2,opt,name=start,proto3" json:"start,omitempty"`
	Limit  uint32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Partid uint64 `protobuf:"varint,4,opt,name=partid,proto3" json:"partid,omitempty"`
}

return message KeyValue?

func (*RangeRequest) Descriptor 

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

func (*RangeRequest) GetLimit 

func (m *RangeRequest) GetLimit() uint32

func (*RangeRequest) GetPartid 

func (m *RangeRequest) GetPartid() uint64

func (*RangeRequest) GetPrefix 

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

func (*RangeRequest) GetStart 

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

func (*RangeRequest) Marshal 

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

func (*RangeRequest) MarshalTo 

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

func (*RangeRequest) MarshalToSizedBuffer 

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

func (*RangeRequest) ProtoMessage 

func (*RangeRequest) ProtoMessage()

func (*RangeRequest) Reset 

func (m *RangeRequest) Reset()

func (*RangeRequest) Size 

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

func (*RangeRequest) String 

func (m *RangeRequest) String() string

func (*RangeRequest) Unmarshal 

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

func (*RangeRequest) XXX_DiscardUnknown 

func (m *RangeRequest) XXX_DiscardUnknown()

func (*RangeRequest) XXX_Marshal 

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

func (*RangeRequest) XXX_Merge 

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

func (*RangeRequest) XXX_Size 

func (m *RangeRequest) XXX_Size() int

func (*RangeRequest) XXX_Unmarshal 

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

type RangeResponse 

type RangeResponse struct {
	Truncated bool     `protobuf:"varint,1,opt,name=truncated,proto3" json:"truncated,omitempty"`
	Keys      [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
}

func (*RangeResponse) Descriptor 

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

func (*RangeResponse) GetKeys 

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

func (*RangeResponse) GetTruncated 

func (m *RangeResponse) GetTruncated() bool

func (*RangeResponse) Marshal 

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

func (*RangeResponse) MarshalTo 

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

func (*RangeResponse) MarshalToSizedBuffer 

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

func (*RangeResponse) ProtoMessage 

func (*RangeResponse) ProtoMessage()

func (*RangeResponse) Reset 

func (m *RangeResponse) Reset()

func (*RangeResponse) Size 

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

func (*RangeResponse) String 

func (m *RangeResponse) String() string

func (*RangeResponse) Unmarshal 

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

func (*RangeResponse) XXX_DiscardUnknown 

func (m *RangeResponse) XXX_DiscardUnknown()

func (*RangeResponse) XXX_Marshal 

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

func (*RangeResponse) XXX_Merge 

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

func (*RangeResponse) XXX_Size 

func (m *RangeResponse) XXX_Size() int

func (*RangeResponse) XXX_Unmarshal 

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

type RegionInfo 

type RegionInfo struct {
	Rg     *Range `protobuf:"bytes,1,opt,name=rg,proto3" json:"rg,omitempty"`
	PartID uint64 `protobuf:"varint,2,opt,name=PartID,proto3" json:"PartID,omitempty"`
	PSID   uint64 `protobuf:"varint,3,opt,name=PSID,proto3" json:"PSID,omitempty"`
}

func (*RegionInfo) Descriptor 

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

func (*RegionInfo) GetPSID 

func (m *RegionInfo) GetPSID() uint64

func (*RegionInfo) GetPartID 

func (m *RegionInfo) GetPartID() uint64

func (*RegionInfo) GetRg 

func (m *RegionInfo) GetRg() *Range

func (*RegionInfo) Marshal 

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

func (*RegionInfo) MarshalTo 

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

func (*RegionInfo) MarshalToSizedBuffer 

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

func (*RegionInfo) ProtoMessage 

func (*RegionInfo) ProtoMessage()

func (*RegionInfo) Reset 

func (m *RegionInfo) Reset()

func (*RegionInfo) Size 

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

func (*RegionInfo) String 

func (m *RegionInfo) String() string

func (*RegionInfo) Unmarshal 

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

func (*RegionInfo) XXX_DiscardUnknown 

func (m *RegionInfo) XXX_DiscardUnknown()

func (*RegionInfo) XXX_Marshal 

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

func (*RegionInfo) XXX_Merge 

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

func (*RegionInfo) XXX_Size 

func (m *RegionInfo) XXX_Size() int

func (*RegionInfo) XXX_Unmarshal 

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

type Regions 

type Regions struct {
	Regions map[uint64]*RegionInfo `` /* 156-byte string literal not displayed */
}

func (*Regions) Descriptor 

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

func (*Regions) GetRegions 

func (m *Regions) GetRegions() map[uint64]*RegionInfo

func (*Regions) Marshal 

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

func (*Regions) MarshalTo 

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

func (*Regions) MarshalToSizedBuffer 

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

func (*Regions) ProtoMessage 

func (*Regions) ProtoMessage()

func (*Regions) Reset 

func (m *Regions) Reset()

func (*Regions) Size 

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

func (*Regions) String 

func (m *Regions) String() string

func (*Regions) Unmarshal 

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

func (*Regions) XXX_DiscardUnknown 

func (m *Regions) XXX_DiscardUnknown()

func (*Regions) XXX_Marshal 

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

func (*Regions) XXX_Merge 

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

func (*Regions) XXX_Size 

func (m *Regions) XXX_Size() int

func (*Regions) XXX_Unmarshal 

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

type RequestOp 

type RequestOp struct {
	// Types that are valid to be assigned to Request:
	//	*RequestOp_RequestPut
	//	*RequestOp_RequestDelete
	//	*RequestOp_RequestGet
	Request isRequestOp_Request `protobuf_oneof:"request"`
}

func (*RequestOp) Descriptor 

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

func (*RequestOp) GetRequest 

func (m *RequestOp) GetRequest() isRequestOp_Request

func (*RequestOp) GetRequestDelete 

func (m *RequestOp) GetRequestDelete() *DeleteRequest

func (*RequestOp) GetRequestGet 

func (m *RequestOp) GetRequestGet() *GetRequest

func (*RequestOp) GetRequestPut 

func (m *RequestOp) GetRequestPut() *PutRequest

func (*RequestOp) Marshal 

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

func (*RequestOp) MarshalTo 

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

func (*RequestOp) MarshalToSizedBuffer 

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

func (*RequestOp) ProtoMessage 

func (*RequestOp) ProtoMessage()

func (*RequestOp) Reset 

func (m *RequestOp) Reset()

func (*RequestOp) Size 

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

func (*RequestOp) String 

func (m *RequestOp) String() string

func (*RequestOp) Unmarshal 

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

func (*RequestOp) XXX_DiscardUnknown 

func (m *RequestOp) XXX_DiscardUnknown()

func (*RequestOp) XXX_Marshal 

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

func (*RequestOp) XXX_Merge 

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

func (*RequestOp) XXX_OneofWrappers 

func (*RequestOp) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*RequestOp) XXX_Size 

func (m *RequestOp) XXX_Size() int

func (*RequestOp) XXX_Unmarshal 

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

type RequestOp_RequestDelete 

type RequestOp_RequestDelete struct {
	RequestDelete *DeleteRequest `protobuf:"bytes,2,opt,name=request_delete,json=requestDelete,proto3,oneof" json:"request_delete,omitempty"`
}

func (*RequestOp_RequestDelete) MarshalTo 

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

func (*RequestOp_RequestDelete) MarshalToSizedBuffer 

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

func (*RequestOp_RequestDelete) Size 

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

type RequestOp_RequestGet 

type RequestOp_RequestGet struct {
	RequestGet *GetRequest `protobuf:"bytes,3,opt,name=request_get,json=requestGet,proto3,oneof" json:"request_get,omitempty"`
}

func (*RequestOp_RequestGet) MarshalTo 

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

func (*RequestOp_RequestGet) MarshalToSizedBuffer 

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

func (*RequestOp_RequestGet) Size 

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

type RequestOp_RequestPut 

type RequestOp_RequestPut struct {
	RequestPut *PutRequest `protobuf:"bytes,1,opt,name=request_put,json=requestPut,proto3,oneof" json:"request_put,omitempty"`
}

func (*RequestOp_RequestPut) MarshalTo 

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

func (*RequestOp_RequestPut) MarshalToSizedBuffer 

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

func (*RequestOp_RequestPut) Size 

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

type ResponseOp 

type ResponseOp struct {
	// Types that are valid to be assigned to Response:
	//	*ResponseOp_ResponsePut
	//	*ResponseOp_ResponseDelete
	//	*ResponseOp_ResponseGet
	Response isResponseOp_Response `protobuf_oneof:"response"`
}

func (*ResponseOp) Descriptor 

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

func (*ResponseOp) GetResponse 

func (m *ResponseOp) GetResponse() isResponseOp_Response

func (*ResponseOp) GetResponseDelete 

func (m *ResponseOp) GetResponseDelete() *DeleteResponse

func (*ResponseOp) GetResponseGet 

func (m *ResponseOp) GetResponseGet() *GetResponse

func (*ResponseOp) GetResponsePut 

func (m *ResponseOp) GetResponsePut() *PutResponse

func (*ResponseOp) Marshal 

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

func (*ResponseOp) MarshalTo 

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

func (*ResponseOp) MarshalToSizedBuffer 

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

func (*ResponseOp) ProtoMessage 

func (*ResponseOp) ProtoMessage()

func (*ResponseOp) Reset 

func (m *ResponseOp) Reset()

func (*ResponseOp) Size 

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

func (*ResponseOp) String 

func (m *ResponseOp) String() string

func (*ResponseOp) Unmarshal 

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

func (*ResponseOp) XXX_DiscardUnknown 

func (m *ResponseOp) XXX_DiscardUnknown()

func (*ResponseOp) XXX_Marshal 

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

func (*ResponseOp) XXX_Merge 

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

func (*ResponseOp) XXX_OneofWrappers 

func (*ResponseOp) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ResponseOp) XXX_Size 

func (m *ResponseOp) XXX_Size() int

func (*ResponseOp) XXX_Unmarshal 

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

type ResponseOp_ResponseDelete 

type ResponseOp_ResponseDelete struct {
	ResponseDelete *DeleteResponse `protobuf:"bytes,2,opt,name=response_delete,json=responseDelete,proto3,oneof" json:"response_delete,omitempty"`
}

func (*ResponseOp_ResponseDelete) MarshalTo 

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

func (*ResponseOp_ResponseDelete) MarshalToSizedBuffer 

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

func (*ResponseOp_ResponseDelete) Size 

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

type ResponseOp_ResponseGet 

type ResponseOp_ResponseGet struct {
	ResponseGet *GetResponse `protobuf:"bytes,3,opt,name=response_get,json=responseGet,proto3,oneof" json:"response_get,omitempty"`
}

func (*ResponseOp_ResponseGet) MarshalTo 

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

func (*ResponseOp_ResponseGet) MarshalToSizedBuffer 

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

func (*ResponseOp_ResponseGet) Size 

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

type ResponseOp_ResponsePut 

type ResponseOp_ResponsePut struct {
	ResponsePut *PutResponse `protobuf:"bytes,1,opt,name=response_put,json=responsePut,proto3,oneof" json:"response_put,omitempty"`
}

func (*ResponseOp_ResponsePut) MarshalTo 

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

func (*ResponseOp_ResponsePut) MarshalToSizedBuffer 

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

func (*ResponseOp_ResponsePut) Size 

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

type SplitPartRequest 

type SplitPartRequest struct {
	PartID uint64 `protobuf:"varint,1,opt,name=PartID,proto3" json:"PartID,omitempty"`
}

func (*SplitPartRequest) Descriptor 

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

func (*SplitPartRequest) GetPartID 

func (m *SplitPartRequest) GetPartID() uint64

func (*SplitPartRequest) Marshal 

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

func (*SplitPartRequest) MarshalTo 

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

func (*SplitPartRequest) MarshalToSizedBuffer 

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

func (*SplitPartRequest) ProtoMessage 

func (*SplitPartRequest) ProtoMessage()

func (*SplitPartRequest) Reset 

func (m *SplitPartRequest) Reset()

func (*SplitPartRequest) Size 

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

func (*SplitPartRequest) String 

func (m *SplitPartRequest) String() string

func (*SplitPartRequest) Unmarshal 

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

func (*SplitPartRequest) XXX_DiscardUnknown 

func (m *SplitPartRequest) XXX_DiscardUnknown()

func (*SplitPartRequest) XXX_Marshal 

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

func (*SplitPartRequest) XXX_Merge 

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

func (*SplitPartRequest) XXX_Size 

func (m *SplitPartRequest) XXX_Size() int

func (*SplitPartRequest) XXX_Unmarshal 

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

type SplitPartResponse 

type SplitPartResponse struct {
}

func (*SplitPartResponse) Descriptor 

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

func (*SplitPartResponse) Marshal 

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

func (*SplitPartResponse) MarshalTo 

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

func (*SplitPartResponse) MarshalToSizedBuffer 

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

func (*SplitPartResponse) ProtoMessage 

func (*SplitPartResponse) ProtoMessage()

func (*SplitPartResponse) Reset 

func (m *SplitPartResponse) Reset()

func (*SplitPartResponse) Size 

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

func (*SplitPartResponse) String 

func (m *SplitPartResponse) String() string

func (*SplitPartResponse) Unmarshal 

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

func (*SplitPartResponse) XXX_DiscardUnknown 

func (m *SplitPartResponse) XXX_DiscardUnknown()

func (*SplitPartResponse) XXX_Marshal 

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

func (*SplitPartResponse) XXX_Merge 

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

func (*SplitPartResponse) XXX_Size 

func (m *SplitPartResponse) XXX_Size() int

func (*SplitPartResponse) XXX_Unmarshal 

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

type TableIndex 

type TableIndex struct {
	Offsets       []*BlockOffset `protobuf:"bytes,1,rep,name=offsets,proto3" json:"offsets,omitempty"`
	BloomFilter   []byte         `protobuf:"bytes,2,opt,name=bloomFilter,proto3" json:"bloomFilter,omitempty"`
	EstimatedSize uint64         `protobuf:"varint,3,opt,name=estimatedSize,proto3" json:"estimatedSize,omitempty"`
	NumOfBlocks   uint32         `protobuf:"varint,4,opt,name=numOfBlocks,proto3" json:"numOfBlocks,omitempty"`
}

func (*TableIndex) Descriptor 

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

func (*TableIndex) GetBloomFilter 

func (m *TableIndex) GetBloomFilter() []byte

func (*TableIndex) GetEstimatedSize 

func (m *TableIndex) GetEstimatedSize() uint64

func (*TableIndex) GetNumOfBlocks 

func (m *TableIndex) GetNumOfBlocks() uint32

func (*TableIndex) GetOffsets 

func (m *TableIndex) GetOffsets() []*BlockOffset

func (*TableIndex) Marshal 

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

func (*TableIndex) MarshalTo 

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

func (*TableIndex) MarshalToSizedBuffer 

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

func (*TableIndex) ProtoMessage 

func (*TableIndex) ProtoMessage()

func (*TableIndex) Reset 

func (m *TableIndex) Reset()

func (*TableIndex) Size 

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

func (*TableIndex) String 

func (m *TableIndex) String() string

func (*TableIndex) Unmarshal 

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

func (*TableIndex) XXX_DiscardUnknown 

func (m *TableIndex) XXX_DiscardUnknown()

func (*TableIndex) XXX_Marshal 

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

func (*TableIndex) XXX_Merge 

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

func (*TableIndex) XXX_Size 

func (m *TableIndex) XXX_Size() int

func (*TableIndex) XXX_Unmarshal 

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

type TableLocations 

type TableLocations struct {
	Locs []*Location `protobuf:"bytes,1,rep,name=locs,proto3" json:"locs,omitempty"`
}

func (*TableLocations) Descriptor 

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

func (*TableLocations) GetLocs 

func (m *TableLocations) GetLocs() []*Location

func (*TableLocations) Marshal 

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

func (*TableLocations) MarshalTo 

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

func (*TableLocations) MarshalToSizedBuffer 

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

func (*TableLocations) ProtoMessage 

func (*TableLocations) ProtoMessage()

func (*TableLocations) Reset 

func (m *TableLocations) Reset()

func (*TableLocations) Size 

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

func (*TableLocations) String 

func (m *TableLocations) String() string

func (*TableLocations) Unmarshal 

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

func (*TableLocations) XXX_DiscardUnknown 

func (m *TableLocations) XXX_DiscardUnknown()

func (*TableLocations) XXX_Marshal 

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

func (*TableLocations) XXX_Merge 

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

func (*TableLocations) XXX_Size 

func (m *TableLocations) XXX_Size() int

func (*TableLocations) XXX_Unmarshal 

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

type UnimplementedPartitionKVServer 

type UnimplementedPartitionKVServer struct {
}

UnimplementedPartitionKVServer can be embedded to have forward compatible implementations.

func (*UnimplementedPartitionKVServer) Batch 

func (*UnimplementedPartitionKVServer) Batch(ctx context.Context, req *BatchRequest) (*BatchResponse, error)

func (*UnimplementedPartitionKVServer) Delete 

func (*UnimplementedPartitionKVServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedPartitionKVServer) Get 

func (*UnimplementedPartitionKVServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedPartitionKVServer) Put 

func (*UnimplementedPartitionKVServer) Put(ctx context.Context, req *PutRequest) (*PutResponse, error)

func (*UnimplementedPartitionKVServer) Range 

func (*UnimplementedPartitionKVServer) Range(ctx context.Context, req *RangeRequest) (*RangeResponse, error)

func (*UnimplementedPartitionKVServer) SplitPart 

func (*UnimplementedPartitionKVServer) SplitPart(ctx context.Context, req *SplitPartRequest) (*SplitPartResponse, 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.