backup

package
v0.0.0-...-e8eeb94 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 14 Imported by: 71

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthBrpb        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBrpb          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBrpb = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var BackupMode_name = map[int32]string{
	0: "SCAN",
	1: "FILE",
}
View Source 
var BackupMode_value = map[string]int32{
	"SCAN": 0,
	"FILE": 1,
}
View Source 
var CompressionType_name = map[int32]string{
	0: "UNKNOWN",
	1: "LZ4",
	2: "SNAPPY",
	3: "ZSTD",
}
View Source 
var CompressionType_value = map[string]int32{
	"UNKNOWN": 0,
	"LZ4":     1,
	"SNAPPY":  2,
	"ZSTD":    3,
}
View Source 
var FileType_name = map[int32]string{
	0: "Delete",
	1: "Put",
}
View Source 
var FileType_value = map[string]int32{
	"Delete": 0,
	"Put":    1,
}
View Source 
var MetaVersion_name = map[int32]string{
	0: "V1",
	1: "V2",
}
View Source 
var MetaVersion_value = map[string]int32{
	"V1": 0,
	"V2": 1,
}
View Source 
var MigrationVersion_name = map[int32]string{
	0: "M0",
	1: "M1",
}
View Source 
var MigrationVersion_value = map[string]int32{
	"M0": 0,
	"M1": 1,
}
View Source 
var PrepareSnapshotBackupEventType_name = map[int32]string{
	0: "WaitApplyDone",
	1: "UpdateLeaseResult",
}
View Source 
var PrepareSnapshotBackupEventType_value = map[string]int32{
	"WaitApplyDone":     0,
	"UpdateLeaseResult": 1,
}
View Source 
var PrepareSnapshotBackupRequestType_name = map[int32]string{
	0: "UpdateLease",
	1: "WaitApply",
	2: "Finish",
}
View Source 
var PrepareSnapshotBackupRequestType_value = map[string]int32{
	"UpdateLease": 0,
	"WaitApply":   1,
	"Finish":      2,
}

Functions

func RegisterBackupServer 

func RegisterBackupServer(s *grpc.Server, srv BackupServer)

func RegisterExternalStorageServer 

func RegisterExternalStorageServer(s *grpc.Server, srv ExternalStorageServer)

Types

type AzureBlobStorage 

type AzureBlobStorage struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// Alias: container
	Bucket string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// Notice: prefix starts without `/`, otherwise the first directory's name is empty.
	Prefix string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// Alias: access_tier.
	// See https://docs.microsoft.com/en-us/azure/storage/blobs/access-tiers-overview
	StorageClass string `protobuf:"bytes,4,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	// if empty, try to read account_name from the node's environment variable $AZURE_STORAGE_ACCOUNT.
	AccountName string `protobuf:"bytes,5,opt,name=account_name,json=accountName,proto3" json:"account_name,omitempty"`
	// There are 3 kinds of credentials, and the priority order is
	//   `SAS > Shared key > Azure AD (env) > Shared key (env)`.
	//
	// 1. Use shared key to access the azure blob
	// If the node's environment variables($AZURE_CLIENT_ID, $AZURE_TENANT_ID, $AZURE_CLIENT_SECRET) exist,
	// prefer to use token to access the azure blob.
	//
	//   See https://learn.microsoft.com/en-us/rest/api/storageservices/authorize-with-shared-key
	//
	// Otherwise, if empty, try to read shared key from the node's environment variable $AZURE_STORAGE_KEY.
	SharedKey string `protobuf:"bytes,6,opt,name=shared_key,json=sharedKey,proto3" json:"shared_key,omitempty"`
	// 2. Use Azure AD (Azure Active Directory) to access the azure blob
	//
	//   See https://learn.microsoft.com/en-us/rest/api/storageservices/authorize-with-azure-active-directory
	//
	// The Azure AD would generate the token, which tasks some time.
	// So it is not recommanded to generate the token in each request.
	// // AzureActiveDirectory azure_ad = #;
	//
	// 3. Use SAS (shared access signature)
	//
	//   See https://learn.microsoft.com/en-us/rest/api/storageservices/delegate-access-with-shared-access-signature
	//
	AccessSig string `protobuf:"bytes,8,opt,name=access_sig,json=accessSig,proto3" json:"access_sig,omitempty"`
	// Server Side Encryption, 2 types in total:
	//
	// 1. Specify an encryption scope for uploaded blobs.
	//
	//   See https://learn.microsoft.com/en-us/azure/storage/blobs/encryption-scope-manage?tabs=powershell#upload-a-blob-with-an-encryption-scope
	//
	EncryptionScope string `protobuf:"bytes,9,opt,name=encryption_scope,json=encryptionScope,proto3" json:"encryption_scope,omitempty"`
	// 2. Provide an encryption key on a request to blob storage.
	//
	//   See https://learn.microsoft.com/en-us/azure/storage/blobs/encryption-customer-provided-keys
	//
	EncryptionKey *AzureCustomerKey `protobuf:"bytes,10,opt,name=encryption_key,json=encryptionKey,proto3" json:"encryption_key,omitempty"`
}

AzureBlobStorage storage backend saves files into azure blob storage.

func (*AzureBlobStorage) Descriptor 

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

func (*AzureBlobStorage) GetAccessSig 

func (m *AzureBlobStorage) GetAccessSig() string

func (*AzureBlobStorage) GetAccountName 

func (m *AzureBlobStorage) GetAccountName() string

func (*AzureBlobStorage) GetBucket 

func (m *AzureBlobStorage) GetBucket() string

func (*AzureBlobStorage) GetEncryptionKey 

func (m *AzureBlobStorage) GetEncryptionKey() *AzureCustomerKey

func (*AzureBlobStorage) GetEncryptionScope 

func (m *AzureBlobStorage) GetEncryptionScope() string

func (*AzureBlobStorage) GetEndpoint 

func (m *AzureBlobStorage) GetEndpoint() string

func (*AzureBlobStorage) GetPrefix 

func (m *AzureBlobStorage) GetPrefix() string

func (*AzureBlobStorage) GetSharedKey 

func (m *AzureBlobStorage) GetSharedKey() string

func (*AzureBlobStorage) GetStorageClass 

func (m *AzureBlobStorage) GetStorageClass() string

func (*AzureBlobStorage) Marshal 

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

func (*AzureBlobStorage) MarshalTo 

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

func (*AzureBlobStorage) MarshalToSizedBuffer 

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

func (*AzureBlobStorage) ProtoMessage 

func (*AzureBlobStorage) ProtoMessage()

func (*AzureBlobStorage) Reset 

func (m *AzureBlobStorage) Reset()

func (*AzureBlobStorage) Size 

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

func (*AzureBlobStorage) String 

func (m *AzureBlobStorage) String() string

func (*AzureBlobStorage) Unmarshal 

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

func (*AzureBlobStorage) XXX_DiscardUnknown 

func (m *AzureBlobStorage) XXX_DiscardUnknown()

func (*AzureBlobStorage) XXX_Marshal 

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

func (*AzureBlobStorage) XXX_Merge 

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

func (*AzureBlobStorage) XXX_Size 

func (m *AzureBlobStorage) XXX_Size() int

func (*AzureBlobStorage) XXX_Unmarshal 

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

type AzureCustomerKey 

type AzureCustomerKey struct {
	// A Base64-encoded AES-256 encryption key value.
	EncryptionKey string `protobuf:"bytes,1,opt,name=encryption_key,json=encryptionKey,proto3" json:"encryption_key,omitempty"`
	// The Base64-encoded SHA256 of the encryption key.
	EncryptionKeySha256 string `protobuf:"bytes,2,opt,name=encryption_key_sha256,json=encryptionKeySha256,proto3" json:"encryption_key_sha256,omitempty"`
}

The encryption algorithm must be AES256.

func (*AzureCustomerKey) Descriptor 

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

func (*AzureCustomerKey) GetEncryptionKey 

func (m *AzureCustomerKey) GetEncryptionKey() string

func (*AzureCustomerKey) GetEncryptionKeySha256 

func (m *AzureCustomerKey) GetEncryptionKeySha256() string

func (*AzureCustomerKey) Marshal 

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

func (*AzureCustomerKey) MarshalTo 

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

func (*AzureCustomerKey) MarshalToSizedBuffer 

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

func (*AzureCustomerKey) ProtoMessage 

func (*AzureCustomerKey) ProtoMessage()

func (*AzureCustomerKey) Reset 

func (m *AzureCustomerKey) Reset()

func (*AzureCustomerKey) Size 

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

func (*AzureCustomerKey) String 

func (m *AzureCustomerKey) String() string

func (*AzureCustomerKey) Unmarshal 

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

func (*AzureCustomerKey) XXX_DiscardUnknown 

func (m *AzureCustomerKey) XXX_DiscardUnknown()

func (*AzureCustomerKey) XXX_Marshal 

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

func (*AzureCustomerKey) XXX_Merge 

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

func (*AzureCustomerKey) XXX_Size 

func (m *AzureCustomerKey) XXX_Size() int

func (*AzureCustomerKey) XXX_Unmarshal 

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

type BackupClient 

type BackupClient interface {
	Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (Backup_BackupClient, error)
	// CheckPendingAdminOp used for snapshot backup. before we start snapshot for a TiKV.
	// we need stop all schedule first and make sure all in-flight schedule has finished.
	// this rpc check all pending conf change for leader.
	CheckPendingAdminOp(ctx context.Context, in *CheckAdminRequest, opts ...grpc.CallOption) (Backup_CheckPendingAdminOpClient, error)
	// PrepareSnapshotBackup is an advanced version of preparing snapshot backup.
	// Check the defination of `PrepareSnapshotBackupRequest` for more.
	PrepareSnapshotBackup(ctx context.Context, opts ...grpc.CallOption) (Backup_PrepareSnapshotBackupClient, error)
	// prepare is used for file-copy backup. before we start the backup for a TiKV.
	// we need invoke this function to generate the SST files map. or we get nothing to backup.
	Prepare(ctx context.Context, in *PrepareRequest, opts ...grpc.CallOption) (*PrepareResponse, error)
	// cleanup used for file-copy backup. after we finish the backup for a TiKV.
	// we need clean some internel state. e.g. checkpoint, SST File maps
	Cleanup(ctx context.Context, in *CleanupRequest, opts ...grpc.CallOption) (*CleanupResponse, error)
}

BackupClient is the client API for Backup service.

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

func NewBackupClient 

func NewBackupClient(cc *grpc.ClientConn) BackupClient

type BackupMeta 

type BackupMeta struct {
	// ID and version of backuped cluster.
	ClusterId      uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ClusterVersion string `protobuf:"bytes,2,opt,name=cluster_version,json=clusterVersion,proto3" json:"cluster_version,omitempty"`
	// Save the version of BR running backup jobs.
	BrVersion string `protobuf:"bytes,11,opt,name=br_version,json=brVersion,proto3" json:"br_version,omitempty"`
	// The backupmeta scheme version.
	Version int32 `protobuf:"varint,12,opt,name=version,proto3" json:"version,omitempty"`
	// A set of files that compose a backup.
	// Note: `files` is deprecated, as it bloats backupmeta. It is kept for
	//       compatibility, so new BR can restore older backups.
	Files []*File `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"`
	// An index to files contains data files.
	FileIndex *MetaFile `protobuf:"bytes,13,opt,name=file_index,json=fileIndex,proto3" json:"file_index,omitempty"`
	// A pair of timestamp specifies a time range of a backup.
	// For full backup, the start_version equals to the end_version,
	// it means point in time.
	// For incremental backup, the time range is specified as
	// (start_version, end_version].
	StartVersion uint64 `protobuf:"varint,5,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndVersion   uint64 `protobuf:"varint,6,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
	// Table metadata describes database and table info.
	// Note: `schemas` is deprecated, as it bloats backupmeta. It is kept for
	//       compatibility, so new BR can restore older backups.
	Schemas []*Schema `protobuf:"bytes,7,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// An index to files contains Schemas.
	SchemaIndex *MetaFile `protobuf:"bytes,14,opt,name=schema_index,json=schemaIndex,proto3" json:"schema_index,omitempty"`
	// If in raw kv mode, `start_versions`, `end_versions` and `schemas` will be
	// ignored, and the backup data's range is represented by raw_ranges.
	IsRawKv bool `protobuf:"varint,8,opt,name=is_raw_kv,json=isRawKv,proto3" json:"is_raw_kv,omitempty"`
	// Note: `raw_ranges` is deprecated, as it bloats backupmeta. It is kept for
	//       compatibility, so new BR can restore older backups.
	RawRanges []*RawRange `protobuf:"bytes,9,rep,name=raw_ranges,json=rawRanges,proto3" json:"raw_ranges,omitempty"`
	// An index to files contains RawRanges.
	RawRangeIndex *MetaFile `protobuf:"bytes,15,opt,name=raw_range_index,json=rawRangeIndex,proto3" json:"raw_range_index,omitempty"`
	// In incremental backup, DDLs which are completed in
	// (lastBackupTS, backupTS] will be stored here.
	// Note: `raw_ranges` is deprecated, as it bloats backupmeta. It is kept for
	//       compatibility, so new BR can restore older backups.
	Ddls []byte `protobuf:"bytes,10,opt,name=ddls,proto3" json:"ddls,omitempty"`
	// An index to files contains DDLs.
	DdlIndexes *MetaFile `protobuf:"bytes,16,opt,name=ddl_indexes,json=ddlIndexes,proto3" json:"ddl_indexes,omitempty"`
	// the backup result into `backupmeta` file
	BackupResult string `protobuf:"bytes,17,opt,name=backup_result,json=backupResult,proto3" json:"backup_result,omitempty"`
	// API version implies the encode of the key and value.
	ApiVersion kvrpcpb.APIVersion `protobuf:"varint,18,opt,name=api_version,json=apiVersion,proto3,enum=kvrpcpb.APIVersion" json:"api_version,omitempty"`
	// the placement policy info in backup cluster. we assume the policy won't be too much for one cluster.
	Policies []*PlacementPolicy `protobuf:"bytes,19,rep,name=policies,proto3" json:"policies,omitempty"`
	// new_collations_enabled specifies the config `new_collations_enabled_on_first_bootstrap` in tidb.
	NewCollationsEnabled string `protobuf:"bytes,20,opt,name=new_collations_enabled,json=newCollationsEnabled,proto3" json:"new_collations_enabled,omitempty"`
	// If in txn kv mode, `schemas` will be ignored, the backup data's range is as same as normal backup.
	IsTxnKv bool `protobuf:"varint,21,opt,name=is_txn_kv,json=isTxnKv,proto3" json:"is_txn_kv,omitempty"`
	// maintain the id mapping from upstream cluster to downstream cluster.
	DbMaps []*PitrDBMap `protobuf:"bytes,22,rep,name=db_maps,json=dbMaps,proto3" json:"db_maps,omitempty"`
	Mode   BackupMode   `protobuf:"varint,23,opt,name=mode,proto3,enum=backup.BackupMode" json:"mode,omitempty"`
	// record the backup range and the correspond SST files when using file-copy backup.
	Ranges []*BackupRange `protobuf:"bytes,24,rep,name=ranges,proto3" json:"ranges,omitempty"`
	// record the size of the backup data files and meta files
	BackupSize uint64 `protobuf:"varint,25,opt,name=backup_size,json=backupSize,proto3" json:"backup_size,omitempty"`
}

The message save the metadata of a backup.

func (*BackupMeta) Descriptor 

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

func (*BackupMeta) GetApiVersion 

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

func (*BackupMeta) GetBackupResult 

func (m *BackupMeta) GetBackupResult() string

func (*BackupMeta) GetBackupSize 

func (m *BackupMeta) GetBackupSize() uint64

func (*BackupMeta) GetBrVersion 

func (m *BackupMeta) GetBrVersion() string

func (*BackupMeta) GetClusterId 

func (m *BackupMeta) GetClusterId() uint64

func (*BackupMeta) GetClusterVersion 

func (m *BackupMeta) GetClusterVersion() string

func (*BackupMeta) GetDbMaps 

func (m *BackupMeta) GetDbMaps() []*PitrDBMap

func (*BackupMeta) GetDdlIndexes 

func (m *BackupMeta) GetDdlIndexes() *MetaFile

func (*BackupMeta) GetDdls 

func (m *BackupMeta) GetDdls() []byte

func (*BackupMeta) GetEndVersion 

func (m *BackupMeta) GetEndVersion() uint64

func (*BackupMeta) GetFileIndex 

func (m *BackupMeta) GetFileIndex() *MetaFile

func (*BackupMeta) GetFiles 

func (m *BackupMeta) GetFiles() []*File

func (*BackupMeta) GetIsRawKv 

func (m *BackupMeta) GetIsRawKv() bool

func (*BackupMeta) GetIsTxnKv 

func (m *BackupMeta) GetIsTxnKv() bool

func (*BackupMeta) GetMode 

func (m *BackupMeta) GetMode() BackupMode

func (*BackupMeta) GetNewCollationsEnabled 

func (m *BackupMeta) GetNewCollationsEnabled() string

func (*BackupMeta) GetPolicies 

func (m *BackupMeta) GetPolicies() []*PlacementPolicy

func (*BackupMeta) GetRanges 

func (m *BackupMeta) GetRanges() []*BackupRange

func (*BackupMeta) GetRawRangeIndex 

func (m *BackupMeta) GetRawRangeIndex() *MetaFile

func (*BackupMeta) GetRawRanges 

func (m *BackupMeta) GetRawRanges() []*RawRange

func (*BackupMeta) GetSchemaIndex 

func (m *BackupMeta) GetSchemaIndex() *MetaFile

func (*BackupMeta) GetSchemas 

func (m *BackupMeta) GetSchemas() []*Schema

func (*BackupMeta) GetStartVersion 

func (m *BackupMeta) GetStartVersion() uint64

func (*BackupMeta) GetVersion 

func (m *BackupMeta) GetVersion() int32

func (*BackupMeta) Marshal 

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

func (*BackupMeta) MarshalTo 

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

func (*BackupMeta) MarshalToSizedBuffer 

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

func (*BackupMeta) ProtoMessage 

func (*BackupMeta) ProtoMessage()

func (*BackupMeta) Reset 

func (m *BackupMeta) Reset()

func (*BackupMeta) Size 

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

func (*BackupMeta) String 

func (m *BackupMeta) String() string

func (*BackupMeta) Unmarshal 

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

func (*BackupMeta) XXX_DiscardUnknown 

func (m *BackupMeta) XXX_DiscardUnknown()

func (*BackupMeta) XXX_Marshal 

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

func (*BackupMeta) XXX_Merge 

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

func (*BackupMeta) XXX_Size 

func (m *BackupMeta) XXX_Size() int

func (*BackupMeta) XXX_Unmarshal 

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

type BackupMode 

type BackupMode int32

BackupMpde represents the mode of this whole backup request to the cluster. and we need to store it in `backupmeta`. 

const (
	// scan and generate precise SST file of a backup range.
	// then we don't need to do anything in future restore.
	// Note: this mode will cost the CPU resource of TiKV.
	BackupMode_SCAN BackupMode = 0
	// check and upload the coarse overlap SST files of a backup range.
	// then we need to use a merge iterator to filter unexpected kv in future restore.
	// Note: this mode will save the CPU resource of TiKV.
	BackupMode_FILE BackupMode = 1
)

func (BackupMode) EnumDescriptor 

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

func (BackupMode) String 

func (x BackupMode) String() string

type BackupRange 

type BackupRange struct {
	StartKey []byte  `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte  `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Files    []*File `protobuf:"bytes,3,rep,name=files,proto3" json:"files,omitempty"`
}

func (*BackupRange) Descriptor 

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

func (*BackupRange) GetEndKey 

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

func (*BackupRange) GetFiles 

func (m *BackupRange) GetFiles() []*File

func (*BackupRange) GetStartKey 

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

func (*BackupRange) Marshal 

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

func (*BackupRange) MarshalTo 

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

func (*BackupRange) MarshalToSizedBuffer 

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

func (*BackupRange) ProtoMessage 

func (*BackupRange) ProtoMessage()

func (*BackupRange) Reset 

func (m *BackupRange) Reset()

func (*BackupRange) Size 

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

func (*BackupRange) String 

func (m *BackupRange) String() string

func (*BackupRange) Unmarshal 

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

func (*BackupRange) XXX_DiscardUnknown 

func (m *BackupRange) XXX_DiscardUnknown()

func (*BackupRange) XXX_Marshal 

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

func (*BackupRange) XXX_Merge 

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

func (*BackupRange) XXX_Size 

func (m *BackupRange) XXX_Size() int

func (*BackupRange) XXX_Unmarshal 

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

type BackupRequest 

type BackupRequest struct {
	ClusterId    uint64 `protobuf:"varint,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,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"`
	StartVersion uint64 `protobuf:"varint,4,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndVersion   uint64 `protobuf:"varint,5,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
	// The I/O rate limit for backup request.
	RateLimit uint64 `protobuf:"varint,7,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	// The concurrency for executing the backup request in every tikv node.
	Concurrency    uint32          `protobuf:"varint,8,opt,name=concurrency,proto3" json:"concurrency,omitempty"`
	StorageBackend *StorageBackend `protobuf:"bytes,9,opt,name=storage_backend,json=storageBackend,proto3" json:"storage_backend,omitempty"`
	// If raw kv mode is enabled, `start_version` and `end_version` will be ignored, and `cf`
	// specifies which cf to backup.
	IsRawKv bool   `protobuf:"varint,10,opt,name=is_raw_kv,json=isRawKv,proto3" json:"is_raw_kv,omitempty"`
	Cf      string `protobuf:"bytes,11,opt,name=cf,proto3" json:"cf,omitempty"`
	// algorithm used for compress sst files
	CompressionType CompressionType `` /* 136-byte string literal not displayed */
	// sst compression level, some algorithms support negative compression levels
	CompressionLevel int32 `protobuf:"varint,13,opt,name=compression_level,json=compressionLevel,proto3" json:"compression_level,omitempty"`
	// The cipher_info is Used to encrypt sst
	CipherInfo *CipherInfo `protobuf:"bytes,14,opt,name=cipher_info,json=cipherInfo,proto3" json:"cipher_info,omitempty"`
	// dst_api_version indicates the key-value encoding version used by the
	// generated SST file. Accepted values:
	// 1. "v1": the generated SST files are encoded with api-v1, can be restored
	//    to TiKV clusters whose api version is set to v1.
	// 2. "v2": the generated SST files are encoded with api-v2, can be restored
	//    to TiKV clusters whose api version is set to v2.
	DstApiVersion kvrpcpb.APIVersion `` /* 128-byte string literal not displayed */
	// with checkpoint, some subintervals of the range have been backed up and recorded.
	// only the remaining sub ranges of the range need to be backed up this time.
	SubRanges []*kvrpcpb.KeyRange `protobuf:"bytes,16,rep,name=sub_ranges,json=subRanges,proto3" json:"sub_ranges,omitempty"`
	// only ranges in the same groups can be merged into one SST file.
	// the ranges in each groups are sorted.
	SortedSubRangesGroups []*SortedSubRanges `` /* 129-byte string literal not displayed */
	// replica_read indicates whether to use replica read for backup.
	// If it is false, the backup will only read data from leader.
	// If it is true, the backup will read data from both leader and follower.
	ReplicaRead bool       `protobuf:"varint,17,opt,name=replica_read,json=replicaRead,proto3" json:"replica_read,omitempty"`
	Mode        BackupMode `protobuf:"varint,18,opt,name=mode,proto3,enum=backup.BackupMode" json:"mode,omitempty"`
	// unique_id represents the handle of this backup. after we implement file-copy backup.
	// we need generate some internal states during the whole backup precedure.
	// this unique id is help to find the state effictively.
	UniqueId string           `protobuf:"bytes,19,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
	Context  *kvrpcpb.Context `protobuf:"bytes,20,opt,name=context,proto3" json:"context,omitempty"`
}

