import_kvpb

package
v0.0.0-...-84f9208 Latest Latest
Warning

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

Go to latest
Published: Oct 26, 2019 License: Apache-2.0 Imports: 8 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")
)
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) 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 (dst *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) 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 (dst *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) 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 (dst *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" 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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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 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) 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 (dst *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) 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 (dst *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)
	// 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)
}

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
	// 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)
}

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 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) 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 (dst *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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OpenEngineRequest) Descriptor

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

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) 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 (dst *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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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 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" 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) 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 (dst *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) 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 (dst *WriteEngineRequest) XXX_Merge(src proto.Message)

func (*WriteEngineRequest) XXX_OneofFuncs

func (*WriteEngineRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs 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,oneof"`
}

func (*WriteEngineRequest_Batch) MarshalTo

func (m *WriteEngineRequest_Batch) MarshalTo(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,oneof"`
}

func (*WriteEngineRequest_Head) MarshalTo

func (m *WriteEngineRequest_Head) MarshalTo(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" 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) 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 (dst *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 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) 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 (dst *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