pspb

package
v0.0.0-...-e603270 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2023 License: Apache-2.0 Imports: 17 Imported by: 1

Documentation

Overview

Package pspb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

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 RegisterPartitionKVHandler 

func RegisterPartitionKVHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPartitionKVHandler registers the http handlers for service PartitionKV to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPartitionKVHandlerClient 

func RegisterPartitionKVHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PartitionKVClient) error

RegisterPartitionKVHandlerClient registers the http handlers for service PartitionKV to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PartitionKVClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PartitionKVClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PartitionKVClient" to call the correct interceptors.

func RegisterPartitionKVHandlerFromEndpoint 

func RegisterPartitionKVHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPartitionKVHandlerFromEndpoint is same as RegisterPartitionKVHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPartitionKVHandlerServer 

func RegisterPartitionKVHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PartitionKVServer) error

RegisterPartitionKVHandlerServer registers the http handlers for service PartitionKV to "mux". UnaryRPC :call PartitionKVServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPartitionKVHandlerFromEndpoint instead.

func RegisterPartitionKVServer 

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

Types

type AutoGCOp 

type AutoGCOp struct {
}

func (*AutoGCOp) Descriptor 

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

func (*AutoGCOp) Marshal 

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

func (*AutoGCOp) MarshalTo 

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

func (*AutoGCOp) MarshalToSizedBuffer 

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

func (*AutoGCOp) ProtoMessage 

func (*AutoGCOp) ProtoMessage()

func (*AutoGCOp) Reset 

func (m *AutoGCOp) Reset()

func (*AutoGCOp) Size 

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

func (*AutoGCOp) String 

func (m *AutoGCOp) String() string

func (*AutoGCOp) Unmarshal 

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

func (*AutoGCOp) XXX_DiscardUnknown 

func (m *AutoGCOp) XXX_DiscardUnknown()

func (*AutoGCOp) XXX_Marshal 

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

func (*AutoGCOp) XXX_Merge 

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

func (*AutoGCOp) XXX_Size 

func (m *AutoGCOp) XXX_Size() int

func (*AutoGCOp) XXX_Unmarshal 

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

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"`
	Discards         map[uint64]int64 `` /* 159-byte string literal not displayed */
	CompressionType  uint32           `protobuf:"varint,8,opt,name=CompressionType,proto3" json:"CompressionType,omitempty"`
}

func (*BlockMeta) Descriptor 

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

func (*BlockMeta) GetCompressedSize 

func (m *BlockMeta) GetCompressedSize() uint32

func (*BlockMeta) GetCompressionType 

func (m *BlockMeta) GetCompressionType() uint32

func (*BlockMeta) GetDiscards 

func (m *BlockMeta) GetDiscards() map[uint64]int64

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 CompactOp 

type CompactOp struct {
}

func (*CompactOp) Descriptor 

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

func (*CompactOp) Marshal 

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

func (*CompactOp) MarshalTo 

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

func (*CompactOp) MarshalToSizedBuffer 

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

func (*CompactOp) ProtoMessage 

func (*CompactOp) ProtoMessage()

func (*CompactOp) Reset 

func (m *CompactOp) Reset()

func (*CompactOp) Size 

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

func (*CompactOp) String 

func (m *CompactOp) String() string

func (*CompactOp) Unmarshal 

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

func (*CompactOp) XXX_DiscardUnknown 

func (m *CompactOp) XXX_DiscardUnknown()

func (*CompactOp) XXX_Marshal 

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

func (*CompactOp) XXX_Merge 

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

func (*CompactOp) XXX_Size 

func (m *CompactOp) XXX_Size() int

func (*CompactOp) XXX_Unmarshal 

func (m *CompactOp) 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 ForceGCOp 

type ForceGCOp struct {
	ExIDs []uint64 `protobuf:"varint,1,rep,packed,name=exIDs,proto3" json:"exIDs,omitempty"`
}

func (*ForceGCOp) Descriptor 

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

func (*ForceGCOp) GetExIDs 

func (m *ForceGCOp) GetExIDs() []uint64

func (*ForceGCOp) Marshal 

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

func (*ForceGCOp) MarshalTo 

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

func (*ForceGCOp) MarshalToSizedBuffer 

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

func (*ForceGCOp) ProtoMessage 

func (*ForceGCOp) ProtoMessage()

func (*ForceGCOp) Reset 

func (m *ForceGCOp) Reset()

func (*ForceGCOp) Size 

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

func (*ForceGCOp) String 

func (m *ForceGCOp) String() string

func (*ForceGCOp) Unmarshal 

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

func (*ForceGCOp) XXX_DiscardUnknown 

func (m *ForceGCOp) XXX_DiscardUnknown()

func (*ForceGCOp) XXX_Marshal 

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

func (*ForceGCOp) XXX_Merge 

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

func (*ForceGCOp) XXX_Size 

func (m *ForceGCOp) XXX_Size() int

func (*ForceGCOp) XXX_Unmarshal 

func (m *ForceGCOp) 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 HeadInfo 

type HeadInfo struct {
	Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Len uint32 `protobuf:"varint,3,opt,name=len,proto3" json:"len,omitempty"`
}

func (*HeadInfo) Descriptor 

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

func (*HeadInfo) GetKey 

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

func (*HeadInfo) GetLen 

func (m *HeadInfo) GetLen() uint32

func (*HeadInfo) Marshal 

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

func (*HeadInfo) MarshalTo 

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

func (*HeadInfo) MarshalToSizedBuffer 

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

func (*HeadInfo) ProtoMessage 

func (*HeadInfo) ProtoMessage()

func (*HeadInfo) Reset 

func (m *HeadInfo) Reset()

func (*HeadInfo) Size 

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

func (*HeadInfo) String 

func (m *HeadInfo) String() string

func (*HeadInfo) Unmarshal 

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

func (*HeadInfo) XXX_DiscardUnknown 

func (m *HeadInfo) XXX_DiscardUnknown()

func (*HeadInfo) XXX_Marshal 

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

func (*HeadInfo) XXX_Merge 

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

func (*HeadInfo) XXX_Size 

func (m *HeadInfo) XXX_Size() int

func (*HeadInfo) XXX_Unmarshal 

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

type HeadRequest 

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

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

func (*HeadRequest) GetKey 

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

func (*HeadRequest) GetPartid 

func (m *HeadRequest) GetPartid() uint64

func (*HeadRequest) Marshal 

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

func (*HeadRequest) MarshalTo 

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

func (*HeadRequest) MarshalToSizedBuffer 

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

func (*HeadRequest) ProtoMessage 

func (*HeadRequest) ProtoMessage()

func (*HeadRequest) Reset 

func (m *HeadRequest) Reset()

func (*HeadRequest) Size 

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

func (*HeadRequest) String 

func (m *HeadRequest) String() string

func (*HeadRequest) Unmarshal 

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

func (*HeadRequest) XXX_DiscardUnknown 

func (m *HeadRequest) XXX_DiscardUnknown()

func (*HeadRequest) XXX_Marshal 

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

func (*HeadRequest) XXX_Merge 

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

func (*HeadRequest) XXX_Size 

func (m *HeadRequest) XXX_Size() int

func (*HeadRequest) XXX_Unmarshal 

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

type HeadResponse 