func (*BackupRequest) Descriptor 

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

func (*BackupRequest) GetCf 

func (m *BackupRequest) GetCf() string

func (*BackupRequest) GetCipherInfo 

func (m *BackupRequest) GetCipherInfo() *CipherInfo

func (*BackupRequest) GetClusterId 

func (m *BackupRequest) GetClusterId() uint64

func (*BackupRequest) GetCompressionLevel 

func (m *BackupRequest) GetCompressionLevel() int32

func (*BackupRequest) GetCompressionType 

func (m *BackupRequest) GetCompressionType() CompressionType

func (*BackupRequest) GetConcurrency 

func (m *BackupRequest) GetConcurrency() uint32

func (*BackupRequest) GetContext 

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

func (*BackupRequest) GetDstApiVersion 

func (m *BackupRequest) GetDstApiVersion() kvrpcpb.APIVersion

func (*BackupRequest) GetEndKey 

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

func (*BackupRequest) GetEndVersion 

func (m *BackupRequest) GetEndVersion() uint64

func (*BackupRequest) GetIsRawKv 

func (m *BackupRequest) GetIsRawKv() bool

func (*BackupRequest) GetMode 

func (m *BackupRequest) GetMode() BackupMode

func (*BackupRequest) GetRateLimit 

func (m *BackupRequest) GetRateLimit() uint64

func (*BackupRequest) GetReplicaRead 

func (m *BackupRequest) GetReplicaRead() bool

func (*BackupRequest) GetSortedSubRangesGroups 

func (m *BackupRequest) GetSortedSubRangesGroups() []*SortedSubRanges

func (*BackupRequest) GetStartKey 

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

func (*BackupRequest) GetStartVersion 

func (m *BackupRequest) GetStartVersion() uint64

func (*BackupRequest) GetStorageBackend 

func (m *BackupRequest) GetStorageBackend() *StorageBackend

func (*BackupRequest) GetSubRanges 

func (m *BackupRequest) GetSubRanges() []*kvrpcpb.KeyRange

func (*BackupRequest) GetUniqueId 

func (m *BackupRequest) GetUniqueId() string

func (*BackupRequest) Marshal 

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

func (*BackupRequest) MarshalTo 

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

func (*BackupRequest) MarshalToSizedBuffer 

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

func (*BackupRequest) ProtoMessage 

func (*BackupRequest) ProtoMessage()

func (*BackupRequest) Reset 

func (m *BackupRequest) Reset()

func (*BackupRequest) Size 

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

func (*BackupRequest) String 

func (m *BackupRequest) String() string

func (*BackupRequest) Unmarshal 

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

func (*BackupRequest) XXX_DiscardUnknown 

func (m *BackupRequest) XXX_DiscardUnknown()

func (*BackupRequest) XXX_Marshal 

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

func (*BackupRequest) XXX_Merge 

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

func (*BackupRequest) XXX_Size 

func (m *BackupRequest) XXX_Size() int

func (*BackupRequest) XXX_Unmarshal 

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

type BackupResponse 

type BackupResponse struct {
	Error    *Error  `protobuf:"bytes,1,opt,name=error,proto3" json:"error,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"`
	Files    []*File `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"`
	// API version implies the encode of the key and value.
	ApiVersion kvrpcpb.APIVersion `protobuf:"varint,5,opt,name=api_version,json=apiVersion,proto3,enum=kvrpcpb.APIVersion" json:"api_version,omitempty"`
}

func (*BackupResponse) Descriptor 

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

func (*BackupResponse) GetApiVersion 

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

func (*BackupResponse) GetEndKey 

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

func (*BackupResponse) GetError 

func (m *BackupResponse) GetError() *Error

func (*BackupResponse) GetFiles 

func (m *BackupResponse) GetFiles() []*File

func (*BackupResponse) GetStartKey 

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

func (*BackupResponse) Marshal 

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

func (*BackupResponse) MarshalTo 

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

func (*BackupResponse) MarshalToSizedBuffer 

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

func (*BackupResponse) ProtoMessage 

func (*BackupResponse) ProtoMessage()

func (*BackupResponse) Reset 

func (m *BackupResponse) Reset()

func (*BackupResponse) Size 

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

func (*BackupResponse) String 

func (m *BackupResponse) String() string

func (*BackupResponse) Unmarshal 

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

func (*BackupResponse) XXX_DiscardUnknown 

func (m *BackupResponse) XXX_DiscardUnknown()

func (*BackupResponse) XXX_Marshal 

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

func (*BackupResponse) XXX_Merge 

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

func (*BackupResponse) XXX_Size 

func (m *BackupResponse) XXX_Size() int

func (*BackupResponse) XXX_Unmarshal 

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

type BackupServer 

type BackupServer interface {
	Backup(*BackupRequest, Backup_BackupServer) error
	// CheckPendingAdminOp used for snapshot backup. before we start snapshot for a TiKV.
	// we need stop all schedule first and make sure all in-flight schedule has finished.
	// this rpc check all pending conf change for leader.
	CheckPendingAdminOp(*CheckAdminRequest, Backup_CheckPendingAdminOpServer) error
	// PrepareSnapshotBackup is an advanced version of preparing snapshot backup.
	// Check the defination of `PrepareSnapshotBackupRequest` for more.
	PrepareSnapshotBackup(Backup_PrepareSnapshotBackupServer) error
	// prepare is used for file-copy backup. before we start the backup for a TiKV.
	// we need invoke this function to generate the SST files map. or we get nothing to backup.
	Prepare(context.Context, *PrepareRequest) (*PrepareResponse, error)
	// cleanup used for file-copy backup. after we finish the backup for a TiKV.
	// we need clean some internel state. e.g. checkpoint, SST File maps
	Cleanup(context.Context, *CleanupRequest) (*CleanupResponse, error)
}

BackupServer is the server API for Backup service.

type Backup_BackupClient 

type Backup_BackupClient interface {
	Recv() (*BackupResponse, error)
	grpc.ClientStream
}

type Backup_BackupServer 

type Backup_BackupServer interface {
	Send(*BackupResponse) error
	grpc.ServerStream
}

type Backup_CheckPendingAdminOpClient 

type Backup_CheckPendingAdminOpClient interface {
	Recv() (*CheckAdminResponse, error)
	grpc.ClientStream
}

type Backup_CheckPendingAdminOpServer 

type Backup_CheckPendingAdminOpServer interface {
	Send(*CheckAdminResponse) error
	grpc.ServerStream
}

type Backup_PrepareSnapshotBackupClient 

type Backup_PrepareSnapshotBackupClient interface {
	Send(*PrepareSnapshotBackupRequest) error
	Recv() (*PrepareSnapshotBackupResponse, error)
	grpc.ClientStream
}

type Backup_PrepareSnapshotBackupServer 

type Backup_PrepareSnapshotBackupServer interface {
	Send(*PrepareSnapshotBackupResponse) error
	Recv() (*PrepareSnapshotBackupRequest, error)
	grpc.ServerStream
}

type Bucket 

type Bucket struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Region       string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	Bucket       string `protobuf:"bytes,4,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix       string `protobuf:"bytes,5,opt,name=prefix,proto3" json:"prefix,omitempty"`
	StorageClass string `protobuf:"bytes,6,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
}

func (*Bucket) Descriptor 

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

func (*Bucket) GetBucket 

func (m *Bucket) GetBucket() string

func (*Bucket) GetEndpoint 

func (m *Bucket) GetEndpoint() string

func (*Bucket) GetPrefix 

func (m *Bucket) GetPrefix() string

func (*Bucket) GetRegion 

func (m *Bucket) GetRegion() string

func (*Bucket) GetStorageClass 

func (m *Bucket) GetStorageClass() string

func (*Bucket) Marshal 

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

func (*Bucket) MarshalTo 

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

func (*Bucket) MarshalToSizedBuffer 

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

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) Reset 

func (m *Bucket) Reset()

func (*Bucket) Size 

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

func (*Bucket) String 

func (m *Bucket) String() string

func (*Bucket) Unmarshal 

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

func (*Bucket) XXX_DiscardUnknown 

func (m *Bucket) XXX_DiscardUnknown()

func (*Bucket) XXX_Marshal 

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

func (*Bucket) XXX_Merge 

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

func (*Bucket) XXX_Size 

func (m *Bucket) XXX_Size() int

func (*Bucket) XXX_Unmarshal 

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

type CheckAdminRequest 

type CheckAdminRequest struct {
}

func (*CheckAdminRequest) Descriptor 

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

func (*CheckAdminRequest) Marshal 

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

func (*CheckAdminRequest) MarshalTo 

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

func (*CheckAdminRequest) MarshalToSizedBuffer 

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

func (*CheckAdminRequest) ProtoMessage 

func (*CheckAdminRequest) ProtoMessage()

func (*CheckAdminRequest) Reset 

func (m *CheckAdminRequest) Reset()

func (*CheckAdminRequest) Size 

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

func (*CheckAdminRequest) String 

func (m *CheckAdminRequest) String() string

func (*CheckAdminRequest) Unmarshal 

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

func (*CheckAdminRequest) XXX_DiscardUnknown 

func (m *CheckAdminRequest) XXX_DiscardUnknown()

func (*CheckAdminRequest) XXX_Marshal 

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

func (*CheckAdminRequest) XXX_Merge 

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

func (*CheckAdminRequest) XXX_Size 

func (m *CheckAdminRequest) XXX_Size() int

func (*CheckAdminRequest) XXX_Unmarshal 

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

type CheckAdminResponse 

type CheckAdminResponse struct {
	Error           *Error         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Region          *metapb.Region `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	HasPendingAdmin bool           `protobuf:"varint,3,opt,name=has_pending_admin,json=hasPendingAdmin,proto3" json:"has_pending_admin,omitempty"`
}

func (*CheckAdminResponse) Descriptor 

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

func (*CheckAdminResponse) GetError 

func (m *CheckAdminResponse) GetError() *Error

func (*CheckAdminResponse) GetHasPendingAdmin 

func (m *CheckAdminResponse) GetHasPendingAdmin() bool

func (*CheckAdminResponse) GetRegion 

func (m *CheckAdminResponse) GetRegion() *metapb.Region

func (*CheckAdminResponse) Marshal 

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

func (*CheckAdminResponse) MarshalTo 

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

func (*CheckAdminResponse) MarshalToSizedBuffer 

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

func (*CheckAdminResponse) ProtoMessage 

func (*CheckAdminResponse) ProtoMessage()

func (*CheckAdminResponse) Reset 

func (m *CheckAdminResponse) Reset()

func (*CheckAdminResponse) Size 

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

func (*CheckAdminResponse) String 

func (m *CheckAdminResponse) String() string

func (*CheckAdminResponse) Unmarshal 

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

func (*CheckAdminResponse) XXX_DiscardUnknown 

func (m *CheckAdminResponse) XXX_DiscardUnknown()

func (*CheckAdminResponse) XXX_Marshal 

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

func (*CheckAdminResponse) XXX_Merge 

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

func (*CheckAdminResponse) XXX_Size 

func (m *CheckAdminResponse) XXX_Size() int

func (*CheckAdminResponse) XXX_Unmarshal 

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

type CipherInfo 

type CipherInfo struct {
	CipherType encryptionpb.EncryptionMethod `` /* 127-byte string literal not displayed */
	CipherKey  []byte                        `protobuf:"bytes,2,opt,name=cipher_key,json=cipherKey,proto3" json:"cipher_key,omitempty"`
}

func (*CipherInfo) Descriptor 

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

func (*CipherInfo) GetCipherKey 

func (m *CipherInfo) GetCipherKey() []byte

func (*CipherInfo) GetCipherType 

func (m *CipherInfo) GetCipherType() encryptionpb.EncryptionMethod

func (*CipherInfo) Marshal 

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

func (*CipherInfo) MarshalTo 

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

func (*CipherInfo) MarshalToSizedBuffer 

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

func (*CipherInfo) ProtoMessage 

func (*CipherInfo) ProtoMessage()

func (*CipherInfo) Reset 

func (m *CipherInfo) Reset()

func (*CipherInfo) Size 

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

func (*CipherInfo) String 

func (m *CipherInfo) String() string

func (*CipherInfo) Unmarshal 

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

func (*CipherInfo) XXX_DiscardUnknown 

func (m *CipherInfo) XXX_DiscardUnknown()

func (*CipherInfo) XXX_Marshal 

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

func (*CipherInfo) XXX_Merge 

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

func (*CipherInfo) XXX_Size 

func (m *CipherInfo) XXX_Size() int

func (*CipherInfo) XXX_Unmarshal 

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

type CleanupRequest 

type CleanupRequest struct {
	// unique_id represents the unique handle of the whole backup predecure.
	// it generated in prepare request and corrosponed to one specific backup.
	UniqueId string `protobuf:"bytes,1,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
}

func (*CleanupRequest) Descriptor 

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

