import_kvpb

package
v0.0.0-...-3b3056d Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthImportKvpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowImportKvpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupImportKvpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Mutation_OP_name = map[int32]string{
	0: "Put",
}
View Source 
var Mutation_OP_value = map[string]int32{
	"Put": 0,
}

Functions

func RegisterImportKVServer 

func RegisterImportKVServer(s *grpc.Server, srv ImportKVServer)

Types

type CleanupEngineRequest 

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

func (*CleanupEngineRequest) Descriptor 

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

func (*CleanupEngineRequest) GetUuid 

func (m *CleanupEngineRequest) GetUuid() []byte

func (*CleanupEngineRequest) Marshal 

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

func (*CleanupEngineRequest) MarshalTo 

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

func (*CleanupEngineRequest) MarshalToSizedBuffer 

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

func (*CleanupEngineRequest) ProtoMessage 

func (*CleanupEngineRequest) ProtoMessage()

func (*CleanupEngineRequest) Reset 

func (m *CleanupEngineRequest) Reset()

func (*CleanupEngineRequest) Size 

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

func (*CleanupEngineRequest) String 

func (m *CleanupEngineRequest) String() string

func (*CleanupEngineRequest) Unmarshal 

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

func (*CleanupEngineRequest) XXX_DiscardUnknown 

func (m *CleanupEngineRequest) XXX_DiscardUnknown()

func (*CleanupEngineRequest) XXX_Marshal 

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

func (*CleanupEngineRequest) XXX_Merge 

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

func (*CleanupEngineRequest) XXX_Size 

func (m *CleanupEngineRequest) XXX_Size() int

func (*CleanupEngineRequest) XXX_Unmarshal 

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

type CleanupEngineResponse 

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

func (*CleanupEngineResponse) Descriptor 

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

func (*CleanupEngineResponse) Marshal 

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

func (*CleanupEngineResponse) MarshalTo 

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

func (*CleanupEngineResponse) MarshalToSizedBuffer 

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

func (*CleanupEngineResponse) ProtoMessage 

func (*CleanupEngineResponse) ProtoMessage()

func (*CleanupEngineResponse) Reset 

func (m *CleanupEngineResponse) Reset()

func (*CleanupEngineResponse) Size 

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

func (*CleanupEngineResponse) String 

func (m *CleanupEngineResponse) String() string

func (*CleanupEngineResponse) Unmarshal 

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

func (*CleanupEngineResponse) XXX_DiscardUnknown 

func (m *CleanupEngineResponse) XXX_DiscardUnknown()

func (*CleanupEngineResponse) XXX_Marshal 

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

func (*CleanupEngineResponse) XXX_Merge 

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

func (*CleanupEngineResponse) XXX_Size 

func (m *CleanupEngineResponse) XXX_Size() int

func (*CleanupEngineResponse) XXX_Unmarshal 

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

type CloseEngineRequest 

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

func (*CloseEngineRequest) Descriptor 

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

func (*CloseEngineRequest) GetUuid 

func (m *CloseEngineRequest) GetUuid() []byte

func (*CloseEngineRequest) Marshal 

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

func (*CloseEngineRequest) MarshalTo 

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

func (*CloseEngineRequest) MarshalToSizedBuffer 

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

func (*CloseEngineRequest) ProtoMessage 

func (*CloseEngineRequest) ProtoMessage()

func (*CloseEngineRequest) Reset 

func (m *CloseEngineRequest) Reset()

func (*CloseEngineRequest) Size 

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

func (*CloseEngineRequest) String 

func (m *CloseEngineRequest) String() string

func (*CloseEngineRequest) Unmarshal 

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

func (*CloseEngineRequest) XXX_DiscardUnknown 

func (m *CloseEngineRequest) XXX_DiscardUnknown()

func (*CloseEngineRequest) XXX_Marshal 

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

func (*CloseEngineRequest) XXX_Merge 

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

func (*CloseEngineRequest) XXX_Size 

func (m *CloseEngineRequest) XXX_Size() int

func (*CloseEngineRequest) XXX_Unmarshal 

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

type CloseEngineResponse 

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

func (*CloseEngineResponse) Descriptor 

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

func (*CloseEngineResponse) GetError 

func (m *CloseEngineResponse) GetError() *Error

func (*CloseEngineResponse) Marshal 

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

func (*CloseEngineResponse) MarshalTo 

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

func (*CloseEngineResponse) MarshalToSizedBuffer 

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

func (*CloseEngineResponse) ProtoMessage 

func (*CloseEngineResponse) ProtoMessage()

func (*CloseEngineResponse) Reset 

func (m *CloseEngineResponse) Reset()

func (*CloseEngineResponse) Size 

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

func (*CloseEngineResponse) String 

func (m *CloseEngineResponse) String() string

