backup

package
v0.1.0 Latest Latest
Warning

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

Go to latest
Published: Jun 15, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

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 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,
}

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

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

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

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

func (m *BackupMeta) GetNewCollationsEnabled() string

func (*BackupMeta) GetPolicies

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

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

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

func (m *BackupRequest) GetRateLimit() uint64

func (*BackupRequest) GetReplicaRead

func (m *BackupRequest) GetReplicaRead() bool

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

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
}

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

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

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

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

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

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

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

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 {
	// SHA256 of the file.
	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 */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

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

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

func (m *DataFileInfo) GetRegionId() int64

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

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

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

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

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

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

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

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

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

func (*IDMap) Descriptor

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

func (*IDMap) GetDownstreamId

func (m *IDMap) GetDownstreamId() int64

func (*IDMap) GetUpstreamId

func (m *IDMap) GetUpstreamId() int64

func (*IDMap) Marshal

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

func (*IDMap) MarshalTo

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

func (*IDMap) MarshalToSizedBuffer

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

func (*IDMap) ProtoMessage

func (*IDMap) ProtoMessage()

func (*IDMap) Reset

func (m *IDMap) Reset()

func (*IDMap) Size

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

func (*IDMap) String

func (m *IDMap) String() string

func (*IDMap) Unmarshal

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

func (*IDMap) XXX_DiscardUnknown

func (m *IDMap) XXX_DiscardUnknown()

func (*IDMap) XXX_Marshal

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

func (*IDMap) XXX_Merge

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

func (*IDMap) XXX_Size

func (m *IDMap) XXX_Size() int

func (*IDMap) XXX_Unmarshal

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

type Local

type Local struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 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 DDLs.
	Ddls                 [][]byte `protobuf:"bytes,5,rep,name=ddls,proto3" json:"ddls,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*MetaFile) Descriptor

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

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

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 Noop

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

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

func (*PitrDBMap) Descriptor

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

func (*PitrDBMap) GetIdMap

func (m *PitrDBMap) GetIdMap() *IDMap

func (*PitrDBMap) GetName

func (m *PitrDBMap) GetName() string

func (*PitrDBMap) GetTables

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

func (*PitrDBMap) Marshal

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

func (*PitrDBMap) MarshalTo

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

func (*PitrDBMap) MarshalToSizedBuffer

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

func (*PitrDBMap) ProtoMessage

func (*PitrDBMap) ProtoMessage()

func (*PitrDBMap) Reset

func (m *PitrDBMap) Reset()

func (*PitrDBMap) Size

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

func (*PitrDBMap) String

func (m *PitrDBMap) String() string

func (*PitrDBMap) Unmarshal

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

func (*PitrDBMap) XXX_DiscardUnknown

func (m *PitrDBMap) XXX_DiscardUnknown()

func (*PitrDBMap) XXX_Marshal

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

func (*PitrDBMap) XXX_Merge

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

func (*PitrDBMap) XXX_Size

func (m *PitrDBMap) XXX_Size() int

func (*PitrDBMap) XXX_Unmarshal

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

type PitrTableMap

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

func (*PitrTableMap) Descriptor

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

func (*PitrTableMap) GetIdMap

func (m *PitrTableMap) GetIdMap() *IDMap

func (*PitrTableMap) GetName

func (m *PitrTableMap) GetName() string

func (*PitrTableMap) GetPartitions

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

func (*PitrTableMap) Marshal

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

func (*PitrTableMap) MarshalTo

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

func (*PitrTableMap) MarshalToSizedBuffer

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

func (*PitrTableMap) ProtoMessage

func (*PitrTableMap) ProtoMessage()

func (*PitrTableMap) Reset

func (m *PitrTableMap) Reset()

func (*PitrTableMap) Size

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

func (*PitrTableMap) String

func (m *PitrTableMap) String() string

func (*PitrTableMap) Unmarshal

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

func (*PitrTableMap) XXX_DiscardUnknown

func (m *PitrTableMap) XXX_DiscardUnknown()

func (*PitrTableMap) XXX_Marshal

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

func (*PitrTableMap) XXX_Merge

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

func (*PitrTableMap) XXX_Size

func (m *PitrTableMap) XXX_Size() int

func (*PitrTableMap) XXX_Unmarshal

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

type PlacementPolicy

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

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

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

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

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

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

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 datas.
	// 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 */
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

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

type UnimplementedBackupServer struct {
}

UnimplementedBackupServer can be embedded to have forward compatible implementations.

func (*UnimplementedBackupServer) Backup

func (*UnimplementedBackupServer) CheckPendingAdminOp

type UnimplementedExternalStorageServer

type UnimplementedExternalStorageServer struct {
}

UnimplementedExternalStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedExternalStorageServer) Restore

func (*UnimplementedExternalStorageServer) Save

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL