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 (*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 (*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) CloseEngine

func (*UnimplementedImportKVServer) CompactCluster

func (*UnimplementedImportKVServer) GetMetrics

func (*UnimplementedImportKVServer) GetVersion

func (*UnimplementedImportKVServer) ImportEngine

func (*UnimplementedImportKVServer) OpenEngine

func (*UnimplementedImportKVServer) SwitchMode

func (*UnimplementedImportKVServer) WriteEngine

func (*UnimplementedImportKVServer) WriteEngineV3

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL