import_sstpb

package
v0.0.0-...-f3c1264 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 2024 License: Apache-2.0 Imports: 14 Imported by: 132

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthImportSstpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowImportSstpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupImportSstpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DownloadRequestType_name = map[int32]string{
	0: "Legacy",
	1: "Keyspace",
}
View Source 
var DownloadRequestType_value = map[string]int32{
	"Legacy":   0,
	"Keyspace": 1,
}
View Source 
var Pair_OP_name = map[int32]string{
	0: "Put",
	1: "Delete",
}
View Source 
var Pair_OP_value = map[string]int32{
	"Put":    0,
	"Delete": 1,
}
View Source 
var SwitchMode_name = map[int32]string{
	0: "Normal",
	1: "Import",
}
View Source 
var SwitchMode_value = map[string]int32{
	"Normal": 0,
	"Import": 1,
}

Functions

func RegisterImportSSTServer 

func RegisterImportSSTServer(s *grpc.Server, srv ImportSSTServer)

Types

type ApplyRequest 

type ApplyRequest struct {
	// The meta of the KV file.
	Meta  *KVMeta   `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	Metas []*KVMeta `protobuf:"bytes,12,rep,name=metas,proto3" json:"metas,omitempty"`
	// Performs a key prefix rewrite after downloading the file.
	// All keys in the files will be rewritten as:
	//
	//  new_key = new_key_prefix + old_key[len(old_key_prefix)..]
	//
	// When used for TiDB, rewriting the prefix changes the table ID. Please
	// note that key-rewrite is applied on the origin keys in encoded
	// representation.
	//
	// You need to ensure that the keys before and after rewriting are in the
	// same order, otherwise the RPC request will fail.
	RewriteRule  RewriteRule    `protobuf:"bytes,2,opt,name=rewrite_rule,json=rewriteRule,proto3" json:"rewrite_rule"`
	RewriteRules []*RewriteRule `protobuf:"bytes,13,rep,name=rewrite_rules,json=rewriteRules,proto3" json:"rewrite_rules,omitempty"`
	// The identity for the stroage backend.
	// When this field presents, the storage would be cached.
	// If there is a cached storage, TiKV would use it driectly.
	StorageCacheId string               `protobuf:"bytes,5,opt,name=storage_cache_id,json=storageCacheId,proto3" json:"storage_cache_id,omitempty"`
	StorageBackend *brpb.StorageBackend `protobuf:"bytes,3,opt,name=storage_backend,json=storageBackend,proto3" json:"storage_backend,omitempty"`
	// context represents region info and it used to build raft commands.
	Context *kvrpcpb.Context `protobuf:"bytes,4,opt,name=context,proto3" json:"context,omitempty"`
	// cipher_info is used to decrypt kv file when download file.
	CipherInfo           *brpb.CipherInfo `protobuf:"bytes,11,opt,name=cipher_info,json=cipherInfo,proto3" json:"cipher_info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ApplyRequest) Descriptor 

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

func (*ApplyRequest) GetCipherInfo 

func (m *ApplyRequest) GetCipherInfo() *brpb.CipherInfo

func (*ApplyRequest) GetContext 

func (m *ApplyRequest) GetContext() *kvrpcpb.Context

func (*ApplyRequest) GetMeta 

func (m *ApplyRequest) GetMeta() *KVMeta

func (*ApplyRequest) GetMetas 

func (m *ApplyRequest) GetMetas() []*KVMeta

func (*ApplyRequest) GetRewriteRule 

func (m *ApplyRequest) GetRewriteRule() RewriteRule

func (*ApplyRequest) GetRewriteRules 

func (m *ApplyRequest) GetRewriteRules() []*RewriteRule

func (*ApplyRequest) GetStorageBackend 

func (m *ApplyRequest) GetStorageBackend() *brpb.StorageBackend

func (*ApplyRequest) GetStorageCacheId 

func (m *ApplyRequest) GetStorageCacheId() string

func (*ApplyRequest) Marshal 

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

func (*ApplyRequest) MarshalTo 

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

func (*ApplyRequest) MarshalToSizedBuffer 

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

func (*ApplyRequest) ProtoMessage 

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) Reset 

func (m *ApplyRequest) Reset()

func (*ApplyRequest) Size 

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

func (*ApplyRequest) String 

func (m *ApplyRequest) String() string

func (*ApplyRequest) Unmarshal 

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

func (*ApplyRequest) XXX_DiscardUnknown 

func (m *ApplyRequest) XXX_DiscardUnknown()

func (*ApplyRequest) XXX_Marshal 

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

func (*ApplyRequest) XXX_Merge 

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

func (*ApplyRequest) XXX_Size 

func (m *ApplyRequest) XXX_Size() int

func (*ApplyRequest) XXX_Unmarshal 

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

type ApplyResponse 

type ApplyResponse struct {
	// The actual key range (after rewrite) of the downloaded file. The range is
	// inclusive in both ends.
	Range                Range    `protobuf:"bytes,1,opt,name=range,proto3" json:"range"`
	Error                *Error   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ApplyResponse) Descriptor 

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

func (*ApplyResponse) GetError 

func (m *ApplyResponse) GetError() *Error

func (*ApplyResponse) GetRange 

func (m *ApplyResponse) GetRange() Range

func (*ApplyResponse) Marshal 

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

func (*ApplyResponse) MarshalTo 

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

func (*ApplyResponse) MarshalToSizedBuffer 

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

func (*ApplyResponse) ProtoMessage 

func (*ApplyResponse) ProtoMessage()

func (*ApplyResponse) Reset 

func (m *ApplyResponse) Reset()

func (*ApplyResponse) Size 

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

func (*ApplyResponse) String 

func (m *ApplyResponse) String() string

func (*ApplyResponse) Unmarshal 

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

func (*ApplyResponse) XXX_DiscardUnknown 

func (m *ApplyResponse) XXX_DiscardUnknown()

func (*ApplyResponse) XXX_Marshal 

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

func (*ApplyResponse) XXX_Merge 

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

func (*ApplyResponse) XXX_Size 

func (m *ApplyResponse) XXX_Size() int

func (*ApplyResponse) XXX_Unmarshal 

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

type ClearRequest 

type ClearRequest struct {
	// clear files in import directory with given prefix.
	Prefix               string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClearRequest) Descriptor 

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

func (*ClearRequest) GetPrefix 

func (m *ClearRequest) GetPrefix() string

func (*ClearRequest) Marshal 

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

func (*ClearRequest) MarshalTo 

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

func (*ClearRequest) MarshalToSizedBuffer 

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

func (*ClearRequest) ProtoMessage 

func (*ClearRequest) ProtoMessage()

func (*ClearRequest) Reset 

func (m *ClearRequest) Reset()

func (*ClearRequest) Size 

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

func (*ClearRequest) String 

func (m *ClearRequest) String() string

func (*ClearRequest) Unmarshal 

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

func (*ClearRequest) XXX_DiscardUnknown 

func (m *ClearRequest) XXX_DiscardUnknown()

func (*ClearRequest) XXX_Marshal 

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

func (*ClearRequest) XXX_Merge 

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

func (*ClearRequest) XXX_Size 

func (m *ClearRequest) XXX_Size() int

func (*ClearRequest) XXX_Unmarshal 

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

type ClearResponse 

type ClearResponse 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 (*ClearResponse) Descriptor 

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

func (*ClearResponse) GetError 

func (m *ClearResponse) GetError() *Error

func (*ClearResponse) Marshal 

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

func (*ClearResponse) MarshalTo 

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

func (*ClearResponse) MarshalToSizedBuffer 

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

func (*ClearResponse) ProtoMessage 

func (*ClearResponse) ProtoMessage()

func (*ClearResponse) Reset 

func (m *ClearResponse) Reset()

func (*ClearResponse) Size 

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

func (*ClearResponse) String 

func (m *ClearResponse) String() string

func (*ClearResponse) Unmarshal 

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

func (*ClearResponse) XXX_DiscardUnknown 

func (m *ClearResponse) XXX_DiscardUnknown()

func (*ClearResponse) XXX_Marshal 

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

func (*ClearResponse) XXX_Merge 

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

func (*ClearResponse) XXX_Size 

func (m *ClearResponse) XXX_Size() int

func (*ClearResponse) XXX_Unmarshal 

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

type CompactRequest 

