backup

package
v0.0.0-...-ad14807 Latest Latest
Warning

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

 Go to latest Published: Feb 5, 2025 License: Apache-2.0 Imports: 14 Imported by: 72

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",
	2: "M2",
}
View Source 
var MigrationVersion_value = map[string]int32{
	"M0": 0,
	"M1": 1,
	"M2": 2,
}
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 IngestedSSTs 

type IngestedSSTs struct {
	// The table IDs rewritten during restoring.
	RewrittenTables []*RewrittenTableID `protobuf:"bytes,1,rep,name=rewritten_tables,json=rewrittenTables,proto3" json:"rewritten_tables,omitempty"`
	// The SST files restored.
	Files []*File `protobuf:"bytes,2,rep,name=files,proto3" json:"files,omitempty"`
	// Treating the whole batch of SSTs as an huge atomic
	// write as this timestamp.
	// That is, when user wants to PiTR to sometime after this,
	// everything restored will present after the PiTR.
	// Otherwise nothing will present.
	AsIfTs uint64 `protobuf:"varint,3,opt,name=as_if_ts,json=asIfTs,proto3" json:"as_if_ts,omitempty"`
	// The hint of the common prefix of the files.
	// Used for speed up garbage collecting.
	FilesPrefixHint string `protobuf:"bytes,4,opt,name=files_prefix_hint,json=filesPrefixHint,proto3" json:"files_prefix_hint,omitempty"`
	// Whether this batch have finished.
	// If not, `as_if_ts` should be ignored and this should only
	// be restored when there is a finished backup with the same
	// `backup_uuid`.
	Finished bool `protobuf:"varint,5,opt,name=finished,proto3" json:"finished,omitempty"`
	// When checkpoint enabled, one restoration may be separated to many
	// of `IngestedSST`s.
	// `IngestedSST`s sharing the same UUID should be treated as one.
	// That is:
	// - The `as_if_ts` should be the largest one among all finished ingested SST batches.
	// - When restoring, all batches sharing the same uuid should be restored or not.
	BackupUuid []byte `protobuf:"bytes,6,opt,name=backup_uuid,json=backupUuid,proto3" json:"backup_uuid,omitempty"`
}

IngestedSSTs is created by a client that wants to put data to the cluster by `Ingest` APIs, these write cannot be directly recorded by log backup. The client should put a migration that contains the SSTs it uploaded.

func (*IngestedSSTs) Descriptor 

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

func (*IngestedSSTs) GetAsIfTs 

func (m *IngestedSSTs) GetAsIfTs() uint64

func (*IngestedSSTs) GetBackupUuid 

func (m *IngestedSSTs) GetBackupUuid() []byte

func (*IngestedSSTs) GetFiles 

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

func (*IngestedSSTs) GetFilesPrefixHint 

func (m *IngestedSSTs) GetFilesPrefixHint() string

func (*IngestedSSTs) GetFinished 

func (m *IngestedSSTs) GetFinished() bool

func (*IngestedSSTs) GetRewrittenTables 

func (m *IngestedSSTs) GetRewrittenTables() []*RewrittenTableID

func (*IngestedSSTs) Marshal 

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

func (*IngestedSSTs) MarshalTo 

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

func (*IngestedSSTs) MarshalToSizedBuffer 

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

func (*IngestedSSTs) ProtoMessage 

func (*IngestedSSTs) ProtoMessage()

func (*IngestedSSTs) Reset 

func (m *IngestedSSTs) Reset()

func (*IngestedSSTs) Size 

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

func (*IngestedSSTs) String 

func (m *IngestedSSTs) String() string

func (*IngestedSSTs) Unmarshal 

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

func (*IngestedSSTs) XXX_DiscardUnknown 

func (m *IngestedSSTs) XXX_DiscardUnknown()

func (*IngestedSSTs) XXX_Marshal 

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

func (*IngestedSSTs) XXX_Merge 

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

func (*IngestedSSTs) XXX_Size 

func (m *IngestedSSTs) XXX_Size() int

func (*IngestedSSTs) XXX_Unmarshal 