func (*CleanupRequest) GetUniqueId 

func (m *CleanupRequest) GetUniqueId() string

func (*CleanupRequest) Marshal 

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

func (*CleanupRequest) MarshalTo 

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

func (*CleanupRequest) MarshalToSizedBuffer 

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

func (*CleanupRequest) ProtoMessage 

func (*CleanupRequest) ProtoMessage()

func (*CleanupRequest) Reset 

func (m *CleanupRequest) Reset()

func (*CleanupRequest) Size 

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

func (*CleanupRequest) String 

func (m *CleanupRequest) String() string

func (*CleanupRequest) Unmarshal 

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

func (*CleanupRequest) XXX_DiscardUnknown 

func (m *CleanupRequest) XXX_DiscardUnknown()

func (*CleanupRequest) XXX_Marshal 

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

func (*CleanupRequest) XXX_Merge 

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

func (*CleanupRequest) XXX_Size 

func (m *CleanupRequest) XXX_Size() int

func (*CleanupRequest) XXX_Unmarshal 

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

type CleanupResponse 

type CleanupResponse struct {
	Error   *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
}

func (*CleanupResponse) Descriptor 

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

func (*CleanupResponse) GetError 

func (m *CleanupResponse) GetError() *Error

func (*CleanupResponse) GetSuccess 

func (m *CleanupResponse) GetSuccess() bool

func (*CleanupResponse) Marshal 

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

func (*CleanupResponse) MarshalTo 

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

func (*CleanupResponse) MarshalToSizedBuffer 

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

func (*CleanupResponse) ProtoMessage 

func (*CleanupResponse) ProtoMessage()

func (*CleanupResponse) Reset 

func (m *CleanupResponse) Reset()

func (*CleanupResponse) Size 

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

func (*CleanupResponse) String 

func (m *CleanupResponse) String() string

func (*CleanupResponse) Unmarshal 

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

func (*CleanupResponse) XXX_DiscardUnknown 

func (m *CleanupResponse) XXX_DiscardUnknown()

func (*CleanupResponse) XXX_Marshal 

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

func (*CleanupResponse) XXX_Merge 

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

func (*CleanupResponse) XXX_Size 

func (m *CleanupResponse) XXX_Size() int

func (*CleanupResponse) XXX_Unmarshal 

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

type CloudDynamic 

type CloudDynamic struct {
	Bucket       *Bucket           `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	ProviderName string            `protobuf:"bytes,2,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"`
	Attrs        map[string]string `` /* 151-byte string literal not displayed */
}

CloudDynamic allows testing new cloud providers and new fields without changing protobuf definitions

func (*CloudDynamic) Descriptor 

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

func (*CloudDynamic) GetAttrs 

func (m *CloudDynamic) GetAttrs() map[string]string

func (*CloudDynamic) GetBucket 

func (m *CloudDynamic) GetBucket() *Bucket

func (*CloudDynamic) GetProviderName 

func (m *CloudDynamic) GetProviderName() string

func (*CloudDynamic) Marshal 

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

func (*CloudDynamic) MarshalTo 

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

func (*CloudDynamic) MarshalToSizedBuffer 

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

func (*CloudDynamic) ProtoMessage 

func (*CloudDynamic) ProtoMessage()

func (*CloudDynamic) Reset 

func (m *CloudDynamic) Reset()

func (*CloudDynamic) Size 

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

func (*CloudDynamic) String 

func (m *CloudDynamic) String() string

func (*CloudDynamic) Unmarshal 

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

func (*CloudDynamic) XXX_DiscardUnknown 

func (m *CloudDynamic) XXX_DiscardUnknown()

func (*CloudDynamic) XXX_Marshal 

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

func (*CloudDynamic) XXX_Merge 

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

func (*CloudDynamic) XXX_Size 

func (m *CloudDynamic) XXX_Size() int

func (*CloudDynamic) XXX_Unmarshal 

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

type ClusterIDError 

type ClusterIDError struct {
	Current uint64 `protobuf:"varint,1,opt,name=current,proto3" json:"current,omitempty"`
	Request uint64 `protobuf:"varint,2,opt,name=request,proto3" json:"request,omitempty"`
}

func (*ClusterIDError) Descriptor 

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

func (*ClusterIDError) GetCurrent 

func (m *ClusterIDError) GetCurrent() uint64

func (*ClusterIDError) GetRequest 

func (m *ClusterIDError) GetRequest() uint64

func (*ClusterIDError) Marshal 

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

func (*ClusterIDError) MarshalTo 

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

func (*ClusterIDError) MarshalToSizedBuffer 

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

func (*ClusterIDError) ProtoMessage 

func (*ClusterIDError) ProtoMessage()

func (*ClusterIDError) Reset 

func (m *ClusterIDError) Reset()

func (*ClusterIDError) Size 

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

func (*ClusterIDError) String 

func (m *ClusterIDError) String() string

func (*ClusterIDError) Unmarshal 

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

func (*ClusterIDError) XXX_DiscardUnknown 

func (m *ClusterIDError) XXX_DiscardUnknown()

func (*ClusterIDError) XXX_Marshal 

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

func (*ClusterIDError) XXX_Merge 

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

func (*ClusterIDError) XXX_Size 

func (m *ClusterIDError) XXX_Size() int

func (*ClusterIDError) XXX_Unmarshal 

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

type CompressionType 

type CompressionType int32

sst files or log files compression algorithm for log files, unknown means not use compression algorithm 

const (
	CompressionType_UNKNOWN CompressionType = 0
	CompressionType_LZ4     CompressionType = 1
	CompressionType_SNAPPY  CompressionType = 2
	CompressionType_ZSTD    CompressionType = 3
)

func (CompressionType) EnumDescriptor 

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

func (CompressionType) String 

func (x CompressionType) String() string

type DataFileGroup 

type DataFileGroup struct {
	// Path of the file.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Partitions of the file.
	DataFilesInfo []*DataFileInfo `protobuf:"bytes,2,rep,name=data_files_info,json=dataFilesInfo,proto3" json:"data_files_info,omitempty"`
	/// Below are extra information of the file, for better filtering files.
	// The min ts of the keys in the file.
	MinTs uint64 `protobuf:"varint,3,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	// The max ts of the keys in the file.
	MaxTs uint64 `protobuf:"varint,4,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	// The resolved ts of the region when saving the file.
	MinResolvedTs uint64 `protobuf:"varint,5,opt,name=min_resolved_ts,json=minResolvedTs,proto3" json:"min_resolved_ts,omitempty"`
	// The file length after compressed.
	Length uint64 `protobuf:"varint,6,opt,name=length,proto3" json:"length,omitempty"`
}

DataFileGroup is the merged file info in log-backup

func (*DataFileGroup) Descriptor 

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

func (*DataFileGroup) GetDataFilesInfo 

func (m *DataFileGroup) GetDataFilesInfo() []*DataFileInfo

func (*DataFileGroup) GetLength 

func (m *DataFileGroup) GetLength() uint64

func (*DataFileGroup) GetMaxTs 

func (m *DataFileGroup) GetMaxTs() uint64

func (*DataFileGroup) GetMinResolvedTs 

func (m *DataFileGroup) GetMinResolvedTs() uint64

func (*DataFileGroup) GetMinTs 

func (m *DataFileGroup) GetMinTs() uint64

func (*DataFileGroup) GetPath 

func (m *DataFileGroup) GetPath() string

func (*DataFileGroup) Marshal 

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

func (*DataFileGroup) MarshalTo 

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

func (*DataFileGroup) MarshalToSizedBuffer 

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

func (*DataFileGroup) ProtoMessage 

func (*DataFileGroup) ProtoMessage()

func (*DataFileGroup) Reset 

func (m *DataFileGroup) Reset()

func (*DataFileGroup) Size 

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

func (*DataFileGroup) String 

func (m *DataFileGroup) String() string

func (*DataFileGroup) Unmarshal 

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

func (*DataFileGroup) XXX_DiscardUnknown 

func (m *DataFileGroup) XXX_DiscardUnknown()

func (*DataFileGroup) XXX_Marshal 

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

func (*DataFileGroup) XXX_Merge 

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

func (*DataFileGroup) XXX_Size 

func (m *DataFileGroup) XXX_Size() int

func (*DataFileGroup) XXX_Unmarshal 

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

type DataFileInfo 

type DataFileInfo struct {
	// Checksum of the plaintext file, i.e., pre-compression, pre-encryption.
	Sha256 []byte `protobuf:"bytes,1,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// Path of the file.
	Path            string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	NumberOfEntries int64  `protobuf:"varint,3,opt,name=number_of_entries,json=numberOfEntries,proto3" json:"number_of_entries,omitempty"`
	/// Below are extra information of the file, for better filtering files.
	// The min ts of the keys in the file.
	MinTs uint64 `protobuf:"varint,4,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	// The max ts of the keys in the file.
	MaxTs uint64 `protobuf:"varint,5,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	// The resolved ts of the region when saving the file.
	ResolvedTs uint64 `protobuf:"varint,6,opt,name=resolved_ts,json=resolvedTs,proto3" json:"resolved_ts,omitempty"`
	// The region of the file.
	RegionId int64 `protobuf:"varint,7,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	// The key range of the file.
	// Encoded and starts with 'z'(internal key).
	StartKey []byte `protobuf:"bytes,8,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,9,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// The column family of the file.
	Cf string `protobuf:"bytes,10,opt,name=cf,proto3" json:"cf,omitempty"`
	// The operation type of the file.
	Type FileType `protobuf:"varint,11,opt,name=type,proto3,enum=backup.FileType" json:"type,omitempty"`
	// Whether the data file contains meta keys(m prefixed keys) only.
	IsMeta bool `protobuf:"varint,12,opt,name=is_meta,json=isMeta,proto3" json:"is_meta,omitempty"`
	// The table ID of the file contains, when `is_meta` is true, would be ignored.
	TableId int64 `protobuf:"varint,13,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// The file length.
	Length uint64 `protobuf:"varint,14,opt,name=length,proto3" json:"length,omitempty"`
	// The minimal begin ts in default cf if this file is write cf.
	MinBeginTsInDefaultCf uint64 `` /* 134-byte string literal not displayed */
	// Offset of the partition. compatible with V1 and V2.
	RangeOffset uint64 `protobuf:"varint,16,opt,name=range_offset,json=rangeOffset,proto3" json:"range_offset,omitempty"`
	// The range length of the merged file, if it exists.
	RangeLength uint64 `protobuf:"varint,17,opt,name=range_length,json=rangeLength,proto3" json:"range_length,omitempty"`
	// The compression type for the file.
	CompressionType CompressionType `` /* 136-byte string literal not displayed */
	// The CRC64XOR of all contents of the file.
	// In older versions, this might be empty.
	Crc64Xor uint64 `protobuf:"varint,19,opt,name=crc64xor,proto3" json:"crc64xor,omitempty"`
	// The original region range the log file belongs to.
	// In older versions, this might be empty.
	// This may not be accurative: file may contain keys less than this.
	RegionStartKey []byte `protobuf:"bytes,20,opt,name=region_start_key,json=regionStartKey,proto3" json:"region_start_key,omitempty"`
	// The original region range the log file belongs to.
	// In older versions, this might be empty.
	// This may not be accurative: file may contain keys greater than this.
	RegionEndKey []byte `protobuf:"bytes,21,opt,name=region_end_key,json=regionEndKey,proto3" json:"region_end_key,omitempty"`
	// The region epoch that the log file belongs to.
	// In older versions, this might be empty.
	// If a region get split or merged during observing, the file may contain multi epoches.
	// This may not be complete: file may contain records from other versions.
	//
	// If there is exactly one epoch,
	// `region_start_key` and `region_end_key` must match this epoch.
	RegionEpoch []*metapb.RegionEpoch `protobuf:"bytes,22,rep,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
	// Encryption information of this data file, not set if plaintext.
	FileEncryptionInfo *encryptionpb.FileEncryptionInfo `protobuf:"bytes,23,opt,name=file_encryption_info,json=fileEncryptionInfo,proto3" json:"file_encryption_info,omitempty"`
}

func (*DataFileInfo) Descriptor 

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

func (*DataFileInfo) GetCf 

func (m *DataFileInfo) GetCf() string

func (*DataFileInfo) GetCompressionType 

func (m *DataFileInfo) GetCompressionType() CompressionType

func (*DataFileInfo) GetCrc64Xor 

func (m *DataFileInfo) GetCrc64Xor() uint64

func (*DataFileInfo) GetEndKey 

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

func (*DataFileInfo) GetFileEncryptionInfo 

func (m *DataFileInfo) GetFileEncryptionInfo() *encryptionpb.FileEncryptionInfo

func (*DataFileInfo) GetIsMeta 

func (m *DataFileInfo) GetIsMeta() bool

func (*DataFileInfo) GetLength 

func (m *DataFileInfo) GetLength() uint64

func (*DataFileInfo) GetMaxTs 

func (m *DataFileInfo) GetMaxTs() uint64

func (*DataFileInfo) GetMinBeginTsInDefaultCf 

func (m *DataFileInfo) GetMinBeginTsInDefaultCf() uint64

func (*DataFileInfo) GetMinTs 

func (m *DataFileInfo) GetMinTs() uint64

func (*DataFileInfo) GetNumberOfEntries 

func (m *DataFileInfo) GetNumberOfEntries() int64

func (*DataFileInfo) GetPath 

func (m *DataFileInfo) GetPath() string

func (*DataFileInfo) GetRangeLength 

func (m *DataFileInfo) GetRangeLength() uint64

func (*DataFileInfo) GetRangeOffset 

func (m *DataFileInfo) GetRangeOffset() uint64

func (*DataFileInfo) GetRegionEndKey 

func (m *DataFileInfo) GetRegionEndKey() []byte

func (*DataFileInfo) GetRegionEpoch 

func (m *DataFileInfo) GetRegionEpoch() []*metapb.RegionEpoch

func (*DataFileInfo) GetRegionId 

func (m *DataFileInfo) GetRegionId() int64

func (*DataFileInfo) GetRegionStartKey 

func (m *DataFileInfo) GetRegionStartKey() []byte

func (*DataFileInfo) GetResolvedTs 

func (m *DataFileInfo) GetResolvedTs() uint64

func (*DataFileInfo) GetSha256 

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

func (*DataFileInfo) GetStartKey 

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

func (*DataFileInfo) GetTableId 

func (m *DataFileInfo) GetTableId() int64

func (*DataFileInfo) GetType 

func (m *DataFileInfo) GetType() FileType

func (*DataFileInfo) Marshal 

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

func (*DataFileInfo) MarshalTo 

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

func (*DataFileInfo) MarshalToSizedBuffer 

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

func (*DataFileInfo) ProtoMessage 

func (*DataFileInfo) ProtoMessage()

func (*DataFileInfo) Reset 

func (m *DataFileInfo) Reset()

func (*DataFileInfo) Size 

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

func (*DataFileInfo) String 

func (m *DataFileInfo) String() string

func (*DataFileInfo) Unmarshal 

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

func (*DataFileInfo) XXX_DiscardUnknown 

func (m *DataFileInfo) XXX_DiscardUnknown()

func (*DataFileInfo) XXX_Marshal 

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

func (*DataFileInfo) XXX_Merge 

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

func (*DataFileInfo) XXX_Size 

func (m *DataFileInfo) XXX_Size() int

func (*DataFileInfo) XXX_Unmarshal 

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

type DeleteSpansOfFile 