type CompactRequest struct {
	// Compact files in the range and above the output level.
	// Compact all files if the range is not specified.
	// Compact all files to the bottommost level if the output level is -1.
	Range                *Range           `protobuf:"bytes,1,opt,name=range,proto3" json:"range,omitempty"`
	OutputLevel          int32            `protobuf:"varint,2,opt,name=output_level,json=outputLevel,proto3" json:"output_level,omitempty"`
	Context              *kvrpcpb.Context `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*CompactRequest) Descriptor 

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

func (*CompactRequest) GetContext 

func (m *CompactRequest) GetContext() *kvrpcpb.Context

func (*CompactRequest) GetOutputLevel 

func (m *CompactRequest) GetOutputLevel() int32

func (*CompactRequest) GetRange 

func (m *CompactRequest) GetRange() *Range

func (*CompactRequest) Marshal 

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

func (*CompactRequest) MarshalTo 

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

func (*CompactRequest) MarshalToSizedBuffer 

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

func (*CompactRequest) ProtoMessage 

func (*CompactRequest) ProtoMessage()

func (*CompactRequest) Reset 

func (m *CompactRequest) Reset()

func (*CompactRequest) Size 

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

func (*CompactRequest) String 

func (m *CompactRequest) String() string

func (*CompactRequest) Unmarshal 

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

func (*CompactRequest) XXX_DiscardUnknown 

func (m *CompactRequest) XXX_DiscardUnknown()

func (*CompactRequest) XXX_Marshal 

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

func (*CompactRequest) XXX_Merge 

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

func (*CompactRequest) XXX_Size 

func (m *CompactRequest) XXX_Size() int

func (*CompactRequest) XXX_Unmarshal 

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

type CompactResponse 

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

func (*CompactResponse) Descriptor 

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

func (*CompactResponse) Marshal 

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

func (*CompactResponse) MarshalTo 

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

func (*CompactResponse) MarshalToSizedBuffer 

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

func (*CompactResponse) ProtoMessage 

func (*CompactResponse) ProtoMessage()

func (*CompactResponse) Reset 

func (m *CompactResponse) Reset()

func (*CompactResponse) Size 

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

func (*CompactResponse) String 

func (m *CompactResponse) String() string

func (*CompactResponse) Unmarshal 

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

func (*CompactResponse) XXX_DiscardUnknown 

func (m *CompactResponse) XXX_DiscardUnknown()

func (*CompactResponse) XXX_Marshal 

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

func (*CompactResponse) XXX_Merge 

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

func (*CompactResponse) XXX_Size 

func (m *CompactResponse) XXX_Size() int

func (*CompactResponse) XXX_Unmarshal 

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

type DownloadRequest 

type DownloadRequest struct {
	// Map represents the map of <name, SSTMeta>.
	// We'll generate all SSTMeta into one SST File.
	Ssts map[string]*SSTMeta `` /* 149-byte string literal not displayed */
	// resolved_ts is used to merge related SST Files.
	ResolvedTs uint64 `protobuf:"varint,3,opt,name=resolved_ts,json=resolvedTs,proto3" json:"resolved_ts,omitempty"`
	// The SST meta used to identify the downloaded file.
	// Must be the same among all nodes in the same Raft group.
	// Note: the "crc32" and "cf_name" fields are ignored in this request,
	// and the "range" field represents the closed key range after rewrite
	// (as origin keys in encoded representation).
	Sst SSTMeta `protobuf:"bytes,2,opt,name=sst,proto3" json:"sst"`
	// The file name of the SST file.
	Name string `protobuf:"bytes,9,opt,name=name,proto3" json:"name,omitempty"`
	// Performs a key prefix rewrite after downloading the SST file.
	// All keys in the SST will be rewritten as:
	//
	//  new_key = new_key_prefix + old_key[len(old_key_prefix)..]
	//
	// When used for TiDB, rewriting the prefix changes the table ID. Please
	// note that key-rewrite is applied on the origin keys in encoded
	// representation (the SST itself should still use data keys in encoded
	// representation).
	//
	// You need to ensure that the keys before and after rewriting are in the
	// same order, otherwise the RPC request will fail.
	RewriteRule    RewriteRule          `protobuf:"bytes,13,opt,name=rewrite_rule,json=rewriteRule,proto3" json:"rewrite_rule"`
	StorageBackend *brpb.StorageBackend `protobuf:"bytes,14,opt,name=storage_backend,json=storageBackend,proto3" json:"storage_backend,omitempty"`
	// The identity for the stroage backend.
	// When this field presents, the storage would be cached.
	// If there is a cached storage, TiKV would use it driectly.
	StorageCacheId string `protobuf:"bytes,17,opt,name=storage_cache_id,json=storageCacheId,proto3" json:"storage_cache_id,omitempty"`
	IsRawKv        bool   `protobuf:"varint,15,opt,name=is_raw_kv,json=isRawKv,proto3" json:"is_raw_kv,omitempty"`
	// cipher_info is used to decrypt sst when download sst
	CipherInfo *brpb.CipherInfo `protobuf:"bytes,16,opt,name=cipher_info,json=cipherInfo,proto3" json:"cipher_info,omitempty"`
	// The type of the download request.
	RequestType          DownloadRequestType `` /* 134-byte string literal not displayed */
	Context              *kvrpcpb.Context    `protobuf:"bytes,19,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*DownloadRequest) Descriptor 

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

func (*DownloadRequest) GetCipherInfo 

func (m *DownloadRequest) GetCipherInfo() *brpb.CipherInfo

func (*DownloadRequest) GetContext 

func (m *DownloadRequest) GetContext() *kvrpcpb.Context

func (*DownloadRequest) GetIsRawKv 

func (m *DownloadRequest) GetIsRawKv() bool

func (*DownloadRequest) GetName 

func (m *DownloadRequest) GetName() string

func (*DownloadRequest) GetRequestType 

func (m *DownloadRequest) GetRequestType() DownloadRequestType

func (*DownloadRequest) GetResolvedTs 

func (m *DownloadRequest) GetResolvedTs() uint64

func (*DownloadRequest) GetRewriteRule 

func (m *DownloadRequest) GetRewriteRule() RewriteRule

func (*DownloadRequest) GetSst 

func (m *DownloadRequest) GetSst() SSTMeta

func (*DownloadRequest) GetSsts 

func (m *DownloadRequest) GetSsts() map[string]*SSTMeta

func (*DownloadRequest) GetStorageBackend 

func (m *DownloadRequest) GetStorageBackend() *brpb.StorageBackend

func (*DownloadRequest) GetStorageCacheId 

func (m *DownloadRequest) GetStorageCacheId() string

func (*DownloadRequest) Marshal 

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

func (*DownloadRequest) MarshalTo 

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

func (*DownloadRequest) MarshalToSizedBuffer 

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

func (*DownloadRequest) ProtoMessage 

func (*DownloadRequest) ProtoMessage()

func (*DownloadRequest) Reset 

func (m *DownloadRequest) Reset()

func (*DownloadRequest) Size 

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

func (*DownloadRequest) String 

func (m *DownloadRequest) String() string

func (*DownloadRequest) Unmarshal 

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

func (*DownloadRequest) XXX_DiscardUnknown 

func (m *DownloadRequest) XXX_DiscardUnknown()

func (*DownloadRequest) XXX_Marshal 

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

func (*DownloadRequest) XXX_Merge 

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

func (*DownloadRequest) XXX_Size 

func (m *DownloadRequest) XXX_Size() int

func (*DownloadRequest) XXX_Unmarshal 

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

type DownloadRequestType 

type DownloadRequestType int32
const (
	// For the compatibility with old version of TiDBs
	DownloadRequestType_Legacy DownloadRequestType = 0
	// For the TiDBs with newer versions that support keyspace feature.
	DownloadRequestType_Keyspace DownloadRequestType = 1
)

func (DownloadRequestType) EnumDescriptor 

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

func (DownloadRequestType) String 

func (x DownloadRequestType) String() string

type DownloadResponse 

type DownloadResponse struct {
	// The actual key range (after rewrite) of the downloaded SST. The range is
	// inclusive in both ends.
	Range Range `protobuf:"bytes,1,opt,name=range,proto3" json:"range"`
	// Whether the SST is empty. An empty SST is prohibited in TiKV, do not
	// ingest if this field is true.
	// (Deprecated, should be replaced by checking `length == 0` in the future)
	IsEmpty bool   `protobuf:"varint,2,opt,name=is_empty,json=isEmpty,proto3" json:"is_empty,omitempty"`
	Error   *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// The CRC32 checksum of the rewritten SST file (implementation can return
	// zero, indicating the CRC32 was not calculated).
	Crc32 uint32 `protobuf:"varint,4,opt,name=crc32,proto3" json:"crc32,omitempty"`
	// The actual length of the rewritten SST file.
	Length uint64 `protobuf:"varint,5,opt,name=length,proto3" json:"length,omitempty"`
	// This field only return when file-copy backup enabled.
	// Because it will merge many SST files in a download request.
	Ssts                 []*SSTMeta `protobuf:"bytes,6,rep,name=ssts,proto3" json:"ssts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DownloadResponse) Descriptor 

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

func (*DownloadResponse) GetCrc32 

func (m *DownloadResponse) GetCrc32() uint32

func (*DownloadResponse) GetError 

func (m *DownloadResponse) GetError() *Error

func (*DownloadResponse) GetIsEmpty 

func (m *DownloadResponse) GetIsEmpty() bool

func (*DownloadResponse) GetLength 

func (m *DownloadResponse) GetLength() uint64

func (*DownloadResponse) GetRange 

func (m *DownloadResponse) GetRange() Range

func (*DownloadResponse) GetSsts 

func (m *DownloadResponse) GetSsts() []*SSTMeta

func (*DownloadResponse) Marshal 

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

func (*DownloadResponse) MarshalTo 

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

func (*DownloadResponse) MarshalToSizedBuffer 

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

func (*DownloadResponse) ProtoMessage 

func (*DownloadResponse) ProtoMessage()

func (*DownloadResponse) Reset 

func (m *DownloadResponse) Reset()

func (*DownloadResponse) Size 

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

func (*DownloadResponse) String 

func (m *DownloadResponse) String() string

func (*DownloadResponse) Unmarshal 

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

func (*DownloadResponse) XXX_DiscardUnknown 

func (m *DownloadResponse) XXX_DiscardUnknown()

func (*DownloadResponse) XXX_Marshal 

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

func (*DownloadResponse) XXX_Merge 

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

func (*DownloadResponse) XXX_Size 

func (m *DownloadResponse) XXX_Size() int

func (*DownloadResponse) XXX_Unmarshal 

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

type DuplicateDetectRequest 

type DuplicateDetectRequest struct {
	Context  *kvrpcpb.Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	StartKey []byte           `protobuf:"bytes,2,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte           `protobuf:"bytes,3,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// Return only the keys found by scanning, not their values.
	KeyOnly bool `protobuf:"varint,4,opt,name=key_only,json=keyOnly,proto3" json:"key_only,omitempty"`
	// We only check the data whose timestamp is larger than `min_commit_ts`. `min_commit_ts` is exclueded.
	MinCommitTs          uint64   `protobuf:"varint,5,opt,name=min_commit_ts,json=minCommitTs,proto3" json:"min_commit_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DuplicateDetectRequest) Descriptor 

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

func (*DuplicateDetectRequest) GetContext 

func (m *DuplicateDetectRequest) GetContext() *kvrpcpb.Context

func (*DuplicateDetectRequest) GetEndKey 

func (m *DuplicateDetectRequest) GetEndKey() []byte

func (*DuplicateDetectRequest) GetKeyOnly 

func (m *DuplicateDetectRequest) GetKeyOnly() bool

func (*DuplicateDetectRequest) GetMinCommitTs 

func (m *DuplicateDetectRequest) GetMinCommitTs() uint64

func (*DuplicateDetectRequest) GetStartKey 

func (m *DuplicateDetectRequest) GetStartKey() []byte

func (*DuplicateDetectRequest) Marshal 

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

func (*DuplicateDetectRequest) MarshalTo 

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

func (*DuplicateDetectRequest) MarshalToSizedBuffer 

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

func (*DuplicateDetectRequest) ProtoMessage 

func (*DuplicateDetectRequest) ProtoMessage()

func (*DuplicateDetectRequest) Reset 

func (m *DuplicateDetectRequest) Reset()

func (*DuplicateDetectRequest) Size 

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

func (*DuplicateDetectRequest) String 

func (m *DuplicateDetectRequest) String() string

func (*DuplicateDetectRequest) Unmarshal 

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

func (*DuplicateDetectRequest) XXX_DiscardUnknown 

func (m *DuplicateDetectRequest) XXX_DiscardUnknown()

func (*DuplicateDetectRequest) XXX_Marshal 

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

func (*DuplicateDetectRequest) XXX_Merge 

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

func (*DuplicateDetectRequest) XXX_Size 

func (m *DuplicateDetectRequest) XXX_Size() int

func (*DuplicateDetectRequest) XXX_Unmarshal 

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

type DuplicateDetectResponse 

type DuplicateDetectResponse struct {
	RegionError *errorpb.Error `protobuf:"bytes,1,opt,name=region_error,json=regionError,proto3" json:"region_error,omitempty"`
	KeyError    *Error         `protobuf:"bytes,2,opt,name=key_error,json=keyError,proto3" json:"key_error,omitempty"`
	// The these keys will be in asc order (but commit time is in desc order),
	//  and the content is just like following:
	// [
	//   {key: "key1", value: "value11", commit_ts: 1005},
	//   {key: "key1", value: "value12", commit_ts: 1004},
	//   {key: "key1", value: "value13", commit_ts: 1001},
	//   {key: "key2", value: "value21", commit_ts: 1004},
	//   {key: "key2", value: "value22", commit_ts: 1002},
	//   ...
	// ]
	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 (*DuplicateDetectResponse) Descriptor 

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

func (*DuplicateDetectResponse) GetKeyError 

func (m *DuplicateDetectResponse) GetKeyError() *Error

func (*DuplicateDetectResponse) GetPairs 

func (m *DuplicateDetectResponse) GetPairs() []*KvPair

func (*DuplicateDetectResponse) GetRegionError 

func (m *DuplicateDetectResponse) GetRegionError() *errorpb.Error

func (*DuplicateDetectResponse) Marshal 

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

func (*DuplicateDetectResponse) MarshalTo 

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

func (*DuplicateDetectResponse) MarshalToSizedBuffer 

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

func (*DuplicateDetectResponse) ProtoMessage 

func (*DuplicateDetectResponse) ProtoMessage()

func (*DuplicateDetectResponse) Reset 

func (m *DuplicateDetectResponse) Reset()

func (*DuplicateDetectResponse) Size 

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

func (*DuplicateDetectResponse) String 

func (m *DuplicateDetectResponse) String() string

func (*DuplicateDetectResponse) Unmarshal 

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

func (*DuplicateDetectResponse) XXX_DiscardUnknown 

func (m *DuplicateDetectResponse) XXX_DiscardUnknown()

func (*DuplicateDetectResponse) XXX_Marshal 

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

func (*DuplicateDetectResponse) XXX_Merge 

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

func (*DuplicateDetectResponse) XXX_Size 

func (m *DuplicateDetectResponse) XXX_Size() int

func (*DuplicateDetectResponse) XXX_Unmarshal 

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

type Error 

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// We meet some internal errors of the store.
	StoreError           *errorpb.Error `protobuf:"bytes,2,opt,name=store_error,json=storeError,proto3" json:"store_error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

For now it is just used for distinguishing the error of the request with the error of gRPC, add more concrete types if it is necessary later.

func (*Error) Descriptor 

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

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetStoreError 

func (m *Error) GetStoreError() *errorpb.Error

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 GetModeRequest 

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

func (*GetModeRequest) Descriptor 

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

func (*GetModeRequest) Marshal 

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

func (*GetModeRequest) MarshalTo 

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

func (*GetModeRequest) MarshalToSizedBuffer 

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

func (*GetModeRequest) ProtoMessage 

func (*GetModeRequest) ProtoMessage()

func (*GetModeRequest) Reset 

func (m *GetModeRequest) Reset()

func (*GetModeRequest) Size 

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

func (*GetModeRequest) String 

func (m *GetModeRequest) String() string

func (*GetModeRequest) Unmarshal 

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

func (*GetModeRequest) XXX_DiscardUnknown 

func (m *GetModeRequest) XXX_DiscardUnknown()

func (*GetModeRequest) XXX_Marshal 

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

func (*GetModeRequest) XXX_Merge 

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

func (*GetModeRequest) XXX_Size 

func (m *GetModeRequest) XXX_Size() int

func (*GetModeRequest) XXX_Unmarshal 

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

type GetModeResponse 

type GetModeResponse struct {
	Mode                 SwitchMode `protobuf:"varint,1,opt,name=mode,proto3,enum=import_sstpb.SwitchMode" json:"mode,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetModeResponse) Descriptor 

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

func (*GetModeResponse) GetMode 

func (m *GetModeResponse) GetMode() SwitchMode

func (*GetModeResponse) Marshal 

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

func (*GetModeResponse) MarshalTo 

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

func (*GetModeResponse) MarshalToSizedBuffer 

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

func (*GetModeResponse) ProtoMessage 

func (*GetModeResponse) ProtoMessage()

func (*GetModeResponse) Reset 

func (m *GetModeResponse) Reset()

func (*GetModeResponse) Size 

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

func (*GetModeResponse) String 

func (m *GetModeResponse) String() string

func (*GetModeResponse) Unmarshal 

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

func (*GetModeResponse) XXX_DiscardUnknown 

func (m *GetModeResponse) XXX_DiscardUnknown()

func (*GetModeResponse) XXX_Marshal 

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

func (*GetModeResponse) XXX_Merge 

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

func (*GetModeResponse) XXX_Size 

func (m *GetModeResponse) XXX_Size() int

func (*GetModeResponse) XXX_Unmarshal 

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

type ImportSSTClient 

type ImportSSTClient interface {
	// Switch to normal/import mode.
	SwitchMode(ctx context.Context, in *SwitchModeRequest, opts ...grpc.CallOption) (*SwitchModeResponse, error)
	// Get import mode(normal/import).
	GetMode(ctx context.Context, in *GetModeRequest, opts ...grpc.CallOption) (*GetModeResponse, error)
	// Upload an SST file to a server.
	Upload(ctx context.Context, opts ...grpc.CallOption) (ImportSST_UploadClient, error)
	// Ingest an uploaded SST file to a region.
	Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)
	// Compact the specific range for better performance.
	Compact(ctx context.Context, in *CompactRequest, opts ...grpc.CallOption) (*CompactResponse, error)
	SetDownloadSpeedLimit(ctx context.Context, in *SetDownloadSpeedLimitRequest, opts ...grpc.CallOption) (*SetDownloadSpeedLimitResponse, error)
	// Download an SST file from an external storage, and performs key-rewrite
	// after downloading.
	Download(ctx context.Context, in *DownloadRequest, opts ...grpc.CallOption) (*DownloadResponse, error)
	// Open a write stream to generate sst files
	Write(ctx context.Context, opts ...grpc.CallOption) (ImportSST_WriteClient, error)
	RawWrite(ctx context.Context, opts ...grpc.CallOption) (ImportSST_RawWriteClient, error)
	// Ingest Multiple files in one request
	MultiIngest(ctx context.Context, in *MultiIngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)
	// Collect duplicate data from TiKV.
	DuplicateDetect(ctx context.Context, in *DuplicateDetectRequest, opts ...grpc.CallOption) (ImportSST_DuplicateDetectClient, error)
	// Apply download & apply increment kv files to TiKV.
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	// ClearFiles clear applied file after restore succeed.
	ClearFiles(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error)
	// Suspend ingest for data listeners don't support catching import data.
	SuspendImportRPC(ctx context.Context, in *SuspendImportRPCRequest, opts ...grpc.CallOption) (*SuspendImportRPCResponse, error)
}

ImportSSTClient is the client API for ImportSST service.

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

func NewImportSSTClient 

func NewImportSSTClient(cc *grpc.ClientConn) ImportSSTClient

type ImportSSTServer 

type ImportSSTServer interface {
	// Switch to normal/import mode.
	SwitchMode(context.Context, *SwitchModeRequest) (*SwitchModeResponse, error)
	// Get import mode(normal/import).
	GetMode(context.Context, *GetModeRequest) (*GetModeResponse, error)
	// Upload an SST file to a server.
	Upload(ImportSST_UploadServer) error
	// Ingest an uploaded SST file to a region.
	Ingest(context.Context, *IngestRequest) (*IngestResponse, error)
	// Compact the specific range for better performance.
	Compact(context.Context, *CompactRequest) (*CompactResponse, error)
	SetDownloadSpeedLimit(context.Context, *SetDownloadSpeedLimitRequest) (*SetDownloadSpeedLimitResponse, error)
	// Download an SST file from an external storage, and performs key-rewrite
	// after downloading.
	Download(context.Context, *DownloadRequest) (*DownloadResponse, error)
	// Open a write stream to generate sst files
	Write(ImportSST_WriteServer) error
	RawWrite(ImportSST_RawWriteServer) error
	// Ingest Multiple files in one request
	MultiIngest(context.Context, *MultiIngestRequest) (*IngestResponse, error)
	// Collect duplicate data from TiKV.
	DuplicateDetect(*DuplicateDetectRequest, ImportSST_DuplicateDetectServer) error
	// Apply download & apply increment kv files to TiKV.
	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
	// ClearFiles clear applied file after restore succeed.
	ClearFiles(context.Context, *ClearRequest) (*ClearResponse, error)
	// Suspend ingest for data listeners don't support catching import data.
	SuspendImportRPC(context.Context, *SuspendImportRPCRequest) (*SuspendImportRPCResponse, error)
}

ImportSSTServer is the server API for ImportSST service.

type ImportSST_DuplicateDetectClient 

type ImportSST_DuplicateDetectClient interface {
	Recv() (*DuplicateDetectResponse, error)
	grpc.ClientStream
}

type ImportSST_DuplicateDetectServer 

type ImportSST_DuplicateDetectServer interface {
	Send(*DuplicateDetectResponse) error
	grpc.ServerStream
}

type ImportSST_RawWriteClient 

type ImportSST_RawWriteClient interface {
	Send(*RawWriteRequest) error
	CloseAndRecv() (*RawWriteResponse, error)
	grpc.ClientStream
}

type ImportSST_RawWriteServer 

type ImportSST_RawWriteServer interface {
	SendAndClose(*RawWriteResponse) error
	Recv() (*RawWriteRequest, error)
	grpc.ServerStream
}

type ImportSST_UploadClient 

type ImportSST_UploadClient interface {
	Send(*UploadRequest) error
	CloseAndRecv() (*UploadResponse, error)
	grpc.ClientStream
}

type ImportSST_UploadServer 

type ImportSST_UploadServer interface {
	SendAndClose(*UploadResponse) error
	Recv() (*UploadRequest, error)
	grpc.ServerStream
}

type ImportSST_WriteClient 

type ImportSST_WriteClient interface {
	Send(*WriteRequest) error
	CloseAndRecv() (*WriteResponse, error)
	grpc.ClientStream
}

type ImportSST_WriteServer 

type ImportSST_WriteServer interface {
	SendAndClose(*WriteResponse) error
	Recv() (*WriteRequest, error)
	grpc.ServerStream
}

type IngestRequest 

type IngestRequest struct {
	Context              *kvrpcpb.Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Sst                  *SSTMeta         `protobuf:"bytes,2,opt,name=sst,proto3" json:"sst,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*IngestRequest) Descriptor 

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

func (*IngestRequest) GetContext 

func (m *IngestRequest) GetContext() *kvrpcpb.Context

func (*IngestRequest) GetSst 

func (m *IngestRequest) GetSst() *SSTMeta

func (*IngestRequest) Marshal 

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

func (*IngestRequest) MarshalTo 

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

func (*IngestRequest) MarshalToSizedBuffer 

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

func (*IngestRequest) ProtoMessage 

func (*IngestRequest) ProtoMessage()

func (*IngestRequest) Reset 

func (m *IngestRequest) Reset()

func (*IngestRequest) Size 

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

func (*IngestRequest) String 

func (m *IngestRequest) String() string

func (*IngestRequest) Unmarshal 

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

func (*IngestRequest) XXX_DiscardUnknown 

func (m *IngestRequest) XXX_DiscardUnknown()

func (*IngestRequest) XXX_Marshal 

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

func (*IngestRequest) XXX_Merge 

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

func (*IngestRequest) XXX_Size 

func (m *IngestRequest) XXX_Size() int

func (*IngestRequest) XXX_Unmarshal 

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

type IngestResponse 

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

func (*IngestResponse) Descriptor 

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

func (*IngestResponse) GetError 

func (m *IngestResponse) GetError() *errorpb.Error

func (*IngestResponse) Marshal 

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

func (*IngestResponse) MarshalTo 

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

func (*IngestResponse) MarshalToSizedBuffer 

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

func (*IngestResponse) ProtoMessage 

func (*IngestResponse) ProtoMessage()

func (*IngestResponse) Reset 

func (m *IngestResponse) Reset()

func (*IngestResponse) Size 

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

func (*IngestResponse) String 

func (m *IngestResponse) String() string

func (*IngestResponse) Unmarshal 

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

func (*IngestResponse) XXX_DiscardUnknown 

func (m *IngestResponse) XXX_DiscardUnknown()

func (*IngestResponse) XXX_Marshal 

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

func (*IngestResponse) XXX_Merge 

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

func (*IngestResponse) XXX_Size 

func (m *IngestResponse) XXX_Size() int

func (*IngestResponse) XXX_Unmarshal 

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

type KVMeta 

type KVMeta struct {
	// The file name of the KV file.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// file offset, sometimes only need to get a part of data from the merged file
	RangeOffset uint64 `protobuf:"varint,11,opt,name=range_offset,json=rangeOffset,proto3" json:"range_offset,omitempty"`
	// file length for check.
	Length uint64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
	// range length of the merged file, if it exists.
	RangeLength uint64 `protobuf:"varint,12,opt,name=range_length,json=rangeLength,proto3" json:"range_length,omitempty"`
	// tell us which cf should apply. WRITE_CF or DEFAULT_CF e.g.
	Cf string `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	// is_delete represents whether we should delete the kv in tikv.
	// it may not be too much delete file. only rollBack operation will generate delete kv file.
	IsDelete bool `protobuf:"varint,4,opt,name=is_delete,json=isDelete,proto3" json:"is_delete,omitempty"`
	// the key ts space being smaller than start_ts can be filter.
	StartTs uint64 `protobuf:"varint,10,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	// the key ts space large than restore_ts can be filter.
	RestoreTs uint64 `protobuf:"varint,5,opt,name=restore_ts,json=restoreTs,proto3" json:"restore_ts,omitempty"`
	StartKey  []byte `protobuf:"bytes,6,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey    []byte `protobuf:"bytes,7,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// used for checksum when download kv file.
	Sha256 []byte `protobuf:"bytes,8,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// the key ts space less than start_snapshot_ts can be filter.
	// Deprecated: this field 'start_snapshot_ts' is replaced by the field 'start_ts'.
	StartSnapshotTs uint64 `protobuf:"varint,9,opt,name=start_snapshot_ts,json=startSnapshotTs,proto3" json:"start_snapshot_ts,omitempty"`
	// the compression type for the file.
	CompressionType      brpb.CompressionType `` /* 136-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*KVMeta) Descriptor 

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

func (*KVMeta) GetCf 

func (m *KVMeta) GetCf() string

func (*KVMeta) GetCompressionType 

func (m *KVMeta) GetCompressionType() brpb.CompressionType

func (*KVMeta) GetEndKey 

func (m *KVMeta) GetEndKey() []byte

func (*KVMeta) GetIsDelete 

func (m *KVMeta) GetIsDelete() bool

func (*KVMeta) GetLength 

func (m *KVMeta) GetLength() uint64

func (*KVMeta) GetName 

func (m *KVMeta) GetName() string

func (*KVMeta) GetRangeLength 

func (m *KVMeta) GetRangeLength() uint64

func (*KVMeta) GetRangeOffset 

func (m *KVMeta) GetRangeOffset() uint64

func (*KVMeta) GetRestoreTs 

func (m *KVMeta) GetRestoreTs() uint64

func (*KVMeta) GetSha256 

func (m *KVMeta) GetSha256() []byte

func (*KVMeta) GetStartKey 

func (m *KVMeta) GetStartKey() []byte

func (*KVMeta) GetStartSnapshotTs 

func (m *KVMeta) GetStartSnapshotTs() uint64

func (*KVMeta) GetStartTs 

func (m *KVMeta) GetStartTs() uint64

func (*KVMeta) Marshal 

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

func (*KVMeta) MarshalTo 

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

func (*KVMeta) MarshalToSizedBuffer 

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

func (*KVMeta) ProtoMessage 

func (*KVMeta) ProtoMessage()

func (*KVMeta) Reset 

func (m *KVMeta) Reset()

func (*KVMeta) Size 

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

func (*KVMeta) String 

func (m *KVMeta) String() string

func (*KVMeta) Unmarshal 

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

func (*KVMeta) XXX_DiscardUnknown 

func (m *KVMeta) XXX_DiscardUnknown()

func (*KVMeta) XXX_Marshal 

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

func (*KVMeta) XXX_Merge 

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

func (*KVMeta) XXX_Size 

func (m *KVMeta) XXX_Size() int

func (*KVMeta) XXX_Unmarshal 

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

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"`
	CommitTs             uint64   `protobuf:"varint,3,opt,name=commit_ts,json=commitTs,proto3" json:"commit_ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KvPair) Descriptor 

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

func (*KvPair) GetCommitTs 

func (m *KvPair) GetCommitTs() uint64

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 MultiIngestRequest 

type MultiIngestRequest struct {
	Context              *kvrpcpb.Context `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	Ssts                 []*SSTMeta       `protobuf:"bytes,2,rep,name=ssts,proto3" json:"ssts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*MultiIngestRequest) Descriptor 

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

func (*MultiIngestRequest) GetContext 

func (m *MultiIngestRequest) GetContext() *kvrpcpb.Context

func (*MultiIngestRequest) GetSsts 

func (m *MultiIngestRequest) GetSsts() []*SSTMeta

func (*MultiIngestRequest) Marshal 

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

func (*MultiIngestRequest) MarshalTo 

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

func (*MultiIngestRequest) MarshalToSizedBuffer 

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

func (*MultiIngestRequest) ProtoMessage 

func (*MultiIngestRequest) ProtoMessage()

func (*MultiIngestRequest) Reset 

func (m *MultiIngestRequest) Reset()

func (*MultiIngestRequest) Size 

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

func (*MultiIngestRequest) String 

func (m *MultiIngestRequest) String() string

func (*MultiIngestRequest) Unmarshal 

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

func (*MultiIngestRequest) XXX_DiscardUnknown 

func (m *MultiIngestRequest) XXX_DiscardUnknown()

func (*MultiIngestRequest) XXX_Marshal 

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

func (*MultiIngestRequest) XXX_Merge 

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

func (*MultiIngestRequest) XXX_Size 

func (m *MultiIngestRequest) XXX_Size() int

func (*MultiIngestRequest) XXX_Unmarshal 

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

type Pair 

type Pair 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"`
	Op                   Pair_OP  `protobuf:"varint,3,opt,name=op,proto3,enum=import_sstpb.Pair_OP" json:"op,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Pair) Descriptor 

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

func (*Pair) GetKey 

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

func (*Pair) GetOp 

func (m *Pair) GetOp() Pair_OP

func (*Pair) GetValue 

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

func (*Pair) Marshal 

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

func (*Pair) MarshalTo 

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

func (*Pair) MarshalToSizedBuffer 

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

func (*Pair) ProtoMessage 

func (*Pair) ProtoMessage()

func (*Pair) Reset 

func (m *Pair) Reset()

func (*Pair) Size 

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

func (*Pair) String 

func (m *Pair) String() string

func (*Pair) Unmarshal 

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

func (*Pair) XXX_DiscardUnknown 

func (m *Pair) XXX_DiscardUnknown()

func (*Pair) XXX_Marshal 

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

func (*Pair) XXX_Merge 

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

func (*Pair) XXX_Size 

func (m *Pair) XXX_Size() int

func (*Pair) XXX_Unmarshal 

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

type Pair_OP 

type Pair_OP int32
const (
	Pair_Put    Pair_OP = 0
	Pair_Delete Pair_OP = 1
)

func (Pair_OP) EnumDescriptor 

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

func (Pair_OP) String 

func (x Pair_OP) String() string

type Range 

type Range struct {
	Start                []byte   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  []byte   `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Range) Descriptor 

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

func (*Range) GetEnd 

func (m *Range) GetEnd() []byte

func (*Range) GetStart 

func (m *Range) GetStart() []byte

func (*Range) Marshal 

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

func (*Range) MarshalTo 

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

func (*Range) MarshalToSizedBuffer 

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

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) Reset 

func (m *Range) Reset()

func (*Range) Size 

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

func (*Range) String 

func (m *Range) String() string

func (*Range) Unmarshal 

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

func (*Range) XXX_DiscardUnknown 

func (m *Range) XXX_DiscardUnknown()

func (*Range) XXX_Marshal 

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

func (*Range) XXX_Merge 

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

func (*Range) XXX_Size 

func (m *Range) XXX_Size() int

func (*Range) XXX_Unmarshal 

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

type RawWriteBatch 

type RawWriteBatch struct {
	Ttl   uint64  `protobuf:"varint,1,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Pairs []*Pair `protobuf:"bytes,2,rep,name=pairs,proto3" json:"pairs,omitempty"`
	// To be compatible with the key encoding of API V2.
	// This field should be generated from the client instead of the server,
	// since the message will be send to all the replicas of a region.
	// Otherwise, the underlying data generated by the server would be inconsistent which is hard to scale
	// for other features like MVCC over RawKV.
	Ts                   uint64   `protobuf:"varint,3,opt,name=ts,proto3" json:"ts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RawWriteBatch) Descriptor 

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

func (*RawWriteBatch) GetPairs 

func (m *RawWriteBatch) GetPairs() []*Pair

func (*RawWriteBatch) GetTs 

func (m *RawWriteBatch) GetTs() uint64

func (*RawWriteBatch) GetTtl 

func (m *RawWriteBatch) GetTtl() uint64

func (*RawWriteBatch) Marshal 

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

func (*RawWriteBatch) MarshalTo 

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

func (*RawWriteBatch) MarshalToSizedBuffer 

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

func (*RawWriteBatch) ProtoMessage 

func (*RawWriteBatch) ProtoMessage()

func (*RawWriteBatch) Reset 

func (m *RawWriteBatch) Reset()

func (*RawWriteBatch) Size 

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

func (*RawWriteBatch) String 

func (m *RawWriteBatch) String() string

func (*RawWriteBatch) Unmarshal 

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

func (*RawWriteBatch) XXX_DiscardUnknown 

func (m *RawWriteBatch) XXX_DiscardUnknown()

func (*RawWriteBatch) XXX_Marshal 

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

func (*RawWriteBatch) XXX_Merge 

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

func (*RawWriteBatch) XXX_Size 

func (m *RawWriteBatch) XXX_Size() int

func (*RawWriteBatch) XXX_Unmarshal 

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

type RawWriteRequest 

type RawWriteRequest struct {
	// Types that are valid to be assigned to Chunk:
	//	*RawWriteRequest_Meta
	//	*RawWriteRequest_Batch
	Chunk                isRawWriteRequest_Chunk `protobuf_oneof:"chunk"`
	Context              *kvrpcpb.Context        `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*RawWriteRequest) Descriptor 

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

func (*RawWriteRequest) GetBatch 

func (m *RawWriteRequest) GetBatch() *RawWriteBatch

func (*RawWriteRequest) GetChunk 

func (m *RawWriteRequest) GetChunk() isRawWriteRequest_Chunk

func (*RawWriteRequest) GetContext 

func (m *RawWriteRequest) GetContext() *kvrpcpb.Context

func (*RawWriteRequest) GetMeta 

func (m *RawWriteRequest) GetMeta() *SSTMeta

func (*RawWriteRequest) Marshal 

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

func (*RawWriteRequest) MarshalTo 

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

func (*RawWriteRequest) MarshalToSizedBuffer 

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

func (*RawWriteRequest) ProtoMessage 

func (*RawWriteRequest) ProtoMessage()

func (*RawWriteRequest) Reset 

func (m *RawWriteRequest) Reset()

func (*RawWriteRequest) Size 

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

func (*RawWriteRequest) String 

func (m *RawWriteRequest) String() string

func (*RawWriteRequest) Unmarshal 

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

func (*RawWriteRequest) XXX_DiscardUnknown 

func (m *RawWriteRequest) XXX_DiscardUnknown()

func (*RawWriteRequest) XXX_Marshal 

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

func (*RawWriteRequest) XXX_Merge 

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

func (*RawWriteRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*RawWriteRequest) XXX_Size 

func (m *RawWriteRequest) XXX_Size() int

func (*RawWriteRequest) XXX_Unmarshal 

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

type RawWriteRequest_Batch 

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

func (*RawWriteRequest_Batch) MarshalTo 

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

func (*RawWriteRequest_Batch) MarshalToSizedBuffer 

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

func (*RawWriteRequest_Batch) Size 

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

type RawWriteRequest_Meta 

type RawWriteRequest_Meta struct {
	Meta *SSTMeta `protobuf:"bytes,1,opt,name=meta,proto3,oneof" json:"meta,omitempty"`
}

func (*RawWriteRequest_Meta) MarshalTo 

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

func (*RawWriteRequest_Meta) MarshalToSizedBuffer 

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

func (*RawWriteRequest_Meta) Size 

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

type RawWriteResponse 

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

func (*RawWriteResponse) Descriptor 

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

func (*RawWriteResponse) GetError 

func (m *RawWriteResponse) GetError() *Error

func (*RawWriteResponse) GetMetas 

func (m *RawWriteResponse) GetMetas() []*SSTMeta

func (*RawWriteResponse) Marshal 

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

func (*RawWriteResponse) MarshalTo 

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

func (*RawWriteResponse) MarshalToSizedBuffer 

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

func (*RawWriteResponse) ProtoMessage 

func (*RawWriteResponse) ProtoMessage()

func (*RawWriteResponse) Reset 

func (m *RawWriteResponse) Reset()

func (*RawWriteResponse) Size 

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

func (*RawWriteResponse) String 

func (m *RawWriteResponse) String() string

func (*RawWriteResponse) Unmarshal 

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

func (*RawWriteResponse) XXX_DiscardUnknown 

func (m *RawWriteResponse) XXX_DiscardUnknown()

func (*RawWriteResponse) XXX_Marshal 

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

func (*RawWriteResponse) XXX_Merge 

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

func (*RawWriteResponse) XXX_Size 

func (m *RawWriteResponse) XXX_Size() int

func (*RawWriteResponse) XXX_Unmarshal 

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

type RewriteRule 

type RewriteRule struct {
	OldKeyPrefix         []byte   `protobuf:"bytes,1,opt,name=old_key_prefix,json=oldKeyPrefix,proto3" json:"old_key_prefix,omitempty"`
	NewKeyPrefix         []byte   `protobuf:"bytes,2,opt,name=new_key_prefix,json=newKeyPrefix,proto3" json:"new_key_prefix,omitempty"`
	NewTimestamp         uint64   `protobuf:"varint,3,opt,name=new_timestamp,json=newTimestamp,proto3" json:"new_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

A rewrite rule is applied on the *encoded* keys (the internal storage representation).

func (*RewriteRule) Descriptor 

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

func (*RewriteRule) GetNewKeyPrefix 

func (m *RewriteRule) GetNewKeyPrefix() []byte

func (*RewriteRule) GetNewTimestamp 

func (m *RewriteRule) GetNewTimestamp() uint64

func (*RewriteRule) GetOldKeyPrefix 

func (m *RewriteRule) GetOldKeyPrefix() []byte

func (*RewriteRule) Marshal 

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

func (*RewriteRule) MarshalTo 

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

func (*RewriteRule) MarshalToSizedBuffer 

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

func (*RewriteRule) ProtoMessage 

func (*RewriteRule) ProtoMessage()

func (*RewriteRule) Reset 

func (m *RewriteRule) Reset()

func (*RewriteRule) Size 

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

func (*RewriteRule) String 

func (m *RewriteRule) String() string

func (*RewriteRule) Unmarshal 

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

func (*RewriteRule) XXX_DiscardUnknown 

func (m *RewriteRule) XXX_DiscardUnknown()

func (*RewriteRule) XXX_Marshal 

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

func (*RewriteRule) XXX_Merge 

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

func (*RewriteRule) XXX_Size 

func (m *RewriteRule) XXX_Size() int

func (*RewriteRule) XXX_Unmarshal 

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

type SSTMeta 

type SSTMeta struct {
	Uuid            []byte              `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Range           *Range              `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Crc32           uint32              `protobuf:"varint,3,opt,name=crc32,proto3" json:"crc32,omitempty"`
	Length          uint64              `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	CfName          string              `protobuf:"bytes,5,opt,name=cf_name,json=cfName,proto3" json:"cf_name,omitempty"`
	RegionId        uint64              `protobuf:"varint,6,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	RegionEpoch     *metapb.RegionEpoch `protobuf:"bytes,7,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	EndKeyExclusive bool                `protobuf:"varint,8,opt,name=end_key_exclusive,json=endKeyExclusive,proto3" json:"end_key_exclusive,omitempty"`
	// total_kvs and total_bytes is equivalent to PD's approximate_keys and approximate_size
	// set these values can save time from tikv upload keys and size to PD through Heartbeat.
	TotalKvs   uint64 `protobuf:"varint,9,opt,name=total_kvs,json=totalKvs,proto3" json:"total_kvs,omitempty"`
	TotalBytes uint64 `protobuf:"varint,10,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	// API version implies the encode of the key and value.
	ApiVersion kvrpcpb.APIVersion `protobuf:"varint,11,opt,name=api_version,json=apiVersion,proto3,enum=kvrpcpb.APIVersion" json:"api_version,omitempty"`
	// cipher_iv is used to encrypt/decrypt sst
	CipherIv             []byte   `protobuf:"bytes,12,opt,name=cipher_iv,json=cipherIv,proto3" json:"cipher_iv,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SSTMeta) Descriptor 

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

func (*SSTMeta) GetApiVersion 

func (m *SSTMeta) GetApiVersion() kvrpcpb.APIVersion

func (*SSTMeta) GetCfName 

func (m *SSTMeta) GetCfName() string

func (*SSTMeta) GetCipherIv 

func (m *SSTMeta) GetCipherIv() []byte

func (*SSTMeta) GetCrc32 

func (m *SSTMeta) GetCrc32() uint32

func (*SSTMeta) GetEndKeyExclusive 

func (m *SSTMeta) GetEndKeyExclusive() bool

func (*SSTMeta) GetLength 

func (m *SSTMeta) GetLength() uint64

func (*SSTMeta) GetRange 

func (m *SSTMeta) GetRange() *Range

func (*SSTMeta) GetRegionEpoch 

func (m *SSTMeta) GetRegionEpoch() *metapb.RegionEpoch

func (*SSTMeta) GetRegionId 

func (m *SSTMeta) GetRegionId() uint64

func (*SSTMeta) GetTotalBytes 

func (m *SSTMeta) GetTotalBytes() uint64

func (*SSTMeta) GetTotalKvs 

func (m *SSTMeta) GetTotalKvs() uint64

func (*SSTMeta) GetUuid 

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

func (*SSTMeta) Marshal 

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

func (*SSTMeta) MarshalTo 

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

func (*SSTMeta) MarshalToSizedBuffer 

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

func (*SSTMeta) ProtoMessage 

func (*SSTMeta) ProtoMessage()

func (*SSTMeta) Reset 

func (m *SSTMeta) Reset()

func (*SSTMeta) Size 

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

func (*SSTMeta) String 

func (m *SSTMeta) String() string

func (*SSTMeta) Unmarshal 

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

func (*SSTMeta) XXX_DiscardUnknown 

func (m *SSTMeta) XXX_DiscardUnknown()

func (*SSTMeta) XXX_Marshal 

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

func (*SSTMeta) XXX_Merge 

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

func (*SSTMeta) XXX_Size 

func (m *SSTMeta) XXX_Size() int

func (*SSTMeta) XXX_Unmarshal 

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

type SetDownloadSpeedLimitRequest 

type SetDownloadSpeedLimitRequest struct {
	// The download speed limit (bytes/second). Set to 0 for unlimited speed.
	SpeedLimit           uint64   `protobuf:"varint,1,opt,name=speed_limit,json=speedLimit,proto3" json:"speed_limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDownloadSpeedLimitRequest) Descriptor 

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

func (*SetDownloadSpeedLimitRequest) GetSpeedLimit 

func (m *SetDownloadSpeedLimitRequest) GetSpeedLimit() uint64

func (*SetDownloadSpeedLimitRequest) Marshal 

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

func (*SetDownloadSpeedLimitRequest) MarshalTo 

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

func (*SetDownloadSpeedLimitRequest) MarshalToSizedBuffer 

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

func (*SetDownloadSpeedLimitRequest) ProtoMessage 

func (*SetDownloadSpeedLimitRequest) ProtoMessage()

func (*SetDownloadSpeedLimitRequest) Reset 

func (m *SetDownloadSpeedLimitRequest) Reset()

func (*SetDownloadSpeedLimitRequest) Size 

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

func (*SetDownloadSpeedLimitRequest) String 

func (m *SetDownloadSpeedLimitRequest) String() string

func (*SetDownloadSpeedLimitRequest) Unmarshal 

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

func (*SetDownloadSpeedLimitRequest) XXX_DiscardUnknown 

func (m *SetDownloadSpeedLimitRequest) XXX_DiscardUnknown()

func (*SetDownloadSpeedLimitRequest) XXX_Marshal 

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

func (*SetDownloadSpeedLimitRequest) XXX_Merge 

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

func (*SetDownloadSpeedLimitRequest) XXX_Size 

func (m *SetDownloadSpeedLimitRequest) XXX_Size() int

func (*SetDownloadSpeedLimitRequest) XXX_Unmarshal 

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

type SetDownloadSpeedLimitResponse 

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

func (*SetDownloadSpeedLimitResponse) Descriptor 

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

func (*SetDownloadSpeedLimitResponse) Marshal 

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

func (*SetDownloadSpeedLimitResponse) MarshalTo 

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

func (*SetDownloadSpeedLimitResponse) MarshalToSizedBuffer 

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

func (*SetDownloadSpeedLimitResponse) ProtoMessage 

func (*SetDownloadSpeedLimitResponse) ProtoMessage()

func (*SetDownloadSpeedLimitResponse) Reset 

func (m *SetDownloadSpeedLimitResponse) Reset()

func (*SetDownloadSpeedLimitResponse) Size 

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

func (*SetDownloadSpeedLimitResponse) String 

func (m *SetDownloadSpeedLimitResponse) String() string

func (*SetDownloadSpeedLimitResponse) Unmarshal 

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

func (*SetDownloadSpeedLimitResponse) XXX_DiscardUnknown 

func (m *SetDownloadSpeedLimitResponse) XXX_DiscardUnknown()

func (*SetDownloadSpeedLimitResponse) XXX_Marshal 

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

func (*SetDownloadSpeedLimitResponse) XXX_Merge 

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

func (*SetDownloadSpeedLimitResponse) XXX_Size 

func (m *SetDownloadSpeedLimitResponse) XXX_Size() int

func (*SetDownloadSpeedLimitResponse) XXX_Unmarshal 

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

type SuspendImportRPCRequest 

type SuspendImportRPCRequest struct {
	// whether to suspend new imports.
	ShouldSuspendImports bool `protobuf:"varint,1,opt,name=should_suspend_imports,json=shouldSuspendImports,proto3" json:"should_suspend_imports,omitempty"`
	// the duration of import service suspension
	// when should_deny_imports is false,
	// this won't take effect.
	DurationInSecs uint64 `protobuf:"varint,2,opt,name=duration_in_secs,json=durationInSecs,proto3" json:"duration_in_secs,omitempty"`
	// The identifier for the caller.
	Caller               string   `protobuf:"bytes,3,opt,name=caller,proto3" json:"caller,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SuspendImportRPCRequest) Descriptor 

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

func (*SuspendImportRPCRequest) GetCaller 

func (m *SuspendImportRPCRequest) GetCaller() string

func (*SuspendImportRPCRequest) GetDurationInSecs 

func (m *SuspendImportRPCRequest) GetDurationInSecs() uint64

func (*SuspendImportRPCRequest) GetShouldSuspendImports 

func (m *SuspendImportRPCRequest) GetShouldSuspendImports() bool

func (*SuspendImportRPCRequest) Marshal 

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

func (*SuspendImportRPCRequest) MarshalTo 

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

func (*SuspendImportRPCRequest) MarshalToSizedBuffer 

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

func (*SuspendImportRPCRequest) ProtoMessage 

func (*SuspendImportRPCRequest) ProtoMessage()

func (*SuspendImportRPCRequest) Reset 

func (m *SuspendImportRPCRequest) Reset()

func (*SuspendImportRPCRequest) Size 

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

func (*SuspendImportRPCRequest) String 

func (m *SuspendImportRPCRequest) String() string

func (*SuspendImportRPCRequest) Unmarshal 

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

func (*SuspendImportRPCRequest) XXX_DiscardUnknown 

func (m *SuspendImportRPCRequest) XXX_DiscardUnknown()

func (*SuspendImportRPCRequest) XXX_Marshal 

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

func (*SuspendImportRPCRequest) XXX_Merge 

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

func (*SuspendImportRPCRequest) XXX_Size 

func (m *SuspendImportRPCRequest) XXX_Size() int

func (*SuspendImportRPCRequest) XXX_Unmarshal 

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

type SuspendImportRPCResponse 

type SuspendImportRPCResponse struct {
	// The last state before this RPC.
	AlreadySuspended     bool     `protobuf:"varint,1,opt,name=already_suspended,json=alreadySuspended,proto3" json:"already_suspended,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SuspendImportRPCResponse) Descriptor 

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

func (*SuspendImportRPCResponse) GetAlreadySuspended 

func (m *SuspendImportRPCResponse) GetAlreadySuspended() bool

func (*SuspendImportRPCResponse) Marshal 

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

func (*SuspendImportRPCResponse) MarshalTo 

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

func (*SuspendImportRPCResponse) MarshalToSizedBuffer 

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

func (*SuspendImportRPCResponse) ProtoMessage 

func (*SuspendImportRPCResponse) ProtoMessage()

func (*SuspendImportRPCResponse) Reset 

func (m *SuspendImportRPCResponse) Reset()

func (*SuspendImportRPCResponse) Size 

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

func (*SuspendImportRPCResponse) String 

func (m *SuspendImportRPCResponse) String() string

func (*SuspendImportRPCResponse) Unmarshal 

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

func (*SuspendImportRPCResponse) XXX_DiscardUnknown 

func (m *SuspendImportRPCResponse) XXX_DiscardUnknown()

func (*SuspendImportRPCResponse) XXX_Marshal 

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

func (*SuspendImportRPCResponse) XXX_Merge 

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

func (*SuspendImportRPCResponse) XXX_Size 

func (m *SuspendImportRPCResponse) XXX_Size() int

func (*SuspendImportRPCResponse) XXX_Unmarshal 

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

type SwitchMode 

type SwitchMode int32
const (
	SwitchMode_Normal SwitchMode = 0
	SwitchMode_Import SwitchMode = 1
)

func (SwitchMode) EnumDescriptor 

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

func (SwitchMode) String 

func (x SwitchMode) String() string

type SwitchModeRequest 

type SwitchModeRequest struct {
	Mode                 SwitchMode `protobuf:"varint,1,opt,name=mode,proto3,enum=import_sstpb.SwitchMode" json:"mode,omitempty"`
	Ranges               []*Range   `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*SwitchModeRequest) Descriptor 

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

func (*SwitchModeRequest) GetMode 

func (m *SwitchModeRequest) GetMode() SwitchMode

func (*SwitchModeRequest) GetRanges 

func (m *SwitchModeRequest) GetRanges() []*Range

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 UnimplementedImportSSTServer 

type UnimplementedImportSSTServer struct {
}

UnimplementedImportSSTServer can be embedded to have forward compatible implementations.

func (*UnimplementedImportSSTServer) Apply 

func (*UnimplementedImportSSTServer) Apply(ctx context.Context, req *ApplyRequest) (*ApplyResponse, error)

func (*UnimplementedImportSSTServer) ClearFiles 

func (*UnimplementedImportSSTServer) ClearFiles(ctx context.Context, req *ClearRequest) (*ClearResponse, error)

func (*UnimplementedImportSSTServer) Compact 

func (*UnimplementedImportSSTServer) Compact(ctx context.Context, req *CompactRequest) (*CompactResponse, error)

func (*UnimplementedImportSSTServer) Download 

func (*UnimplementedImportSSTServer) Download(ctx context.Context, req *DownloadRequest) (*DownloadResponse, error)

func (*UnimplementedImportSSTServer) DuplicateDetect 

func (*UnimplementedImportSSTServer) DuplicateDetect(req *DuplicateDetectRequest, srv ImportSST_DuplicateDetectServer) error

func (*UnimplementedImportSSTServer) GetMode 

func (*UnimplementedImportSSTServer) GetMode(ctx context.Context, req *GetModeRequest) (*GetModeResponse, error)

func (*UnimplementedImportSSTServer) Ingest 

func (*UnimplementedImportSSTServer) Ingest(ctx context.Context, req *IngestRequest) (*IngestResponse, error)

func (*UnimplementedImportSSTServer) MultiIngest 

func (*UnimplementedImportSSTServer) MultiIngest(ctx context.Context, req *MultiIngestRequest) (*IngestResponse, error)

func (*UnimplementedImportSSTServer) RawWrite 

func (*UnimplementedImportSSTServer) RawWrite(srv ImportSST_RawWriteServer) error

func (*UnimplementedImportSSTServer) SetDownloadSpeedLimit 

func (*UnimplementedImportSSTServer) SetDownloadSpeedLimit(ctx context.Context, req *SetDownloadSpeedLimitRequest) (*SetDownloadSpeedLimitResponse, error)

func (*UnimplementedImportSSTServer) SuspendImportRPC 

func (*UnimplementedImportSSTServer) SuspendImportRPC(ctx context.Context, req *SuspendImportRPCRequest) (*SuspendImportRPCResponse, error)

func (*UnimplementedImportSSTServer) SwitchMode 

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

func (*UnimplementedImportSSTServer) Upload 

func (*UnimplementedImportSSTServer) Upload(srv ImportSST_UploadServer) error

func (*UnimplementedImportSSTServer) Write 

func (*UnimplementedImportSSTServer) Write(srv ImportSST_WriteServer) error

type UploadRequest 

type UploadRequest struct {
	// Types that are valid to be assigned to Chunk:
	//	*UploadRequest_Meta
	//	*UploadRequest_Data
	Chunk                isUploadRequest_Chunk `protobuf_oneof:"chunk"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*UploadRequest) Descriptor 

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

func (*UploadRequest) GetChunk 

func (m *UploadRequest) GetChunk() isUploadRequest_Chunk

func (*UploadRequest) GetData 

func (m *UploadRequest) GetData() []byte

func (*UploadRequest) GetMeta 

func (m *UploadRequest) GetMeta() *SSTMeta

func (*UploadRequest) Marshal 

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

func (*UploadRequest) MarshalTo 

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

func (*UploadRequest) MarshalToSizedBuffer 

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

func (*UploadRequest) ProtoMessage 

func (*UploadRequest) ProtoMessage()

func (*UploadRequest) Reset 

func (m *UploadRequest) Reset()

func (*UploadRequest) Size 

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

func (*UploadRequest) String 

func (m *UploadRequest) String() string

func (*UploadRequest) Unmarshal 

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

func (*UploadRequest) XXX_DiscardUnknown 

func (m *UploadRequest) XXX_DiscardUnknown()

func (*UploadRequest) XXX_Marshal 

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

func (*UploadRequest) XXX_Merge 

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

func (*UploadRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*UploadRequest) XXX_Size 

func (m *UploadRequest) XXX_Size() int

func (*UploadRequest) XXX_Unmarshal 

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

type UploadRequest_Data 

type UploadRequest_Data struct {
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3,oneof" json:"data,omitempty"`
}

func (*UploadRequest_Data) MarshalTo 

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

func (*UploadRequest_Data) MarshalToSizedBuffer 

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

func (*UploadRequest_Data) Size 

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

type UploadRequest_Meta 

type UploadRequest_Meta struct {
	Meta *SSTMeta `protobuf:"bytes,1,opt,name=meta,proto3,oneof" json:"meta,omitempty"`
}

func (*UploadRequest_Meta) MarshalTo 

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

func (*UploadRequest_Meta) MarshalToSizedBuffer 

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

func (*UploadRequest_Meta) Size 

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

type UploadResponse 

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

func (*UploadResponse) Descriptor 

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

func (*UploadResponse) Marshal 

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

func (*UploadResponse) MarshalTo 

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

func (*UploadResponse) MarshalToSizedBuffer 

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

func (*UploadResponse) ProtoMessage 

func (*UploadResponse) ProtoMessage()

func (*UploadResponse) Reset 

func (m *UploadResponse) Reset()

func (*UploadResponse) Size 

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

func (*UploadResponse) String 

func (m *UploadResponse) String() string

func (*UploadResponse) Unmarshal 

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

func (*UploadResponse) XXX_DiscardUnknown 

func (m *UploadResponse) XXX_DiscardUnknown()

func (*UploadResponse) XXX_Marshal 

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

func (*UploadResponse) XXX_Merge 

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

func (*UploadResponse) XXX_Size 

func (m *UploadResponse) XXX_Size() int

func (*UploadResponse) XXX_Unmarshal 

func (m *UploadResponse) 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"`
	Pairs                []*Pair  `protobuf:"bytes,2,rep,name=pairs,proto3" json:"pairs,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) GetPairs 

func (m *WriteBatch) GetPairs() []*Pair

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 WriteRequest 

type WriteRequest struct {
	// Types that are valid to be assigned to Chunk:
	//	*WriteRequest_Meta
	//	*WriteRequest_Batch
	Chunk                isWriteRequest_Chunk `protobuf_oneof:"chunk"`
	Context              *kvrpcpb.Context     `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetBatch 

func (m *WriteRequest) GetBatch() *WriteBatch

func (*WriteRequest) GetChunk 

func (m *WriteRequest) GetChunk() isWriteRequest_Chunk

func (*WriteRequest) GetContext 

func (m *WriteRequest) GetContext() *kvrpcpb.Context

func (*WriteRequest) GetMeta 

func (m *WriteRequest) GetMeta() *SSTMeta

func (*WriteRequest) Marshal 

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

func (*WriteRequest) MarshalTo 

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

func (*WriteRequest) MarshalToSizedBuffer 

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

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) Size 

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

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) Unmarshal 

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

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

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

func (*WriteRequest) XXX_Merge 

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

func (*WriteRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

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

type WriteRequest_Batch 

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

func (*WriteRequest_Batch) MarshalTo 

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

func (*WriteRequest_Batch) MarshalToSizedBuffer 

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

func (*WriteRequest_Batch) Size 

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

type WriteRequest_Meta 

type WriteRequest_Meta struct {
	Meta *SSTMeta `protobuf:"bytes,1,opt,name=meta,proto3,oneof" json:"meta,omitempty"`
}

func (*WriteRequest_Meta) MarshalTo 

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

func (*WriteRequest_Meta) MarshalToSizedBuffer 

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

func (*WriteRequest_Meta) Size 

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

type WriteResponse 

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

func (*WriteResponse) Descriptor 

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

func (*WriteResponse) GetError 

func (m *WriteResponse) GetError() *Error

func (*WriteResponse) GetMetas 

func (m *WriteResponse) GetMetas() []*SSTMeta

func (*WriteResponse) Marshal 

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

func (*WriteResponse) MarshalTo 

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

func (*WriteResponse) MarshalToSizedBuffer 

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

func (*WriteResponse) ProtoMessage 

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) Reset 

func (m *WriteResponse) Reset()

func (*WriteResponse) Size 

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

func (*WriteResponse) String 

func (m *WriteResponse) String() string

func (*WriteResponse) Unmarshal 

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

func (*WriteResponse) XXX_DiscardUnknown 

func (m *WriteResponse) XXX_DiscardUnknown()

func (*WriteResponse) XXX_Marshal 

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

func (*WriteResponse) XXX_Merge 

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

func (*WriteResponse) XXX_Size 

func (m *WriteResponse) XXX_Size() int

func (*WriteResponse) XXX_Unmarshal 

func (m *WriteResponse) 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.