func (m *IngestedSSTs) 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 {
	// The selector of compaction source.
	// Files contains ANY record greater than this (and less than `until_ts`) will be selected.
	// The source and artificats may contain records out of the `from_ts` and `until_ts` range.
	// When restoring, please use `input_min_ts` to filter out not needed compactions instead.
	CompactionFromTs uint64 `protobuf:"varint,1,opt,name=compaction_from_ts,json=compactionFromTs,proto3" json:"compaction_from_ts,omitempty"`
	// The selector of compaction source.
	// Files contains ANY record less than this (and not less than `from_ts`) will be selected.
	// The source and artificats may contain records out of the `from_ts` and `until_ts` range.
	// When restoring, please use `input_max_ts` to filter out not needed compactions instead.
	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"`
	// The smallest TS of record contained among all selected files of this compaction.
	InputMinTs uint64 `protobuf:"varint,8,opt,name=input_min_ts,json=inputMinTs,proto3" json:"input_min_ts,omitempty"`
	// The largest TS of record contained among all selected files of this compaction.
	InputMaxTs uint64 `protobuf:"varint,9,opt,name=input_max_ts,json=inputMaxTs,proto3" json:"input_max_ts,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) GetInputMaxTs 

func (m *LogFileCompaction) GetInputMaxTs() uint64

func (*LogFileCompaction) GetInputMinTs 

func (m *LogFileCompaction) GetInputMinTs() uint64

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"`
	// The ingested SSTs.
	// It is mutable during restoring, hence a reference.
	IngestedSstPaths []string `protobuf:"bytes,7,rep,name=ingested_sst_paths,json=ingestedSstPaths,proto3" json:"ingested_sst_paths,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) GetIngestedSstPaths 

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

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
	// Added `ingested_sst_paths`.
	MigrationVersion_M2 MigrationVersion = 2
)

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"`
	// whether this db has been filtered out
	FilteredOut bool `protobuf:"varint,4,opt,name=filtered_out,json=filteredOut,proto3" json:"filtered_out,omitempty"`
}

func (*PitrDBMap) Descriptor 

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

func (*PitrDBMap) GetFilteredOut 

func (m *PitrDBMap) GetFilteredOut() bool

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"`
	// whether this table has been filtered out
	FilteredOut bool `protobuf:"varint,4,opt,name=filtered_out,json=filteredOut,proto3" json:"filtered_out,omitempty"`
}

func (*PitrTableMap) Descriptor 

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

func (*PitrTableMap) GetFilteredOut 

func (m *PitrTableMap) GetFilteredOut() bool

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 RewrittenTableID 

type RewrittenTableID struct {
	// The table ID in the backup data.
	AncestorUpstream int64 `protobuf:"varint,1,opt,name=ancestor_upstream,json=ancestorUpstream,proto3" json:"ancestor_upstream,omitempty"`
	// The rewritten table ID during restoring.
	Upstream int64 `protobuf:"varint,2,opt,name=upstream,proto3" json:"upstream,omitempty"`
}

RewrittenTableID records a sort of modification over the SSTs during restoring.

When "backing up" this "restored" SST, we want to backup the original SST before any rewrite. But in some cases, SSTs are not restored "as is", TiKV may rewrite or truncate its content by the client's request.

func (*RewrittenTableID) Descriptor 

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

func (*RewrittenTableID) GetAncestorUpstream 

func (m *RewrittenTableID) GetAncestorUpstream() int64

func (*RewrittenTableID) GetUpstream 

func (m *RewrittenTableID) GetUpstream() int64

func (*RewrittenTableID) Marshal 

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

func (*RewrittenTableID) MarshalTo 

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

func (*RewrittenTableID) MarshalToSizedBuffer 

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

func (*RewrittenTableID) ProtoMessage 

func (*RewrittenTableID) ProtoMessage()

func (*RewrittenTableID) Reset 

func (m *RewrittenTableID) Reset()

func (*RewrittenTableID) Size 

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

func (*RewrittenTableID) String 

func (m *RewrittenTableID) String() string

func (*RewrittenTableID) Unmarshal 

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

func (*RewrittenTableID) XXX_DiscardUnknown 

func (m *RewrittenTableID) XXX_DiscardUnknown()

func (*RewrittenTableID) XXX_Marshal 

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

func (*RewrittenTableID) XXX_Merge 

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

func (*RewrittenTableID) XXX_Size 

func (m *RewrittenTableID) XXX_Size() int

func (*RewrittenTableID) XXX_Unmarshal 

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