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

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.