type DeleteSpansOfFile struct {
	Path  string  `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Spans []*Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
	// This is a hint for garbage collecting.
	// So we can easily check whether a set of spans consists the whole file.
	WholeFileLength uint64 `protobuf:"varint,3,opt,name=whole_file_length,json=wholeFileLength,proto3" json:"whole_file_length,omitempty"`
}

An extended version of `SpansOfFile`, added more metadata for the execution of delayed deletion.

func (*DeleteSpansOfFile) Descriptor 

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

func (*DeleteSpansOfFile) GetPath 

func (m *DeleteSpansOfFile) GetPath() string

func (*DeleteSpansOfFile) GetSpans 

func (m *DeleteSpansOfFile) GetSpans() []*Span

func (*DeleteSpansOfFile) GetWholeFileLength 

func (m *DeleteSpansOfFile) GetWholeFileLength() uint64

func (*DeleteSpansOfFile) Marshal 

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

func (*DeleteSpansOfFile) MarshalTo 

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

func (*DeleteSpansOfFile) MarshalToSizedBuffer 

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

func (*DeleteSpansOfFile) ProtoMessage 

func (*DeleteSpansOfFile) ProtoMessage()

func (*DeleteSpansOfFile) Reset 

func (m *DeleteSpansOfFile) Reset()

func (*DeleteSpansOfFile) Size 

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

func (*DeleteSpansOfFile) String 

func (m *DeleteSpansOfFile) String() string

func (*DeleteSpansOfFile) Unmarshal 

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

func (*DeleteSpansOfFile) XXX_DiscardUnknown 

func (m *DeleteSpansOfFile) XXX_DiscardUnknown()

func (*DeleteSpansOfFile) XXX_Marshal 

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

func (*DeleteSpansOfFile) XXX_Merge 

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

func (*DeleteSpansOfFile) XXX_Size 

func (m *DeleteSpansOfFile) XXX_Size() int

func (*DeleteSpansOfFile) XXX_Unmarshal 

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

type Error 

type Error struct {
	Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	// Types that are valid to be assigned to Detail:
	//	*Error_ClusterIdError
	//	*Error_KvError
	//	*Error_RegionError
	Detail isError_Detail `protobuf_oneof:"detail"`
}

func (*Error) Descriptor 

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

func (*Error) GetClusterIdError 

func (m *Error) GetClusterIdError() *ClusterIDError

func (*Error) GetDetail 

func (m *Error) GetDetail() isError_Detail

func (*Error) GetKvError 

func (m *Error) GetKvError() *kvrpcpb.KeyError

func (*Error) GetMsg 

func (m *Error) GetMsg() string

func (*Error) GetRegionError 

func (m *Error) GetRegionError() *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_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

type Error_ClusterIdError 

type Error_ClusterIdError struct {
	ClusterIdError *ClusterIDError `protobuf:"bytes,3,opt,name=cluster_id_error,json=clusterIdError,proto3,oneof" json:"cluster_id_error,omitempty"`
}

func (*Error_ClusterIdError) MarshalTo 

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

func (*Error_ClusterIdError) MarshalToSizedBuffer 

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

func (*Error_ClusterIdError) Size 

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

type Error_KvError 

type Error_KvError struct {
	KvError *kvrpcpb.KeyError `protobuf:"bytes,4,opt,name=kv_error,json=kvError,proto3,oneof" json:"kv_error,omitempty"`
}

func (*Error_KvError) MarshalTo 

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

func (*Error_KvError) MarshalToSizedBuffer 

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

func (*Error_KvError) Size 

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

type Error_RegionError 

type Error_RegionError struct {
	RegionError *errorpb.Error `protobuf:"bytes,5,opt,name=region_error,json=regionError,proto3,oneof" json:"region_error,omitempty"`
}

func (*Error_RegionError) MarshalTo 

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

func (*Error_RegionError) MarshalToSizedBuffer 

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

func (*Error_RegionError) Size 

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

type ExternalStorageClient 

type ExternalStorageClient interface {
	// Restore to a file
	Restore(ctx context.Context, in *ExternalStorageRestoreRequest, opts ...grpc.CallOption) (*ExternalStorageRestoreResponse, error)
	// Save a file to storage
	Save(ctx context.Context, in *ExternalStorageSaveRequest, opts ...grpc.CallOption) (*ExternalStorageSaveResponse, error)
}

ExternalStorageClient is the client API for ExternalStorage service.

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

func NewExternalStorageClient 

func NewExternalStorageClient(cc *grpc.ClientConn) ExternalStorageClient

type ExternalStorageRestoreRequest 

type ExternalStorageRestoreRequest struct {
	StorageBackend *StorageBackend `protobuf:"bytes,1,opt,name=storage_backend,json=storageBackend,proto3" json:"storage_backend,omitempty"`
	ObjectName     string          `protobuf:"bytes,2,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	RestoreName    string          `protobuf:"bytes,3,opt,name=restore_name,json=restoreName,proto3" json:"restore_name,omitempty"`
	ContentLength  uint64          `protobuf:"varint,4,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
}

func (*ExternalStorageRestoreRequest) Descriptor 

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

func (*ExternalStorageRestoreRequest) GetContentLength 

func (m *ExternalStorageRestoreRequest) GetContentLength() uint64

func (*ExternalStorageRestoreRequest) GetObjectName 

func (m *ExternalStorageRestoreRequest) GetObjectName() string

func (*ExternalStorageRestoreRequest) GetRestoreName 

func (m *ExternalStorageRestoreRequest) GetRestoreName() string

func (*ExternalStorageRestoreRequest) GetStorageBackend 

func (m *ExternalStorageRestoreRequest) GetStorageBackend() *StorageBackend

func (*ExternalStorageRestoreRequest) Marshal 

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

func (*ExternalStorageRestoreRequest) MarshalTo 

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

func (*ExternalStorageRestoreRequest) MarshalToSizedBuffer 

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

func (*ExternalStorageRestoreRequest) ProtoMessage 

func (*ExternalStorageRestoreRequest) ProtoMessage()

func (*ExternalStorageRestoreRequest) Reset 

func (m *ExternalStorageRestoreRequest) Reset()

func (*ExternalStorageRestoreRequest) Size 

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

func (*ExternalStorageRestoreRequest) String 

func (m *ExternalStorageRestoreRequest) String() string

func (*ExternalStorageRestoreRequest) Unmarshal 

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

func (*ExternalStorageRestoreRequest) XXX_DiscardUnknown 

func (m *ExternalStorageRestoreRequest) XXX_DiscardUnknown()

func (*ExternalStorageRestoreRequest) XXX_Marshal 

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

func (*ExternalStorageRestoreRequest) XXX_Merge 

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

func (*ExternalStorageRestoreRequest) XXX_Size 

func (m *ExternalStorageRestoreRequest) XXX_Size() int

func (*ExternalStorageRestoreRequest) XXX_Unmarshal 

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

type ExternalStorageRestoreResponse 

type ExternalStorageRestoreResponse struct {
}

func (*ExternalStorageRestoreResponse) Descriptor 

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

func (*ExternalStorageRestoreResponse) Marshal 

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

func (*ExternalStorageRestoreResponse) MarshalTo 

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

func (*ExternalStorageRestoreResponse) MarshalToSizedBuffer 

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

func (*ExternalStorageRestoreResponse) ProtoMessage 

func (*ExternalStorageRestoreResponse) ProtoMessage()

func (*ExternalStorageRestoreResponse) Reset 

func (m *ExternalStorageRestoreResponse) Reset()

func (*ExternalStorageRestoreResponse) Size 

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

func (*ExternalStorageRestoreResponse) String 

func (m *ExternalStorageRestoreResponse) String() string

func (*ExternalStorageRestoreResponse) Unmarshal 

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

func (*ExternalStorageRestoreResponse) XXX_DiscardUnknown 

func (m *ExternalStorageRestoreResponse) XXX_DiscardUnknown()

func (*ExternalStorageRestoreResponse) XXX_Marshal 

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

func (*ExternalStorageRestoreResponse) XXX_Merge 

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

func (*ExternalStorageRestoreResponse) XXX_Size 

func (m *ExternalStorageRestoreResponse) XXX_Size() int

func (*ExternalStorageRestoreResponse) XXX_Unmarshal 

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

type ExternalStorageSaveRequest 

type ExternalStorageSaveRequest struct {
	StorageBackend *StorageBackend `protobuf:"bytes,1,opt,name=storage_backend,json=storageBackend,proto3" json:"storage_backend,omitempty"`
	ObjectName     string          `protobuf:"bytes,2,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"`
	ContentLength  uint64          `protobuf:"varint,3,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"`
}

func (*ExternalStorageSaveRequest) Descriptor 

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

func (*ExternalStorageSaveRequest) GetContentLength 

func (m *ExternalStorageSaveRequest) GetContentLength() uint64

func (*ExternalStorageSaveRequest) GetObjectName 

func (m *ExternalStorageSaveRequest) GetObjectName() string

func (*ExternalStorageSaveRequest) GetStorageBackend 

func (m *ExternalStorageSaveRequest) GetStorageBackend() *StorageBackend

func (*ExternalStorageSaveRequest) Marshal 

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

func (*ExternalStorageSaveRequest) MarshalTo 

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

func (*ExternalStorageSaveRequest) MarshalToSizedBuffer 

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

func (*ExternalStorageSaveRequest) ProtoMessage 

func (*ExternalStorageSaveRequest) ProtoMessage()

func (*ExternalStorageSaveRequest) Reset 

func (m *ExternalStorageSaveRequest) Reset()

func (*ExternalStorageSaveRequest) Size 

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

func (*ExternalStorageSaveRequest) String 

func (m *ExternalStorageSaveRequest) String() string

func (*ExternalStorageSaveRequest) Unmarshal 

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

func (*ExternalStorageSaveRequest) XXX_DiscardUnknown 

func (m *ExternalStorageSaveRequest) XXX_DiscardUnknown()

func (*ExternalStorageSaveRequest) XXX_Marshal 

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

func (*ExternalStorageSaveRequest) XXX_Merge 

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

func (*ExternalStorageSaveRequest) XXX_Size 

func (m *ExternalStorageSaveRequest) XXX_Size() int

func (*ExternalStorageSaveRequest) XXX_Unmarshal 

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

type ExternalStorageSaveResponse 

type ExternalStorageSaveResponse struct {
}

func (*ExternalStorageSaveResponse) Descriptor 

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

func (*ExternalStorageSaveResponse) Marshal 

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

func (*ExternalStorageSaveResponse) MarshalTo 

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

func (*ExternalStorageSaveResponse) MarshalToSizedBuffer 

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

func (*ExternalStorageSaveResponse) ProtoMessage 

func (*ExternalStorageSaveResponse) ProtoMessage()

func (*ExternalStorageSaveResponse) Reset 

func (m *ExternalStorageSaveResponse) Reset()

func (*ExternalStorageSaveResponse) Size 

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

func (*ExternalStorageSaveResponse) String 

func (m *ExternalStorageSaveResponse) String() string

func (*ExternalStorageSaveResponse) Unmarshal 

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

func (*ExternalStorageSaveResponse) XXX_DiscardUnknown 

func (m *ExternalStorageSaveResponse) XXX_DiscardUnknown()

func (*ExternalStorageSaveResponse) XXX_Marshal 

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

func (*ExternalStorageSaveResponse) XXX_Merge 

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

func (*ExternalStorageSaveResponse) XXX_Size 

func (m *ExternalStorageSaveResponse) XXX_Size() int

func (*ExternalStorageSaveResponse) XXX_Unmarshal 

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

type ExternalStorageServer 

type ExternalStorageServer interface {
	// Restore to a file
	Restore(context.Context, *ExternalStorageRestoreRequest) (*ExternalStorageRestoreResponse, error)
	// Save a file to storage
	Save(context.Context, *ExternalStorageSaveRequest) (*ExternalStorageSaveResponse, error)
}

ExternalStorageServer is the server API for ExternalStorage service.

type File 

type File struct {
	Name         string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Sha256       []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	StartKey     []byte `protobuf:"bytes,3,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey       []byte `protobuf:"bytes,4,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	StartVersion uint64 `protobuf:"varint,5,opt,name=start_version,json=startVersion,proto3" json:"start_version,omitempty"`
	EndVersion   uint64 `protobuf:"varint,6,opt,name=end_version,json=endVersion,proto3" json:"end_version,omitempty"`
	// recorded the total statistics across multiple tables
	Crc64Xor   uint64 `protobuf:"varint,7,opt,name=crc64xor,proto3" json:"crc64xor,omitempty"`
	TotalKvs   uint64 `protobuf:"varint,8,opt,name=total_kvs,json=totalKvs,proto3" json:"total_kvs,omitempty"`
	TotalBytes uint64 `protobuf:"varint,9,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	// recorded when the SST kvs are from different tables
	TableMetas []*TableMeta `protobuf:"bytes,13,rep,name=table_metas,json=tableMetas,proto3" json:"table_metas,omitempty"`
	Cf         string       `protobuf:"bytes,10,opt,name=cf,proto3" json:"cf,omitempty"`
	Size_      uint64       `protobuf:"varint,11,opt,name=size,proto3" json:"size,omitempty"`
	// cipher_iv is used for AES cipher
	CipherIv []byte `protobuf:"bytes,12,opt,name=cipher_iv,json=cipherIv,proto3" json:"cipher_iv,omitempty"`
}

func (*File) Descriptor 

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

func (*File) GetCf 

func (m *File) GetCf() string

func (*File) GetCipherIv 

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

func (*File) GetCrc64Xor 

func (m *File) GetCrc64Xor() uint64

func (*File) GetEndKey 

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

func (*File) GetEndVersion 

func (m *File) GetEndVersion() uint64

func (*File) GetName 

func (m *File) GetName() string

func (*File) GetSha256 

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

func (*File) GetSize_ 

func (m *File) GetSize_() uint64

func (*File) GetStartKey 

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

func (*File) GetStartVersion 

func (m *File) GetStartVersion() uint64

func (*File) GetTableMetas 

func (m *File) GetTableMetas() []*TableMeta

func (*File) GetTotalBytes 

func (m *File) GetTotalBytes() uint64

func (*File) GetTotalKvs 

func (m *File) GetTotalKvs() uint64

func (*File) Marshal 

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

func (*File) MarshalTo 

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

func (*File) MarshalToSizedBuffer 

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

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) Reset 

func (m *File) Reset()

func (*File) Size 

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

func (*File) String 

func (m *File) String() string

func (*File) Unmarshal 

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

func (*File) XXX_DiscardUnknown 

func (m *File) XXX_DiscardUnknown()

func (*File) XXX_Marshal 

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

func (*File) XXX_Merge 

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

func (*File) XXX_Size 

func (m *File) XXX_Size() int

func (*File) XXX_Unmarshal 

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

type FileType 

type FileType int32
const (
	FileType_Delete FileType = 0
	FileType_Put    FileType = 1
)

func (FileType) EnumDescriptor 

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

func (FileType) String 

func (x FileType) String() string

type GCS 

type GCS struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Bucket       string `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix       string `protobuf:"bytes,3,opt,name=prefix,proto3" json:"prefix,omitempty"`
	StorageClass string `protobuf:"bytes,4,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	// If not empty, applies a predefined set of access controls.
	// See https://cloud.google.com/storage/docs/access-control/lists#predefined-acl
	// for valid values.
	PredefinedAcl string `protobuf:"bytes,5,opt,name=predefined_acl,json=predefinedAcl,proto3" json:"predefined_acl,omitempty"`
	// Service Account Credentials JSON blob
	// You can get one from https://console.cloud.google.com/apis/credentials, and
	// copy the content, set it as string here.
	CredentialsBlob string `protobuf:"bytes,6,opt,name=credentials_blob,json=credentialsBlob,proto3" json:"credentials_blob,omitempty"`
}

GCS storage backend saves files into google cloud storage.

func (*GCS) Descriptor 

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

func (*GCS) GetBucket 

func (m *GCS) GetBucket() string

func (*GCS) GetCredentialsBlob 

func (m *GCS) GetCredentialsBlob() string

func (*GCS) GetEndpoint 

func (m *GCS) GetEndpoint() string

func (*GCS) GetPredefinedAcl 

func (m *GCS) GetPredefinedAcl() string

func (*GCS) GetPrefix 

func (m *GCS) GetPrefix() string

func (*GCS) GetStorageClass 

func (m *GCS) GetStorageClass() string

func (*GCS) Marshal 

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

func (*GCS) MarshalTo 

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

func (*GCS) MarshalToSizedBuffer 

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

func (*GCS) ProtoMessage 

func (*GCS) ProtoMessage()

func (*GCS) Reset 

func (m *GCS) Reset()

func (*GCS) Size 

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

func (*GCS) String 

func (m *GCS) String() string

func (*GCS) Unmarshal 

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

func (*GCS) XXX_DiscardUnknown 

func (m *GCS) XXX_DiscardUnknown()

func (*GCS) XXX_Marshal 

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

func (*GCS) XXX_Merge 

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

func (*GCS) XXX_Size 

func (m *GCS) XXX_Size() int

func (*GCS) XXX_Unmarshal 

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

type HDFS 

type HDFS struct {
	//  a URL: hdfs:///some/path or hdfs://host:port/some/path
	Remote string `protobuf:"bytes,1,opt,name=remote,proto3" json:"remote,omitempty"`
}

HDFS storage backend saves file into HDFS compatible storages

func (*HDFS) Descriptor 

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

func (*HDFS) GetRemote 

func (m *HDFS) GetRemote() string

func (*HDFS) Marshal 

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

func (*HDFS) MarshalTo 

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

func (*HDFS) MarshalToSizedBuffer 

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

func (*HDFS) ProtoMessage 

func (*HDFS) ProtoMessage()

func (*HDFS) Reset 

func (m *HDFS) Reset()

func (*HDFS) Size 

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

func (*HDFS) String 

func (m *HDFS) String() string

func (*HDFS) Unmarshal 

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

func (*HDFS) XXX_DiscardUnknown 

func (m *HDFS) XXX_DiscardUnknown()

func (*HDFS) XXX_Marshal 

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

func (*HDFS) XXX_Merge 

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

func (*HDFS) XXX_Size 

func (m *HDFS) XXX_Size() int

func (*HDFS) XXX_Unmarshal 

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

type IDMap 

type IDMap struct {
	UpstreamId   int64 `protobuf:"varint,1,opt,name=upstream_id,json=upstreamId,proto3" json:"upstream_id,omitempty"`
	DownstreamId int64 `protobuf:"varint,2,opt,name=downstream_id,json=downstreamId,proto3" json:"downstream_id,omitempty"`
}

func (*IDMap) Descriptor 

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

func (*IDMap) GetDownstreamId 

func (m *IDMap) GetDownstreamId() int64

func (*IDMap) GetUpstreamId 

func (m *IDMap) GetUpstreamId() int64

func (*IDMap) Marshal 

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

func (*IDMap) MarshalTo 

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

func (*IDMap) MarshalToSizedBuffer 

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

func (*IDMap) ProtoMessage 

func (*IDMap) ProtoMessage()

func (*IDMap) Reset 

func (m *IDMap) Reset()

func (*IDMap) Size 

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

func (*IDMap) String 

func (m *IDMap) String() string

func (*IDMap) Unmarshal 

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

func (*IDMap) XXX_DiscardUnknown 

func (m *IDMap) XXX_DiscardUnknown()

func (*IDMap) XXX_Marshal 

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

func (*IDMap) XXX_Merge 

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

func (*IDMap) XXX_Size 

func (m *IDMap) XXX_Size() int

func (*IDMap) XXX_Unmarshal 

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

type Local 

type Local struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
}

Local storage backend saves files into local disk

func (*Local) Descriptor 

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

func (*Local) GetPath 

func (m *Local) GetPath() string

func (*Local) Marshal 

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

func (*Local) MarshalTo 

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

func (*Local) MarshalToSizedBuffer 

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

func (*Local) ProtoMessage 

func (*Local) ProtoMessage()

func (*Local) Reset 

func (m *Local) Reset()

func (*Local) Size 

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

func (*Local) String 

func (m *Local) String() string

func (*Local) Unmarshal 

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

func (*Local) XXX_DiscardUnknown 

func (m *Local) XXX_DiscardUnknown()

func (*Local) XXX_Marshal 

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

func (*Local) XXX_Merge 

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

func (*Local) XXX_Size 

func (m *Local) XXX_Size() int

func (*Local) XXX_Unmarshal 

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

type LogFileCompaction 

type LogFileCompaction struct {
	CompactionFromTs  uint64 `protobuf:"varint,1,opt,name=compaction_from_ts,json=compactionFromTs,proto3" json:"compaction_from_ts,omitempty"`
	CompactionUntilTs uint64 `protobuf:"varint,2,opt,name=compaction_until_ts,json=compactionUntilTs,proto3" json:"compaction_until_ts,omitempty"`
	// The user provided name for the compaction.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// The statistics or other useful information for human.
	Comments string `protobuf:"bytes,4,opt,name=comments,proto3" json:"comments,omitempty"`
	// relative path to the generated subcompaction metas. ("artificates")
	Artifacts string `protobuf:"bytes,5,opt,name=artifacts,proto3" json:"artifacts,omitempty"`
	// the XOR of all artificate's hash.
	ArtifactsHash uint64 `protobuf:"varint,6,opt,name=artifacts_hash,json=artifactsHash,proto3" json:"artifacts_hash,omitempty"`
	// relative path to the subcompaction generated SST files.
	// this is a hint for garbage-collecting, so we don't need to read the metas one by one.
	// Those SSTs cannot be directly used, what you need is probably in `artificates`.
	GeneratedFiles string `protobuf:"bytes,7,opt,name=generated_files,json=generatedFiles,proto3" json:"generated_files,omitempty"`
}

func (*LogFileCompaction) Descriptor 

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

func (*LogFileCompaction) GetArtifacts 

func (m *LogFileCompaction) GetArtifacts() string

func (*LogFileCompaction) GetArtifactsHash 

func (m *LogFileCompaction) GetArtifactsHash() uint64

func (*LogFileCompaction) GetComments 

func (m *LogFileCompaction) GetComments() string

func (*LogFileCompaction) GetCompactionFromTs 

func (m *LogFileCompaction) GetCompactionFromTs() uint64

func (*LogFileCompaction) GetCompactionUntilTs 

func (m *LogFileCompaction) GetCompactionUntilTs() uint64

func (*LogFileCompaction) GetGeneratedFiles 

func (m *LogFileCompaction) GetGeneratedFiles() string

func (*LogFileCompaction) GetName 

func (m *LogFileCompaction) GetName() string

func (*LogFileCompaction) Marshal 

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

func (*LogFileCompaction) MarshalTo 

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

func (*LogFileCompaction) MarshalToSizedBuffer 

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

func (*LogFileCompaction) ProtoMessage 

func (*LogFileCompaction) ProtoMessage()

func (*LogFileCompaction) Reset 

func (m *LogFileCompaction) Reset()

func (*LogFileCompaction) Size 

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

func (*LogFileCompaction) String 

func (m *LogFileCompaction) String() string

func (*LogFileCompaction) Unmarshal 

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

func (*LogFileCompaction) XXX_DiscardUnknown 

func (m *LogFileCompaction) XXX_DiscardUnknown()

func (*LogFileCompaction) XXX_Marshal 

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

func (*LogFileCompaction) XXX_Merge 

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

func (*LogFileCompaction) XXX_Size 

func (m *LogFileCompaction) XXX_Size() int

func (*LogFileCompaction) XXX_Unmarshal 

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

type LogFileSubcompaction 

type LogFileSubcompaction struct {
	// The metadata of the subcompaction.
	Meta *LogFileSubcompactionMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// The generated SSTs.
	SstOutputs []*File `protobuf:"bytes,2,rep,name=sst_outputs,json=sstOutputs,proto3" json:"sst_outputs,omitempty"`
	// The hint for the history of the region that contains the keys being compacted.
	// This may be helpful for splitting, but it does not guarantee completeness and accuracy.
	RegionMetaHints []*RegionMetaHint `protobuf:"bytes,3,rep,name=region_meta_hints,json=regionMetaHints,proto3" json:"region_meta_hints,omitempty"`
}

A subcompaction from a compaction. Subcompactions are actions that collect then sort key values from one region.

func (*LogFileSubcompaction) Descriptor 

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

func (*LogFileSubcompaction) GetMeta 

func (m *LogFileSubcompaction) GetMeta() *LogFileSubcompactionMeta

func (*LogFileSubcompaction) GetRegionMetaHints 

func (m *LogFileSubcompaction) GetRegionMetaHints() []*RegionMetaHint

func (*LogFileSubcompaction) GetSstOutputs 

func (m *LogFileSubcompaction) GetSstOutputs() []*File

func (*LogFileSubcompaction) Marshal 

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

func (*LogFileSubcompaction) MarshalTo 

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

func (*LogFileSubcompaction) MarshalToSizedBuffer 

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

func (*LogFileSubcompaction) ProtoMessage 

func (*LogFileSubcompaction) ProtoMessage()

func (*LogFileSubcompaction) Reset 

func (m *LogFileSubcompaction) Reset()

func (*LogFileSubcompaction) Size 

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

func (*LogFileSubcompaction) String 

func (m *LogFileSubcompaction) String() string

func (*LogFileSubcompaction) Unmarshal 

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

func (*LogFileSubcompaction) XXX_DiscardUnknown 

func (m *LogFileSubcompaction) XXX_DiscardUnknown()

func (*LogFileSubcompaction) XXX_Marshal 

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

func (*LogFileSubcompaction) XXX_Merge 

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

func (*LogFileSubcompaction) XXX_Size 

func (m *LogFileSubcompaction) XXX_Size() int

func (*LogFileSubcompaction) XXX_Unmarshal 

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

type LogFileSubcompactionMeta 

type LogFileSubcompactionMeta struct {
	// The whole size of this subcompaction.
	// It should be the physical size of all input logs.
	Size_ uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// The region that we perform the subcompaction.
	RegionId   uint64 `protobuf:"varint,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	Cf         string `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
	InputMaxTs uint64 `protobuf:"varint,4,opt,name=input_max_ts,json=inputMaxTs,proto3" json:"input_max_ts,omitempty"`
	InputMinTs uint64 `protobuf:"varint,5,opt,name=input_min_ts,json=inputMinTs,proto3" json:"input_min_ts,omitempty"`
	// The whole compaction's configure.
	CompactFromTs  uint64 `protobuf:"varint,6,opt,name=compact_from_ts,json=compactFromTs,proto3" json:"compact_from_ts,omitempty"`
	CompactUntilTs uint64 `protobuf:"varint,7,opt,name=compact_until_ts,json=compactUntilTs,proto3" json:"compact_until_ts,omitempty"`
	// The key range of the input logs.
	// They are encoded user key. (i.e. mem-comparable, no 'z' prefix)
	MinKey []byte `protobuf:"bytes,8,opt,name=min_key,json=minKey,proto3" json:"min_key,omitempty"`
	// The largest key from the input.
	MaxKey []byte `protobuf:"bytes,9,opt,name=max_key,json=maxKey,proto3" json:"max_key,omitempty"`
	// The type of operations in the file. (Write or Delete)
	Ty      FileType `protobuf:"varint,10,opt,name=ty,proto3,enum=backup.FileType" json:"ty,omitempty"`
	TableId int64    `protobuf:"varint,11,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	// The input log files of this.
	Sources []*SpansOfFile `protobuf:"bytes,12,rep,name=sources,proto3" json:"sources,omitempty"`
}

func (*LogFileSubcompactionMeta) Descriptor 

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

func (*LogFileSubcompactionMeta) GetCf 

func (m *LogFileSubcompactionMeta) GetCf() string

func (*LogFileSubcompactionMeta) GetCompactFromTs 

func (m *LogFileSubcompactionMeta) GetCompactFromTs() uint64

func (*LogFileSubcompactionMeta) GetCompactUntilTs 

func (m *LogFileSubcompactionMeta) GetCompactUntilTs() uint64

func (*LogFileSubcompactionMeta) GetInputMaxTs 

func (m *LogFileSubcompactionMeta) GetInputMaxTs() uint64

func (*LogFileSubcompactionMeta) GetInputMinTs 

func (m *LogFileSubcompactionMeta) GetInputMinTs() uint64

func (*LogFileSubcompactionMeta) GetMaxKey 

func (m *LogFileSubcompactionMeta) GetMaxKey() []byte

func (*LogFileSubcompactionMeta) GetMinKey 

func (m *LogFileSubcompactionMeta) GetMinKey() []byte

func (*LogFileSubcompactionMeta) GetRegionId 

func (m *LogFileSubcompactionMeta) GetRegionId() uint64

func (*LogFileSubcompactionMeta) GetSize_ 

func (m *LogFileSubcompactionMeta) GetSize_() uint64

func (*LogFileSubcompactionMeta) GetSources 

func (m *LogFileSubcompactionMeta) GetSources() []*SpansOfFile

func (*LogFileSubcompactionMeta) GetTableId 

func (m *LogFileSubcompactionMeta) GetTableId() int64

func (*LogFileSubcompactionMeta) GetTy 

func (m *LogFileSubcompactionMeta) GetTy() FileType

func (*LogFileSubcompactionMeta) Marshal 

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

func (*LogFileSubcompactionMeta) MarshalTo 

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

func (*LogFileSubcompactionMeta) MarshalToSizedBuffer 

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

func (*LogFileSubcompactionMeta) ProtoMessage 

func (*LogFileSubcompactionMeta) ProtoMessage()

func (*LogFileSubcompactionMeta) Reset 

func (m *LogFileSubcompactionMeta) Reset()

func (*LogFileSubcompactionMeta) Size 

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

func (*LogFileSubcompactionMeta) String 

func (m *LogFileSubcompactionMeta) String() string

func (*LogFileSubcompactionMeta) Unmarshal 

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

func (*LogFileSubcompactionMeta) XXX_DiscardUnknown 

func (m *LogFileSubcompactionMeta) XXX_DiscardUnknown()

func (*LogFileSubcompactionMeta) XXX_Marshal 

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

func (*LogFileSubcompactionMeta) XXX_Merge 

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

func (*LogFileSubcompactionMeta) XXX_Size 

func (m *LogFileSubcompactionMeta) XXX_Size() int

func (*LogFileSubcompactionMeta) XXX_Unmarshal 

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

type LogFileSubcompactions 

type LogFileSubcompactions struct {
	Subcompactions []*LogFileSubcompaction `protobuf:"bytes,1,rep,name=subcompactions,proto3" json:"subcompactions,omitempty"`
}

Batched version of `LogFileSubcompaction`. So we can store many subcompactions to one file, to reduce the number of file.

func (*LogFileSubcompactions) Descriptor 

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

func (*LogFileSubcompactions) GetSubcompactions 

func (m *LogFileSubcompactions) GetSubcompactions() []*LogFileSubcompaction

func (*LogFileSubcompactions) Marshal 

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

func (*LogFileSubcompactions) MarshalTo 

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

func (*LogFileSubcompactions) MarshalToSizedBuffer 

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

func (*LogFileSubcompactions) ProtoMessage 

func (*LogFileSubcompactions) ProtoMessage()

func (*LogFileSubcompactions) Reset 

func (m *LogFileSubcompactions) Reset()

func (*LogFileSubcompactions) Size 

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

func (*LogFileSubcompactions) String 

func (m *LogFileSubcompactions) String() string

func (*LogFileSubcompactions) Unmarshal 

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

func (*LogFileSubcompactions) XXX_DiscardUnknown 

func (m *LogFileSubcompactions) XXX_DiscardUnknown()

func (*LogFileSubcompactions) XXX_Marshal 

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

func (*LogFileSubcompactions) XXX_Merge 

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

func (*LogFileSubcompactions) XXX_Size 

func (m *LogFileSubcompactions) XXX_Size() int

func (*LogFileSubcompactions) XXX_Unmarshal 

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

type MasterKeyConfig 

type MasterKeyConfig struct {
	EncryptionType encryptionpb.EncryptionMethod `` /* 139-byte string literal not displayed */
	MasterKeys     []*encryptionpb.MasterKey     `protobuf:"bytes,2,rep,name=master_keys,json=masterKeys,proto3" json:"master_keys,omitempty"`
}

func (*MasterKeyConfig) Descriptor 

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

func (*MasterKeyConfig) GetEncryptionType 

func (m *MasterKeyConfig) GetEncryptionType() encryptionpb.EncryptionMethod

func (*MasterKeyConfig) GetMasterKeys 

func (m *MasterKeyConfig) GetMasterKeys() []*encryptionpb.MasterKey

func (*MasterKeyConfig) Marshal 

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

func (*MasterKeyConfig) MarshalTo 

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

func (*MasterKeyConfig) MarshalToSizedBuffer 

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

func (*MasterKeyConfig) ProtoMessage 

func (*MasterKeyConfig) ProtoMessage()

func (*MasterKeyConfig) Reset 

func (m *MasterKeyConfig) Reset()

func (*MasterKeyConfig) Size 

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

func (*MasterKeyConfig) String 

func (m *MasterKeyConfig) String() string

func (*MasterKeyConfig) Unmarshal 

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

func (*MasterKeyConfig) XXX_DiscardUnknown 

func (m *MasterKeyConfig) XXX_DiscardUnknown()

func (*MasterKeyConfig) XXX_Marshal 

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

func (*MasterKeyConfig) XXX_Merge 

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

func (*MasterKeyConfig) XXX_Size 

func (m *MasterKeyConfig) XXX_Size() int

func (*MasterKeyConfig) XXX_Unmarshal 

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

type MetaEdit 

type MetaEdit struct {
	// Path to the meta file.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Delete the physical files (MetaFileGroup) in the meta file.
	DeletePhysicalFiles []string `protobuf:"bytes,2,rep,name=delete_physical_files,json=deletePhysicalFiles,proto3" json:"delete_physical_files,omitempty"`
	// Delete the logical files (MetaFileInfo) in the meta file.
	// Note: Even the operation have been performed in the meta,
	// this modification should be kept as long as the corresponding physical
	// file not deleted. Or we may cannot know when to delete the physical file.
	// Then the file will be leak until truncated.
	DeleteLogicalFiles []*DeleteSpansOfFile `protobuf:"bytes,3,rep,name=delete_logical_files,json=deleteLogicalFiles,proto3" json:"delete_logical_files,omitempty"`
	// Whether to delete the metadata itself.
	DestructSelf bool `protobuf:"varint,4,opt,name=destruct_self,json=destructSelf,proto3" json:"destruct_self,omitempty"`
}

func (*MetaEdit) Descriptor 

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

func (*MetaEdit) GetDeleteLogicalFiles 

func (m *MetaEdit) GetDeleteLogicalFiles() []*DeleteSpansOfFile

func (*MetaEdit) GetDeletePhysicalFiles 

func (m *MetaEdit) GetDeletePhysicalFiles() []string

func (*MetaEdit) GetDestructSelf 

func (m *MetaEdit) GetDestructSelf() bool

func (*MetaEdit) GetPath 

func (m *MetaEdit) GetPath() string

func (*MetaEdit) Marshal 

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

func (*MetaEdit) MarshalTo 

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

func (*MetaEdit) MarshalToSizedBuffer 

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

func (*MetaEdit) ProtoMessage 

func (*MetaEdit) ProtoMessage()

func (*MetaEdit) Reset 

func (m *MetaEdit) Reset()

func (*MetaEdit) Size 

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

func (*MetaEdit) String 

func (m *MetaEdit) String() string

func (*MetaEdit) Unmarshal 

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

func (*MetaEdit) XXX_DiscardUnknown 

func (m *MetaEdit) XXX_DiscardUnknown()

func (*MetaEdit) XXX_Marshal 

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

func (*MetaEdit) XXX_Merge 

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

func (*MetaEdit) XXX_Size 

func (m *MetaEdit) XXX_Size() int

func (*MetaEdit) XXX_Unmarshal 

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

type MetaFile 

type MetaFile struct {
	// A set of files that contains a MetaFile.
	// It is used as a multi-level index.
	MetaFiles []*File `protobuf:"bytes,1,rep,name=meta_files,json=metaFiles,proto3" json:"meta_files,omitempty"`
	// A set of files that contains user data.
	DataFiles []*File `protobuf:"bytes,2,rep,name=data_files,json=dataFiles,proto3" json:"data_files,omitempty"`
	// A set of files that contains Schemas.
	Schemas []*Schema `protobuf:"bytes,3,rep,name=schemas,proto3" json:"schemas,omitempty"`
	// A set of files that contains RawRanges.
	RawRanges []*RawRange `protobuf:"bytes,4,rep,name=raw_ranges,json=rawRanges,proto3" json:"raw_ranges,omitempty"`
	// A set of files that contains BackupRanges.
	BackupRanges []*BackupRange `protobuf:"bytes,6,rep,name=backup_ranges,json=backupRanges,proto3" json:"backup_ranges,omitempty"`
	// A set of files that contains DDLs.
	Ddls [][]byte `protobuf:"bytes,5,rep,name=ddls,proto3" json:"ddls,omitempty"`
}

MetaFile describes a multi-level index of data used in backup.

func (*MetaFile) Descriptor 

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

func (*MetaFile) GetBackupRanges 

func (m *MetaFile) GetBackupRanges() []*BackupRange

func (*MetaFile) GetDataFiles 

func (m *MetaFile) GetDataFiles() []*File

func (*MetaFile) GetDdls 

func (m *MetaFile) GetDdls() [][]byte

func (*MetaFile) GetMetaFiles 

func (m *MetaFile) GetMetaFiles() []*File

func (*MetaFile) GetRawRanges 

func (m *MetaFile) GetRawRanges() []*RawRange

func (*MetaFile) GetSchemas 

func (m *MetaFile) GetSchemas() []*Schema

func (*MetaFile) Marshal 

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

func (*MetaFile) MarshalTo 

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

func (*MetaFile) MarshalToSizedBuffer 

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

func (*MetaFile) ProtoMessage 

func (*MetaFile) ProtoMessage()

func (*MetaFile) Reset 

func (m *MetaFile) Reset()

func (*MetaFile) Size 

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

func (*MetaFile) String 

func (m *MetaFile) String() string

func (*MetaFile) Unmarshal 

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

func (*MetaFile) XXX_DiscardUnknown 

func (m *MetaFile) XXX_DiscardUnknown()

func (*MetaFile) XXX_Marshal 

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

func (*MetaFile) XXX_Merge 

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

func (*MetaFile) XXX_Size 

func (m *MetaFile) XXX_Size() int

func (*MetaFile) XXX_Unmarshal 

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

type MetaVersion 

type MetaVersion int32
const (
	MetaVersion_V1 MetaVersion = 0
	MetaVersion_V2 MetaVersion = 1
)

func (MetaVersion) EnumDescriptor 

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

func (MetaVersion) String 

func (x MetaVersion) String() string

type Metadata 

type Metadata struct {
	// deprecated after(in) v6.3.0 TiKV cluster
	Files       []*DataFileInfo  `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	FileGroups  []*DataFileGroup `protobuf:"bytes,6,rep,name=file_groups,json=fileGroups,proto3" json:"file_groups,omitempty"`
	StoreId     int64            `protobuf:"varint,2,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
	ResolvedTs  uint64           `protobuf:"varint,3,opt,name=resolved_ts,json=resolvedTs,proto3" json:"resolved_ts,omitempty"`
	MaxTs       uint64           `protobuf:"varint,4,opt,name=max_ts,json=maxTs,proto3" json:"max_ts,omitempty"`
	MinTs       uint64           `protobuf:"varint,5,opt,name=min_ts,json=minTs,proto3" json:"min_ts,omitempty"`
	MetaVersion MetaVersion      `protobuf:"varint,7,opt,name=meta_version,json=metaVersion,proto3,enum=backup.MetaVersion" json:"meta_version,omitempty"`
}

func (*Metadata) Descriptor 

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

func (*Metadata) GetFileGroups 

func (m *Metadata) GetFileGroups() []*DataFileGroup

func (*Metadata) GetFiles 

func (m *Metadata) GetFiles() []*DataFileInfo

func (*Metadata) GetMaxTs 

func (m *Metadata) GetMaxTs() uint64

func (*Metadata) GetMetaVersion 

func (m *Metadata) GetMetaVersion() MetaVersion

func (*Metadata) GetMinTs 

func (m *Metadata) GetMinTs() uint64

func (*Metadata) GetResolvedTs 

func (m *Metadata) GetResolvedTs() uint64

func (*Metadata) GetStoreId 

func (m *Metadata) GetStoreId() int64

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) MarshalToSizedBuffer 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) Unmarshal 

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

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type Migration 

type Migration struct {
	Creator     string               `protobuf:"bytes,5,opt,name=creator,proto3" json:"creator,omitempty"`
	Version     MigrationVersion     `protobuf:"varint,6,opt,name=version,proto3,enum=backup.MigrationVersion" json:"version,omitempty"`
	EditMeta    []*MetaEdit          `protobuf:"bytes,1,rep,name=edit_meta,json=editMeta,proto3" json:"edit_meta,omitempty"`
	TruncatedTo uint64               `protobuf:"varint,2,opt,name=truncated_to,json=truncatedTo,proto3" json:"truncated_to,omitempty"`
	Compactions []*LogFileCompaction `protobuf:"bytes,3,rep,name=compactions,proto3" json:"compactions,omitempty"`
	// Delete all files matches this prefix.
	DestructPrefix []string `protobuf:"bytes,4,rep,name=destruct_prefix,json=destructPrefix,proto3" json:"destruct_prefix,omitempty"`
}

func (*Migration) Descriptor 

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

func (*Migration) GetCompactions 

func (m *Migration) GetCompactions() []*LogFileCompaction

func (*Migration) GetCreator 

func (m *Migration) GetCreator() string

func (*Migration) GetDestructPrefix 

func (m *Migration) GetDestructPrefix() []string

func (*Migration) GetEditMeta 

func (m *Migration) GetEditMeta() []*MetaEdit

func (*Migration) GetTruncatedTo 

func (m *Migration) GetTruncatedTo() uint64

func (*Migration) GetVersion 

func (m *Migration) GetVersion() MigrationVersion

func (*Migration) Marshal 

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

func (*Migration) MarshalTo 

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

func (*Migration) MarshalToSizedBuffer 

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

func (*Migration) ProtoMessage 

func (*Migration) ProtoMessage()

func (*Migration) Reset 

func (m *Migration) Reset()

func (*Migration) Size 

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

func (*Migration) String 

func (m *Migration) String() string

func (*Migration) Unmarshal 

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

func (*Migration) XXX_DiscardUnknown 

func (m *Migration) XXX_DiscardUnknown()

func (*Migration) XXX_Marshal 

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

func (*Migration) XXX_Merge 

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

func (*Migration) XXX_Size 

func (m *Migration) XXX_Size() int

func (*Migration) XXX_Unmarshal 

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

type MigrationVersion 

type MigrationVersion int32
const (
	// The initial version. Somehow "UNKNOWN".
	MigrationVersion_M0 MigrationVersion = 0
	// Added `creator` and `version`.
	MigrationVersion_M1 MigrationVersion = 1
)

func (MigrationVersion) EnumDescriptor 

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

func (MigrationVersion) String 

func (x MigrationVersion) String() string

type Noop 

type Noop struct {
}

Noop storage backend saves files into void.

func (*Noop) Descriptor 

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

func (*Noop) Marshal 

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

func (*Noop) MarshalTo 

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

func (*Noop) MarshalToSizedBuffer 

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

func (*Noop) ProtoMessage 

func (*Noop) ProtoMessage()

func (*Noop) Reset 

func (m *Noop) Reset()

func (*Noop) Size 

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

func (*Noop) String 

func (m *Noop) String() string

func (*Noop) Unmarshal 

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

func (*Noop) XXX_DiscardUnknown 

func (m *Noop) XXX_DiscardUnknown()

func (*Noop) XXX_Marshal 

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

func (*Noop) XXX_Merge 

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

func (*Noop) XXX_Size 

func (m *Noop) XXX_Size() int

func (*Noop) XXX_Unmarshal 

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

type PitrDBMap 

type PitrDBMap struct {
	Name   string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IdMap  *IDMap          `protobuf:"bytes,2,opt,name=id_map,json=idMap,proto3" json:"id_map,omitempty"`
	Tables []*PitrTableMap `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"`
}

func (*PitrDBMap) Descriptor 

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

func (*PitrDBMap) GetIdMap 

func (m *PitrDBMap) GetIdMap() *IDMap

func (*PitrDBMap) GetName 

func (m *PitrDBMap) GetName() string

func (*PitrDBMap) GetTables 

func (m *PitrDBMap) GetTables() []*PitrTableMap

func (*PitrDBMap) Marshal 

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

func (*PitrDBMap) MarshalTo 

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

func (*PitrDBMap) MarshalToSizedBuffer 

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

func (*PitrDBMap) ProtoMessage 

func (*PitrDBMap) ProtoMessage()

func (*PitrDBMap) Reset 

func (m *PitrDBMap) Reset()

func (*PitrDBMap) Size 

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

func (*PitrDBMap) String 

func (m *PitrDBMap) String() string

func (*PitrDBMap) Unmarshal 

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

func (*PitrDBMap) XXX_DiscardUnknown 

func (m *PitrDBMap) XXX_DiscardUnknown()

func (*PitrDBMap) XXX_Marshal 

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

func (*PitrDBMap) XXX_Merge 

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

func (*PitrDBMap) XXX_Size 

func (m *PitrDBMap) XXX_Size() int

func (*PitrDBMap) XXX_Unmarshal 

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

type PitrTableMap 

