Documentation
¶
Index ¶
- Variables
- func RegisterBackupServer(s *grpc.Server, srv BackupServer)
- func RegisterExternalStorageServer(s *grpc.Server, srv ExternalStorageServer)
- type AzureBlobStorage
- func (*AzureBlobStorage) Descriptor() ([]byte, []int)
- func (m *AzureBlobStorage) GetAccessSig() string
- func (m *AzureBlobStorage) GetAccountName() string
- func (m *AzureBlobStorage) GetBucket() string
- func (m *AzureBlobStorage) GetEncryptionScope() string
- func (m *AzureBlobStorage) GetEndpoint() string
- func (m *AzureBlobStorage) GetPrefix() string
- func (m *AzureBlobStorage) GetSharedKey() string
- func (m *AzureBlobStorage) GetStorageClass() string
- func (m *AzureBlobStorage) Marshal() (dAtA []byte, err error)
- func (m *AzureBlobStorage) MarshalTo(dAtA []byte) (int, error)
- func (m *AzureBlobStorage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*AzureBlobStorage) ProtoMessage()
- func (m *AzureBlobStorage) Reset()
- func (m *AzureBlobStorage) Size() (n int)
- func (m *AzureBlobStorage) String() string
- func (m *AzureBlobStorage) Unmarshal(dAtA []byte) error
- func (m *AzureBlobStorage) XXX_DiscardUnknown()
- func (m *AzureBlobStorage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AzureBlobStorage) XXX_Merge(src proto.Message)
- func (m *AzureBlobStorage) XXX_Size() int
- func (m *AzureBlobStorage) XXX_Unmarshal(b []byte) error
- type BackupClient
- type BackupMeta
- func (*BackupMeta) Descriptor() ([]byte, []int)
- func (m *BackupMeta) GetApiVersion() kvrpcpb.APIVersion
- func (m *BackupMeta) GetBackupResult() string
- func (m *BackupMeta) GetBrVersion() string
- func (m *BackupMeta) GetClusterId() uint64
- func (m *BackupMeta) GetClusterVersion() string
- func (m *BackupMeta) GetDbMaps() []*PitrDBMap
- func (m *BackupMeta) GetDdlIndexes() *MetaFile
- func (m *BackupMeta) GetDdls() []byte
- func (m *BackupMeta) GetEndVersion() uint64
- func (m *BackupMeta) GetFileIndex() *MetaFile
- func (m *BackupMeta) GetFiles() []*File
- func (m *BackupMeta) GetIsRawKv() bool
- func (m *BackupMeta) GetIsTxnKv() bool
- func (m *BackupMeta) GetNewCollationsEnabled() string
- func (m *BackupMeta) GetPolicies() []*PlacementPolicy
- func (m *BackupMeta) GetRawRangeIndex() *MetaFile
- func (m *BackupMeta) GetRawRanges() []*RawRange
- func (m *BackupMeta) GetSchemaIndex() *MetaFile
- func (m *BackupMeta) GetSchemas() []*Schema
- func (m *BackupMeta) GetStartVersion() uint64
- func (m *BackupMeta) GetVersion() int32
- func (m *BackupMeta) Marshal() (dAtA []byte, err error)
- func (m *BackupMeta) MarshalTo(dAtA []byte) (int, error)
- func (m *BackupMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BackupMeta) ProtoMessage()
- func (m *BackupMeta) Reset()
- func (m *BackupMeta) Size() (n int)
- func (m *BackupMeta) String() string
- func (m *BackupMeta) Unmarshal(dAtA []byte) error
- func (m *BackupMeta) XXX_DiscardUnknown()
- func (m *BackupMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BackupMeta) XXX_Merge(src proto.Message)
- func (m *BackupMeta) XXX_Size() int
- func (m *BackupMeta) XXX_Unmarshal(b []byte) error
- type BackupRequest
- func (*BackupRequest) Descriptor() ([]byte, []int)
- func (m *BackupRequest) GetCf() string
- func (m *BackupRequest) GetCipherInfo() *CipherInfo
- func (m *BackupRequest) GetClusterId() uint64
- func (m *BackupRequest) GetCompressionLevel() int32
- func (m *BackupRequest) GetCompressionType() CompressionType
- func (m *BackupRequest) GetConcurrency() uint32
- func (m *BackupRequest) GetDstApiVersion() kvrpcpb.APIVersion
- func (m *BackupRequest) GetEndKey() []byte
- func (m *BackupRequest) GetEndVersion() uint64
- func (m *BackupRequest) GetIsRawKv() bool
- func (m *BackupRequest) GetRateLimit() uint64
- func (m *BackupRequest) GetReplicaRead() bool
- func (m *BackupRequest) GetStartKey() []byte
- func (m *BackupRequest) GetStartVersion() uint64
- func (m *BackupRequest) GetStorageBackend() *StorageBackend
- func (m *BackupRequest) GetSubRanges() []*kvrpcpb.KeyRange
- func (m *BackupRequest) Marshal() (dAtA []byte, err error)
- func (m *BackupRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *BackupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BackupRequest) ProtoMessage()
- func (m *BackupRequest) Reset()
- func (m *BackupRequest) Size() (n int)
- func (m *BackupRequest) String() string
- func (m *BackupRequest) Unmarshal(dAtA []byte) error
- func (m *BackupRequest) XXX_DiscardUnknown()
- func (m *BackupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BackupRequest) XXX_Merge(src proto.Message)
- func (m *BackupRequest) XXX_Size() int
- func (m *BackupRequest) XXX_Unmarshal(b []byte) error
- type BackupResponse
- func (*BackupResponse) Descriptor() ([]byte, []int)
- func (m *BackupResponse) GetApiVersion() kvrpcpb.APIVersion
- func (m *BackupResponse) GetEndKey() []byte
- func (m *BackupResponse) GetError() *Error
- func (m *BackupResponse) GetFiles() []*File
- func (m *BackupResponse) GetStartKey() []byte
- func (m *BackupResponse) Marshal() (dAtA []byte, err error)
- func (m *BackupResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *BackupResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*BackupResponse) ProtoMessage()
- func (m *BackupResponse) Reset()
- func (m *BackupResponse) Size() (n int)
- func (m *BackupResponse) String() string
- func (m *BackupResponse) Unmarshal(dAtA []byte) error
- func (m *BackupResponse) XXX_DiscardUnknown()
- func (m *BackupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *BackupResponse) XXX_Merge(src proto.Message)
- func (m *BackupResponse) XXX_Size() int
- func (m *BackupResponse) XXX_Unmarshal(b []byte) error
- type BackupServer
- type Backup_BackupClient
- type Backup_BackupServer
- type Backup_CheckPendingAdminOpClient
- type Backup_CheckPendingAdminOpServer
- type Bucket
- func (*Bucket) Descriptor() ([]byte, []int)
- func (m *Bucket) GetBucket() string
- func (m *Bucket) GetEndpoint() string
- func (m *Bucket) GetPrefix() string
- func (m *Bucket) GetRegion() string
- func (m *Bucket) GetStorageClass() string
- func (m *Bucket) Marshal() (dAtA []byte, err error)
- func (m *Bucket) MarshalTo(dAtA []byte) (int, error)
- func (m *Bucket) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Bucket) ProtoMessage()
- func (m *Bucket) Reset()
- func (m *Bucket) Size() (n int)
- func (m *Bucket) String() string
- func (m *Bucket) Unmarshal(dAtA []byte) error
- func (m *Bucket) XXX_DiscardUnknown()
- func (m *Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Bucket) XXX_Merge(src proto.Message)
- func (m *Bucket) XXX_Size() int
- func (m *Bucket) XXX_Unmarshal(b []byte) error
- type CheckAdminRequest
- func (*CheckAdminRequest) Descriptor() ([]byte, []int)
- func (m *CheckAdminRequest) Marshal() (dAtA []byte, err error)
- func (m *CheckAdminRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckAdminRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckAdminRequest) ProtoMessage()
- func (m *CheckAdminRequest) Reset()
- func (m *CheckAdminRequest) Size() (n int)
- func (m *CheckAdminRequest) String() string
- func (m *CheckAdminRequest) Unmarshal(dAtA []byte) error
- func (m *CheckAdminRequest) XXX_DiscardUnknown()
- func (m *CheckAdminRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckAdminRequest) XXX_Merge(src proto.Message)
- func (m *CheckAdminRequest) XXX_Size() int
- func (m *CheckAdminRequest) XXX_Unmarshal(b []byte) error
- type CheckAdminResponse
- func (*CheckAdminResponse) Descriptor() ([]byte, []int)
- func (m *CheckAdminResponse) GetError() *Error
- func (m *CheckAdminResponse) GetHasPendingAdmin() bool
- func (m *CheckAdminResponse) GetRegion() *metapb.Region
- func (m *CheckAdminResponse) Marshal() (dAtA []byte, err error)
- func (m *CheckAdminResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *CheckAdminResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CheckAdminResponse) ProtoMessage()
- func (m *CheckAdminResponse) Reset()
- func (m *CheckAdminResponse) Size() (n int)
- func (m *CheckAdminResponse) String() string
- func (m *CheckAdminResponse) Unmarshal(dAtA []byte) error
- func (m *CheckAdminResponse) XXX_DiscardUnknown()
- func (m *CheckAdminResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CheckAdminResponse) XXX_Merge(src proto.Message)
- func (m *CheckAdminResponse) XXX_Size() int
- func (m *CheckAdminResponse) XXX_Unmarshal(b []byte) error
- type CipherInfo
- func (*CipherInfo) Descriptor() ([]byte, []int)
- func (m *CipherInfo) GetCipherKey() []byte
- func (m *CipherInfo) GetCipherType() encryptionpb.EncryptionMethod
- func (m *CipherInfo) Marshal() (dAtA []byte, err error)
- func (m *CipherInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *CipherInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CipherInfo) ProtoMessage()
- func (m *CipherInfo) Reset()
- func (m *CipherInfo) Size() (n int)
- func (m *CipherInfo) String() string
- func (m *CipherInfo) Unmarshal(dAtA []byte) error
- func (m *CipherInfo) XXX_DiscardUnknown()
- func (m *CipherInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CipherInfo) XXX_Merge(src proto.Message)
- func (m *CipherInfo) XXX_Size() int
- func (m *CipherInfo) XXX_Unmarshal(b []byte) error
- type CloudDynamic
- func (*CloudDynamic) Descriptor() ([]byte, []int)
- func (m *CloudDynamic) GetAttrs() map[string]string
- func (m *CloudDynamic) GetBucket() *Bucket
- func (m *CloudDynamic) GetProviderName() string
- func (m *CloudDynamic) Marshal() (dAtA []byte, err error)
- func (m *CloudDynamic) MarshalTo(dAtA []byte) (int, error)
- func (m *CloudDynamic) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*CloudDynamic) ProtoMessage()
- func (m *CloudDynamic) Reset()
- func (m *CloudDynamic) Size() (n int)
- func (m *CloudDynamic) String() string
- func (m *CloudDynamic) Unmarshal(dAtA []byte) error
- func (m *CloudDynamic) XXX_DiscardUnknown()
- func (m *CloudDynamic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CloudDynamic) XXX_Merge(src proto.Message)
- func (m *CloudDynamic) XXX_Size() int
- func (m *CloudDynamic) XXX_Unmarshal(b []byte) error
- type ClusterIDError
- func (*ClusterIDError) Descriptor() ([]byte, []int)
- func (m *ClusterIDError) GetCurrent() uint64
- func (m *ClusterIDError) GetRequest() uint64
- func (m *ClusterIDError) Marshal() (dAtA []byte, err error)
- func (m *ClusterIDError) MarshalTo(dAtA []byte) (int, error)
- func (m *ClusterIDError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ClusterIDError) ProtoMessage()
- func (m *ClusterIDError) Reset()
- func (m *ClusterIDError) Size() (n int)
- func (m *ClusterIDError) String() string
- func (m *ClusterIDError) Unmarshal(dAtA []byte) error
- func (m *ClusterIDError) XXX_DiscardUnknown()
- func (m *ClusterIDError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClusterIDError) XXX_Merge(src proto.Message)
- func (m *ClusterIDError) XXX_Size() int
- func (m *ClusterIDError) XXX_Unmarshal(b []byte) error
- type CompressionType
- type DataFileGroup
- func (*DataFileGroup) Descriptor() ([]byte, []int)
- func (m *DataFileGroup) GetDataFilesInfo() []*DataFileInfo
- func (m *DataFileGroup) GetLength() uint64
- func (m *DataFileGroup) GetMaxTs() uint64
- func (m *DataFileGroup) GetMinResolvedTs() uint64
- func (m *DataFileGroup) GetMinTs() uint64
- func (m *DataFileGroup) GetPath() string
- func (m *DataFileGroup) Marshal() (dAtA []byte, err error)
- func (m *DataFileGroup) MarshalTo(dAtA []byte) (int, error)
- func (m *DataFileGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DataFileGroup) ProtoMessage()
- func (m *DataFileGroup) Reset()
- func (m *DataFileGroup) Size() (n int)
- func (m *DataFileGroup) String() string
- func (m *DataFileGroup) Unmarshal(dAtA []byte) error
- func (m *DataFileGroup) XXX_DiscardUnknown()
- func (m *DataFileGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataFileGroup) XXX_Merge(src proto.Message)
- func (m *DataFileGroup) XXX_Size() int
- func (m *DataFileGroup) XXX_Unmarshal(b []byte) error
- type DataFileInfo
- func (*DataFileInfo) Descriptor() ([]byte, []int)
- func (m *DataFileInfo) GetCf() string
- func (m *DataFileInfo) GetCompressionType() CompressionType
- func (m *DataFileInfo) GetEndKey() []byte
- func (m *DataFileInfo) GetIsMeta() bool
- func (m *DataFileInfo) GetLength() uint64
- func (m *DataFileInfo) GetMaxTs() uint64
- func (m *DataFileInfo) GetMinBeginTsInDefaultCf() uint64
- func (m *DataFileInfo) GetMinTs() uint64
- func (m *DataFileInfo) GetNumberOfEntries() int64
- func (m *DataFileInfo) GetPath() string
- func (m *DataFileInfo) GetRangeLength() uint64
- func (m *DataFileInfo) GetRangeOffset() uint64
- func (m *DataFileInfo) GetRegionId() int64
- func (m *DataFileInfo) GetResolvedTs() uint64
- func (m *DataFileInfo) GetSha256() []byte
- func (m *DataFileInfo) GetStartKey() []byte
- func (m *DataFileInfo) GetTableId() int64
- func (m *DataFileInfo) GetType() FileType
- func (m *DataFileInfo) Marshal() (dAtA []byte, err error)
- func (m *DataFileInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *DataFileInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DataFileInfo) ProtoMessage()
- func (m *DataFileInfo) Reset()
- func (m *DataFileInfo) Size() (n int)
- func (m *DataFileInfo) String() string
- func (m *DataFileInfo) Unmarshal(dAtA []byte) error
- func (m *DataFileInfo) XXX_DiscardUnknown()
- func (m *DataFileInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DataFileInfo) XXX_Merge(src proto.Message)
- func (m *DataFileInfo) XXX_Size() int
- func (m *DataFileInfo) XXX_Unmarshal(b []byte) error
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (m *Error) GetClusterIdError() *ClusterIDError
- func (m *Error) GetDetail() isError_Detail
- func (m *Error) GetKvError() *kvrpcpb.KeyError
- func (m *Error) GetMsg() string
- func (m *Error) GetRegionError() *errorpb.Error
- func (m *Error) Marshal() (dAtA []byte, err error)
- func (m *Error) MarshalTo(dAtA []byte) (int, error)
- func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- func (m *Error) XXX_DiscardUnknown()
- func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Error) XXX_Merge(src proto.Message)
- func (*Error) XXX_OneofWrappers() []interface{}
- func (m *Error) XXX_Size() int
- func (m *Error) XXX_Unmarshal(b []byte) error
- type Error_ClusterIdError
- type Error_KvError
- type Error_RegionError
- type ExternalStorageClient
- type ExternalStorageRestoreRequest
- func (*ExternalStorageRestoreRequest) Descriptor() ([]byte, []int)
- func (m *ExternalStorageRestoreRequest) GetContentLength() uint64
- func (m *ExternalStorageRestoreRequest) GetObjectName() string
- func (m *ExternalStorageRestoreRequest) GetRestoreName() string
- func (m *ExternalStorageRestoreRequest) GetStorageBackend() *StorageBackend
- func (m *ExternalStorageRestoreRequest) Marshal() (dAtA []byte, err error)
- func (m *ExternalStorageRestoreRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ExternalStorageRestoreRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExternalStorageRestoreRequest) ProtoMessage()
- func (m *ExternalStorageRestoreRequest) Reset()
- func (m *ExternalStorageRestoreRequest) Size() (n int)
- func (m *ExternalStorageRestoreRequest) String() string
- func (m *ExternalStorageRestoreRequest) Unmarshal(dAtA []byte) error
- func (m *ExternalStorageRestoreRequest) XXX_DiscardUnknown()
- func (m *ExternalStorageRestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExternalStorageRestoreRequest) XXX_Merge(src proto.Message)
- func (m *ExternalStorageRestoreRequest) XXX_Size() int
- func (m *ExternalStorageRestoreRequest) XXX_Unmarshal(b []byte) error
- type ExternalStorageRestoreResponse
- func (*ExternalStorageRestoreResponse) Descriptor() ([]byte, []int)
- func (m *ExternalStorageRestoreResponse) Marshal() (dAtA []byte, err error)
- func (m *ExternalStorageRestoreResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ExternalStorageRestoreResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExternalStorageRestoreResponse) ProtoMessage()
- func (m *ExternalStorageRestoreResponse) Reset()
- func (m *ExternalStorageRestoreResponse) Size() (n int)
- func (m *ExternalStorageRestoreResponse) String() string
- func (m *ExternalStorageRestoreResponse) Unmarshal(dAtA []byte) error
- func (m *ExternalStorageRestoreResponse) XXX_DiscardUnknown()
- func (m *ExternalStorageRestoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExternalStorageRestoreResponse) XXX_Merge(src proto.Message)
- func (m *ExternalStorageRestoreResponse) XXX_Size() int
- func (m *ExternalStorageRestoreResponse) XXX_Unmarshal(b []byte) error
- type ExternalStorageSaveRequest
- func (*ExternalStorageSaveRequest) Descriptor() ([]byte, []int)
- func (m *ExternalStorageSaveRequest) GetContentLength() uint64
- func (m *ExternalStorageSaveRequest) GetObjectName() string
- func (m *ExternalStorageSaveRequest) GetStorageBackend() *StorageBackend
- func (m *ExternalStorageSaveRequest) Marshal() (dAtA []byte, err error)
- func (m *ExternalStorageSaveRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ExternalStorageSaveRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExternalStorageSaveRequest) ProtoMessage()
- func (m *ExternalStorageSaveRequest) Reset()
- func (m *ExternalStorageSaveRequest) Size() (n int)
- func (m *ExternalStorageSaveRequest) String() string
- func (m *ExternalStorageSaveRequest) Unmarshal(dAtA []byte) error
- func (m *ExternalStorageSaveRequest) XXX_DiscardUnknown()
- func (m *ExternalStorageSaveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExternalStorageSaveRequest) XXX_Merge(src proto.Message)
- func (m *ExternalStorageSaveRequest) XXX_Size() int
- func (m *ExternalStorageSaveRequest) XXX_Unmarshal(b []byte) error
- type ExternalStorageSaveResponse
- func (*ExternalStorageSaveResponse) Descriptor() ([]byte, []int)
- func (m *ExternalStorageSaveResponse) Marshal() (dAtA []byte, err error)
- func (m *ExternalStorageSaveResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ExternalStorageSaveResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ExternalStorageSaveResponse) ProtoMessage()
- func (m *ExternalStorageSaveResponse) Reset()
- func (m *ExternalStorageSaveResponse) Size() (n int)
- func (m *ExternalStorageSaveResponse) String() string
- func (m *ExternalStorageSaveResponse) Unmarshal(dAtA []byte) error
- func (m *ExternalStorageSaveResponse) XXX_DiscardUnknown()
- func (m *ExternalStorageSaveResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExternalStorageSaveResponse) XXX_Merge(src proto.Message)
- func (m *ExternalStorageSaveResponse) XXX_Size() int
- func (m *ExternalStorageSaveResponse) XXX_Unmarshal(b []byte) error
- type ExternalStorageServer
- type File
- func (*File) Descriptor() ([]byte, []int)
- func (m *File) GetCf() string
- func (m *File) GetCipherIv() []byte
- func (m *File) GetCrc64Xor() uint64
- func (m *File) GetEndKey() []byte
- func (m *File) GetEndVersion() uint64
- func (m *File) GetName() string
- func (m *File) GetSha256() []byte
- func (m *File) GetSize_() uint64
- func (m *File) GetStartKey() []byte
- func (m *File) GetStartVersion() uint64
- func (m *File) GetTotalBytes() uint64
- func (m *File) GetTotalKvs() uint64
- func (m *File) Marshal() (dAtA []byte, err error)
- func (m *File) MarshalTo(dAtA []byte) (int, error)
- func (m *File) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*File) ProtoMessage()
- func (m *File) Reset()
- func (m *File) Size() (n int)
- func (m *File) String() string
- func (m *File) Unmarshal(dAtA []byte) error
- func (m *File) XXX_DiscardUnknown()
- func (m *File) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *File) XXX_Merge(src proto.Message)
- func (m *File) XXX_Size() int
- func (m *File) XXX_Unmarshal(b []byte) error
- type FileType
- type GCS
- func (*GCS) Descriptor() ([]byte, []int)
- func (m *GCS) GetBucket() string
- func (m *GCS) GetCredentialsBlob() string
- func (m *GCS) GetEndpoint() string
- func (m *GCS) GetPredefinedAcl() string
- func (m *GCS) GetPrefix() string
- func (m *GCS) GetStorageClass() string
- func (m *GCS) Marshal() (dAtA []byte, err error)
- func (m *GCS) MarshalTo(dAtA []byte) (int, error)
- func (m *GCS) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GCS) ProtoMessage()
- func (m *GCS) Reset()
- func (m *GCS) Size() (n int)
- func (m *GCS) String() string
- func (m *GCS) Unmarshal(dAtA []byte) error
- func (m *GCS) XXX_DiscardUnknown()
- func (m *GCS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GCS) XXX_Merge(src proto.Message)
- func (m *GCS) XXX_Size() int
- func (m *GCS) XXX_Unmarshal(b []byte) error
- type HDFS
- func (*HDFS) Descriptor() ([]byte, []int)
- func (m *HDFS) GetRemote() string
- func (m *HDFS) Marshal() (dAtA []byte, err error)
- func (m *HDFS) MarshalTo(dAtA []byte) (int, error)
- func (m *HDFS) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*HDFS) ProtoMessage()
- func (m *HDFS) Reset()
- func (m *HDFS) Size() (n int)
- func (m *HDFS) String() string
- func (m *HDFS) Unmarshal(dAtA []byte) error
- func (m *HDFS) XXX_DiscardUnknown()
- func (m *HDFS) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HDFS) XXX_Merge(src proto.Message)
- func (m *HDFS) XXX_Size() int
- func (m *HDFS) XXX_Unmarshal(b []byte) error
- type IDMap
- func (*IDMap) Descriptor() ([]byte, []int)
- func (m *IDMap) GetDownstreamId() int64
- func (m *IDMap) GetUpstreamId() int64
- func (m *IDMap) Marshal() (dAtA []byte, err error)
- func (m *IDMap) MarshalTo(dAtA []byte) (int, error)
- func (m *IDMap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*IDMap) ProtoMessage()
- func (m *IDMap) Reset()
- func (m *IDMap) Size() (n int)
- func (m *IDMap) String() string
- func (m *IDMap) Unmarshal(dAtA []byte) error
- func (m *IDMap) XXX_DiscardUnknown()
- func (m *IDMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IDMap) XXX_Merge(src proto.Message)
- func (m *IDMap) XXX_Size() int
- func (m *IDMap) XXX_Unmarshal(b []byte) error
- type Local
- func (*Local) Descriptor() ([]byte, []int)
- func (m *Local) GetPath() string
- func (m *Local) Marshal() (dAtA []byte, err error)
- func (m *Local) MarshalTo(dAtA []byte) (int, error)
- func (m *Local) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Local) ProtoMessage()
- func (m *Local) Reset()
- func (m *Local) Size() (n int)
- func (m *Local) String() string
- func (m *Local) Unmarshal(dAtA []byte) error
- func (m *Local) XXX_DiscardUnknown()
- func (m *Local) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Local) XXX_Merge(src proto.Message)
- func (m *Local) XXX_Size() int
- func (m *Local) XXX_Unmarshal(b []byte) error
- type MetaFile
- func (*MetaFile) Descriptor() ([]byte, []int)
- func (m *MetaFile) GetDataFiles() []*File
- func (m *MetaFile) GetDdls() [][]byte
- func (m *MetaFile) GetMetaFiles() []*File
- func (m *MetaFile) GetRawRanges() []*RawRange
- func (m *MetaFile) GetSchemas() []*Schema
- func (m *MetaFile) Marshal() (dAtA []byte, err error)
- func (m *MetaFile) MarshalTo(dAtA []byte) (int, error)
- func (m *MetaFile) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MetaFile) ProtoMessage()
- func (m *MetaFile) Reset()
- func (m *MetaFile) Size() (n int)
- func (m *MetaFile) String() string
- func (m *MetaFile) Unmarshal(dAtA []byte) error
- func (m *MetaFile) XXX_DiscardUnknown()
- func (m *MetaFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MetaFile) XXX_Merge(src proto.Message)
- func (m *MetaFile) XXX_Size() int
- func (m *MetaFile) XXX_Unmarshal(b []byte) error
- type MetaVersion
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)
- func (m *Metadata) GetFileGroups() []*DataFileGroup
- func (m *Metadata) GetFiles() []*DataFileInfo
- func (m *Metadata) GetMaxTs() uint64
- func (m *Metadata) GetMetaVersion() MetaVersion
- func (m *Metadata) GetMinTs() uint64
- func (m *Metadata) GetResolvedTs() uint64
- func (m *Metadata) GetStoreId() int64
- func (m *Metadata) Marshal() (dAtA []byte, err error)
- func (m *Metadata) MarshalTo(dAtA []byte) (int, error)
- func (m *Metadata) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) Size() (n int)
- func (m *Metadata) String() string
- func (m *Metadata) Unmarshal(dAtA []byte) error
- func (m *Metadata) XXX_DiscardUnknown()
- func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Metadata) XXX_Merge(src proto.Message)
- func (m *Metadata) XXX_Size() int
- func (m *Metadata) XXX_Unmarshal(b []byte) error
- type Noop
- func (*Noop) Descriptor() ([]byte, []int)
- func (m *Noop) Marshal() (dAtA []byte, err error)
- func (m *Noop) MarshalTo(dAtA []byte) (int, error)
- func (m *Noop) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Noop) ProtoMessage()
- func (m *Noop) Reset()
- func (m *Noop) Size() (n int)
- func (m *Noop) String() string
- func (m *Noop) Unmarshal(dAtA []byte) error
- func (m *Noop) XXX_DiscardUnknown()
- func (m *Noop) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Noop) XXX_Merge(src proto.Message)
- func (m *Noop) XXX_Size() int
- func (m *Noop) XXX_Unmarshal(b []byte) error
- type PitrDBMap
- func (*PitrDBMap) Descriptor() ([]byte, []int)
- func (m *PitrDBMap) GetIdMap() *IDMap
- func (m *PitrDBMap) GetName() string
- func (m *PitrDBMap) GetTables() []*PitrTableMap
- func (m *PitrDBMap) Marshal() (dAtA []byte, err error)
- func (m *PitrDBMap) MarshalTo(dAtA []byte) (int, error)
- func (m *PitrDBMap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PitrDBMap) ProtoMessage()
- func (m *PitrDBMap) Reset()
- func (m *PitrDBMap) Size() (n int)
- func (m *PitrDBMap) String() string
- func (m *PitrDBMap) Unmarshal(dAtA []byte) error
- func (m *PitrDBMap) XXX_DiscardUnknown()
- func (m *PitrDBMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PitrDBMap) XXX_Merge(src proto.Message)
- func (m *PitrDBMap) XXX_Size() int
- func (m *PitrDBMap) XXX_Unmarshal(b []byte) error
- type PitrTableMap
- func (*PitrTableMap) Descriptor() ([]byte, []int)
- func (m *PitrTableMap) GetIdMap() *IDMap
- func (m *PitrTableMap) GetName() string
- func (m *PitrTableMap) GetPartitions() []*IDMap
- func (m *PitrTableMap) Marshal() (dAtA []byte, err error)
- func (m *PitrTableMap) MarshalTo(dAtA []byte) (int, error)
- func (m *PitrTableMap) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PitrTableMap) ProtoMessage()
- func (m *PitrTableMap) Reset()
- func (m *PitrTableMap) Size() (n int)
- func (m *PitrTableMap) String() string
- func (m *PitrTableMap) Unmarshal(dAtA []byte) error
- func (m *PitrTableMap) XXX_DiscardUnknown()
- func (m *PitrTableMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PitrTableMap) XXX_Merge(src proto.Message)
- func (m *PitrTableMap) XXX_Size() int
- func (m *PitrTableMap) XXX_Unmarshal(b []byte) error
- type PlacementPolicy
- func (*PlacementPolicy) Descriptor() ([]byte, []int)
- func (m *PlacementPolicy) GetInfo() []byte
- func (m *PlacementPolicy) Marshal() (dAtA []byte, err error)
- func (m *PlacementPolicy) MarshalTo(dAtA []byte) (int, error)
- func (m *PlacementPolicy) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PlacementPolicy) ProtoMessage()
- func (m *PlacementPolicy) Reset()
- func (m *PlacementPolicy) Size() (n int)
- func (m *PlacementPolicy) String() string
- func (m *PlacementPolicy) Unmarshal(dAtA []byte) error
- func (m *PlacementPolicy) XXX_DiscardUnknown()
- func (m *PlacementPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PlacementPolicy) XXX_Merge(src proto.Message)
- func (m *PlacementPolicy) XXX_Size() int
- func (m *PlacementPolicy) XXX_Unmarshal(b []byte) error
- type RawRange
- func (*RawRange) Descriptor() ([]byte, []int)
- func (m *RawRange) GetCf() string
- func (m *RawRange) GetEndKey() []byte
- func (m *RawRange) GetStartKey() []byte
- func (m *RawRange) Marshal() (dAtA []byte, err error)
- func (m *RawRange) MarshalTo(dAtA []byte) (int, error)
- func (m *RawRange) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RawRange) ProtoMessage()
- func (m *RawRange) Reset()
- func (m *RawRange) Size() (n int)
- func (m *RawRange) String() string
- func (m *RawRange) Unmarshal(dAtA []byte) error
- func (m *RawRange) XXX_DiscardUnknown()
- func (m *RawRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RawRange) XXX_Merge(src proto.Message)
- func (m *RawRange) XXX_Size() int
- func (m *RawRange) XXX_Unmarshal(b []byte) error
- type S3
- func (*S3) Descriptor() ([]byte, []int)
- func (m *S3) GetAccessKey() string
- func (m *S3) GetAcl() string
- func (m *S3) GetBucket() string
- func (m *S3) GetEndpoint() string
- func (m *S3) GetExternalId() string
- func (m *S3) GetForcePathStyle() bool
- func (m *S3) GetObjectLockEnabled() bool
- func (m *S3) GetPrefix() string
- func (m *S3) GetProvider() string
- func (m *S3) GetRegion() string
- func (m *S3) GetRoleArn() string
- func (m *S3) GetSecretAccessKey() string
- func (m *S3) GetSessionToken() string
- func (m *S3) GetSse() string
- func (m *S3) GetSseKmsKeyId() string
- func (m *S3) GetStorageClass() string
- func (m *S3) Marshal() (dAtA []byte, err error)
- func (m *S3) MarshalTo(dAtA []byte) (int, error)
- func (m *S3) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*S3) ProtoMessage()
- func (m *S3) Reset()
- func (m *S3) Size() (n int)
- func (m *S3) String() string
- func (m *S3) Unmarshal(dAtA []byte) error
- func (m *S3) XXX_DiscardUnknown()
- func (m *S3) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *S3) XXX_Merge(src proto.Message)
- func (m *S3) XXX_Size() int
- func (m *S3) XXX_Unmarshal(b []byte) error
- type Schema
- func (*Schema) Descriptor() ([]byte, []int)
- func (m *Schema) GetCrc64Xor() uint64
- func (m *Schema) GetDb() []byte
- func (m *Schema) GetStats() []byte
- func (m *Schema) GetTable() []byte
- func (m *Schema) GetTiflashReplicas() uint32
- func (m *Schema) GetTotalBytes() uint64
- func (m *Schema) GetTotalKvs() uint64
- func (m *Schema) Marshal() (dAtA []byte, err error)
- func (m *Schema) MarshalTo(dAtA []byte) (int, error)
- func (m *Schema) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Schema) ProtoMessage()
- func (m *Schema) Reset()
- func (m *Schema) Size() (n int)
- func (m *Schema) String() string
- func (m *Schema) Unmarshal(dAtA []byte) error
- func (m *Schema) XXX_DiscardUnknown()
- func (m *Schema) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Schema) XXX_Merge(src proto.Message)
- func (m *Schema) XXX_Size() int
- func (m *Schema) XXX_Unmarshal(b []byte) error
- type StorageBackend
- func (*StorageBackend) Descriptor() ([]byte, []int)
- func (m *StorageBackend) GetAzureBlobStorage() *AzureBlobStorage
- func (m *StorageBackend) GetBackend() isStorageBackend_Backend
- func (m *StorageBackend) GetCloudDynamic() *CloudDynamic
- func (m *StorageBackend) GetGcs() *GCS
- func (m *StorageBackend) GetHdfs() *HDFS
- func (m *StorageBackend) GetLocal() *Local
- func (m *StorageBackend) GetNoop() *Noop
- func (m *StorageBackend) GetS3() *S3
- func (m *StorageBackend) Marshal() (dAtA []byte, err error)
- func (m *StorageBackend) MarshalTo(dAtA []byte) (int, error)
- func (m *StorageBackend) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StorageBackend) ProtoMessage()
- func (m *StorageBackend) Reset()
- func (m *StorageBackend) Size() (n int)
- func (m *StorageBackend) String() string
- func (m *StorageBackend) Unmarshal(dAtA []byte) error
- func (m *StorageBackend) XXX_DiscardUnknown()
- func (m *StorageBackend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StorageBackend) XXX_Merge(src proto.Message)
- func (*StorageBackend) XXX_OneofWrappers() []interface{}
- func (m *StorageBackend) XXX_Size() int
- func (m *StorageBackend) XXX_Unmarshal(b []byte) error
- type StorageBackend_AzureBlobStorage
- type StorageBackend_CloudDynamic
- type StorageBackend_Gcs
- type StorageBackend_Hdfs
- type StorageBackend_Local
- type StorageBackend_Noop
- type StorageBackend_S3
- type StreamBackupError
- func (*StreamBackupError) Descriptor() ([]byte, []int)
- func (m *StreamBackupError) GetErrorCode() string
- func (m *StreamBackupError) GetErrorMessage() string
- func (m *StreamBackupError) GetHappenAt() uint64
- func (m *StreamBackupError) GetStoreId() uint64
- func (m *StreamBackupError) Marshal() (dAtA []byte, err error)
- func (m *StreamBackupError) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamBackupError) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamBackupError) ProtoMessage()
- func (m *StreamBackupError) Reset()
- func (m *StreamBackupError) Size() (n int)
- func (m *StreamBackupError) String() string
- func (m *StreamBackupError) Unmarshal(dAtA []byte) error
- func (m *StreamBackupError) XXX_DiscardUnknown()
- func (m *StreamBackupError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamBackupError) XXX_Merge(src proto.Message)
- func (m *StreamBackupError) XXX_Size() int
- func (m *StreamBackupError) XXX_Unmarshal(b []byte) error
- type StreamBackupTaskInfo
- func (*StreamBackupTaskInfo) Descriptor() ([]byte, []int)
- func (m *StreamBackupTaskInfo) GetCompressionType() CompressionType
- func (m *StreamBackupTaskInfo) GetEndTs() uint64
- func (m *StreamBackupTaskInfo) GetName() string
- func (m *StreamBackupTaskInfo) GetStartTs() uint64
- func (m *StreamBackupTaskInfo) GetStorage() *StorageBackend
- func (m *StreamBackupTaskInfo) GetTableFilter() []string
- func (m *StreamBackupTaskInfo) Marshal() (dAtA []byte, err error)
- func (m *StreamBackupTaskInfo) MarshalTo(dAtA []byte) (int, error)
- func (m *StreamBackupTaskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*StreamBackupTaskInfo) ProtoMessage()
- func (m *StreamBackupTaskInfo) Reset()
- func (m *StreamBackupTaskInfo) Size() (n int)
- func (m *StreamBackupTaskInfo) String() string
- func (m *StreamBackupTaskInfo) Unmarshal(dAtA []byte) error
- func (m *StreamBackupTaskInfo) XXX_DiscardUnknown()
- func (m *StreamBackupTaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamBackupTaskInfo) XXX_Merge(src proto.Message)
- func (m *StreamBackupTaskInfo) XXX_Size() int
- func (m *StreamBackupTaskInfo) XXX_Unmarshal(b []byte) error
- type UnimplementedBackupServer
- type UnimplementedExternalStorageServer
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthBrpb = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowBrpb = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupBrpb = fmt.Errorf("proto: unexpected end of group") )
var CompressionType_name = map[int32]string{
0: "UNKNOWN",
1: "LZ4",
2: "SNAPPY",
3: "ZSTD",
}
var CompressionType_value = map[string]int32{
"UNKNOWN": 0,
"LZ4": 1,
"SNAPPY": 2,
"ZSTD": 3,
}
var FileType_name = map[int32]string{
0: "Delete",
1: "Put",
}
var FileType_value = map[string]int32{
"Delete": 0,
"Put": 1,
}
var MetaVersion_name = map[int32]string{
0: "V1",
1: "V2",
}
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"` // `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) 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) 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) 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) 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) GetEndpoint ¶
func (*Bucket) GetStorageClass ¶
func (*Bucket) MarshalToSizedBuffer ¶
func (*Bucket) ProtoMessage ¶
func (*Bucket) ProtoMessage()
func (*Bucket) XXX_DiscardUnknown ¶
func (m *Bucket) XXX_DiscardUnknown()
func (*Bucket) XXX_Marshal ¶
func (*Bucket) XXX_Unmarshal ¶
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) 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) 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) 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) 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) 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) GetClusterIdError ¶
func (m *Error) GetClusterIdError() *ClusterIDError
func (*Error) GetKvError ¶
func (*Error) GetRegionError ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) XXX_DiscardUnknown ¶
func (m *Error) XXX_DiscardUnknown()
func (*Error) XXX_Marshal ¶
func (*Error) XXX_OneofWrappers ¶
func (*Error) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*Error) XXX_Unmarshal ¶
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) 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 (m *ExternalStorageRestoreRequest) String() string
func (*ExternalStorageRestoreRequest) Unmarshal ¶
func (m *ExternalStorageRestoreRequest) Unmarshal(dAtA []byte) error
func (*ExternalStorageRestoreRequest) XXX_DiscardUnknown ¶
func (m *ExternalStorageRestoreRequest) XXX_DiscardUnknown()
func (*ExternalStorageRestoreRequest) XXX_Marshal ¶
func (m *ExternalStorageRestoreRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExternalStorageRestoreRequest) XXX_Merge ¶
func (m *ExternalStorageRestoreRequest) XXX_Merge(src proto.Message)
func (*ExternalStorageRestoreRequest) XXX_Size ¶
func (m *ExternalStorageRestoreRequest) XXX_Size() int
func (*ExternalStorageRestoreRequest) XXX_Unmarshal ¶
func (m *ExternalStorageRestoreRequest) XXX_Unmarshal(b []byte) error
type ExternalStorageRestoreResponse ¶
type ExternalStorageRestoreResponse struct { 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 (m *ExternalStorageRestoreResponse) String() string
func (*ExternalStorageRestoreResponse) Unmarshal ¶
func (m *ExternalStorageRestoreResponse) Unmarshal(dAtA []byte) error
func (*ExternalStorageRestoreResponse) XXX_DiscardUnknown ¶
func (m *ExternalStorageRestoreResponse) XXX_DiscardUnknown()
func (*ExternalStorageRestoreResponse) XXX_Marshal ¶
func (m *ExternalStorageRestoreResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExternalStorageRestoreResponse) XXX_Merge ¶
func (m *ExternalStorageRestoreResponse) XXX_Merge(src proto.Message)
func (*ExternalStorageRestoreResponse) XXX_Size ¶
func (m *ExternalStorageRestoreResponse) XXX_Size() int
func (*ExternalStorageRestoreResponse) XXX_Unmarshal ¶
func (m *ExternalStorageRestoreResponse) XXX_Unmarshal(b []byte) error
type ExternalStorageSaveRequest ¶
type ExternalStorageSaveRequest struct { StorageBackend *StorageBackend `protobuf:"bytes,1,opt,name=storage_backend,json=storageBackend,proto3" json:"storage_backend,omitempty"` ObjectName string `protobuf:"bytes,2,opt,name=object_name,json=objectName,proto3" json:"object_name,omitempty"` ContentLength uint64 `protobuf:"varint,3,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` 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) GetCipherIv ¶
func (*File) GetCrc64Xor ¶
func (*File) GetEndVersion ¶
func (*File) GetStartKey ¶
func (*File) GetStartVersion ¶
func (*File) GetTotalBytes ¶
func (*File) GetTotalKvs ¶
func (*File) ProtoMessage ¶
func (*File) ProtoMessage()
func (*File) XXX_DiscardUnknown ¶
func (m *File) XXX_DiscardUnknown()
func (*File) XXX_Unmarshal ¶
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) GetCredentialsBlob ¶
func (*GCS) GetEndpoint ¶
func (*GCS) GetPredefinedAcl ¶
func (*GCS) GetStorageClass ¶
func (*GCS) ProtoMessage ¶
func (*GCS) ProtoMessage()
func (*GCS) XXX_DiscardUnknown ¶
func (m *GCS) XXX_DiscardUnknown()
func (*GCS) XXX_Unmarshal ¶
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) ProtoMessage ¶
func (*HDFS) ProtoMessage()
func (*HDFS) XXX_DiscardUnknown ¶
func (m *HDFS) XXX_DiscardUnknown()
func (*HDFS) XXX_Unmarshal ¶
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) GetDownstreamId ¶
func (*IDMap) GetUpstreamId ¶
func (*IDMap) ProtoMessage ¶
func (*IDMap) ProtoMessage()
func (*IDMap) XXX_DiscardUnknown ¶
func (m *IDMap) XXX_DiscardUnknown()
func (*IDMap) XXX_Marshal ¶
func (*IDMap) XXX_Unmarshal ¶
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) ProtoMessage ¶
func (*Local) ProtoMessage()
func (*Local) XXX_DiscardUnknown ¶
func (m *Local) XXX_DiscardUnknown()
func (*Local) XXX_Marshal ¶
func (*Local) XXX_Unmarshal ¶
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) GetDataFiles ¶
func (*MetaFile) GetMetaFiles ¶
func (*MetaFile) GetRawRanges ¶
func (*MetaFile) GetSchemas ¶
func (*MetaFile) MarshalToSizedBuffer ¶
func (*MetaFile) ProtoMessage ¶
func (*MetaFile) ProtoMessage()
func (*MetaFile) XXX_DiscardUnknown ¶
func (m *MetaFile) XXX_DiscardUnknown()
func (*MetaFile) XXX_Marshal ¶
func (*MetaFile) XXX_Unmarshal ¶
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) GetFileGroups ¶
func (m *Metadata) GetFileGroups() []*DataFileGroup
func (*Metadata) GetFiles ¶
func (m *Metadata) GetFiles() []*DataFileInfo
func (*Metadata) GetMetaVersion ¶
func (m *Metadata) GetMetaVersion() MetaVersion
func (*Metadata) GetResolvedTs ¶
func (*Metadata) GetStoreId ¶
func (*Metadata) MarshalToSizedBuffer ¶
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
func (*Metadata) XXX_DiscardUnknown ¶
func (m *Metadata) XXX_DiscardUnknown()
func (*Metadata) XXX_Marshal ¶
func (*Metadata) XXX_Unmarshal ¶
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) ProtoMessage ¶
func (*Noop) ProtoMessage()
func (*Noop) XXX_DiscardUnknown ¶
func (m *Noop) XXX_DiscardUnknown()
func (*Noop) XXX_Unmarshal ¶
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) GetTables ¶
func (m *PitrDBMap) GetTables() []*PitrTableMap
func (*PitrDBMap) MarshalToSizedBuffer ¶
func (*PitrDBMap) ProtoMessage ¶
func (*PitrDBMap) ProtoMessage()
func (*PitrDBMap) XXX_DiscardUnknown ¶
func (m *PitrDBMap) XXX_DiscardUnknown()
func (*PitrDBMap) XXX_Marshal ¶
func (*PitrDBMap) XXX_Unmarshal ¶
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) 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) 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) GetStartKey ¶
func (*RawRange) MarshalToSizedBuffer ¶
func (*RawRange) ProtoMessage ¶
func (*RawRange) ProtoMessage()
func (*RawRange) XXX_DiscardUnknown ¶
func (m *RawRange) XXX_DiscardUnknown()
func (*RawRange) XXX_Marshal ¶
func (*RawRange) XXX_Unmarshal ¶
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) GetAccessKey ¶
func (*S3) GetEndpoint ¶
func (*S3) GetExternalId ¶
func (*S3) GetForcePathStyle ¶
func (*S3) GetObjectLockEnabled ¶
func (*S3) GetProvider ¶
func (*S3) GetRoleArn ¶
func (*S3) GetSecretAccessKey ¶
func (*S3) GetSessionToken ¶
func (*S3) GetSseKmsKeyId ¶
func (*S3) GetStorageClass ¶
func (*S3) ProtoMessage ¶
func (*S3) ProtoMessage()
func (*S3) XXX_DiscardUnknown ¶
func (m *S3) XXX_DiscardUnknown()
func (*S3) XXX_Unmarshal ¶
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) GetCrc64Xor ¶
func (*Schema) GetTiflashReplicas ¶
func (*Schema) GetTotalBytes ¶
func (*Schema) GetTotalKvs ¶
func (*Schema) MarshalToSizedBuffer ¶
func (*Schema) ProtoMessage ¶
func (*Schema) ProtoMessage()
func (*Schema) XXX_DiscardUnknown ¶
func (m *Schema) XXX_DiscardUnknown()
func (*Schema) XXX_Marshal ¶
func (*Schema) XXX_Unmarshal ¶
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) 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) Backup(req *BackupRequest, srv Backup_BackupServer) error
func (*UnimplementedBackupServer) CheckPendingAdminOp ¶
func (*UnimplementedBackupServer) CheckPendingAdminOp(req *CheckAdminRequest, srv Backup_CheckPendingAdminOpServer) error
type UnimplementedExternalStorageServer ¶
type UnimplementedExternalStorageServer struct { }
UnimplementedExternalStorageServer can be embedded to have forward compatible implementations.
func (*UnimplementedExternalStorageServer) Restore ¶
func (*UnimplementedExternalStorageServer) Restore(ctx context.Context, req *ExternalStorageRestoreRequest) (*ExternalStorageRestoreResponse, error)
func (*UnimplementedExternalStorageServer) Save ¶
func (*UnimplementedExternalStorageServer) Save(ctx context.Context, req *ExternalStorageSaveRequest) (*ExternalStorageSaveResponse, error)