Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var DownloadRequestType_name = map[int32]string + var DownloadRequestType_value = map[string]int32 + var ErrIntOverflowImportSstpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthImportSstpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupImportSstpb = fmt.Errorf("proto: unexpected end of group") + var Pair_OP_name = map[int32]string + var Pair_OP_value = map[string]int32 + var SwitchMode_name = map[int32]string + var SwitchMode_value = map[string]int32 + func RegisterImportSSTServer(s *grpc.Server, srv ImportSSTServer) + type ApplyRequest struct + CipherInfo *brpb.CipherInfo + Context *kvrpcpb.Context + Meta *KVMeta + Metas []*KVMeta + RewriteRule RewriteRule + RewriteRules []*RewriteRule + StorageBackend *brpb.StorageBackend + StorageCacheId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ApplyRequest) Descriptor() ([]byte, []int) + func (*ApplyRequest) ProtoMessage() + func (m *ApplyRequest) GetCipherInfo() *brpb.CipherInfo + func (m *ApplyRequest) GetContext() *kvrpcpb.Context + func (m *ApplyRequest) GetMeta() *KVMeta + func (m *ApplyRequest) GetMetas() []*KVMeta + func (m *ApplyRequest) GetRewriteRule() RewriteRule + func (m *ApplyRequest) GetRewriteRules() []*RewriteRule + func (m *ApplyRequest) GetStorageBackend() *brpb.StorageBackend + func (m *ApplyRequest) GetStorageCacheId() string + func (m *ApplyRequest) Marshal() (dAtA []byte, err error) + func (m *ApplyRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ApplyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ApplyRequest) Reset() + func (m *ApplyRequest) Size() (n int) + func (m *ApplyRequest) String() string + func (m *ApplyRequest) Unmarshal(dAtA []byte) error + func (m *ApplyRequest) XXX_DiscardUnknown() + func (m *ApplyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ApplyRequest) XXX_Merge(src proto.Message) + func (m *ApplyRequest) XXX_Size() int + func (m *ApplyRequest) XXX_Unmarshal(b []byte) error + type ApplyResponse struct + Error *Error + Range Range + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ApplyResponse) Descriptor() ([]byte, []int) + func (*ApplyResponse) ProtoMessage() + func (m *ApplyResponse) GetError() *Error + func (m *ApplyResponse) GetRange() Range + func (m *ApplyResponse) Marshal() (dAtA []byte, err error) + func (m *ApplyResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ApplyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ApplyResponse) Reset() + func (m *ApplyResponse) Size() (n int) + func (m *ApplyResponse) String() string + func (m *ApplyResponse) Unmarshal(dAtA []byte) error + func (m *ApplyResponse) XXX_DiscardUnknown() + func (m *ApplyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ApplyResponse) XXX_Merge(src proto.Message) + func (m *ApplyResponse) XXX_Size() int + func (m *ApplyResponse) XXX_Unmarshal(b []byte) error + type ClearRequest struct + Prefix string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClearRequest) Descriptor() ([]byte, []int) + func (*ClearRequest) ProtoMessage() + func (m *ClearRequest) GetPrefix() string + func (m *ClearRequest) Marshal() (dAtA []byte, err error) + func (m *ClearRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ClearRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClearRequest) Reset() + func (m *ClearRequest) Size() (n int) + func (m *ClearRequest) String() string + func (m *ClearRequest) Unmarshal(dAtA []byte) error + func (m *ClearRequest) XXX_DiscardUnknown() + func (m *ClearRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClearRequest) XXX_Merge(src proto.Message) + func (m *ClearRequest) XXX_Size() int + func (m *ClearRequest) XXX_Unmarshal(b []byte) error + type ClearResponse struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClearResponse) Descriptor() ([]byte, []int) + func (*ClearResponse) ProtoMessage() + func (m *ClearResponse) GetError() *Error + func (m *ClearResponse) Marshal() (dAtA []byte, err error) + func (m *ClearResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ClearResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ClearResponse) Reset() + func (m *ClearResponse) Size() (n int) + func (m *ClearResponse) String() string + func (m *ClearResponse) Unmarshal(dAtA []byte) error + func (m *ClearResponse) XXX_DiscardUnknown() + func (m *ClearResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClearResponse) XXX_Merge(src proto.Message) + func (m *ClearResponse) XXX_Size() int + func (m *ClearResponse) XXX_Unmarshal(b []byte) error + type CompactRequest struct + Context *kvrpcpb.Context + OutputLevel int32 + Range *Range + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactRequest) Descriptor() ([]byte, []int) + func (*CompactRequest) ProtoMessage() + func (m *CompactRequest) GetContext() *kvrpcpb.Context + func (m *CompactRequest) GetOutputLevel() int32 + func (m *CompactRequest) GetRange() *Range + func (m *CompactRequest) Marshal() (dAtA []byte, err error) + func (m *CompactRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CompactRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactRequest) Reset() + func (m *CompactRequest) Size() (n int) + func (m *CompactRequest) String() string + func (m *CompactRequest) Unmarshal(dAtA []byte) error + func (m *CompactRequest) XXX_DiscardUnknown() + func (m *CompactRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactRequest) XXX_Merge(src proto.Message) + func (m *CompactRequest) XXX_Size() int + func (m *CompactRequest) XXX_Unmarshal(b []byte) error + type CompactResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactResponse) Descriptor() ([]byte, []int) + func (*CompactResponse) ProtoMessage() + func (m *CompactResponse) Marshal() (dAtA []byte, err error) + func (m *CompactResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CompactResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactResponse) Reset() + func (m *CompactResponse) Size() (n int) + func (m *CompactResponse) String() string + func (m *CompactResponse) Unmarshal(dAtA []byte) error + func (m *CompactResponse) XXX_DiscardUnknown() + func (m *CompactResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactResponse) XXX_Merge(src proto.Message) + func (m *CompactResponse) XXX_Size() int + func (m *CompactResponse) XXX_Unmarshal(b []byte) error + type DownloadRequest struct + CipherInfo *brpb.CipherInfo + IsRawKv bool + Name string + RequestType DownloadRequestType + RewriteRule RewriteRule + Sst SSTMeta + StorageBackend *brpb.StorageBackend + StorageCacheId string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DownloadRequest) Descriptor() ([]byte, []int) + func (*DownloadRequest) ProtoMessage() + func (m *DownloadRequest) GetCipherInfo() *brpb.CipherInfo + func (m *DownloadRequest) GetIsRawKv() bool + func (m *DownloadRequest) GetName() string + func (m *DownloadRequest) GetRequestType() DownloadRequestType + func (m *DownloadRequest) GetRewriteRule() RewriteRule + func (m *DownloadRequest) GetSst() SSTMeta + func (m *DownloadRequest) GetStorageBackend() *brpb.StorageBackend + func (m *DownloadRequest) GetStorageCacheId() string + func (m *DownloadRequest) Marshal() (dAtA []byte, err error) + func (m *DownloadRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DownloadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DownloadRequest) Reset() + func (m *DownloadRequest) Size() (n int) + func (m *DownloadRequest) String() string + func (m *DownloadRequest) Unmarshal(dAtA []byte) error + func (m *DownloadRequest) XXX_DiscardUnknown() + func (m *DownloadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DownloadRequest) XXX_Merge(src proto.Message) + func (m *DownloadRequest) XXX_Size() int + func (m *DownloadRequest) XXX_Unmarshal(b []byte) error + type DownloadRequestType int32 + const DownloadRequestType_Keyspace + const DownloadRequestType_Legacy + func (DownloadRequestType) EnumDescriptor() ([]byte, []int) + func (x DownloadRequestType) String() string + type DownloadResponse struct + Crc32 uint32 + Error *Error + IsEmpty bool + Length uint64 + Range Range + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DownloadResponse) Descriptor() ([]byte, []int) + func (*DownloadResponse) ProtoMessage() + func (m *DownloadResponse) GetCrc32() uint32 + func (m *DownloadResponse) GetError() *Error + func (m *DownloadResponse) GetIsEmpty() bool + func (m *DownloadResponse) GetLength() uint64 + func (m *DownloadResponse) GetRange() Range + func (m *DownloadResponse) Marshal() (dAtA []byte, err error) + func (m *DownloadResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DownloadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DownloadResponse) Reset() + func (m *DownloadResponse) Size() (n int) + func (m *DownloadResponse) String() string + func (m *DownloadResponse) Unmarshal(dAtA []byte) error + func (m *DownloadResponse) XXX_DiscardUnknown() + func (m *DownloadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DownloadResponse) XXX_Merge(src proto.Message) + func (m *DownloadResponse) XXX_Size() int + func (m *DownloadResponse) XXX_Unmarshal(b []byte) error + type DuplicateDetectRequest struct + Context *kvrpcpb.Context + EndKey []byte + KeyOnly bool + MinCommitTs uint64 + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DuplicateDetectRequest) Descriptor() ([]byte, []int) + func (*DuplicateDetectRequest) ProtoMessage() + func (m *DuplicateDetectRequest) GetContext() *kvrpcpb.Context + func (m *DuplicateDetectRequest) GetEndKey() []byte + func (m *DuplicateDetectRequest) GetKeyOnly() bool + func (m *DuplicateDetectRequest) GetMinCommitTs() uint64 + func (m *DuplicateDetectRequest) GetStartKey() []byte + func (m *DuplicateDetectRequest) Marshal() (dAtA []byte, err error) + func (m *DuplicateDetectRequest) MarshalTo(dAtA []byte) (int, error) + func (m *DuplicateDetectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DuplicateDetectRequest) Reset() + func (m *DuplicateDetectRequest) Size() (n int) + func (m *DuplicateDetectRequest) String() string + func (m *DuplicateDetectRequest) Unmarshal(dAtA []byte) error + func (m *DuplicateDetectRequest) XXX_DiscardUnknown() + func (m *DuplicateDetectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DuplicateDetectRequest) XXX_Merge(src proto.Message) + func (m *DuplicateDetectRequest) XXX_Size() int + func (m *DuplicateDetectRequest) XXX_Unmarshal(b []byte) error + type DuplicateDetectResponse struct + KeyError *Error + Pairs []*KvPair + RegionError *errorpb.Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DuplicateDetectResponse) Descriptor() ([]byte, []int) + func (*DuplicateDetectResponse) ProtoMessage() + func (m *DuplicateDetectResponse) GetKeyError() *Error + func (m *DuplicateDetectResponse) GetPairs() []*KvPair + func (m *DuplicateDetectResponse) GetRegionError() *errorpb.Error + func (m *DuplicateDetectResponse) Marshal() (dAtA []byte, err error) + func (m *DuplicateDetectResponse) MarshalTo(dAtA []byte) (int, error) + func (m *DuplicateDetectResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *DuplicateDetectResponse) Reset() + func (m *DuplicateDetectResponse) Size() (n int) + func (m *DuplicateDetectResponse) String() string + func (m *DuplicateDetectResponse) Unmarshal(dAtA []byte) error + func (m *DuplicateDetectResponse) XXX_DiscardUnknown() + func (m *DuplicateDetectResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DuplicateDetectResponse) XXX_Merge(src proto.Message) + func (m *DuplicateDetectResponse) XXX_Size() int + func (m *DuplicateDetectResponse) XXX_Unmarshal(b []byte) error + type Error struct + Message string + StoreError *errorpb.Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetMessage() string + func (m *Error) GetStoreError() *errorpb.Error + func (m *Error) Marshal() (dAtA []byte, err error) + func (m *Error) MarshalTo(dAtA []byte) (int, error) + func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error) Reset() + func (m *Error) Size() (n int) + func (m *Error) String() string + func (m *Error) Unmarshal(dAtA []byte) error + func (m *Error) XXX_DiscardUnknown() + func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error) XXX_Merge(src proto.Message) + func (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type GetModeRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetModeRequest) Descriptor() ([]byte, []int) + func (*GetModeRequest) ProtoMessage() + func (m *GetModeRequest) Marshal() (dAtA []byte, err error) + func (m *GetModeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetModeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetModeRequest) Reset() + func (m *GetModeRequest) Size() (n int) + func (m *GetModeRequest) String() string + func (m *GetModeRequest) Unmarshal(dAtA []byte) error + func (m *GetModeRequest) XXX_DiscardUnknown() + func (m *GetModeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetModeRequest) XXX_Merge(src proto.Message) + func (m *GetModeRequest) XXX_Size() int + func (m *GetModeRequest) XXX_Unmarshal(b []byte) error + type GetModeResponse struct + Mode SwitchMode + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetModeResponse) Descriptor() ([]byte, []int) + func (*GetModeResponse) ProtoMessage() + func (m *GetModeResponse) GetMode() SwitchMode + func (m *GetModeResponse) Marshal() (dAtA []byte, err error) + func (m *GetModeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetModeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetModeResponse) Reset() + func (m *GetModeResponse) Size() (n int) + func (m *GetModeResponse) String() string + func (m *GetModeResponse) Unmarshal(dAtA []byte) error + func (m *GetModeResponse) XXX_DiscardUnknown() + func (m *GetModeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetModeResponse) XXX_Merge(src proto.Message) + func (m *GetModeResponse) XXX_Size() int + func (m *GetModeResponse) XXX_Unmarshal(b []byte) error + type ImportSSTClient interface + Apply func(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error) + ClearFiles func(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error) + Compact func(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error) + Download func(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (*DownloadResponse, error) + DuplicateDetect func(ctx context.Context, in *DuplicateDetectRequest, opts ...grpc.CallOption) (ImportSST_DuplicateDetectClient, error) + GetMode func(ctx context.Context, in *GetModeRequest, opts ...grpc.CallOption) (*GetModeResponse, error) + Ingest func(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error) + MultiIngest func(ctx context.Context, in *MultiIngestRequest, opts ...grpc.CallOption) (*IngestResponse, error) + RawWrite func(ctx context.Context, opts ...grpc.CallOption) (ImportSST_RawWriteClient, error) + SetDownloadSpeedLimit func(ctx context.Context, in *SetDownloadSpeedLimitRequest, opts ...grpc.CallOption) (*SetDownloadSpeedLimitResponse, error) + SwitchMode func(ctx context.Context, in *SwitchModeRequest, opts ...grpc.CallOption) (*SwitchModeResponse, error) + Upload func(ctx context.Context, opts ...grpc.CallOption) (ImportSST_UploadClient, error) + Write func(ctx context.Context, opts ...grpc.CallOption) (ImportSST_WriteClient, error) + func NewImportSSTClient(cc *grpc.ClientConn) ImportSSTClient + type ImportSSTServer interface + Apply func(context.Context, *ApplyRequest) (*ApplyResponse, error) + ClearFiles func(context.Context, *ClearRequest) (*ClearResponse, error) + Compact func(context.Context, *CompactRequest) (*CompactResponse, error) + Download func(context.Context, *DownloadRequest) (*DownloadResponse, error) + DuplicateDetect func(*DuplicateDetectRequest, ImportSST_DuplicateDetectServer) error + GetMode func(context.Context, *GetModeRequest) (*GetModeResponse, error) + Ingest func(context.Context, *IngestRequest) (*IngestResponse, error) + MultiIngest func(context.Context, *MultiIngestRequest) (*IngestResponse, error) + RawWrite func(ImportSST_RawWriteServer) error + SetDownloadSpeedLimit func(context.Context, *SetDownloadSpeedLimitRequest) (*SetDownloadSpeedLimitResponse, error) + SwitchMode func(context.Context, *SwitchModeRequest) (*SwitchModeResponse, error) + Upload func(ImportSST_UploadServer) error + Write func(ImportSST_WriteServer) error + type ImportSST_DuplicateDetectClient interface + Recv func() (*DuplicateDetectResponse, error) + type ImportSST_DuplicateDetectServer interface + Send func(*DuplicateDetectResponse) error + type ImportSST_RawWriteClient interface + CloseAndRecv func() (*RawWriteResponse, error) + Send func(*RawWriteRequest) error + type ImportSST_RawWriteServer interface + Recv func() (*RawWriteRequest, error) + SendAndClose func(*RawWriteResponse) error + type ImportSST_UploadClient interface + CloseAndRecv func() (*UploadResponse, error) + Send func(*UploadRequest) error + type ImportSST_UploadServer interface + Recv func() (*UploadRequest, error) + SendAndClose func(*UploadResponse) error + type ImportSST_WriteClient interface + CloseAndRecv func() (*WriteResponse, error) + Send func(*WriteRequest) error + type ImportSST_WriteServer interface + Recv func() (*WriteRequest, error) + SendAndClose func(*WriteResponse) error + type IngestRequest struct + Context *kvrpcpb.Context + Sst *SSTMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IngestRequest) Descriptor() ([]byte, []int) + func (*IngestRequest) ProtoMessage() + func (m *IngestRequest) GetContext() *kvrpcpb.Context + func (m *IngestRequest) GetSst() *SSTMeta + func (m *IngestRequest) Marshal() (dAtA []byte, err error) + func (m *IngestRequest) MarshalTo(dAtA []byte) (int, error) + func (m *IngestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IngestRequest) Reset() + func (m *IngestRequest) Size() (n int) + func (m *IngestRequest) String() string + func (m *IngestRequest) Unmarshal(dAtA []byte) error + func (m *IngestRequest) XXX_DiscardUnknown() + func (m *IngestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IngestRequest) XXX_Merge(src proto.Message) + func (m *IngestRequest) XXX_Size() int + func (m *IngestRequest) XXX_Unmarshal(b []byte) error + type IngestResponse struct + Error *errorpb.Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IngestResponse) Descriptor() ([]byte, []int) + func (*IngestResponse) ProtoMessage() + func (m *IngestResponse) GetError() *errorpb.Error + func (m *IngestResponse) Marshal() (dAtA []byte, err error) + func (m *IngestResponse) MarshalTo(dAtA []byte) (int, error) + func (m *IngestResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *IngestResponse) Reset() + func (m *IngestResponse) Size() (n int) + func (m *IngestResponse) String() string + func (m *IngestResponse) Unmarshal(dAtA []byte) error + func (m *IngestResponse) XXX_DiscardUnknown() + func (m *IngestResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *IngestResponse) XXX_Merge(src proto.Message) + func (m *IngestResponse) XXX_Size() int + func (m *IngestResponse) XXX_Unmarshal(b []byte) error + type KVMeta struct + Cf string + CompressionType brpb.CompressionType + EndKey []byte + IsDelete bool + Length uint64 + Name string + RangeLength uint64 + RangeOffset uint64 + RestoreTs uint64 + Sha256 []byte + StartKey []byte + StartSnapshotTs uint64 + StartTs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KVMeta) Descriptor() ([]byte, []int) + func (*KVMeta) ProtoMessage() + func (m *KVMeta) GetCf() string + func (m *KVMeta) GetCompressionType() brpb.CompressionType + func (m *KVMeta) GetEndKey() []byte + func (m *KVMeta) GetIsDelete() bool + func (m *KVMeta) GetLength() uint64 + func (m *KVMeta) GetName() string + func (m *KVMeta) GetRangeLength() uint64 + func (m *KVMeta) GetRangeOffset() uint64 + func (m *KVMeta) GetRestoreTs() uint64 + func (m *KVMeta) GetSha256() []byte + func (m *KVMeta) GetStartKey() []byte + func (m *KVMeta) GetStartSnapshotTs() uint64 + func (m *KVMeta) GetStartTs() uint64 + func (m *KVMeta) Marshal() (dAtA []byte, err error) + func (m *KVMeta) MarshalTo(dAtA []byte) (int, error) + func (m *KVMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KVMeta) Reset() + func (m *KVMeta) Size() (n int) + func (m *KVMeta) String() string + func (m *KVMeta) Unmarshal(dAtA []byte) error + func (m *KVMeta) XXX_DiscardUnknown() + func (m *KVMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KVMeta) XXX_Merge(src proto.Message) + func (m *KVMeta) XXX_Size() int + func (m *KVMeta) XXX_Unmarshal(b []byte) error + type KvPair struct + CommitTs uint64 + Key []byte + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KvPair) Descriptor() ([]byte, []int) + func (*KvPair) ProtoMessage() + func (m *KvPair) GetCommitTs() uint64 + func (m *KvPair) GetKey() []byte + func (m *KvPair) GetValue() []byte + func (m *KvPair) Marshal() (dAtA []byte, err error) + func (m *KvPair) MarshalTo(dAtA []byte) (int, error) + func (m *KvPair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *KvPair) Reset() + func (m *KvPair) Size() (n int) + func (m *KvPair) String() string + func (m *KvPair) Unmarshal(dAtA []byte) error + func (m *KvPair) XXX_DiscardUnknown() + func (m *KvPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *KvPair) XXX_Merge(src proto.Message) + func (m *KvPair) XXX_Size() int + func (m *KvPair) XXX_Unmarshal(b []byte) error + type MultiIngestRequest struct + Context *kvrpcpb.Context + Ssts []*SSTMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MultiIngestRequest) Descriptor() ([]byte, []int) + func (*MultiIngestRequest) ProtoMessage() + func (m *MultiIngestRequest) GetContext() *kvrpcpb.Context + func (m *MultiIngestRequest) GetSsts() []*SSTMeta + func (m *MultiIngestRequest) Marshal() (dAtA []byte, err error) + func (m *MultiIngestRequest) MarshalTo(dAtA []byte) (int, error) + func (m *MultiIngestRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *MultiIngestRequest) Reset() + func (m *MultiIngestRequest) Size() (n int) + func (m *MultiIngestRequest) String() string + func (m *MultiIngestRequest) Unmarshal(dAtA []byte) error + func (m *MultiIngestRequest) XXX_DiscardUnknown() + func (m *MultiIngestRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MultiIngestRequest) XXX_Merge(src proto.Message) + func (m *MultiIngestRequest) XXX_Size() int + func (m *MultiIngestRequest) XXX_Unmarshal(b []byte) error + type Pair struct + Key []byte + Op Pair_OP + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Pair) Descriptor() ([]byte, []int) + func (*Pair) ProtoMessage() + func (m *Pair) GetKey() []byte + func (m *Pair) GetOp() Pair_OP + func (m *Pair) GetValue() []byte + func (m *Pair) Marshal() (dAtA []byte, err error) + func (m *Pair) MarshalTo(dAtA []byte) (int, error) + func (m *Pair) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Pair) Reset() + func (m *Pair) Size() (n int) + func (m *Pair) String() string + func (m *Pair) Unmarshal(dAtA []byte) error + func (m *Pair) XXX_DiscardUnknown() + func (m *Pair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Pair) XXX_Merge(src proto.Message) + func (m *Pair) XXX_Size() int + func (m *Pair) XXX_Unmarshal(b []byte) error + type Pair_OP int32 + const Pair_Delete + const Pair_Put + func (Pair_OP) EnumDescriptor() ([]byte, []int) + func (x Pair_OP) String() string + type Range struct + End []byte + Start []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Range) Descriptor() ([]byte, []int) + func (*Range) ProtoMessage() + func (m *Range) GetEnd() []byte + func (m *Range) GetStart() []byte + func (m *Range) Marshal() (dAtA []byte, err error) + func (m *Range) MarshalTo(dAtA []byte) (int, error) + func (m *Range) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Range) Reset() + func (m *Range) Size() (n int) + func (m *Range) String() string + func (m *Range) Unmarshal(dAtA []byte) error + func (m *Range) XXX_DiscardUnknown() + func (m *Range) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Range) XXX_Merge(src proto.Message) + func (m *Range) XXX_Size() int + func (m *Range) XXX_Unmarshal(b []byte) error + type RawWriteBatch struct + Pairs []*Pair + Ts uint64 + Ttl uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RawWriteBatch) Descriptor() ([]byte, []int) + func (*RawWriteBatch) ProtoMessage() + func (m *RawWriteBatch) GetPairs() []*Pair + func (m *RawWriteBatch) GetTs() uint64 + func (m *RawWriteBatch) GetTtl() uint64 + func (m *RawWriteBatch) Marshal() (dAtA []byte, err error) + func (m *RawWriteBatch) MarshalTo(dAtA []byte) (int, error) + func (m *RawWriteBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RawWriteBatch) Reset() + func (m *RawWriteBatch) Size() (n int) + func (m *RawWriteBatch) String() string + func (m *RawWriteBatch) Unmarshal(dAtA []byte) error + func (m *RawWriteBatch) XXX_DiscardUnknown() + func (m *RawWriteBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RawWriteBatch) XXX_Merge(src proto.Message) + func (m *RawWriteBatch) XXX_Size() int + func (m *RawWriteBatch) XXX_Unmarshal(b []byte) error + type RawWriteRequest struct + Chunk isRawWriteRequest_Chunk + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RawWriteRequest) Descriptor() ([]byte, []int) + func (*RawWriteRequest) ProtoMessage() + func (*RawWriteRequest) XXX_OneofWrappers() []interface{} + func (m *RawWriteRequest) GetBatch() *RawWriteBatch + func (m *RawWriteRequest) GetChunk() isRawWriteRequest_Chunk + func (m *RawWriteRequest) GetMeta() *SSTMeta + func (m *RawWriteRequest) Marshal() (dAtA []byte, err error) + func (m *RawWriteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *RawWriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RawWriteRequest) Reset() + func (m *RawWriteRequest) Size() (n int) + func (m *RawWriteRequest) String() string + func (m *RawWriteRequest) Unmarshal(dAtA []byte) error + func (m *RawWriteRequest) XXX_DiscardUnknown() + func (m *RawWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RawWriteRequest) XXX_Merge(src proto.Message) + func (m *RawWriteRequest) XXX_Size() int + func (m *RawWriteRequest) XXX_Unmarshal(b []byte) error + type RawWriteRequest_Batch struct + Batch *RawWriteBatch + func (m *RawWriteRequest_Batch) MarshalTo(dAtA []byte) (int, error) + func (m *RawWriteRequest_Batch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RawWriteRequest_Batch) Size() (n int) + type RawWriteRequest_Meta struct + Meta *SSTMeta + func (m *RawWriteRequest_Meta) MarshalTo(dAtA []byte) (int, error) + func (m *RawWriteRequest_Meta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RawWriteRequest_Meta) Size() (n int) + type RawWriteResponse struct + Error *Error + Metas []*SSTMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RawWriteResponse) Descriptor() ([]byte, []int) + func (*RawWriteResponse) ProtoMessage() + func (m *RawWriteResponse) GetError() *Error + func (m *RawWriteResponse) GetMetas() []*SSTMeta + func (m *RawWriteResponse) Marshal() (dAtA []byte, err error) + func (m *RawWriteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *RawWriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RawWriteResponse) Reset() + func (m *RawWriteResponse) Size() (n int) + func (m *RawWriteResponse) String() string + func (m *RawWriteResponse) Unmarshal(dAtA []byte) error + func (m *RawWriteResponse) XXX_DiscardUnknown() + func (m *RawWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RawWriteResponse) XXX_Merge(src proto.Message) + func (m *RawWriteResponse) XXX_Size() int + func (m *RawWriteResponse) XXX_Unmarshal(b []byte) error + type RewriteRule struct + NewKeyPrefix []byte + NewTimestamp uint64 + OldKeyPrefix []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RewriteRule) Descriptor() ([]byte, []int) + func (*RewriteRule) ProtoMessage() + func (m *RewriteRule) GetNewKeyPrefix() []byte + func (m *RewriteRule) GetNewTimestamp() uint64 + func (m *RewriteRule) GetOldKeyPrefix() []byte + func (m *RewriteRule) Marshal() (dAtA []byte, err error) + func (m *RewriteRule) MarshalTo(dAtA []byte) (int, error) + func (m *RewriteRule) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RewriteRule) Reset() + func (m *RewriteRule) Size() (n int) + func (m *RewriteRule) String() string + func (m *RewriteRule) Unmarshal(dAtA []byte) error + func (m *RewriteRule) XXX_DiscardUnknown() + func (m *RewriteRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RewriteRule) XXX_Merge(src proto.Message) + func (m *RewriteRule) XXX_Size() int + func (m *RewriteRule) XXX_Unmarshal(b []byte) error + type SSTMeta struct + ApiVersion kvrpcpb.APIVersion + CfName string + CipherIv []byte + Crc32 uint32 + EndKeyExclusive bool + Length uint64 + Range *Range + RegionEpoch *metapb.RegionEpoch + RegionId uint64 + TotalBytes uint64 + TotalKvs uint64 + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SSTMeta) Descriptor() ([]byte, []int) + func (*SSTMeta) ProtoMessage() + func (m *SSTMeta) GetApiVersion() kvrpcpb.APIVersion + func (m *SSTMeta) GetCfName() string + func (m *SSTMeta) GetCipherIv() []byte + func (m *SSTMeta) GetCrc32() uint32 + func (m *SSTMeta) GetEndKeyExclusive() bool + func (m *SSTMeta) GetLength() uint64 + func (m *SSTMeta) GetRange() *Range + func (m *SSTMeta) GetRegionEpoch() *metapb.RegionEpoch + func (m *SSTMeta) GetRegionId() uint64 + func (m *SSTMeta) GetTotalBytes() uint64 + func (m *SSTMeta) GetTotalKvs() uint64 + func (m *SSTMeta) GetUuid() []byte + func (m *SSTMeta) Marshal() (dAtA []byte, err error) + func (m *SSTMeta) MarshalTo(dAtA []byte) (int, error) + func (m *SSTMeta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SSTMeta) Reset() + func (m *SSTMeta) Size() (n int) + func (m *SSTMeta) String() string + func (m *SSTMeta) Unmarshal(dAtA []byte) error + func (m *SSTMeta) XXX_DiscardUnknown() + func (m *SSTMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SSTMeta) XXX_Merge(src proto.Message) + func (m *SSTMeta) XXX_Size() int + func (m *SSTMeta) XXX_Unmarshal(b []byte) error + type SetDownloadSpeedLimitRequest struct + SpeedLimit uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetDownloadSpeedLimitRequest) Descriptor() ([]byte, []int) + func (*SetDownloadSpeedLimitRequest) ProtoMessage() + func (m *SetDownloadSpeedLimitRequest) GetSpeedLimit() uint64 + func (m *SetDownloadSpeedLimitRequest) Marshal() (dAtA []byte, err error) + func (m *SetDownloadSpeedLimitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SetDownloadSpeedLimitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SetDownloadSpeedLimitRequest) Reset() + func (m *SetDownloadSpeedLimitRequest) Size() (n int) + func (m *SetDownloadSpeedLimitRequest) String() string + func (m *SetDownloadSpeedLimitRequest) Unmarshal(dAtA []byte) error + func (m *SetDownloadSpeedLimitRequest) XXX_DiscardUnknown() + func (m *SetDownloadSpeedLimitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetDownloadSpeedLimitRequest) XXX_Merge(src proto.Message) + func (m *SetDownloadSpeedLimitRequest) XXX_Size() int + func (m *SetDownloadSpeedLimitRequest) XXX_Unmarshal(b []byte) error + type SetDownloadSpeedLimitResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SetDownloadSpeedLimitResponse) Descriptor() ([]byte, []int) + func (*SetDownloadSpeedLimitResponse) ProtoMessage() + func (m *SetDownloadSpeedLimitResponse) Marshal() (dAtA []byte, err error) + func (m *SetDownloadSpeedLimitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SetDownloadSpeedLimitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SetDownloadSpeedLimitResponse) Reset() + func (m *SetDownloadSpeedLimitResponse) Size() (n int) + func (m *SetDownloadSpeedLimitResponse) String() string + func (m *SetDownloadSpeedLimitResponse) Unmarshal(dAtA []byte) error + func (m *SetDownloadSpeedLimitResponse) XXX_DiscardUnknown() + func (m *SetDownloadSpeedLimitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SetDownloadSpeedLimitResponse) XXX_Merge(src proto.Message) + func (m *SetDownloadSpeedLimitResponse) XXX_Size() int + func (m *SetDownloadSpeedLimitResponse) XXX_Unmarshal(b []byte) error + type SwitchMode int32 + const SwitchMode_Import + const SwitchMode_Normal + func (SwitchMode) EnumDescriptor() ([]byte, []int) + func (x SwitchMode) String() string + type SwitchModeRequest struct + Mode SwitchMode + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SwitchModeRequest) Descriptor() ([]byte, []int) + func (*SwitchModeRequest) ProtoMessage() + func (m *SwitchModeRequest) GetMode() SwitchMode + func (m *SwitchModeRequest) Marshal() (dAtA []byte, err error) + func (m *SwitchModeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SwitchModeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SwitchModeRequest) Reset() + func (m *SwitchModeRequest) Size() (n int) + func (m *SwitchModeRequest) String() string + func (m *SwitchModeRequest) Unmarshal(dAtA []byte) error + func (m *SwitchModeRequest) XXX_DiscardUnknown() + func (m *SwitchModeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SwitchModeRequest) XXX_Merge(src proto.Message) + func (m *SwitchModeRequest) XXX_Size() int + func (m *SwitchModeRequest) XXX_Unmarshal(b []byte) error + type SwitchModeResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SwitchModeResponse) Descriptor() ([]byte, []int) + func (*SwitchModeResponse) ProtoMessage() + func (m *SwitchModeResponse) Marshal() (dAtA []byte, err error) + func (m *SwitchModeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SwitchModeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SwitchModeResponse) Reset() + func (m *SwitchModeResponse) Size() (n int) + func (m *SwitchModeResponse) String() string + func (m *SwitchModeResponse) Unmarshal(dAtA []byte) error + func (m *SwitchModeResponse) XXX_DiscardUnknown() + func (m *SwitchModeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SwitchModeResponse) XXX_Merge(src proto.Message) + func (m *SwitchModeResponse) XXX_Size() int + func (m *SwitchModeResponse) XXX_Unmarshal(b []byte) error + type UnimplementedImportSSTServer struct + func (*UnimplementedImportSSTServer) Apply(ctx context.Context, req *ApplyRequest) (*ApplyResponse, error) + func (*UnimplementedImportSSTServer) ClearFiles(ctx context.Context, req *ClearRequest) (*ClearResponse, error) + func (*UnimplementedImportSSTServer) Compact(ctx context.Context, req *CompactRequest) (*CompactResponse, error) + func (*UnimplementedImportSSTServer) Download(ctx context.Context, req *DownloadRequest) (*DownloadResponse, error) + func (*UnimplementedImportSSTServer) DuplicateDetect(req *DuplicateDetectRequest, srv ImportSST_DuplicateDetectServer) error + func (*UnimplementedImportSSTServer) GetMode(ctx context.Context, req *GetModeRequest) (*GetModeResponse, error) + func (*UnimplementedImportSSTServer) Ingest(ctx context.Context, req *IngestRequest) (*IngestResponse, error) + func (*UnimplementedImportSSTServer) MultiIngest(ctx context.Context, req *MultiIngestRequest) (*IngestResponse, error) + func (*UnimplementedImportSSTServer) RawWrite(srv ImportSST_RawWriteServer) error + func (*UnimplementedImportSSTServer) SetDownloadSpeedLimit(ctx context.Context, req *SetDownloadSpeedLimitRequest) (*SetDownloadSpeedLimitResponse, error) + func (*UnimplementedImportSSTServer) SwitchMode(ctx context.Context, req *SwitchModeRequest) (*SwitchModeResponse, error) + func (*UnimplementedImportSSTServer) Upload(srv ImportSST_UploadServer) error + func (*UnimplementedImportSSTServer) Write(srv ImportSST_WriteServer) error + type UploadRequest struct + Chunk isUploadRequest_Chunk + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UploadRequest) Descriptor() ([]byte, []int) + func (*UploadRequest) ProtoMessage() + func (*UploadRequest) XXX_OneofWrappers() []interface{} + func (m *UploadRequest) GetChunk() isUploadRequest_Chunk + func (m *UploadRequest) GetData() []byte + func (m *UploadRequest) GetMeta() *SSTMeta + func (m *UploadRequest) Marshal() (dAtA []byte, err error) + func (m *UploadRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UploadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UploadRequest) Reset() + func (m *UploadRequest) Size() (n int) + func (m *UploadRequest) String() string + func (m *UploadRequest) Unmarshal(dAtA []byte) error + func (m *UploadRequest) XXX_DiscardUnknown() + func (m *UploadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UploadRequest) XXX_Merge(src proto.Message) + func (m *UploadRequest) XXX_Size() int + func (m *UploadRequest) XXX_Unmarshal(b []byte) error + type UploadRequest_Data struct + Data []byte + func (m *UploadRequest_Data) MarshalTo(dAtA []byte) (int, error) + func (m *UploadRequest_Data) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UploadRequest_Data) Size() (n int) + type UploadRequest_Meta struct + Meta *SSTMeta + func (m *UploadRequest_Meta) MarshalTo(dAtA []byte) (int, error) + func (m *UploadRequest_Meta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UploadRequest_Meta) Size() (n int) + type UploadResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UploadResponse) Descriptor() ([]byte, []int) + func (*UploadResponse) ProtoMessage() + func (m *UploadResponse) Marshal() (dAtA []byte, err error) + func (m *UploadResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UploadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UploadResponse) Reset() + func (m *UploadResponse) Size() (n int) + func (m *UploadResponse) String() string + func (m *UploadResponse) Unmarshal(dAtA []byte) error + func (m *UploadResponse) XXX_DiscardUnknown() + func (m *UploadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UploadResponse) XXX_Merge(src proto.Message) + func (m *UploadResponse) XXX_Size() int + func (m *UploadResponse) XXX_Unmarshal(b []byte) error + type WriteBatch struct + CommitTs uint64 + Pairs []*Pair + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteBatch) Descriptor() ([]byte, []int) + func (*WriteBatch) ProtoMessage() + func (m *WriteBatch) GetCommitTs() uint64 + func (m *WriteBatch) GetPairs() []*Pair + func (m *WriteBatch) Marshal() (dAtA []byte, err error) + func (m *WriteBatch) MarshalTo(dAtA []byte) (int, error) + func (m *WriteBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteBatch) Reset() + func (m *WriteBatch) Size() (n int) + func (m *WriteBatch) String() string + func (m *WriteBatch) Unmarshal(dAtA []byte) error + func (m *WriteBatch) XXX_DiscardUnknown() + func (m *WriteBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteBatch) XXX_Merge(src proto.Message) + func (m *WriteBatch) XXX_Size() int + func (m *WriteBatch) XXX_Unmarshal(b []byte) error + type WriteRequest struct + Chunk isWriteRequest_Chunk + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteRequest) Descriptor() ([]byte, []int) + func (*WriteRequest) ProtoMessage() + func (*WriteRequest) XXX_OneofWrappers() []interface{} + func (m *WriteRequest) GetBatch() *WriteBatch + func (m *WriteRequest) GetChunk() isWriteRequest_Chunk + func (m *WriteRequest) GetMeta() *SSTMeta + func (m *WriteRequest) Marshal() (dAtA []byte, err error) + func (m *WriteRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WriteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteRequest) Reset() + func (m *WriteRequest) Size() (n int) + func (m *WriteRequest) String() string + func (m *WriteRequest) Unmarshal(dAtA []byte) error + func (m *WriteRequest) XXX_DiscardUnknown() + func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteRequest) XXX_Merge(src proto.Message) + func (m *WriteRequest) XXX_Size() int + func (m *WriteRequest) XXX_Unmarshal(b []byte) error + type WriteRequest_Batch struct + Batch *WriteBatch + func (m *WriteRequest_Batch) MarshalTo(dAtA []byte) (int, error) + func (m *WriteRequest_Batch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteRequest_Batch) Size() (n int) + type WriteRequest_Meta struct + Meta *SSTMeta + func (m *WriteRequest_Meta) MarshalTo(dAtA []byte) (int, error) + func (m *WriteRequest_Meta) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteRequest_Meta) Size() (n int) + type WriteResponse struct + Error *Error + Metas []*SSTMeta + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteResponse) Descriptor() ([]byte, []int) + func (*WriteResponse) ProtoMessage() + func (m *WriteResponse) GetError() *Error + func (m *WriteResponse) GetMetas() []*SSTMeta + func (m *WriteResponse) Marshal() (dAtA []byte, err error) + func (m *WriteResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WriteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteResponse) Reset() + func (m *WriteResponse) Size() (n int) + func (m *WriteResponse) String() string + func (m *WriteResponse) Unmarshal(dAtA []byte) error + func (m *WriteResponse) XXX_DiscardUnknown() + func (m *WriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteResponse) XXX_Merge(src proto.Message) + func (m *WriteResponse) XXX_Size() int + func (m *WriteResponse) XXX_Unmarshal(b []byte) error