type PitrTableMap struct {
	Name       string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	IdMap      *IDMap   `protobuf:"bytes,2,opt,name=id_map,json=idMap,proto3" json:"id_map,omitempty"`
	Partitions []*IDMap `protobuf:"bytes,3,rep,name=partitions,proto3" json:"partitions,omitempty"`
}

func (*PitrTableMap) Descriptor 

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

func (*PitrTableMap) GetIdMap 

func (m *PitrTableMap) GetIdMap() *IDMap

func (*PitrTableMap) GetName 

func (m *PitrTableMap) GetName() string

func (*PitrTableMap) GetPartitions 

func (m *PitrTableMap) GetPartitions() []*IDMap

func (*PitrTableMap) Marshal 

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

func (*PitrTableMap) MarshalTo 

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

func (*PitrTableMap) MarshalToSizedBuffer 

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

func (*PitrTableMap) ProtoMessage 

func (*PitrTableMap) ProtoMessage()

func (*PitrTableMap) Reset 

func (m *PitrTableMap) Reset()

func (*PitrTableMap) Size 

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

func (*PitrTableMap) String 

func (m *PitrTableMap) String() string

func (*PitrTableMap) Unmarshal 

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

func (*PitrTableMap) XXX_DiscardUnknown 

func (m *PitrTableMap) XXX_DiscardUnknown()

func (*PitrTableMap) XXX_Marshal 

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

func (*PitrTableMap) XXX_Merge 

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

func (*PitrTableMap) XXX_Size 

func (m *PitrTableMap) XXX_Size() int

func (*PitrTableMap) XXX_Unmarshal 

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

type PlacementPolicy 

type PlacementPolicy struct {
	Info []byte `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

func (*PlacementPolicy) Descriptor 

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

func (*PlacementPolicy) GetInfo 

func (m *PlacementPolicy) GetInfo() []byte

func (*PlacementPolicy) Marshal 

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

func (*PlacementPolicy) MarshalTo 

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

func (*PlacementPolicy) MarshalToSizedBuffer 

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

func (*PlacementPolicy) ProtoMessage 

func (*PlacementPolicy) ProtoMessage()

func (*PlacementPolicy) Reset 

func (m *PlacementPolicy) Reset()

func (*PlacementPolicy) Size 

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

func (*PlacementPolicy) String 

func (m *PlacementPolicy) String() string

func (*PlacementPolicy) Unmarshal 

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

func (*PlacementPolicy) XXX_DiscardUnknown 

func (m *PlacementPolicy) XXX_DiscardUnknown()

func (*PlacementPolicy) XXX_Marshal 

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

func (*PlacementPolicy) XXX_Merge 

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

func (*PlacementPolicy) XXX_Size 

func (m *PlacementPolicy) XXX_Size() int

func (*PlacementPolicy) XXX_Unmarshal 

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

type PrepareRequest 

type PrepareRequest struct {
	// whether save state to the storage.
	SaveToStorage bool `protobuf:"varint,1,opt,name=save_to_storage,json=saveToStorage,proto3" json:"save_to_storage,omitempty"`
}

func (*PrepareRequest) Descriptor 

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

func (*PrepareRequest) GetSaveToStorage 

func (m *PrepareRequest) GetSaveToStorage() bool

func (*PrepareRequest) Marshal 

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

func (*PrepareRequest) MarshalTo 

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

func (*PrepareRequest) MarshalToSizedBuffer 

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

func (*PrepareRequest) ProtoMessage 

func (*PrepareRequest) ProtoMessage()

func (*PrepareRequest) Reset 

func (m *PrepareRequest) Reset()

func (*PrepareRequest) Size 

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

func (*PrepareRequest) String 

func (m *PrepareRequest) String() string

func (*PrepareRequest) Unmarshal 

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

func (*PrepareRequest) XXX_DiscardUnknown 

func (m *PrepareRequest) XXX_DiscardUnknown()

func (*PrepareRequest) XXX_Marshal 

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

func (*PrepareRequest) XXX_Merge 

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

func (*PrepareRequest) XXX_Size 

func (m *PrepareRequest) XXX_Size() int

func (*PrepareRequest) XXX_Unmarshal 

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

type PrepareResponse 

type PrepareResponse struct {
	Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// unique_id represents the unique handle of the whole backup predecure.
	// if unique_id = 0 means prepare failed.
	// if unique_id > 0 means prepare success and all states saved with this unique info.
	UniqueId         string `protobuf:"bytes,2,opt,name=unique_id,json=uniqueId,proto3" json:"unique_id,omitempty"`
	CollectFileCount uint64 `protobuf:"varint,3,opt,name=collect_file_count,json=collectFileCount,proto3" json:"collect_file_count,omitempty"`
	CollectFileSize  uint64 `protobuf:"varint,4,opt,name=collect_file_size,json=collectFileSize,proto3" json:"collect_file_size,omitempty"`
}

func (*PrepareResponse) Descriptor 

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

func (*PrepareResponse) GetCollectFileCount 

func (m *PrepareResponse) GetCollectFileCount() uint64

func (*PrepareResponse) GetCollectFileSize 

func (m *PrepareResponse) GetCollectFileSize() uint64

func (*PrepareResponse) GetError 

func (m *PrepareResponse) GetError() *Error

func (*PrepareResponse) GetUniqueId 

func (m *PrepareResponse) GetUniqueId() string

func (*PrepareResponse) Marshal 

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

func (*PrepareResponse) MarshalTo 

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

func (*PrepareResponse) MarshalToSizedBuffer 

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

func (*PrepareResponse) ProtoMessage 

func (*PrepareResponse) ProtoMessage()

func (*PrepareResponse) Reset 

func (m *PrepareResponse) Reset()

func (*PrepareResponse) Size 

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

func (*PrepareResponse) String 

func (m *PrepareResponse) String() string

func (*PrepareResponse) Unmarshal 

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

func (*PrepareResponse) XXX_DiscardUnknown 

func (m *PrepareResponse) XXX_DiscardUnknown()

func (*PrepareResponse) XXX_Marshal 

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

func (*PrepareResponse) XXX_Merge 

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

func (*PrepareResponse) XXX_Size 

func (m *PrepareResponse) XXX_Size() int

func (*PrepareResponse) XXX_Unmarshal 

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

type PrepareSnapshotBackupEventType 

type PrepareSnapshotBackupEventType int32
const (
	// A region has finished wait apply.
	PrepareSnapshotBackupEventType_WaitApplyDone PrepareSnapshotBackupEventType = 0
	// A lease has been updated.
	PrepareSnapshotBackupEventType_UpdateLeaseResult PrepareSnapshotBackupEventType = 1
)

func (PrepareSnapshotBackupEventType) EnumDescriptor 

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

func (PrepareSnapshotBackupEventType) String 

func (x PrepareSnapshotBackupEventType) String() string

type PrepareSnapshotBackupRequest 

type PrepareSnapshotBackupRequest struct {
	// The type of the request.
	Ty PrepareSnapshotBackupRequestType `protobuf:"varint,1,opt,name=ty,proto3,enum=backup.PrepareSnapshotBackupRequestType" json:"ty,omitempty"`
	// The regions related to the request.
	// If the request is "UpdateLease" or "Finish", it should be empty.
	Regions []*metapb.Region `protobuf:"bytes,2,rep,name=regions,proto3" json:"regions,omitempty"`
	// The lease duration for "UpdateLease" request.
	LeaseInSeconds uint64 `protobuf:"varint,3,opt,name=lease_in_seconds,json=leaseInSeconds,proto3" json:"lease_in_seconds,omitempty"`
}

func (*PrepareSnapshotBackupRequest) Descriptor 

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

func (*PrepareSnapshotBackupRequest) GetLeaseInSeconds 

func (m *PrepareSnapshotBackupRequest) GetLeaseInSeconds() uint64

func (*PrepareSnapshotBackupRequest) GetRegions 

func (m *PrepareSnapshotBackupRequest) GetRegions() []*metapb.Region

func (*PrepareSnapshotBackupRequest) GetTy 

func (m *PrepareSnapshotBackupRequest) GetTy() PrepareSnapshotBackupRequestType

func (*PrepareSnapshotBackupRequest) Marshal 

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

func (*PrepareSnapshotBackupRequest) MarshalTo 

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

func (*PrepareSnapshotBackupRequest) MarshalToSizedBuffer 

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

func (*PrepareSnapshotBackupRequest) ProtoMessage 

func (*PrepareSnapshotBackupRequest) ProtoMessage()

func (*PrepareSnapshotBackupRequest) Reset 

func (m *PrepareSnapshotBackupRequest) Reset()

func (*PrepareSnapshotBackupRequest) Size 

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

func (*PrepareSnapshotBackupRequest) String 

func (m *PrepareSnapshotBackupRequest) String() string

func (*PrepareSnapshotBackupRequest) Unmarshal 

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

func (*PrepareSnapshotBackupRequest) XXX_DiscardUnknown 

func (m *PrepareSnapshotBackupRequest) XXX_DiscardUnknown()

func (*PrepareSnapshotBackupRequest) XXX_Marshal 

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

func (*PrepareSnapshotBackupRequest) XXX_Merge 

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

func (*PrepareSnapshotBackupRequest) XXX_Size 

func (m *PrepareSnapshotBackupRequest) XXX_Size() int

func (*PrepareSnapshotBackupRequest) XXX_Unmarshal 

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

type PrepareSnapshotBackupRequestType 

type PrepareSnapshotBackupRequestType int32
const (
	// Update the lease of suspending some commands (Which may impact the
	// disk snapshot backup) to be proposed.
	// As long as the lease is kept, those commands may not be proposed.
	// If the client has gone, the lease will be destroyed after its TTL.
	PrepareSnapshotBackupRequestType_UpdateLease PrepareSnapshotBackupRequestType = 0
	// Wait a region apply to the last index.
	PrepareSnapshotBackupRequestType_WaitApply PrepareSnapshotBackupRequestType = 1
	// Hint before closing the stream. Server will go back to normal after this.
	// This should also return a final "UpdateLeaseResult" to the client, which
	// indices whether the last lease is valid.
	PrepareSnapshotBackupRequestType_Finish PrepareSnapshotBackupRequestType = 2
)

func (PrepareSnapshotBackupRequestType) EnumDescriptor 

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

func (PrepareSnapshotBackupRequestType) String 

func (x PrepareSnapshotBackupRequestType) String() string

type PrepareSnapshotBackupResponse 

type PrepareSnapshotBackupResponse struct {
	// The type of the event.
	Ty PrepareSnapshotBackupEventType `protobuf:"varint,1,opt,name=ty,proto3,enum=backup.PrepareSnapshotBackupEventType" json:"ty,omitempty"`
	// The region bind to the type.
	// For "WaitApplyDone".
	Region *metapb.Region `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// The error of the execution.
	Error *errorpb.Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// Whether the last lease is valid.
	// For "UpdateLease" and "Finish".
	LastLeaseIsValid bool `protobuf:"varint,4,opt,name=last_lease_is_valid,json=lastLeaseIsValid,proto3" json:"last_lease_is_valid,omitempty"`
}

func (*PrepareSnapshotBackupResponse) Descriptor 

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

func (*PrepareSnapshotBackupResponse) GetError 

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

func (*PrepareSnapshotBackupResponse) GetLastLeaseIsValid 

func (m *PrepareSnapshotBackupResponse) GetLastLeaseIsValid() bool

func (*PrepareSnapshotBackupResponse) GetRegion 

func (m *PrepareSnapshotBackupResponse) GetRegion() *metapb.Region

func (*PrepareSnapshotBackupResponse) GetTy 

func (m *PrepareSnapshotBackupResponse) GetTy() PrepareSnapshotBackupEventType

func (*PrepareSnapshotBackupResponse) Marshal 

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

func (*PrepareSnapshotBackupResponse) MarshalTo 

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

func (*PrepareSnapshotBackupResponse) MarshalToSizedBuffer 

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

func (*PrepareSnapshotBackupResponse) ProtoMessage 

func (*PrepareSnapshotBackupResponse) ProtoMessage()

func (*PrepareSnapshotBackupResponse) Reset 

func (m *PrepareSnapshotBackupResponse) Reset()

func (*PrepareSnapshotBackupResponse) Size 

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

func (*PrepareSnapshotBackupResponse) String 