func (*CloseEngineResponse) Unmarshal 

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

func (*CloseEngineResponse) XXX_DiscardUnknown 

func (m *CloseEngineResponse) XXX_DiscardUnknown()

func (*CloseEngineResponse) XXX_Marshal 

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

func (*CloseEngineResponse) XXX_Merge 

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

func (*CloseEngineResponse) XXX_Size 

func (m *CloseEngineResponse) XXX_Size() int

func (*CloseEngineResponse) XXX_Unmarshal 

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

type CompactClusterRequest 

type CompactClusterRequest struct {
	PdAddr               string                       `protobuf:"bytes,1,opt,name=pd_addr,json=pdAddr,proto3" json:"pd_addr,omitempty"`
	Request              *import_sstpb.CompactRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*CompactClusterRequest) Descriptor 

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

func (*CompactClusterRequest) GetPdAddr 

func (m *CompactClusterRequest) GetPdAddr() string

func (*CompactClusterRequest) GetRequest 

func (m *CompactClusterRequest) GetRequest() *import_sstpb.CompactRequest

func (*CompactClusterRequest) Marshal 

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

func (*CompactClusterRequest) MarshalTo 

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

func (*CompactClusterRequest) MarshalToSizedBuffer 

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

func (*CompactClusterRequest) ProtoMessage 

func (*CompactClusterRequest) ProtoMessage()

func (*CompactClusterRequest) Reset 

func (m *CompactClusterRequest) Reset()

func (*CompactClusterRequest) Size 

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

func (*CompactClusterRequest) String 

func (m *CompactClusterRequest) String() string

func (*CompactClusterRequest) Unmarshal 

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

func (*CompactClusterRequest) XXX_DiscardUnknown 

func (m *CompactClusterRequest) XXX_DiscardUnknown()

func (*CompactClusterRequest) XXX_Marshal 

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

func (*CompactClusterRequest) XXX_Merge 

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

func (*CompactClusterRequest) XXX_Size 

func (m *CompactClusterRequest) XXX_Size() int

func (*CompactClusterRequest) XXX_Unmarshal 

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

type CompactClusterResponse 

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

func (*CompactClusterResponse) Descriptor 

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

func (*CompactClusterResponse) Marshal 

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

func (*CompactClusterResponse) MarshalTo 

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

func (*CompactClusterResponse) MarshalToSizedBuffer 

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

func (*CompactClusterResponse) ProtoMessage 

func (*CompactClusterResponse) ProtoMessage()

func (*CompactClusterResponse) Reset 

func (m *CompactClusterResponse) Reset()

func (*CompactClusterResponse) Size 

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

func (*CompactClusterResponse) String 

func (m *CompactClusterResponse) String() string

func (*CompactClusterResponse) Unmarshal 

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

func (*CompactClusterResponse) XXX_DiscardUnknown 

func (m *CompactClusterResponse) XXX_DiscardUnknown()

func (*CompactClusterResponse) XXX_Marshal 

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

func (*CompactClusterResponse) XXX_Merge 

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

func (*CompactClusterResponse) XXX_Size 

func (m *CompactClusterResponse) XXX_Size() int

func (*CompactClusterResponse) XXX_Unmarshal 

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

type Error 

type Error struct {
	// This can happen if the client hasn't opened the engine, or the server
	// restarts while the client is writing or closing. An unclosed engine will
	// be removed on server restart, so the client should not continue but
	// restart the previous job in that case.
	EngineNotFound       *Error_EngineNotFound `protobuf:"bytes,1,opt,name=engine_not_found,json=engineNotFound,proto3" json:"engine_not_found,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetEngineNotFound 

func (m *Error) GetEngineNotFound() *Error_EngineNotFound

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) MarshalToSizedBuffer 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

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

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type Error_EngineNotFound 

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

func (*Error_EngineNotFound) Descriptor 

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

func (*Error_EngineNotFound) GetUuid 

func (m *Error_EngineNotFound) GetUuid() []byte

func (*Error_EngineNotFound) Marshal 

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

func (*Error_EngineNotFound) MarshalTo 

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

func (*Error_EngineNotFound) MarshalToSizedBuffer 

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

func (*Error_EngineNotFound) ProtoMessage 

func (*Error_EngineNotFound) ProtoMessage()

func (*Error_EngineNotFound) Reset 

func (m *Error_EngineNotFound) Reset()

func (*Error_EngineNotFound) Size 

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

func (*Error_EngineNotFound) String 

func (m *Error_EngineNotFound) String() string

func (*Error_EngineNotFound) Unmarshal 

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

func (*Error_EngineNotFound) XXX_DiscardUnknown 

func (m *Error_EngineNotFound) XXX_DiscardUnknown()

func (*Error_EngineNotFound) XXX_Marshal 

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

func (*Error_EngineNotFound) XXX_Merge 

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

func (*Error_EngineNotFound) XXX_Size 

func (m *Error_EngineNotFound) XXX_Size() int

func (*Error_EngineNotFound) XXX_Unmarshal 

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

type GetMetricsRequest 

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

func (*GetMetricsRequest) Descriptor 

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

func (*GetMetricsRequest) Marshal 

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

func (*GetMetricsRequest) MarshalTo 

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

func (*GetMetricsRequest) MarshalToSizedBuffer 

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

func (*GetMetricsRequest) ProtoMessage 

func (*GetMetricsRequest) ProtoMessage()

func (*GetMetricsRequest) Reset 

func (m *GetMetricsRequest) Reset()

func (*GetMetricsRequest) Size 

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

func (*GetMetricsRequest) String 

func (m *GetMetricsRequest) String() string

func (*GetMetricsRequest) Unmarshal 

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

func (*GetMetricsRequest) XXX_DiscardUnknown 

func (m *GetMetricsRequest) XXX_DiscardUnknown()

func (*GetMetricsRequest) XXX_Marshal 

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

func (*GetMetricsRequest) XXX_Merge 

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

func (*GetMetricsRequest) XXX_Size 

func (m *GetMetricsRequest) XXX_Size() int

func (*GetMetricsRequest) XXX_Unmarshal 

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

type GetMetricsResponse 

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

func (*GetMetricsResponse) Descriptor 

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

func (*GetMetricsResponse) GetPrometheus 

func (m *GetMetricsResponse) GetPrometheus() string

func (*GetMetricsResponse) Marshal 

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

func (*GetMetricsResponse) MarshalTo 

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

func (*GetMetricsResponse) MarshalToSizedBuffer 

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

func (*GetMetricsResponse) ProtoMessage 

func (*GetMetricsResponse) ProtoMessage()

func (*GetMetricsResponse) Reset 

func (m *GetMetricsResponse) Reset()

func (*GetMetricsResponse) Size 

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

func (*GetMetricsResponse) String 

func (m *GetMetricsResponse) String() string

func (*GetMetricsResponse) Unmarshal 

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

func (*GetMetricsResponse) XXX_DiscardUnknown 

func (m *GetMetricsResponse) XXX_DiscardUnknown()

func (*GetMetricsResponse) XXX_Marshal 

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

func (*GetMetricsResponse) XXX_Merge 

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

func (*GetMetricsResponse) XXX_Size 

func (m *GetMetricsResponse) XXX_Size() int

func (*GetMetricsResponse) XXX_Unmarshal 

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

type GetVersionRequest 

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

func (*GetVersionRequest) Descriptor 

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

func (*GetVersionRequest) Marshal 

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

func (*GetVersionRequest) MarshalTo 

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

func (*GetVersionRequest) MarshalToSizedBuffer 

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

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) Reset 

func (m *GetVersionRequest) Reset()

func (*GetVersionRequest) Size 

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

func (*GetVersionRequest) String 

func (m *GetVersionRequest) String() string

func (*GetVersionRequest) Unmarshal 

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

func (*GetVersionRequest) XXX_DiscardUnknown 

func (m *GetVersionRequest) XXX_DiscardUnknown()

func (*GetVersionRequest) XXX_Marshal 

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

func (*GetVersionRequest) XXX_Merge 

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

func (*GetVersionRequest) XXX_Size 

func (m *GetVersionRequest) XXX_Size() int

func (*GetVersionRequest) XXX_Unmarshal 

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

type GetVersionResponse 

type GetVersionResponse struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Commit               string   `protobuf:"bytes,2,opt,name=commit,proto3" json:"commit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVersionResponse) Descriptor 

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

func (*GetVersionResponse) GetCommit 

func (m *GetVersionResponse) GetCommit() string

func (*GetVersionResponse) GetVersion 

func (m *GetVersionResponse) GetVersion() string

func (*GetVersionResponse) Marshal 

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

func (*GetVersionResponse) MarshalTo 

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

func (*GetVersionResponse) MarshalToSizedBuffer 

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

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) Reset 

func (m *GetVersionResponse) Reset()

func (*GetVersionResponse) Size 

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

func (*GetVersionResponse) String 

func (m *GetVersionResponse) String() string

func (*GetVersionResponse) Unmarshal 

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

func (*GetVersionResponse) XXX_DiscardUnknown 

func (m *GetVersionResponse) XXX_DiscardUnknown()

func (*GetVersionResponse) XXX_Marshal 

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

func (*GetVersionResponse) XXX_Merge 

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

func (*GetVersionResponse) XXX_Size 

func (m *GetVersionResponse) XXX_Size() int

func (*GetVersionResponse) XXX_Unmarshal 

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

type ImportEngineRequest 