type HeadResponse struct {
	Info *HeadInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

func (*HeadResponse) Descriptor 

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

func (*HeadResponse) GetInfo 

func (m *HeadResponse) GetInfo() *HeadInfo

func (*HeadResponse) Marshal 

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

func (*HeadResponse) MarshalTo 

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

func (*HeadResponse) MarshalToSizedBuffer 

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

func (*HeadResponse) ProtoMessage 

func (*HeadResponse) ProtoMessage()

func (*HeadResponse) Reset 

func (m *HeadResponse) Reset()

func (*HeadResponse) Size 

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

func (*HeadResponse) String 

func (m *HeadResponse) String() string

func (*HeadResponse) Unmarshal 

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

func (*HeadResponse) XXX_DiscardUnknown 

func (m *HeadResponse) XXX_DiscardUnknown()

func (*HeadResponse) XXX_Marshal 

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

func (*HeadResponse) XXX_Merge 

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

func (*HeadResponse) XXX_Size 

func (m *HeadResponse) XXX_Size() int

func (*HeadResponse) XXX_Unmarshal 

func (m *HeadResponse) 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 MaintenanceRequest 

type MaintenanceRequest struct {
	Partid uint64 `protobuf:"varint,1,opt,name=partid,proto3" json:"partid,omitempty"`
	// Types that are valid to be assigned to OP:
	//	*MaintenanceRequest_Compact
	//	*MaintenanceRequest_Autogc
	//	*MaintenanceRequest_Forcegc
	OP isMaintenanceRequest_OP `protobuf_oneof:"OP"`
}

func (*MaintenanceRequest) Descriptor 

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

func (*MaintenanceRequest) GetAutogc 

func (m *MaintenanceRequest) GetAutogc() *AutoGCOp

func (*MaintenanceRequest) GetCompact 

func (m *MaintenanceRequest) GetCompact() *CompactOp

func (*MaintenanceRequest) GetForcegc 

func (m *MaintenanceRequest) GetForcegc() *ForceGCOp

func (*MaintenanceRequest) GetOP 

func (m *MaintenanceRequest) GetOP() isMaintenanceRequest_OP

func (*MaintenanceRequest) GetPartid 

func (m *MaintenanceRequest) GetPartid() uint64

func (*MaintenanceRequest) Marshal 

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

func (*MaintenanceRequest) MarshalTo 

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

func (*MaintenanceRequest) MarshalToSizedBuffer 

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

func (*MaintenanceRequest) ProtoMessage 

func (*MaintenanceRequest) ProtoMessage()

func (*MaintenanceRequest) Reset 

func (m *MaintenanceRequest) Reset()

func (*MaintenanceRequest) Size 

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

func (*MaintenanceRequest) String 

func (m *MaintenanceRequest) String() string

func (*MaintenanceRequest) Unmarshal 

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

func (*MaintenanceRequest) XXX_DiscardUnknown 

func (m *MaintenanceRequest) XXX_DiscardUnknown()

func (*MaintenanceRequest) XXX_Marshal 

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

func (*MaintenanceRequest) XXX_Merge 

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

func (*MaintenanceRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MaintenanceRequest) XXX_Size 

func (m *MaintenanceRequest) XXX_Size() int

func (*MaintenanceRequest) XXX_Unmarshal 

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

type MaintenanceRequest_Autogc 

type MaintenanceRequest_Autogc struct {
	Autogc *AutoGCOp `protobuf:"bytes,3,opt,name=autogc,proto3,oneof" json:"autogc,omitempty"`
}

func (*MaintenanceRequest_Autogc) MarshalTo 

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

func (*MaintenanceRequest_Autogc) MarshalToSizedBuffer 

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

func (*MaintenanceRequest_Autogc) Size 

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

type MaintenanceRequest_Compact 

type MaintenanceRequest_Compact struct {
	Compact *CompactOp `protobuf:"bytes,2,opt,name=compact,proto3,oneof" json:"compact,omitempty"`
}

func (*MaintenanceRequest_Compact) MarshalTo 

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

func (*MaintenanceRequest_Compact) MarshalToSizedBuffer 

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

func (*MaintenanceRequest_Compact) Size 

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

type MaintenanceRequest_Forcegc 

type MaintenanceRequest_Forcegc struct {
	Forcegc *ForceGCOp `protobuf:"bytes,4,opt,name=forcegc,proto3,oneof" json:"forcegc,omitempty"`
}

func (*MaintenanceRequest_Forcegc) MarshalTo 

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

func (*MaintenanceRequest_Forcegc) MarshalToSizedBuffer 

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

func (*MaintenanceRequest_Forcegc) Size 

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

type MaintenanceResponse 

type MaintenanceResponse struct {
}

func (*MaintenanceResponse) Descriptor 

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

func (*MaintenanceResponse) Marshal 

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

func (*MaintenanceResponse) MarshalTo 

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

func (*MaintenanceResponse) MarshalToSizedBuffer 

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

func (*MaintenanceResponse) ProtoMessage 

func (*MaintenanceResponse) ProtoMessage()

func (*MaintenanceResponse) Reset 

func (m *MaintenanceResponse) Reset()

func (*MaintenanceResponse) Size 

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

func (*MaintenanceResponse) String 

func (m *MaintenanceResponse) String() string

func (*MaintenanceResponse) Unmarshal 

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

func (*MaintenanceResponse) XXX_DiscardUnknown 

func (m *MaintenanceResponse) XXX_DiscardUnknown()

func (*MaintenanceResponse) XXX_Marshal 

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

func (*MaintenanceResponse) XXX_Merge 

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

func (*MaintenanceResponse) XXX_Size 

func (m *MaintenanceResponse) XXX_Size() int

func (*MaintenanceResponse) XXX_Unmarshal 

func (m *MaintenanceResponse) 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 {
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error)
	Head(ctx context.Context, in *HeadRequest, opts ...grpc.CallOption) (*HeadResponse, 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)
	StreamPut(ctx context.Context, opts ...grpc.CallOption) (PartitionKV_StreamPutClient, error)
	//ps management API
	//system performace
	SplitPart(ctx context.Context, in *SplitPartRequest, opts ...grpc.CallOption) (*SplitPartResponse, error)
	Maintenance(ctx context.Context, in *MaintenanceRequest, opts ...grpc.CallOption) (*MaintenanceResponse, 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 {
	Batch(context.Context, *BatchRequest) (*BatchResponse, error)
	Put(context.Context, *PutRequest) (*PutResponse, error)
	Head(context.Context, *HeadRequest) (*HeadResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Range(context.Context, *RangeRequest) (*RangeResponse, error)
	StreamPut(PartitionKV_StreamPutServer) error
	//ps management API
	//system performace
	SplitPart(context.Context, *SplitPartRequest) (*SplitPartResponse, error)
	Maintenance(context.Context, *MaintenanceRequest) (*MaintenanceResponse, error)
}

PartitionKVServer is the server API for PartitionKV service.

type PartitionKV_StreamPutClient 

type PartitionKV_StreamPutClient interface {
	Send(*StreamPutRequest) error
	CloseAndRecv() (*PutResponse, error)
	grpc.ClientStream
}

type PartitionKV_StreamPutServer 

type PartitionKV_StreamPutServer interface {
	SendAndClose(*PutResponse) error
	Recv() (*StreamPutRequest, error)
	grpc.ServerStream
}

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"`
	MetaStream uint64 `protobuf:"varint,9,opt,name=metaStream,proto3" json:"metaStream,omitempty"`
}

func (*PartitionMeta) Descriptor 

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

func (*PartitionMeta) GetLogStream 

func (m *PartitionMeta) GetLogStream() uint64

func (*PartitionMeta) GetMetaStream 

func (m *PartitionMeta) GetMetaStream() 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 StreamPutRequest 

type StreamPutRequest struct {
	// Types that are valid to be assigned to Data:
	//	*StreamPutRequest_Header
	//	*StreamPutRequest_Payload
	Data isStreamPutRequest_Data `protobuf_oneof:"data"`
}

func (*StreamPutRequest) Descriptor 

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

func (*StreamPutRequest) GetData 

func (m *StreamPutRequest) GetData() isStreamPutRequest_Data

func (*StreamPutRequest) GetHeader 

func (m *StreamPutRequest) GetHeader() *StreamPutRequestHeader

func (*StreamPutRequest) GetPayload 

func (m *StreamPutRequest) GetPayload() []byte

func (*StreamPutRequest) Marshal 

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

func (*StreamPutRequest) MarshalTo 

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

func (*StreamPutRequest) MarshalToSizedBuffer 

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

func (*StreamPutRequest) ProtoMessage 

func (*StreamPutRequest) ProtoMessage()

func (*StreamPutRequest) Reset 

func (m *StreamPutRequest) Reset()

func (*StreamPutRequest) Size 

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

func (*StreamPutRequest) String 

func (m *StreamPutRequest) String() string

func (*StreamPutRequest) Unmarshal 

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

func (*StreamPutRequest) XXX_DiscardUnknown 

func (m *StreamPutRequest) XXX_DiscardUnknown()

func (*StreamPutRequest) XXX_Marshal 

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

func (*StreamPutRequest) XXX_Merge 

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

func (*StreamPutRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamPutRequest) XXX_Size 

func (m *StreamPutRequest) XXX_Size() int

func (*StreamPutRequest) XXX_Unmarshal 

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

type StreamPutRequestHeader 

type StreamPutRequestHeader struct {
	Key        []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	LenOfValue uint32 `protobuf:"varint,2,opt,name=lenOfValue,proto3" json:"lenOfValue,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 (*StreamPutRequestHeader) Descriptor 

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

func (*StreamPutRequestHeader) GetExpiresAt 

func (m *StreamPutRequestHeader) GetExpiresAt() uint64

func (*StreamPutRequestHeader) GetKey 

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

func (*StreamPutRequestHeader) GetLenOfValue 

func (m *StreamPutRequestHeader) GetLenOfValue() uint32

func (*StreamPutRequestHeader) GetPartid 

func (m *StreamPutRequestHeader) GetPartid() uint64

func (*StreamPutRequestHeader) Marshal 

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

func (*StreamPutRequestHeader) MarshalTo 

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

func (*StreamPutRequestHeader) MarshalToSizedBuffer 

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

func (*StreamPutRequestHeader) ProtoMessage 

func (*StreamPutRequestHeader) ProtoMessage()

func (*StreamPutRequestHeader) Reset 

func (m *StreamPutRequestHeader) Reset()

func (*StreamPutRequestHeader) Size 

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

func (*StreamPutRequestHeader) String 

func (m *StreamPutRequestHeader) String() string

func (*StreamPutRequestHeader) Unmarshal 

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

func (*StreamPutRequestHeader) XXX_DiscardUnknown 

func (m *StreamPutRequestHeader) XXX_DiscardUnknown()

func (*StreamPutRequestHeader) XXX_Marshal 

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

func (*StreamPutRequestHeader) XXX_Merge 

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

func (*StreamPutRequestHeader) XXX_Size 

func (m *StreamPutRequestHeader) XXX_Size() int

func (*StreamPutRequestHeader) XXX_Unmarshal 

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

type StreamPutRequest_Header 

type StreamPutRequest_Header struct {
	Header *StreamPutRequestHeader `protobuf:"bytes,1,opt,name=header,proto3,oneof" json:"header,omitempty"`
}

func (*StreamPutRequest_Header) MarshalTo 

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

func (*StreamPutRequest_Header) MarshalToSizedBuffer 

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

func (*StreamPutRequest_Header) Size 

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

type StreamPutRequest_Payload 

type StreamPutRequest_Payload struct {
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
}

func (*StreamPutRequest_Payload) MarshalTo 

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

func (*StreamPutRequest_Payload) MarshalToSizedBuffer 

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

func (*StreamPutRequest_Payload) Size 

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

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) Head 

func (*UnimplementedPartitionKVServer) Head(ctx context.Context, req *HeadRequest) (*HeadResponse, error)

func (*UnimplementedPartitionKVServer) Maintenance 

func (*UnimplementedPartitionKVServer) Maintenance(ctx context.Context, req *MaintenanceRequest) (*MaintenanceResponse, 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)

func (*UnimplementedPartitionKVServer) StreamPut 

func (*UnimplementedPartitionKVServer) StreamPut(srv PartitionKV_StreamPutServer) 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.