func (m *PrepareSnapshotBackupResponse) String() string

func (*PrepareSnapshotBackupResponse) Unmarshal 

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

func (*PrepareSnapshotBackupResponse) XXX_DiscardUnknown 

func (m *PrepareSnapshotBackupResponse) XXX_DiscardUnknown()

func (*PrepareSnapshotBackupResponse) XXX_Marshal 

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

func (*PrepareSnapshotBackupResponse) XXX_Merge 

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

func (*PrepareSnapshotBackupResponse) XXX_Size 

func (m *PrepareSnapshotBackupResponse) XXX_Size() int

func (*PrepareSnapshotBackupResponse) XXX_Unmarshal 

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

type RawRange 

type RawRange struct {
	StartKey []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	EndKey   []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	Cf       string `protobuf:"bytes,3,opt,name=cf,proto3" json:"cf,omitempty"`
}

func (*RawRange) Descriptor 

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

func (*RawRange) GetCf 

func (m *RawRange) GetCf() string

func (*RawRange) GetEndKey 

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

func (*RawRange) GetStartKey 

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

func (*RawRange) Marshal 

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

func (*RawRange) MarshalTo 

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

func (*RawRange) MarshalToSizedBuffer 

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

func (*RawRange) ProtoMessage 

func (*RawRange) ProtoMessage()

func (*RawRange) Reset 

func (m *RawRange) Reset()

func (*RawRange) Size 

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

func (*RawRange) String 

func (m *RawRange) String() string

func (*RawRange) Unmarshal 

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

func (*RawRange) XXX_DiscardUnknown 

func (m *RawRange) XXX_DiscardUnknown()

func (*RawRange) XXX_Marshal 

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

func (*RawRange) XXX_Merge 

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

func (*RawRange) XXX_Size 

func (m *RawRange) XXX_Size() int

func (*RawRange) XXX_Unmarshal 

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

type RegionMetaHint 

type RegionMetaHint struct {
	// The left boundary of the region of this epoch.
	// It is an byte-comparable encoded key without TS.
	StartKey []byte `protobuf:"bytes,1,opt,name=start_key,json=startKey,proto3" json:"start_key,omitempty"`
	// The right boundary of the region of the epoch.
	EndKey []byte `protobuf:"bytes,2,opt,name=end_key,json=endKey,proto3" json:"end_key,omitempty"`
	// The region epoch.
	RegionEpoch *metapb.RegionEpoch `protobuf:"bytes,3,opt,name=region_epoch,json=regionEpoch,proto3" json:"region_epoch,omitempty"`
}

func (*RegionMetaHint) Descriptor 

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

func (*RegionMetaHint) GetEndKey 

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

func (*RegionMetaHint) GetRegionEpoch 

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

func (*RegionMetaHint) GetStartKey 

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

func (*RegionMetaHint) Marshal 

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

func (*RegionMetaHint) MarshalTo 

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

func (*RegionMetaHint) MarshalToSizedBuffer 

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

func (*RegionMetaHint) ProtoMessage 

func (*RegionMetaHint) ProtoMessage()

func (*RegionMetaHint) Reset 

func (m *RegionMetaHint) Reset()

func (*RegionMetaHint) Size 

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

func (*RegionMetaHint) String 

func (m *RegionMetaHint) String() string

func (*RegionMetaHint) Unmarshal 

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

func (*RegionMetaHint) XXX_DiscardUnknown 

func (m *RegionMetaHint) XXX_DiscardUnknown()

func (*RegionMetaHint) XXX_Marshal 

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

func (*RegionMetaHint) XXX_Merge 

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

func (*RegionMetaHint) XXX_Size 

func (m *RegionMetaHint) XXX_Size() int

func (*RegionMetaHint) XXX_Unmarshal 

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

type S3 

type S3 struct {
	Endpoint     string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Region       string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	Bucket       string `protobuf:"bytes,3,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Prefix       string `protobuf:"bytes,4,opt,name=prefix,proto3" json:"prefix,omitempty"`
	StorageClass string `protobuf:"bytes,5,opt,name=storage_class,json=storageClass,proto3" json:"storage_class,omitempty"`
	// server side encryption
	Sse               string `protobuf:"bytes,6,opt,name=sse,proto3" json:"sse,omitempty"`
	Acl               string `protobuf:"bytes,7,opt,name=acl,proto3" json:"acl,omitempty"`
	AccessKey         string `protobuf:"bytes,8,opt,name=access_key,json=accessKey,proto3" json:"access_key,omitempty"`
	SecretAccessKey   string `protobuf:"bytes,9,opt,name=secret_access_key,json=secretAccessKey,proto3" json:"secret_access_key,omitempty"`
	ForcePathStyle    bool   `protobuf:"varint,10,opt,name=force_path_style,json=forcePathStyle,proto3" json:"force_path_style,omitempty"`
	SseKmsKeyId       string `protobuf:"bytes,11,opt,name=sse_kms_key_id,json=sseKmsKeyId,proto3" json:"sse_kms_key_id,omitempty"`
	RoleArn           string `protobuf:"bytes,12,opt,name=role_arn,json=roleArn,proto3" json:"role_arn,omitempty"`
	ExternalId        string `protobuf:"bytes,13,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	ObjectLockEnabled bool   `protobuf:"varint,14,opt,name=object_lock_enabled,json=objectLockEnabled,proto3" json:"object_lock_enabled,omitempty"`
	SessionToken      string `protobuf:"bytes,15,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`
	Provider          string `protobuf:"bytes,16,opt,name=provider,proto3" json:"provider,omitempty"`
	Profile           string `protobuf:"bytes,17,opt,name=profile,proto3" json:"profile,omitempty"`
}

S3 storage backend saves files into S3 compatible storages For non-aws providers, endpoint must be provided

func (*S3) Descriptor 

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

func (*S3) GetAccessKey 

func (m *S3) GetAccessKey() string

func (*S3) GetAcl 

func (m *S3) GetAcl() string

func (*S3) GetBucket 

func (m *S3) GetBucket() string

func (*S3) GetEndpoint 

func (m *S3) GetEndpoint() string

func (*S3) GetExternalId 

func (m *S3) GetExternalId() string

func (*S3) GetForcePathStyle 

func (m *S3) GetForcePathStyle() bool

func (*S3) GetObjectLockEnabled 

func (m *S3) GetObjectLockEnabled() bool

func (*S3) GetPrefix 

func (m *S3) GetPrefix() string

func (*S3) GetProfile 

func (m *S3) GetProfile() string

func (*S3) GetProvider 

func (m *S3) GetProvider() string

func (*S3) GetRegion 

func (m *S3) GetRegion() string

func (*S3) GetRoleArn 

func (m *S3) GetRoleArn() string

func (*S3) GetSecretAccessKey 

func (m *S3) GetSecretAccessKey() string

func (*S3) GetSessionToken 

func (m *S3) GetSessionToken() string

func (*S3) GetSse 

func (m *S3) GetSse() string

func (*S3) GetSseKmsKeyId 

func (m *S3) GetSseKmsKeyId() string

func (*S3) GetStorageClass 

func (m *S3) GetStorageClass() string

func (*S3) Marshal 

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

func (*S3) MarshalTo 

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

func (*S3) MarshalToSizedBuffer 

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

func (*S3) ProtoMessage 

func (*S3) ProtoMessage()

func (*S3) Reset 

func (m *S3) Reset()

func (*S3) Size 

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

func (*S3) String 

func (m *S3) String() string

func (*S3) Unmarshal 

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

func (*S3) XXX_DiscardUnknown 

func (m *S3) XXX_DiscardUnknown()

func (*S3) XXX_Marshal 

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

func (*S3) XXX_Merge 

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

func (*S3) XXX_Size 

func (m *S3) XXX_Size() int

func (*S3) XXX_Unmarshal 

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

type Schema 

type Schema struct {
	Db              []byte `protobuf:"bytes,1,opt,name=db,proto3" json:"db,omitempty"`
	Table           []byte `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Crc64Xor        uint64 `protobuf:"varint,3,opt,name=crc64xor,proto3" json:"crc64xor,omitempty"`
	TotalKvs        uint64 `protobuf:"varint,4,opt,name=total_kvs,json=totalKvs,proto3" json:"total_kvs,omitempty"`
	TotalBytes      uint64 `protobuf:"varint,5,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
	TiflashReplicas uint32 `protobuf:"varint,6,opt,name=tiflash_replicas,json=tiflashReplicas,proto3" json:"tiflash_replicas,omitempty"`
	// stats represents the dump stats for a analyzed table, which generate by DumpStatsToJSON
	// https://github.com/pingcap/tidb/blob/e136429d8dc5d70f43cd3f94179b0b9f47595097/statistics/handle/dump.go#L116
	Stats []byte `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats,omitempty"`
	// An index of files that contains stats data
	StatsIndex []*StatsFileIndex `protobuf:"bytes,8,rep,name=stats_index,json=statsIndex,proto3" json:"stats_index,omitempty"`
}

func (*Schema) Descriptor 

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

func (*Schema) GetCrc64Xor 

func (m *Schema) GetCrc64Xor() uint64

func (*Schema) GetDb 

func (m *Schema) GetDb() []byte

func (*Schema) GetStats 

func (m *Schema) GetStats() []byte

func (*Schema) GetStatsIndex 

func (m *Schema) GetStatsIndex() []*StatsFileIndex

func (*Schema) GetTable 

func (m *Schema) GetTable() []byte

func (*Schema) GetTiflashReplicas 

func (m *Schema) GetTiflashReplicas() uint32

func (*Schema) GetTotalBytes 

func (m *Schema) GetTotalBytes() uint64

func (*Schema) GetTotalKvs 

func (m *Schema) GetTotalKvs() uint64

func (*Schema) Marshal 

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

func (*Schema) MarshalTo 

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

func (*Schema) MarshalToSizedBuffer 

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

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) Reset 

func (m *Schema) Reset()

func (*Schema) Size 

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

func (*Schema) String 

func (m *Schema) String() string

func (*Schema) Unmarshal 

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

func (*Schema) XXX_DiscardUnknown 

func (m *Schema) XXX_DiscardUnknown()

func (*Schema) XXX_Marshal 

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

func (*Schema) XXX_Merge 

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

func (*Schema) XXX_Size 

func (m *Schema) XXX_Size() int

func (*Schema) XXX_Unmarshal 

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

type SortedSubRanges 

type SortedSubRanges struct {
	SubRanges []*kvrpcpb.KeyRange `protobuf:"bytes,1,rep,name=sub_ranges,json=subRanges,proto3" json:"sub_ranges,omitempty"`
}

func (*SortedSubRanges) Descriptor 

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

func (*SortedSubRanges) GetSubRanges 

func (m *SortedSubRanges) GetSubRanges() []*kvrpcpb.KeyRange

func (*SortedSubRanges) Marshal 

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

func (*SortedSubRanges) MarshalTo 

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

func (*SortedSubRanges) MarshalToSizedBuffer 

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

func (*SortedSubRanges) ProtoMessage 

func (*SortedSubRanges) ProtoMessage()

func (*SortedSubRanges) Reset 

func (m *SortedSubRanges) Reset()

func (*SortedSubRanges) Size 

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

func (*SortedSubRanges) String 

func (m *SortedSubRanges) String() string

func (*SortedSubRanges) Unmarshal 

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

func (*SortedSubRanges) XXX_DiscardUnknown 

func (m *SortedSubRanges) XXX_DiscardUnknown()

func (*SortedSubRanges) XXX_Marshal 

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

func (*SortedSubRanges) XXX_Merge 

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

func (*SortedSubRanges) XXX_Size 

func (m *SortedSubRanges) XXX_Size() int

func (*SortedSubRanges) XXX_Unmarshal 

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

type Span 

type Span struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Length uint64 `protobuf:"varint,2,opt,name=length,proto3" json:"length,omitempty"`
}

func (*Span) Descriptor 

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

func (*Span) GetLength 

func (m *Span) GetLength() uint64

func (*Span) GetOffset 

func (m *Span) GetOffset() uint64

func (*Span) Marshal 

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

func (*Span) MarshalTo 

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

func (*Span) MarshalToSizedBuffer 

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

func (*Span) ProtoMessage 

func (*Span) ProtoMessage()

func (*Span) Reset 

func (m *Span) Reset()

func (*Span) Size 

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

func (*Span) String 

func (m *Span) String() string

func (*Span) Unmarshal 

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

func (*Span) XXX_DiscardUnknown 

func (m *Span) XXX_DiscardUnknown()

func (*Span) XXX_Marshal 

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

func (*Span) XXX_Merge 

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

func (*Span) XXX_Size 

func (m *Span) XXX_Size() int

func (*Span) XXX_Unmarshal 

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

type SpansOfFile 

type SpansOfFile struct {
	Path  string  `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Spans []*Span `protobuf:"bytes,2,rep,name=spans,proto3" json:"spans,omitempty"`
}

func (*SpansOfFile) Descriptor 

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

func (*SpansOfFile) GetPath 

func (m *SpansOfFile) GetPath() string

func (*SpansOfFile) GetSpans 

func (m *SpansOfFile) GetSpans() []*Span

func (*SpansOfFile) Marshal 

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

func (*SpansOfFile) MarshalTo 

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

func (*SpansOfFile) MarshalToSizedBuffer 

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

func (*SpansOfFile) ProtoMessage 

func (*SpansOfFile) ProtoMessage()

func (*SpansOfFile) Reset 

func (m *SpansOfFile) Reset()

func (*SpansOfFile) Size 

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

func (*SpansOfFile) String 

func (m *SpansOfFile) String() string

func (*SpansOfFile) Unmarshal 

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

func (*SpansOfFile) XXX_DiscardUnknown 

func (m *SpansOfFile) XXX_DiscardUnknown()

func (*SpansOfFile) XXX_Marshal 

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

func (*SpansOfFile) XXX_Merge 

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

func (*SpansOfFile) XXX_Size 

func (m *SpansOfFile) XXX_Size() int

func (*SpansOfFile) XXX_Unmarshal 

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

type StatsBlock 

type StatsBlock struct {
	// The physical id which the stats json data belongs to.
	PhysicalId int64 `protobuf:"varint,1,opt,name=physical_id,json=physicalId,proto3" json:"physical_id,omitempty"`
	// The marshal data of the part of json_table. Currently it is the partition table.
	JsonTable []byte `protobuf:"bytes,2,opt,name=json_table,json=jsonTable,proto3" json:"json_table,omitempty"`
}

func (*StatsBlock) Descriptor 

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

func (*StatsBlock) GetJsonTable 

func (m *StatsBlock) GetJsonTable() []byte

func (*StatsBlock) GetPhysicalId 

func (m *StatsBlock) GetPhysicalId() int64

func (*StatsBlock) Marshal 

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

func (*StatsBlock) MarshalTo 

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

func (*StatsBlock) MarshalToSizedBuffer 

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

func (*StatsBlock) ProtoMessage 

func (*StatsBlock) ProtoMessage()

func (*StatsBlock) Reset 

func (m *StatsBlock) Reset()

func (*StatsBlock) Size 

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

func (*StatsBlock) String 

func (m *StatsBlock) String() string

func (*StatsBlock) Unmarshal 

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

func (*StatsBlock) XXX_DiscardUnknown 

func (m *StatsBlock) XXX_DiscardUnknown()

func (*StatsBlock) XXX_Marshal 

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

func (*StatsBlock) XXX_Merge 

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

func (*StatsBlock) XXX_Size 

func (m *StatsBlock) XXX_Size() int

func (*StatsBlock) XXX_Unmarshal 

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

type StatsFile 

type StatsFile struct {
	// A set of files that contains json_tables.
	Blocks []*StatsBlock `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
}

func (*StatsFile) Descriptor 

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

func (*StatsFile) GetBlocks 

func (m *StatsFile) GetBlocks() []*StatsBlock

func (*StatsFile) Marshal 

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

func (*StatsFile) MarshalTo 

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

func (*StatsFile) MarshalToSizedBuffer 

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

func (*StatsFile) ProtoMessage 

func (*StatsFile) ProtoMessage()

func (*StatsFile) Reset 

func (m *StatsFile) Reset()

func (*StatsFile) Size 

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

func (*StatsFile) String 

func (m *StatsFile) String() string

func (*StatsFile) Unmarshal 

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

func (*StatsFile) XXX_DiscardUnknown 

func (m *StatsFile) XXX_DiscardUnknown()

func (*StatsFile) XXX_Marshal 

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

func (*StatsFile) XXX_Merge 

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

func (*StatsFile) XXX_Size 

func (m *StatsFile) XXX_Size() int

func (*StatsFile) XXX_Unmarshal 

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

type StatsFileIndex 

type StatsFileIndex struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Sha256 []byte `protobuf:"bytes,2,opt,name=sha256,proto3" json:"sha256,omitempty"`
	// the size of the file content encrypted
	SizeEnc uint64 `protobuf:"varint,3,opt,name=size_enc,json=sizeEnc,proto3" json:"size_enc,omitempty"`
	// the size of the original file content
	SizeOri uint64 `protobuf:"varint,4,opt,name=size_ori,json=sizeOri,proto3" json:"size_ori,omitempty"`
	// cipher_iv is used for AES cipher
	CipherIv []byte `protobuf:"bytes,5,opt,name=cipher_iv,json=cipherIv,proto3" json:"cipher_iv,omitempty"`
	// If the size of the stats is very small, save the data into the metafile
	InlineData []byte `protobuf:"bytes,6,opt,name=inline_data,json=inlineData,proto3" json:"inline_data,omitempty"`
}

func (*StatsFileIndex) Descriptor 

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

func (*StatsFileIndex) GetCipherIv 

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

func (*StatsFileIndex) GetInlineData 

func (m *StatsFileIndex) GetInlineData() []byte

func (*StatsFileIndex) GetName 

func (m *StatsFileIndex) GetName() string

func (*StatsFileIndex) GetSha256 

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

func (*StatsFileIndex) GetSizeEnc 

func (m *StatsFileIndex) GetSizeEnc() uint64

func (*StatsFileIndex) GetSizeOri 

func (m *StatsFileIndex) GetSizeOri() uint64

func (*StatsFileIndex) Marshal 

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

func (*StatsFileIndex) MarshalTo 

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

func (*StatsFileIndex) MarshalToSizedBuffer 

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

func (*StatsFileIndex) ProtoMessage 

func (*StatsFileIndex) ProtoMessage()