type ImportEngineRequest struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	PdAddr               string   `protobuf:"bytes,2,opt,name=pd_addr,json=pdAddr,proto3" json:"pd_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImportEngineRequest) Descriptor 

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

func (*ImportEngineRequest) GetPdAddr 

func (m *ImportEngineRequest) GetPdAddr() string

func (*ImportEngineRequest) GetUuid 

func (m *ImportEngineRequest) GetUuid() []byte

func (*ImportEngineRequest) Marshal 

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

func (*ImportEngineRequest) MarshalTo 

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

func (*ImportEngineRequest) MarshalToSizedBuffer 

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

func (*ImportEngineRequest) ProtoMessage 

func (*ImportEngineRequest) ProtoMessage()

func (*ImportEngineRequest) Reset 

func (m *ImportEngineRequest) Reset()

func (*ImportEngineRequest) Size 

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

func (*ImportEngineRequest) String 

func (m *ImportEngineRequest) String() string

func (*ImportEngineRequest) Unmarshal 

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

func (*ImportEngineRequest) XXX_DiscardUnknown 

func (m *ImportEngineRequest) XXX_DiscardUnknown()

func (*ImportEngineRequest) XXX_Marshal 

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

func (*ImportEngineRequest) XXX_Merge 

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

func (*ImportEngineRequest) XXX_Size 

func (m *ImportEngineRequest) XXX_Size() int

func (*ImportEngineRequest) XXX_Unmarshal 

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

type ImportEngineResponse 

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

func (*ImportEngineResponse) Descriptor 

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

func (*ImportEngineResponse) Marshal 

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

func (*ImportEngineResponse) MarshalTo 

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

func (*ImportEngineResponse) MarshalToSizedBuffer 

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

func (*ImportEngineResponse) ProtoMessage 

func (*ImportEngineResponse) ProtoMessage()

func (*ImportEngineResponse) Reset 

func (m *ImportEngineResponse) Reset()

func (*ImportEngineResponse) Size 

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

func (*ImportEngineResponse) String 

func (m *ImportEngineResponse) String() string

func (*ImportEngineResponse) Unmarshal 

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

func (*ImportEngineResponse) XXX_DiscardUnknown 

func (m *ImportEngineResponse) XXX_DiscardUnknown()

func (*ImportEngineResponse) XXX_Marshal 

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

func (*ImportEngineResponse) XXX_Merge 

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

func (*ImportEngineResponse) XXX_Size 

func (m *ImportEngineResponse) XXX_Size() int

func (*ImportEngineResponse) XXX_Unmarshal 

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

type ImportKVClient 

type ImportKVClient interface {
	// Switch the target cluster to normal/import mode.
	SwitchMode(ctx context.Context, in *SwitchModeRequest, opts ...grpc.CallOption) (*SwitchModeResponse, error)
	// Open an engine.
	OpenEngine(ctx context.Context, in *OpenEngineRequest, opts ...grpc.CallOption) (*OpenEngineResponse, error)
	// Open a write stream to the engine.
	WriteEngine(ctx context.Context, opts ...grpc.CallOption) (ImportKV_WriteEngineClient, error)
	// Write to engine, single message version
	WriteEngineV3(ctx context.Context, in *WriteEngineV3Request, opts ...grpc.CallOption) (*WriteEngineResponse, error)
	// Close the engine.
	CloseEngine(ctx context.Context, in *CloseEngineRequest, opts ...grpc.CallOption) (*CloseEngineResponse, error)
	// Import the engine to the target cluster.
	ImportEngine(ctx context.Context, in *ImportEngineRequest, opts ...grpc.CallOption) (*ImportEngineResponse, error)
	// Clean up the engine.
	CleanupEngine(ctx context.Context, in *CleanupEngineRequest, opts ...grpc.CallOption) (*CleanupEngineResponse, error)
	// Compact the target cluster for better performance.
	CompactCluster(ctx context.Context, in *CompactClusterRequest, opts ...grpc.CallOption) (*CompactClusterResponse, error)
	// Get current version and commit hash
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*GetVersionResponse, error)
	// Get importer metrics
	GetMetrics(ctx context.Context, in *GetMetricsRequest, opts ...grpc.CallOption) (*GetMetricsResponse, error)
}

ImportKVClient is the client API for ImportKV service.

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

func NewImportKVClient 

func NewImportKVClient(cc *grpc.ClientConn) ImportKVClient

type ImportKVServer 

type ImportKVServer interface {
	// Switch the target cluster to normal/import mode.
	SwitchMode(context.Context, *SwitchModeRequest) (*SwitchModeResponse, error)
	// Open an engine.
	OpenEngine(context.Context, *OpenEngineRequest) (*OpenEngineResponse, error)
	// Open a write stream to the engine.
	WriteEngine(ImportKV_WriteEngineServer) error
	// Write to engine, single message version
	WriteEngineV3(context.Context, *WriteEngineV3Request) (*WriteEngineResponse, error)
	// Close the engine.
	CloseEngine(context.Context, *CloseEngineRequest) (*CloseEngineResponse, error)
	// Import the engine to the target cluster.
	ImportEngine(context.Context, *ImportEngineRequest) (*ImportEngineResponse, error)
	// Clean up the engine.
	CleanupEngine(context.Context, *CleanupEngineRequest) (*CleanupEngineResponse, error)
	// Compact the target cluster for better performance.
	CompactCluster(context.Context, *CompactClusterRequest) (*CompactClusterResponse, error)
	// Get current version and commit hash
	GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
	// Get importer metrics
	GetMetrics(context.Context, *GetMetricsRequest) (*GetMetricsResponse, error)
}

ImportKVServer is the server API for ImportKV service.

type ImportKV_WriteEngineClient 

type ImportKV_WriteEngineClient interface {
	Send(*WriteEngineRequest) error
	CloseAndRecv() (*WriteEngineResponse, error)
	grpc.ClientStream
}

type ImportKV_WriteEngineServer 

type ImportKV_WriteEngineServer interface {
	SendAndClose(*WriteEngineResponse) error
	Recv() (*WriteEngineRequest, error)
	grpc.ServerStream
}

type KVPair 

type KVPair 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KVPair) Descriptor 

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

func (*KVPair) GetKey 

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

func (*KVPair) GetValue 

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

func (*KVPair) Marshal 

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

func (*KVPair) MarshalTo 

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

func (*KVPair) MarshalToSizedBuffer 

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

func (*KVPair) ProtoMessage 

func (*KVPair) ProtoMessage()

func (*KVPair) Reset 

func (m *KVPair) Reset()

func (*KVPair) Size 

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

func (*KVPair) String 

func (m *KVPair) String() string

func (*KVPair) Unmarshal 

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

func (*KVPair) XXX_DiscardUnknown 

func (m *KVPair) XXX_DiscardUnknown()

func (*KVPair) XXX_Marshal 

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

func (*KVPair) XXX_Merge 

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

func (*KVPair) XXX_Size 

func (m *KVPair) XXX_Size() int

func (*KVPair) XXX_Unmarshal 

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

type Mutation 

type Mutation struct {
	Op                   Mutation_OP `protobuf:"varint,1,opt,name=op,proto3,enum=import_kvpb.Mutation_OP" json:"op,omitempty"`
	Key                  []byte      `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value                []byte      `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Mutation) Descriptor 

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

func (*Mutation) GetKey 

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

func (*Mutation) GetOp 

func (m *Mutation) GetOp() Mutation_OP

func (*Mutation) GetValue 

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

func (*Mutation) Marshal 

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

func (*Mutation) MarshalTo 

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

func (*Mutation) MarshalToSizedBuffer 

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

func (*Mutation) ProtoMessage 

func (*Mutation) ProtoMessage()

func (*Mutation) Reset 

func (m *Mutation) Reset()

func (*Mutation) Size 

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

func (*Mutation) String 

func (m *Mutation) String() string

func (*Mutation) Unmarshal 

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

func (*Mutation) XXX_DiscardUnknown 

func (m *Mutation) XXX_DiscardUnknown()

func (*Mutation) XXX_Marshal 

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

func (*Mutation) XXX_Merge 

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

func (*Mutation) XXX_Size 

func (m *Mutation) XXX_Size() int

func (*Mutation) XXX_Unmarshal 

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

type Mutation_OP 

type Mutation_OP int32
const (
	Mutation_Put Mutation_OP = 0
)

func (Mutation_OP) EnumDescriptor 

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

func (Mutation_OP) String 

func (x Mutation_OP) String() string

type OpenEngineRequest 

type OpenEngineRequest struct {
	Uuid                 []byte   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	KeyPrefix            []byte   `protobuf:"bytes,2,opt,name=key_prefix,json=keyPrefix,proto3" json:"key_prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpenEngineRequest) Descriptor 

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

