Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var ErrIntOverflowImportKvpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthImportKvpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupImportKvpb = fmt.Errorf("proto: unexpected end of group") + var Mutation_OP_name = map[int32]string + var Mutation_OP_value = map[string]int32 + func RegisterImportKVServer(s *grpc.Server, srv ImportKVServer) + type CleanupEngineRequest struct + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CleanupEngineRequest) Descriptor() ([]byte, []int) + func (*CleanupEngineRequest) ProtoMessage() + func (m *CleanupEngineRequest) GetUuid() []byte + func (m *CleanupEngineRequest) Marshal() (dAtA []byte, err error) + func (m *CleanupEngineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CleanupEngineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CleanupEngineRequest) Reset() + func (m *CleanupEngineRequest) Size() (n int) + func (m *CleanupEngineRequest) String() string + func (m *CleanupEngineRequest) Unmarshal(dAtA []byte) error + func (m *CleanupEngineRequest) XXX_DiscardUnknown() + func (m *CleanupEngineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CleanupEngineRequest) XXX_Merge(src proto.Message) + func (m *CleanupEngineRequest) XXX_Size() int + func (m *CleanupEngineRequest) XXX_Unmarshal(b []byte) error + type CleanupEngineResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CleanupEngineResponse) Descriptor() ([]byte, []int) + func (*CleanupEngineResponse) ProtoMessage() + func (m *CleanupEngineResponse) Marshal() (dAtA []byte, err error) + func (m *CleanupEngineResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CleanupEngineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CleanupEngineResponse) Reset() + func (m *CleanupEngineResponse) Size() (n int) + func (m *CleanupEngineResponse) String() string + func (m *CleanupEngineResponse) Unmarshal(dAtA []byte) error + func (m *CleanupEngineResponse) XXX_DiscardUnknown() + func (m *CleanupEngineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CleanupEngineResponse) XXX_Merge(src proto.Message) + func (m *CleanupEngineResponse) XXX_Size() int + func (m *CleanupEngineResponse) XXX_Unmarshal(b []byte) error + type CloseEngineRequest struct + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseEngineRequest) Descriptor() ([]byte, []int) + func (*CloseEngineRequest) ProtoMessage() + func (m *CloseEngineRequest) GetUuid() []byte + func (m *CloseEngineRequest) Marshal() (dAtA []byte, err error) + func (m *CloseEngineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CloseEngineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CloseEngineRequest) Reset() + func (m *CloseEngineRequest) Size() (n int) + func (m *CloseEngineRequest) String() string + func (m *CloseEngineRequest) Unmarshal(dAtA []byte) error + func (m *CloseEngineRequest) XXX_DiscardUnknown() + func (m *CloseEngineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CloseEngineRequest) XXX_Merge(src proto.Message) + func (m *CloseEngineRequest) XXX_Size() int + func (m *CloseEngineRequest) XXX_Unmarshal(b []byte) error + type CloseEngineResponse struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloseEngineResponse) Descriptor() ([]byte, []int) + func (*CloseEngineResponse) ProtoMessage() + func (m *CloseEngineResponse) GetError() *Error + func (m *CloseEngineResponse) Marshal() (dAtA []byte, err error) + func (m *CloseEngineResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CloseEngineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CloseEngineResponse) Reset() + func (m *CloseEngineResponse) Size() (n int) + func (m *CloseEngineResponse) String() string + func (m *CloseEngineResponse) Unmarshal(dAtA []byte) error + func (m *CloseEngineResponse) XXX_DiscardUnknown() + func (m *CloseEngineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CloseEngineResponse) XXX_Merge(src proto.Message) + func (m *CloseEngineResponse) XXX_Size() int + func (m *CloseEngineResponse) XXX_Unmarshal(b []byte) error + type CompactClusterRequest struct + PdAddr string + Request *import_sstpb.CompactRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactClusterRequest) Descriptor() ([]byte, []int) + func (*CompactClusterRequest) ProtoMessage() + func (m *CompactClusterRequest) GetPdAddr() string + func (m *CompactClusterRequest) GetRequest() *import_sstpb.CompactRequest + func (m *CompactClusterRequest) Marshal() (dAtA []byte, err error) + func (m *CompactClusterRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CompactClusterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactClusterRequest) Reset() + func (m *CompactClusterRequest) Size() (n int) + func (m *CompactClusterRequest) String() string + func (m *CompactClusterRequest) Unmarshal(dAtA []byte) error + func (m *CompactClusterRequest) XXX_DiscardUnknown() + func (m *CompactClusterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactClusterRequest) XXX_Merge(src proto.Message) + func (m *CompactClusterRequest) XXX_Size() int + func (m *CompactClusterRequest) XXX_Unmarshal(b []byte) error + type CompactClusterResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactClusterResponse) Descriptor() ([]byte, []int) + func (*CompactClusterResponse) ProtoMessage() + func (m *CompactClusterResponse) Marshal() (dAtA []byte, err error) + func (m *CompactClusterResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CompactClusterResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactClusterResponse) Reset() + func (m *CompactClusterResponse) Size() (n int) + func (m *CompactClusterResponse) String() string + func (m *CompactClusterResponse) Unmarshal(dAtA []byte) error + func (m *CompactClusterResponse) XXX_DiscardUnknown() + func (m *CompactClusterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactClusterResponse) XXX_Merge(src proto.Message) + func (m *CompactClusterResponse) XXX_Size() int + func (m *CompactClusterResponse) XXX_Unmarshal(b []byte) error + type Error struct + EngineNotFound *Error_EngineNotFound + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (m *Error) GetEngineNotFound() *Error_EngineNotFound + 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 Error_EngineNotFound struct + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error_EngineNotFound) Descriptor() ([]byte, []int) + func (*Error_EngineNotFound) ProtoMessage() + func (m *Error_EngineNotFound) GetUuid() []byte + func (m *Error_EngineNotFound) Marshal() (dAtA []byte, err error) + func (m *Error_EngineNotFound) MarshalTo(dAtA []byte) (int, error) + func (m *Error_EngineNotFound) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error_EngineNotFound) Reset() + func (m *Error_EngineNotFound) Size() (n int) + func (m *Error_EngineNotFound) String() string + func (m *Error_EngineNotFound) Unmarshal(dAtA []byte) error + func (m *Error_EngineNotFound) XXX_DiscardUnknown() + func (m *Error_EngineNotFound) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Error_EngineNotFound) XXX_Merge(src proto.Message) + func (m *Error_EngineNotFound) XXX_Size() int + func (m *Error_EngineNotFound) XXX_Unmarshal(b []byte) error + type GetMetricsRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMetricsRequest) Descriptor() ([]byte, []int) + func (*GetMetricsRequest) ProtoMessage() + func (m *GetMetricsRequest) Marshal() (dAtA []byte, err error) + func (m *GetMetricsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetMetricsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetMetricsRequest) Reset() + func (m *GetMetricsRequest) Size() (n int) + func (m *GetMetricsRequest) String() string + func (m *GetMetricsRequest) Unmarshal(dAtA []byte) error + func (m *GetMetricsRequest) XXX_DiscardUnknown() + func (m *GetMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMetricsRequest) XXX_Merge(src proto.Message) + func (m *GetMetricsRequest) XXX_Size() int + func (m *GetMetricsRequest) XXX_Unmarshal(b []byte) error + type GetMetricsResponse struct + Prometheus string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetMetricsResponse) Descriptor() ([]byte, []int) + func (*GetMetricsResponse) ProtoMessage() + func (m *GetMetricsResponse) GetPrometheus() string + func (m *GetMetricsResponse) Marshal() (dAtA []byte, err error) + func (m *GetMetricsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetMetricsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetMetricsResponse) Reset() + func (m *GetMetricsResponse) Size() (n int) + func (m *GetMetricsResponse) String() string + func (m *GetMetricsResponse) Unmarshal(dAtA []byte) error + func (m *GetMetricsResponse) XXX_DiscardUnknown() + func (m *GetMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetMetricsResponse) XXX_Merge(src proto.Message) + func (m *GetMetricsResponse) XXX_Size() int + func (m *GetMetricsResponse) XXX_Unmarshal(b []byte) error + type GetVersionRequest struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetVersionRequest) Descriptor() ([]byte, []int) + func (*GetVersionRequest) ProtoMessage() + func (m *GetVersionRequest) Marshal() (dAtA []byte, err error) + func (m *GetVersionRequest) MarshalTo(dAtA []byte) (int, error) + func (m *GetVersionRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetVersionRequest) Reset() + func (m *GetVersionRequest) Size() (n int) + func (m *GetVersionRequest) String() string + func (m *GetVersionRequest) Unmarshal(dAtA []byte) error + func (m *GetVersionRequest) XXX_DiscardUnknown() + func (m *GetVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetVersionRequest) XXX_Merge(src proto.Message) + func (m *GetVersionRequest) XXX_Size() int + func (m *GetVersionRequest) XXX_Unmarshal(b []byte) error + type GetVersionResponse struct + Commit string + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetVersionResponse) Descriptor() ([]byte, []int) + func (*GetVersionResponse) ProtoMessage() + func (m *GetVersionResponse) GetCommit() string + func (m *GetVersionResponse) GetVersion() string + func (m *GetVersionResponse) Marshal() (dAtA []byte, err error) + func (m *GetVersionResponse) MarshalTo(dAtA []byte) (int, error) + func (m *GetVersionResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *GetVersionResponse) Reset() + func (m *GetVersionResponse) Size() (n int) + func (m *GetVersionResponse) String() string + func (m *GetVersionResponse) Unmarshal(dAtA []byte) error + func (m *GetVersionResponse) XXX_DiscardUnknown() + func (m *GetVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetVersionResponse) XXX_Merge(src proto.Message) + func (m *GetVersionResponse) XXX_Size() int + func (m *GetVersionResponse) XXX_Unmarshal(b []byte) error + type ImportEngineRequest struct + PdAddr string + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportEngineRequest) Descriptor() ([]byte, []int) + func (*ImportEngineRequest) ProtoMessage() + func (m *ImportEngineRequest) GetPdAddr() string + func (m *ImportEngineRequest) GetUuid() []byte + func (m *ImportEngineRequest) Marshal() (dAtA []byte, err error) + func (m *ImportEngineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ImportEngineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportEngineRequest) Reset() + func (m *ImportEngineRequest) Size() (n int) + func (m *ImportEngineRequest) String() string + func (m *ImportEngineRequest) Unmarshal(dAtA []byte) error + func (m *ImportEngineRequest) XXX_DiscardUnknown() + func (m *ImportEngineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportEngineRequest) XXX_Merge(src proto.Message) + func (m *ImportEngineRequest) XXX_Size() int + func (m *ImportEngineRequest) XXX_Unmarshal(b []byte) error + type ImportEngineResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ImportEngineResponse) Descriptor() ([]byte, []int) + func (*ImportEngineResponse) ProtoMessage() + func (m *ImportEngineResponse) Marshal() (dAtA []byte, err error) + func (m *ImportEngineResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ImportEngineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ImportEngineResponse) Reset() + func (m *ImportEngineResponse) Size() (n int) + func (m *ImportEngineResponse) String() string + func (m *ImportEngineResponse) Unmarshal(dAtA []byte) error + func (m *ImportEngineResponse) XXX_DiscardUnknown() + func (m *ImportEngineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ImportEngineResponse) XXX_Merge(src proto.Message) + func (m *ImportEngineResponse) XXX_Size() int + func (m *ImportEngineResponse) XXX_Unmarshal(b []byte) error + type ImportKVClient interface + CleanupEngine func(ctx context.Context, in *CleanupEngineRequest, opts ...grpc.CallOption) (*CleanupEngineResponse, error) + CloseEngine func(ctx context.Context, in *CloseEngineRequest, opts ...grpc.CallOption) (*CloseEngineResponse, error) + CompactCluster func(ctx context.Context, in *CompactClusterRequest, opts ...grpc.CallOption) (*CompactClusterResponse, error) + GetMetrics func(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error) + GetVersion func(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*GetVersionResponse, error) + ImportEngine func(ctx context.Context, in *ImportEngineRequest, opts ...grpc.CallOption) (*ImportEngineResponse, error) + OpenEngine func(ctx context.Context, in *OpenEngineRequest, opts ...grpc.CallOption) (*OpenEngineResponse, error) + SwitchMode func(ctx context.Context, in *SwitchModeRequest, opts ...grpc.CallOption) (*SwitchModeResponse, error) + WriteEngine func(ctx context.Context, opts ...grpc.CallOption) (ImportKV_WriteEngineClient, error) + WriteEngineV3 func(ctx context.Context, in *WriteEngineV3Request, opts ...grpc.CallOption) (*WriteEngineResponse, error) + func NewImportKVClient(cc *grpc.ClientConn) ImportKVClient + type ImportKVServer interface + CleanupEngine func(context.Context, *CleanupEngineRequest) (*CleanupEngineResponse, error) + CloseEngine func(context.Context, *CloseEngineRequest) (*CloseEngineResponse, error) + CompactCluster func(context.Context, *CompactClusterRequest) (*CompactClusterResponse, error) + GetMetrics func(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error) + GetVersion func(context.Context, *GetVersionRequest) (*GetVersionResponse, error) + ImportEngine func(context.Context, *ImportEngineRequest) (*ImportEngineResponse, error) + OpenEngine func(context.Context, *OpenEngineRequest) (*OpenEngineResponse, error) + SwitchMode func(context.Context, *SwitchModeRequest) (*SwitchModeResponse, error) + WriteEngine func(ImportKV_WriteEngineServer) error + WriteEngineV3 func(context.Context, *WriteEngineV3Request) (*WriteEngineResponse, error) + type ImportKV_WriteEngineClient interface + CloseAndRecv func() (*WriteEngineResponse, error) + Send func(*WriteEngineRequest) error + type ImportKV_WriteEngineServer interface + Recv func() (*WriteEngineRequest, error) + SendAndClose func(*WriteEngineResponse) error + type KVPair struct + Key []byte + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*KVPair) Descriptor() ([]byte, []int) + func (*KVPair) ProtoMessage() + 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 Mutation struct + Key []byte + Op Mutation_OP + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Mutation) Descriptor() ([]byte, []int) + func (*Mutation) ProtoMessage() + func (m *Mutation) GetKey() []byte + func (m *Mutation) GetOp() Mutation_OP + func (m *Mutation) GetValue() []byte + func (m *Mutation) Marshal() (dAtA []byte, err error) + func (m *Mutation) MarshalTo(dAtA []byte) (int, error) + func (m *Mutation) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Mutation) Reset() + func (m *Mutation) Size() (n int) + func (m *Mutation) String() string + func (m *Mutation) Unmarshal(dAtA []byte) error + func (m *Mutation) XXX_DiscardUnknown() + func (m *Mutation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Mutation) XXX_Merge(src proto.Message) + func (m *Mutation) XXX_Size() int + func (m *Mutation) XXX_Unmarshal(b []byte) error + type Mutation_OP int32 + const Mutation_Put + func (Mutation_OP) EnumDescriptor() ([]byte, []int) + func (x Mutation_OP) String() string + type OpenEngineRequest struct + KeyPrefix []byte + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OpenEngineRequest) Descriptor() ([]byte, []int) + func (*OpenEngineRequest) ProtoMessage() + func (m *OpenEngineRequest) GetKeyPrefix() []byte + func (m *OpenEngineRequest) GetUuid() []byte + func (m *OpenEngineRequest) Marshal() (dAtA []byte, err error) + func (m *OpenEngineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *OpenEngineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OpenEngineRequest) Reset() + func (m *OpenEngineRequest) Size() (n int) + func (m *OpenEngineRequest) String() string + func (m *OpenEngineRequest) Unmarshal(dAtA []byte) error + func (m *OpenEngineRequest) XXX_DiscardUnknown() + func (m *OpenEngineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OpenEngineRequest) XXX_Merge(src proto.Message) + func (m *OpenEngineRequest) XXX_Size() int + func (m *OpenEngineRequest) XXX_Unmarshal(b []byte) error + type OpenEngineResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*OpenEngineResponse) Descriptor() ([]byte, []int) + func (*OpenEngineResponse) ProtoMessage() + func (m *OpenEngineResponse) Marshal() (dAtA []byte, err error) + func (m *OpenEngineResponse) MarshalTo(dAtA []byte) (int, error) + func (m *OpenEngineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *OpenEngineResponse) Reset() + func (m *OpenEngineResponse) Size() (n int) + func (m *OpenEngineResponse) String() string + func (m *OpenEngineResponse) Unmarshal(dAtA []byte) error + func (m *OpenEngineResponse) XXX_DiscardUnknown() + func (m *OpenEngineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *OpenEngineResponse) XXX_Merge(src proto.Message) + func (m *OpenEngineResponse) XXX_Size() int + func (m *OpenEngineResponse) XXX_Unmarshal(b []byte) error + type SwitchModeRequest struct + PdAddr string + Request *import_sstpb.SwitchModeRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SwitchModeRequest) Descriptor() ([]byte, []int) + func (*SwitchModeRequest) ProtoMessage() + func (m *SwitchModeRequest) GetPdAddr() string + func (m *SwitchModeRequest) GetRequest() *import_sstpb.SwitchModeRequest + 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 UnimplementedImportKVServer struct + func (*UnimplementedImportKVServer) CleanupEngine(ctx context.Context, req *CleanupEngineRequest) (*CleanupEngineResponse, error) + func (*UnimplementedImportKVServer) CloseEngine(ctx context.Context, req *CloseEngineRequest) (*CloseEngineResponse, error) + func (*UnimplementedImportKVServer) CompactCluster(ctx context.Context, req *CompactClusterRequest) (*CompactClusterResponse, error) + func (*UnimplementedImportKVServer) GetMetrics(ctx context.Context, req *GetMetricsRequest) (*GetMetricsResponse, error) + func (*UnimplementedImportKVServer) GetVersion(ctx context.Context, req *GetVersionRequest) (*GetVersionResponse, error) + func (*UnimplementedImportKVServer) ImportEngine(ctx context.Context, req *ImportEngineRequest) (*ImportEngineResponse, error) + func (*UnimplementedImportKVServer) OpenEngine(ctx context.Context, req *OpenEngineRequest) (*OpenEngineResponse, error) + func (*UnimplementedImportKVServer) SwitchMode(ctx context.Context, req *SwitchModeRequest) (*SwitchModeResponse, error) + func (*UnimplementedImportKVServer) WriteEngine(srv ImportKV_WriteEngineServer) error + func (*UnimplementedImportKVServer) WriteEngineV3(ctx context.Context, req *WriteEngineV3Request) (*WriteEngineResponse, error) + type WriteBatch struct + CommitTs uint64 + Mutations []*Mutation + 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) GetMutations() []*Mutation + 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 WriteEngineRequest struct + Chunk isWriteEngineRequest_Chunk + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteEngineRequest) Descriptor() ([]byte, []int) + func (*WriteEngineRequest) ProtoMessage() + func (*WriteEngineRequest) XXX_OneofWrappers() []interface{} + func (m *WriteEngineRequest) GetBatch() *WriteBatch + func (m *WriteEngineRequest) GetChunk() isWriteEngineRequest_Chunk + func (m *WriteEngineRequest) GetHead() *WriteHead + func (m *WriteEngineRequest) Marshal() (dAtA []byte, err error) + func (m *WriteEngineRequest) MarshalTo(dAtA []byte) (int, error) + func (m *WriteEngineRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteEngineRequest) Reset() + func (m *WriteEngineRequest) Size() (n int) + func (m *WriteEngineRequest) String() string + func (m *WriteEngineRequest) Unmarshal(dAtA []byte) error + func (m *WriteEngineRequest) XXX_DiscardUnknown() + func (m *WriteEngineRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteEngineRequest) XXX_Merge(src proto.Message) + func (m *WriteEngineRequest) XXX_Size() int + func (m *WriteEngineRequest) XXX_Unmarshal(b []byte) error + type WriteEngineRequest_Batch struct + Batch *WriteBatch + func (m *WriteEngineRequest_Batch) MarshalTo(dAtA []byte) (int, error) + func (m *WriteEngineRequest_Batch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteEngineRequest_Batch) Size() (n int) + type WriteEngineRequest_Head struct + Head *WriteHead + func (m *WriteEngineRequest_Head) MarshalTo(dAtA []byte) (int, error) + func (m *WriteEngineRequest_Head) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteEngineRequest_Head) Size() (n int) + type WriteEngineResponse struct + Error *Error + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteEngineResponse) Descriptor() ([]byte, []int) + func (*WriteEngineResponse) ProtoMessage() + func (m *WriteEngineResponse) GetError() *Error + func (m *WriteEngineResponse) Marshal() (dAtA []byte, err error) + func (m *WriteEngineResponse) MarshalTo(dAtA []byte) (int, error) + func (m *WriteEngineResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteEngineResponse) Reset() + func (m *WriteEngineResponse) Size() (n int) + func (m *WriteEngineResponse) String() string + func (m *WriteEngineResponse) Unmarshal(dAtA []byte) error + func (m *WriteEngineResponse) XXX_DiscardUnknown() + func (m *WriteEngineResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteEngineResponse) XXX_Merge(src proto.Message) + func (m *WriteEngineResponse) XXX_Size() int + func (m *WriteEngineResponse) XXX_Unmarshal(b []byte) error + type WriteEngineV3Request struct + CommitTs uint64 + Pairs []*KVPair + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteEngineV3Request) Descriptor() ([]byte, []int) + func (*WriteEngineV3Request) ProtoMessage() + func (m *WriteEngineV3Request) GetCommitTs() uint64 + func (m *WriteEngineV3Request) GetPairs() []*KVPair + func (m *WriteEngineV3Request) GetUuid() []byte + func (m *WriteEngineV3Request) Marshal() (dAtA []byte, err error) + func (m *WriteEngineV3Request) MarshalTo(dAtA []byte) (int, error) + func (m *WriteEngineV3Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteEngineV3Request) Reset() + func (m *WriteEngineV3Request) Size() (n int) + func (m *WriteEngineV3Request) String() string + func (m *WriteEngineV3Request) Unmarshal(dAtA []byte) error + func (m *WriteEngineV3Request) XXX_DiscardUnknown() + func (m *WriteEngineV3Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteEngineV3Request) XXX_Merge(src proto.Message) + func (m *WriteEngineV3Request) XXX_Size() int + func (m *WriteEngineV3Request) XXX_Unmarshal(b []byte) error + type WriteHead struct + Uuid []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WriteHead) Descriptor() ([]byte, []int) + func (*WriteHead) ProtoMessage() + func (m *WriteHead) GetUuid() []byte + func (m *WriteHead) Marshal() (dAtA []byte, err error) + func (m *WriteHead) MarshalTo(dAtA []byte) (int, error) + func (m *WriteHead) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *WriteHead) Reset() + func (m *WriteHead) Size() (n int) + func (m *WriteHead) String() string + func (m *WriteHead) Unmarshal(dAtA []byte) error + func (m *WriteHead) XXX_DiscardUnknown() + func (m *WriteHead) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WriteHead) XXX_Merge(src proto.Message) + func (m *WriteHead) XXX_Size() int + func (m *WriteHead) XXX_Unmarshal(b []byte) error