func (*StatsFileIndex) Reset 

func (m *StatsFileIndex) Reset()

func (*StatsFileIndex) Size 

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

func (*StatsFileIndex) String 

func (m *StatsFileIndex) String() string

func (*StatsFileIndex) Unmarshal 

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

func (*StatsFileIndex) XXX_DiscardUnknown 

func (m *StatsFileIndex) XXX_DiscardUnknown()

func (*StatsFileIndex) XXX_Marshal 

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

func (*StatsFileIndex) XXX_Merge 

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

func (*StatsFileIndex) XXX_Size 

func (m *StatsFileIndex) XXX_Size() int

func (*StatsFileIndex) XXX_Unmarshal 

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

type StorageBackend 

type StorageBackend struct {
	// Types that are valid to be assigned to Backend:
	//	*StorageBackend_Noop
	//	*StorageBackend_Local
	//	*StorageBackend_S3
	//	*StorageBackend_Gcs
	//	*StorageBackend_CloudDynamic
	//	*StorageBackend_Hdfs
	//	*StorageBackend_AzureBlobStorage
	Backend isStorageBackend_Backend `protobuf_oneof:"backend"`
}

func (*StorageBackend) Descriptor 

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

func (*StorageBackend) GetAzureBlobStorage 

func (m *StorageBackend) GetAzureBlobStorage() *AzureBlobStorage

func (*StorageBackend) GetBackend 

func (m *StorageBackend) GetBackend() isStorageBackend_Backend

func (*StorageBackend) GetCloudDynamic 

func (m *StorageBackend) GetCloudDynamic() *CloudDynamic

func (*StorageBackend) GetGcs 

func (m *StorageBackend) GetGcs() *GCS

func (*StorageBackend) GetHdfs 

func (m *StorageBackend) GetHdfs() *HDFS

func (*StorageBackend) GetLocal 

func (m *StorageBackend) GetLocal() *Local

func (*StorageBackend) GetNoop 

func (m *StorageBackend) GetNoop() *Noop

func (*StorageBackend) GetS3 

func (m *StorageBackend) GetS3() *S3

func (*StorageBackend) Marshal 

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

func (*StorageBackend) MarshalTo 

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

func (*StorageBackend) MarshalToSizedBuffer 

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

func (*StorageBackend) ProtoMessage 

func (*StorageBackend) ProtoMessage()

func (*StorageBackend) Reset 

func (m *StorageBackend) Reset()

func (*StorageBackend) Size 

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

func (*StorageBackend) String 

func (m *StorageBackend) String() string

func (*StorageBackend) Unmarshal 

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

func (*StorageBackend) XXX_DiscardUnknown 

func (m *StorageBackend) XXX_DiscardUnknown()

func (*StorageBackend) XXX_Marshal 

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

func (*StorageBackend) XXX_Merge 

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

func (*StorageBackend) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*StorageBackend) XXX_Size 

func (m *StorageBackend) XXX_Size() int

func (*StorageBackend) XXX_Unmarshal 

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

type StorageBackend_AzureBlobStorage 

type StorageBackend_AzureBlobStorage struct {
	AzureBlobStorage *AzureBlobStorage `protobuf:"bytes,7,opt,name=azure_blob_storage,json=azureBlobStorage,proto3,oneof" json:"azure_blob_storage,omitempty"`
}

func (*StorageBackend_AzureBlobStorage) MarshalTo 

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

func (*StorageBackend_AzureBlobStorage) MarshalToSizedBuffer 

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

func (*StorageBackend_AzureBlobStorage) Size 

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

type StorageBackend_CloudDynamic 

type StorageBackend_CloudDynamic struct {
	CloudDynamic *CloudDynamic `protobuf:"bytes,5,opt,name=cloud_dynamic,json=cloudDynamic,proto3,oneof" json:"cloud_dynamic,omitempty"`
}

func (*StorageBackend_CloudDynamic) MarshalTo 

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

func (*StorageBackend_CloudDynamic) MarshalToSizedBuffer 

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

func (*StorageBackend_CloudDynamic) Size 

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

type StorageBackend_Gcs 

type StorageBackend_Gcs struct {
	Gcs *GCS `protobuf:"bytes,4,opt,name=gcs,proto3,oneof" json:"gcs,omitempty"`
}

func (*StorageBackend_Gcs) MarshalTo 

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

func (*StorageBackend_Gcs) MarshalToSizedBuffer 

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

func (*StorageBackend_Gcs) Size 

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

type StorageBackend_Hdfs 

type StorageBackend_Hdfs struct {
	Hdfs *HDFS `protobuf:"bytes,6,opt,name=hdfs,proto3,oneof" json:"hdfs,omitempty"`
}

func (*StorageBackend_Hdfs) MarshalTo 

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

func (*StorageBackend_Hdfs) MarshalToSizedBuffer 

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

func (*StorageBackend_Hdfs) Size 

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

type StorageBackend_Local 

type StorageBackend_Local struct {
	Local *Local `protobuf:"bytes,2,opt,name=local,proto3,oneof" json:"local,omitempty"`
}

func (*StorageBackend_Local) MarshalTo 

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

func (*StorageBackend_Local) MarshalToSizedBuffer 

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

func (*StorageBackend_Local) Size 

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

type StorageBackend_Noop 

type StorageBackend_Noop struct {
	Noop *Noop `protobuf:"bytes,1,opt,name=noop,proto3,oneof" json:"noop,omitempty"`
}

func (*StorageBackend_Noop) MarshalTo 

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

func (*StorageBackend_Noop) MarshalToSizedBuffer 

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

func (*StorageBackend_Noop) Size 

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

type StorageBackend_S3 

type StorageBackend_S3 struct {
	S3 *S3 `protobuf:"bytes,3,opt,name=s3,proto3,oneof" json:"s3,omitempty"`
}

func (*StorageBackend_S3) MarshalTo 

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

func (*StorageBackend_S3) MarshalToSizedBuffer 

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

func (*StorageBackend_S3) Size 

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

type StreamBackupError 

type StreamBackupError struct {
	// the unix epoch time (in millisecs) of the time the error reported.
	HappenAt uint64 `protobuf:"varint,1,opt,name=happen_at,json=happenAt,proto3" json:"happen_at,omitempty"`
	// the unified error code of the error.
	ErrorCode string `protobuf:"bytes,2,opt,name=error_code,json=errorCode,proto3" json:"error_code,omitempty"`
	// the user-friendly error message.
	ErrorMessage string `protobuf:"bytes,3,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// the store id of who issues the error.
	StoreId uint64 `protobuf:"varint,4,opt,name=store_id,json=storeId,proto3" json:"store_id,omitempty"`
}

func (*StreamBackupError) Descriptor 

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

func (*StreamBackupError) GetErrorCode 

func (m *StreamBackupError) GetErrorCode() string

func (*StreamBackupError) GetErrorMessage 

func (m *StreamBackupError) GetErrorMessage() string

func (*StreamBackupError) GetHappenAt 

func (m *StreamBackupError) GetHappenAt() uint64

func (*StreamBackupError) GetStoreId 

func (m *StreamBackupError) GetStoreId() uint64

func (*StreamBackupError) Marshal 

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

func (*StreamBackupError) MarshalTo 

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

func (*StreamBackupError) MarshalToSizedBuffer 

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

func (*StreamBackupError) ProtoMessage 

func (*StreamBackupError) ProtoMessage()

func (*StreamBackupError) Reset 

func (m *StreamBackupError) Reset()

func (*StreamBackupError) Size 

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

func (*StreamBackupError) String 

func (m *StreamBackupError) String() string

func (*StreamBackupError) Unmarshal 

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

func (*StreamBackupError) XXX_DiscardUnknown 

func (m *StreamBackupError) XXX_DiscardUnknown()

func (*StreamBackupError) XXX_Marshal 

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

func (*StreamBackupError) XXX_Merge 

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

func (*StreamBackupError) XXX_Size 

func (m *StreamBackupError) XXX_Size() int

func (*StreamBackupError) XXX_Unmarshal 

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

type StreamBackupTaskInfo 

type StreamBackupTaskInfo struct {
	// The storage for backup, parsed by BR.
	Storage *StorageBackend `protobuf:"bytes,1,opt,name=storage,proto3" json:"storage,omitempty"`
	// The time range for backing up.
	StartTs uint64 `protobuf:"varint,2,opt,name=start_ts,json=startTs,proto3" json:"start_ts,omitempty"`
	EndTs   uint64 `protobuf:"varint,3,opt,name=end_ts,json=endTs,proto3" json:"end_ts,omitempty"`
	// Misc meta data.
	// The name of the task, also the ID of the task.
	Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	// The table filter of the task.
	// Only for displaying the task info.
	TableFilter []string `protobuf:"bytes,5,rep,name=table_filter,json=tableFilter,proto3" json:"table_filter,omitempty"`
	// compression type
	CompressionType CompressionType `` /* 135-byte string literal not displayed */
	// security config for backup files
	SecurityConfig *StreamBackupTaskSecurityConfig `protobuf:"bytes,7,opt,name=security_config,json=securityConfig,proto3" json:"security_config,omitempty"`
}

func (*StreamBackupTaskInfo) Descriptor 

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

func (*StreamBackupTaskInfo) GetCompressionType 

func (m *StreamBackupTaskInfo) GetCompressionType() CompressionType

func (*StreamBackupTaskInfo) GetEndTs 

func (m *StreamBackupTaskInfo) GetEndTs() uint64

func (*StreamBackupTaskInfo) GetName 

func (m *StreamBackupTaskInfo) GetName() string

func (*StreamBackupTaskInfo) GetSecurityConfig 

func (m *StreamBackupTaskInfo) GetSecurityConfig() *StreamBackupTaskSecurityConfig

func (*StreamBackupTaskInfo) GetStartTs 

func (m *StreamBackupTaskInfo) GetStartTs() uint64

func (*StreamBackupTaskInfo) GetStorage 

func (m *StreamBackupTaskInfo) GetStorage() *StorageBackend

func (*StreamBackupTaskInfo) GetTableFilter 

func (m *StreamBackupTaskInfo) GetTableFilter() []string

func (*StreamBackupTaskInfo) Marshal 

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

func (*StreamBackupTaskInfo) MarshalTo 

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

func (*StreamBackupTaskInfo) MarshalToSizedBuffer 

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

func (*StreamBackupTaskInfo) ProtoMessage 

func (*StreamBackupTaskInfo) ProtoMessage()

func (*StreamBackupTaskInfo) Reset 

func (m *StreamBackupTaskInfo) Reset()

func (*StreamBackupTaskInfo) Size 

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

func (*StreamBackupTaskInfo) String 

func (m *StreamBackupTaskInfo) String() string

func (*StreamBackupTaskInfo) Unmarshal 

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

func (*StreamBackupTaskInfo) XXX_DiscardUnknown 

func (m *StreamBackupTaskInfo) XXX_DiscardUnknown()

func (*StreamBackupTaskInfo) XXX_Marshal 

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

func (*StreamBackupTaskInfo) XXX_Merge 

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

func (*StreamBackupTaskInfo) XXX_Size 

func (m *StreamBackupTaskInfo) XXX_Size() int

func (*StreamBackupTaskInfo) XXX_Unmarshal 

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

type StreamBackupTaskSecurityConfig 

type StreamBackupTaskSecurityConfig struct {
	// Types that are valid to be assigned to Encryption:
	//	*StreamBackupTaskSecurityConfig_PlaintextDataKey
	//	*StreamBackupTaskSecurityConfig_MasterKeyConfig
	Encryption isStreamBackupTaskSecurityConfig_Encryption `protobuf_oneof:"encryption"`
}

func (*StreamBackupTaskSecurityConfig) Descriptor 

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

func (*StreamBackupTaskSecurityConfig) GetEncryption 

func (m *StreamBackupTaskSecurityConfig) GetEncryption() isStreamBackupTaskSecurityConfig_Encryption

func (*StreamBackupTaskSecurityConfig) GetMasterKeyConfig 

func (m *StreamBackupTaskSecurityConfig) GetMasterKeyConfig() *MasterKeyConfig

func (*StreamBackupTaskSecurityConfig) GetPlaintextDataKey 

func (m *StreamBackupTaskSecurityConfig) GetPlaintextDataKey() *CipherInfo

func (*StreamBackupTaskSecurityConfig) Marshal 

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

func (*StreamBackupTaskSecurityConfig) MarshalTo 

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

func (*StreamBackupTaskSecurityConfig) MarshalToSizedBuffer 

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

func (*StreamBackupTaskSecurityConfig) ProtoMessage 

func (*StreamBackupTaskSecurityConfig) ProtoMessage()

func (*StreamBackupTaskSecurityConfig) Reset 

func (m *StreamBackupTaskSecurityConfig) Reset()

func (*StreamBackupTaskSecurityConfig) Size 

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

func (*StreamBackupTaskSecurityConfig) String 

func (m *StreamBackupTaskSecurityConfig) String() string

func (*StreamBackupTaskSecurityConfig) Unmarshal 

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

func (*StreamBackupTaskSecurityConfig) XXX_DiscardUnknown 

func (m *StreamBackupTaskSecurityConfig) XXX_DiscardUnknown()

func (*StreamBackupTaskSecurityConfig) XXX_Marshal 

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

func (*StreamBackupTaskSecurityConfig) XXX_Merge 

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

func (*StreamBackupTaskSecurityConfig) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*StreamBackupTaskSecurityConfig) XXX_Size 

func (m *StreamBackupTaskSecurityConfig) XXX_Size() int

func (*StreamBackupTaskSecurityConfig) XXX_Unmarshal 

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

type StreamBackupTaskSecurityConfig_MasterKeyConfig 

type StreamBackupTaskSecurityConfig_MasterKeyConfig struct {
	MasterKeyConfig *MasterKeyConfig `protobuf:"bytes,2,opt,name=master_key_config,json=masterKeyConfig,proto3,oneof" json:"master_key_config,omitempty"`
}

func (*StreamBackupTaskSecurityConfig_MasterKeyConfig) MarshalTo 

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

func (*StreamBackupTaskSecurityConfig_MasterKeyConfig) MarshalToSizedBuffer 

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

func (*StreamBackupTaskSecurityConfig_MasterKeyConfig) Size 

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

type StreamBackupTaskSecurityConfig_PlaintextDataKey 

type StreamBackupTaskSecurityConfig_PlaintextDataKey struct {
	PlaintextDataKey *CipherInfo `protobuf:"bytes,1,opt,name=plaintext_data_key,json=plaintextDataKey,proto3,oneof" json:"plaintext_data_key,omitempty"`
}

func (*StreamBackupTaskSecurityConfig_PlaintextDataKey) MarshalTo 

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

func (*StreamBackupTaskSecurityConfig_PlaintextDataKey) MarshalToSizedBuffer 

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

func (*StreamBackupTaskSecurityConfig_PlaintextDataKey) Size 

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

type TableMeta 

type TableMeta struct {
	// physical id is either table id or partition id
	PhysicalId int64  `protobuf:"varint,1,opt,name=physical_id,json=physicalId,proto3" json:"physical_id,omitempty"`
	Crc64Xor   uint64 `protobuf:"varint,2,opt,name=crc64xor,proto3" json:"crc64xor,omitempty"`
	TotalKvs   uint64 `protobuf:"varint,3,opt,name=total_kvs,json=totalKvs,proto3" json:"total_kvs,omitempty"`
	TotalBytes uint64 `protobuf:"varint,4,opt,name=total_bytes,json=totalBytes,proto3" json:"total_bytes,omitempty"`
}

The message saves the physical table checksum

func (*TableMeta) Descriptor 

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

func (*TableMeta) GetCrc64Xor 

func (m *TableMeta) GetCrc64Xor() uint64

func (*TableMeta) GetPhysicalId 

func (m *TableMeta) GetPhysicalId() int64

func (*TableMeta) GetTotalBytes 

func (m *TableMeta) GetTotalBytes() uint64

func (*TableMeta) GetTotalKvs 

func (m *TableMeta) GetTotalKvs() uint64

func (*TableMeta) Marshal 

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

func (*TableMeta) MarshalTo 

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

func (*TableMeta) MarshalToSizedBuffer 

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

func (*TableMeta) ProtoMessage 

func (*TableMeta) ProtoMessage()

func (*TableMeta) Reset 

func (m *TableMeta) Reset()

func (*TableMeta) Size 

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

func (*TableMeta) String 

func (m *TableMeta) String() string

func (*TableMeta) Unmarshal 

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

func (*TableMeta) XXX_DiscardUnknown 

func (m *TableMeta) XXX_DiscardUnknown()

func (*TableMeta) XXX_Marshal 

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

func (*TableMeta) XXX_Merge 

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

func (*TableMeta) XXX_Size 

func (m *TableMeta) XXX_Size() int

func (*TableMeta) XXX_Unmarshal 

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

type UnimplementedBackupServer 

type UnimplementedBackupServer struct {
}

UnimplementedBackupServer can be embedded to have forward compatible implementations.

func (*UnimplementedBackupServer) Backup 

func (*UnimplementedBackupServer) Backup(req *BackupRequest, srv Backup_BackupServer) error

func (*UnimplementedBackupServer) CheckPendingAdminOp 

func (*UnimplementedBackupServer) CheckPendingAdminOp(req *CheckAdminRequest, srv Backup_CheckPendingAdminOpServer) error

func (*UnimplementedBackupServer) Cleanup 

func (*UnimplementedBackupServer) Cleanup(ctx context.Context, req *CleanupRequest) (*CleanupResponse, error)

func (*UnimplementedBackupServer) Prepare 

func (*UnimplementedBackupServer) Prepare(ctx context.Context, req *PrepareRequest) (*PrepareResponse, error)

func (*UnimplementedBackupServer) PrepareSnapshotBackup 

func (*UnimplementedBackupServer) PrepareSnapshotBackup(srv Backup_PrepareSnapshotBackupServer) error

type UnimplementedExternalStorageServer 

type UnimplementedExternalStorageServer struct {
}

UnimplementedExternalStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedExternalStorageServer) Restore 

func (*UnimplementedExternalStorageServer) Restore(ctx context.Context, req *ExternalStorageRestoreRequest) (*ExternalStorageRestoreResponse, error)

func (*UnimplementedExternalStorageServer) Save 

func (*UnimplementedExternalStorageServer) Save(ctx context.Context, req *ExternalStorageSaveRequest) (*ExternalStorageSaveResponse, 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.