func (*OpenEngineRequest) GetKeyPrefix 

func (m *OpenEngineRequest) GetKeyPrefix() []byte

func (*OpenEngineRequest) GetUuid 

func (m *OpenEngineRequest) GetUuid() []byte

func (*OpenEngineRequest) Marshal 

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

func (*OpenEngineRequest) MarshalTo 

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

func (*OpenEngineRequest) MarshalToSizedBuffer 

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

func (*OpenEngineRequest) ProtoMessage 

func (*OpenEngineRequest) ProtoMessage()

func (*OpenEngineRequest) Reset 

func (m *OpenEngineRequest) Reset()

func (*OpenEngineRequest) Size 

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

func (*OpenEngineRequest) String 

func (m *OpenEngineRequest) String() string

func (*OpenEngineRequest) Unmarshal 

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

func (*OpenEngineRequest) XXX_DiscardUnknown 

func (m *OpenEngineRequest) XXX_DiscardUnknown()

func (*OpenEngineRequest) XXX_Marshal 

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

func (*OpenEngineRequest) XXX_Merge 

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

func (*OpenEngineRequest) XXX_Size 

func (m *OpenEngineRequest) XXX_Size() int

func (*OpenEngineRequest) XXX_Unmarshal 

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

type OpenEngineResponse 

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

func (*OpenEngineResponse) Descriptor 

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

func (*OpenEngineResponse) Marshal 

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

func (*OpenEngineResponse) MarshalTo 

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

func (*OpenEngineResponse) MarshalToSizedBuffer 

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

func (*OpenEngineResponse) ProtoMessage 

func (*OpenEngineResponse) ProtoMessage()

func (*OpenEngineResponse) Reset 

func (m *OpenEngineResponse) Reset()

func (*OpenEngineResponse) Size 

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

func (*OpenEngineResponse) String 

func (m *OpenEngineResponse) String() string

func (*OpenEngineResponse) Unmarshal 

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

func (*OpenEngineResponse) XXX_DiscardUnknown 

func (m *OpenEngineResponse) XXX_DiscardUnknown()

func (*OpenEngineResponse) XXX_Marshal 

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

func (*OpenEngineResponse) XXX_Merge 

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

func (*OpenEngineResponse) XXX_Size 

func (m *OpenEngineResponse) XXX_Size() int

func (*OpenEngineResponse) XXX_Unmarshal 

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

type SwitchModeRequest 

type SwitchModeRequest struct {
	PdAddr               string                          `protobuf:"bytes,1,opt,name=pd_addr,json=pdAddr,proto3" json:"pd_addr,omitempty"`
	Request              *import_sstpb.SwitchModeRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*SwitchModeRequest) Descriptor 

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

func (*SwitchModeRequest) GetPdAddr 

func (m *SwitchModeRequest) GetPdAddr() string

func (*SwitchModeRequest) GetRequest 

func (m *SwitchModeRequest) GetRequest() *import_sstpb.SwitchModeRequest

func (*SwitchModeRequest) Marshal 

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

func (*SwitchModeRequest) MarshalTo 

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

func (*SwitchModeRequest) MarshalToSizedBuffer 

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

func (*SwitchModeRequest) ProtoMessage 

func (*SwitchModeRequest) ProtoMessage()

func (*SwitchModeRequest) Reset 

func (m *SwitchModeRequest) Reset()

func (*SwitchModeRequest) Size 

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

func (*SwitchModeRequest) String 

func (m *SwitchModeRequest) String() string

func (*SwitchModeRequest) Unmarshal 

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

func (*SwitchModeRequest) XXX_DiscardUnknown 

func (m *SwitchModeRequest) XXX_DiscardUnknown()

func (*SwitchModeRequest) XXX_Marshal 

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

func (*SwitchModeRequest) XXX_Merge 

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

func (*SwitchModeRequest) XXX_Size 

func (m *SwitchModeRequest) XXX_Size() int

func (*SwitchModeRequest) XXX_Unmarshal 

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

type SwitchModeResponse 

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

func (*SwitchModeResponse) Descriptor 

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

func (*SwitchModeResponse) Marshal 

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

func (*SwitchModeResponse) MarshalTo 

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

func (*SwitchModeResponse) MarshalToSizedBuffer 

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

func (*SwitchModeResponse) ProtoMessage 

func (*SwitchModeResponse) ProtoMessage()

func (*SwitchModeResponse) Reset 

func (m *SwitchModeResponse) Reset()

func (*SwitchModeResponse) Size 

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

func (*SwitchModeResponse) String 

func (m *SwitchModeResponse) String() string

func (*SwitchModeResponse) Unmarshal 

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

func (*SwitchModeResponse) XXX_DiscardUnknown 

func (m *SwitchModeResponse) XXX_DiscardUnknown()

func (*SwitchModeResponse) XXX_Marshal 

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

func (*SwitchModeResponse) XXX_Merge 

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

func (*SwitchModeResponse) XXX_Size 

func (m *SwitchModeResponse) XXX_Size() int

func (*SwitchModeResponse) XXX_Unmarshal 

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

type UnimplementedImportKVServer 

type UnimplementedImportKVServer struct {
}

UnimplementedImportKVServer can be embedded to have forward compatible implementations.

func (*UnimplementedImportKVServer) CleanupEngine 

func (*UnimplementedImportKVServer) CleanupEngine(ctx context.Context, req *CleanupEngineRequest) (*CleanupEngineResponse, error)

func (*UnimplementedImportKVServer) CloseEngine 

func (*UnimplementedImportKVServer) CloseEngine(ctx context.Context, req *CloseEngineRequest) (*CloseEngineResponse, error)

func (*UnimplementedImportKVServer) CompactCluster 

func (*UnimplementedImportKVServer) CompactCluster(ctx context.Context, req *CompactClusterRequest) (*CompactClusterResponse, error)

func (*UnimplementedImportKVServer) GetMetrics 

func (*UnimplementedImportKVServer) GetMetrics(ctx context.Context, req *GetMetricsRequest) (*GetMetricsResponse, error)

func (*UnimplementedImportKVServer) GetVersion 

func (*UnimplementedImportKVServer) GetVersion(ctx context.Context, req *GetVersionRequest) (*GetVersionResponse, error)

func (*UnimplementedImportKVServer) ImportEngine 

func (*UnimplementedImportKVServer) ImportEngine(ctx context.Context, req *ImportEngineRequest) (*ImportEngineResponse, error)

func (*UnimplementedImportKVServer) OpenEngine 

func (*UnimplementedImportKVServer) OpenEngine(ctx context.Context, req *OpenEngineRequest) (*OpenEngineResponse, error)

func (*UnimplementedImportKVServer) SwitchMode 

func (*UnimplementedImportKVServer) SwitchMode(ctx context.Context, req *SwitchModeRequest) (*SwitchModeResponse, error)

func (*UnimplementedImportKVServer) WriteEngine 

func (*UnimplementedImportKVServer) WriteEngine(srv ImportKV_WriteEngineServer) error

func (*UnimplementedImportKVServer) WriteEngineV3 

func (*UnimplementedImportKVServer) WriteEngineV3(ctx context.Context, req *WriteEngineV3Request) (*WriteEngineResponse, error)

type WriteBatch 

type WriteBatch struct {
	CommitTs             uint64      `protobuf:"varint,1,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	Mutations            []*Mutation `protobuf:"bytes,2,rep,name=mutations,proto3" json:"mutations,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*WriteBatch) Descriptor 

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

func (*WriteBatch) GetCommitTs 

func (m *WriteBatch) GetCommitTs() uint64

func (*WriteBatch) GetMutations 

func (m *WriteBatch) GetMutations() []*Mutation

func (*WriteBatch) Marshal 

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

func (*WriteBatch) MarshalTo 

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

func (*WriteBatch) MarshalToSizedBuffer 

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

func (*WriteBatch) ProtoMessage 

func (*WriteBatch) ProtoMessage()

func (*WriteBatch) Reset 

func (m *WriteBatch) Reset()

func (*WriteBatch) Size 

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

func (*WriteBatch) String 

func (m *WriteBatch) String() string

func (*WriteBatch) Unmarshal 

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

func (*WriteBatch) XXX_DiscardUnknown 

func (m *WriteBatch) XXX_DiscardUnknown()

func (*WriteBatch) XXX_Marshal 

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

func (*WriteBatch) XXX_Merge 

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

func (*WriteBatch) XXX_Size 

func (m *WriteBatch) XXX_Size() int

func (*WriteBatch) XXX_Unmarshal 

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

type WriteEngineRequest 

type WriteEngineRequest struct {
	// Types that are valid to be assigned to Chunk:
	//	*WriteEngineRequest_Head
	//	*WriteEngineRequest_Batch
	Chunk                isWriteEngineRequest_Chunk `protobuf_oneof:"chunk"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*WriteEngineRequest) Descriptor 

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

func (*WriteEngineRequest) GetBatch 

func (m *WriteEngineRequest) GetBatch() *WriteBatch

func (*WriteEngineRequest) GetChunk 

func (m *WriteEngineRequest) GetChunk() isWriteEngineRequest_Chunk

func (*WriteEngineRequest) GetHead 

func (m *WriteEngineRequest) GetHead() *WriteHead

func (*WriteEngineRequest) Marshal 

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

func (*WriteEngineRequest) MarshalTo 

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

func (*WriteEngineRequest) MarshalToSizedBuffer 

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

func (*WriteEngineRequest) ProtoMessage 

func (*WriteEngineRequest) ProtoMessage()

func (*WriteEngineRequest) Reset 

func (m *WriteEngineRequest) Reset()

func (*WriteEngineRequest) Size 

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

func (*WriteEngineRequest) String 

func (m *WriteEngineRequest) String() string

func (*WriteEngineRequest) Unmarshal 

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

func (*WriteEngineRequest) XXX_DiscardUnknown 

func (m *WriteEngineRequest) XXX_DiscardUnknown()

func (*WriteEngineRequest) XXX_Marshal 

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

func (*WriteEngineRequest) XXX_Merge 

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

func (*WriteEngineRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*WriteEngineRequest) XXX_Size 

func (m *WriteEngineRequest) XXX_Size() int

func (*WriteEngineRequest) XXX_Unmarshal 

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

type WriteEngineRequest_Batch 

type WriteEngineRequest_Batch struct {
	Batch *WriteBatch `protobuf:"bytes,2,opt,name=batch,proto3,oneof" json:"batch,omitempty"`
}

func (*WriteEngineRequest_Batch) MarshalTo 

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

func (*WriteEngineRequest_Batch) MarshalToSizedBuffer 

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

func (*WriteEngineRequest_Batch) Size 

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

type WriteEngineRequest_Head 

type WriteEngineRequest_Head struct {
	Head *WriteHead `protobuf:"bytes,1,opt,name=head,proto3,oneof" json:"head,omitempty"`
}

func (*WriteEngineRequest_Head) MarshalTo 

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

func (*WriteEngineRequest_Head) MarshalToSizedBuffer 

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

func (*WriteEngineRequest_Head) Size 

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

type WriteEngineResponse 

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

func (*WriteEngineResponse) Descriptor 

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

func (*WriteEngineResponse) GetError 

func (m *WriteEngineResponse) GetError() *Error

func (*WriteEngineResponse) Marshal 

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

func (*WriteEngineResponse) MarshalTo 

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

func (*WriteEngineResponse) MarshalToSizedBuffer 

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

func (*WriteEngineResponse) ProtoMessage 

func (*WriteEngineResponse) ProtoMessage()

func (*WriteEngineResponse) Reset 

func (m *WriteEngineResponse) Reset()

func (*WriteEngineResponse) Size 

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

func (*WriteEngineResponse) String 

func (m *WriteEngineResponse) String() string

func (*WriteEngineResponse) Unmarshal 

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

func (*WriteEngineResponse) XXX_DiscardUnknown 

func (m *WriteEngineResponse) XXX_DiscardUnknown()

func (*WriteEngineResponse) XXX_Marshal 

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

func (*WriteEngineResponse) XXX_Merge 

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

func (*WriteEngineResponse) XXX_Size 

func (m *WriteEngineResponse) XXX_Size() int

func (*WriteEngineResponse) XXX_Unmarshal 

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

type WriteEngineV3Request 

type WriteEngineV3Request struct {
	Uuid                 []byte    `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	CommitTs             uint64    `protobuf:"varint,2,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	Pairs                []*KVPair `protobuf:"bytes,3,rep,name=pairs,proto3" json:"pairs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*WriteEngineV3Request) Descriptor 

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

func (*WriteEngineV3Request) GetCommitTs 

func (m *WriteEngineV3Request) GetCommitTs() uint64

func (*WriteEngineV3Request) GetPairs 

func (m *WriteEngineV3Request) GetPairs() []*KVPair

func (*WriteEngineV3Request) GetUuid 

func (m *WriteEngineV3Request) GetUuid() []byte

func (*WriteEngineV3Request) Marshal 

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

func (*WriteEngineV3Request) MarshalTo 

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

func (*WriteEngineV3Request) MarshalToSizedBuffer 

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

func (*WriteEngineV3Request) ProtoMessage 

func (*WriteEngineV3Request) ProtoMessage()

func (*WriteEngineV3Request) Reset 

func (m *WriteEngineV3Request) Reset()

func (*WriteEngineV3Request) Size 

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

func (*WriteEngineV3Request) String 

func (m *WriteEngineV3Request) String() string

func (*WriteEngineV3Request) Unmarshal 

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

func (*WriteEngineV3Request) XXX_DiscardUnknown 

func (m *WriteEngineV3Request) XXX_DiscardUnknown()

func (*WriteEngineV3Request) XXX_Marshal 

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

func (*WriteEngineV3Request) XXX_Merge 

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

func (*WriteEngineV3Request) XXX_Size 

func (m *WriteEngineV3Request) XXX_Size() int

func (*WriteEngineV3Request) XXX_Unmarshal 

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

type WriteHead 

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

func (*WriteHead) Descriptor 

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

func (*WriteHead) GetUuid 

func (m *WriteHead) GetUuid() []byte

func (*WriteHead) Marshal 

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

func (*WriteHead) MarshalTo 

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

func (*WriteHead) MarshalToSizedBuffer 

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

func (*WriteHead) ProtoMessage 

func (*WriteHead) ProtoMessage()

func (*WriteHead) Reset 

func (m *WriteHead) Reset()

func (*WriteHead) Size 

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

func (*WriteHead) String 

func (m *WriteHead) String() string

func (*WriteHead) Unmarshal 

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

func (*WriteHead) XXX_DiscardUnknown 

func (m *WriteHead) XXX_DiscardUnknown()

func (*WriteHead) XXX_Marshal 

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

func (*WriteHead) XXX_Merge 

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

func (*WriteHead) XXX_Size 

func (m *WriteHead) XXX_Size() int

func (*WriteHead) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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