Documentation ¶
Index ¶
- Variables
- func RegisterBackupServer(s *grpc.Server, srv BackupServer)
- func RegisterExternalStorageServer(s *grpc.Server, srv ExternalStorageServer)
- type BackupClient
- type BackupMeta
- func (*BackupMeta) Descriptor() ([]byte, []int)
- func (m *BackupMeta) GetBrVersion() string
- func (m *BackupMeta) GetClusterId() uint64
- func (m *BackupMeta) GetClusterVersion() string
- 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) 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 (*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 (dst *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) GetClusterId() uint64
- func (m *BackupRequest) GetCompressionLevel() int32
- func (m *BackupRequest) GetCompressionType() CompressionType
- func (m *BackupRequest) GetConcurrency() uint32
- func (m *BackupRequest) GetEndKey() []byte
- func (m *BackupRequest) GetEndVersion() uint64
- func (m *BackupRequest) GetIsRawKv() bool
- func (m *BackupRequest) GetRateLimit() uint64
- func (m *BackupRequest) GetStartKey() []byte
- func (m *BackupRequest) GetStartVersion() uint64
- func (m *BackupRequest) GetStorageBackend() *StorageBackend
- func (m *BackupRequest) Marshal() (dAtA []byte, err error)
- func (m *BackupRequest) MarshalTo(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 (dst *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) 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 (*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 (dst *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 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 (*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 (dst *Bucket) XXX_Merge(src proto.Message)
- func (m *Bucket) XXX_Size() int
- func (m *Bucket) 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 (*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 (dst *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 (*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 (dst *ClusterIDError) XXX_Merge(src proto.Message)
- func (m *ClusterIDError) XXX_Size() int
- func (m *ClusterIDError) XXX_Unmarshal(b []byte) error
- type CompressionType
- 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 (*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 (dst *Error) XXX_Merge(src proto.Message)
- func (*Error) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- 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 (*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 (dst *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 (*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 (dst *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 (*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 (dst *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 (*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 (dst *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) 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 (*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 (dst *File) XXX_Merge(src proto.Message)
- func (m *File) XXX_Size() int
- func (m *File) XXX_Unmarshal(b []byte) error
- 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 (*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 (dst *GCS) XXX_Merge(src proto.Message)
- func (m *GCS) XXX_Size() int
- func (m *GCS) 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 (*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 (dst *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 (*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 (dst *MetaFile) XXX_Merge(src proto.Message)
- func (m *MetaFile) XXX_Size() int
- func (m *MetaFile) 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 (*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 (dst *Noop) XXX_Merge(src proto.Message)
- func (m *Noop) XXX_Size() int
- func (m *Noop) 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 (*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 (dst *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) GetForcePathStyle() bool
- func (m *S3) GetPrefix() string
- func (m *S3) GetRegion() string
- func (m *S3) GetSecretAccessKey() 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 (*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 (dst *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 (*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 (dst *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) GetBackend() isStorageBackend_Backend
- func (m *StorageBackend) GetCloudDynamic() *CloudDynamic
- func (m *StorageBackend) GetGcs() *GCS
- 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 (*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 (dst *StorageBackend) XXX_Merge(src proto.Message)
- func (*StorageBackend) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *StorageBackend) XXX_Size() int
- func (m *StorageBackend) XXX_Unmarshal(b []byte) error
- type StorageBackend_CloudDynamic
- type StorageBackend_Gcs
- type StorageBackend_Local
- type StorageBackend_Noop
- type StorageBackend_S3
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthBackup = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowBackup = fmt.Errorf("proto: integer overflow") )
View Source
var CompressionType_name = map[int32]string{
0: "UNKNOWN",
1: "LZ4",
2: "SNAPPY",
3: "ZSTD",
}
View Source
var CompressionType_value = map[string]int32{
"UNKNOWN": 0,
"LZ4": 1,
"SNAPPY": 2,
"ZSTD": 3,
}
Functions ¶
func RegisterBackupServer ¶
func RegisterBackupServer(s *grpc.Server, srv BackupServer)
func RegisterExternalStorageServer ¶
func RegisterExternalStorageServer(s *grpc.Server, srv ExternalStorageServer)
Types ¶
type BackupClient ¶
type BackupClient interface {
Backup(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (Backup_BackupClient, error)
}
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" json:"files,omitempty"` // An index to files contains data files. FileIndex *MetaFile `protobuf:"bytes,13,opt,name=file_index,json=fileIndex" 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" json:"schemas,omitempty"` // An index to files contains Schemas. SchemaIndex *MetaFile `protobuf:"bytes,14,opt,name=schema_index,json=schemaIndex" 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" json:"raw_ranges,omitempty"` // An index to files contains RawRanges. RawRangeIndex *MetaFile `protobuf:"bytes,15,opt,name=raw_range_index,json=rawRangeIndex" 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" json:"ddl_indexes,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) GetBrVersion ¶
func (m *BackupMeta) GetBrVersion() string
func (*BackupMeta) GetClusterId ¶
func (m *BackupMeta) GetClusterId() uint64
func (*BackupMeta) GetClusterVersion ¶
func (m *BackupMeta) GetClusterVersion() string
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) 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) 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 (dst *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" 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"` 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) 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) 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) GetStartKey ¶
func (m *BackupRequest) GetStartKey() []byte
func (*BackupRequest) GetStartVersion ¶
func (m *BackupRequest) GetStartVersion() uint64
func (*BackupRequest) GetStorageBackend ¶
func (m *BackupRequest) GetStorageBackend() *StorageBackend
func (*BackupRequest) Marshal ¶
func (m *BackupRequest) Marshal() (dAtA []byte, err 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 (dst *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" 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" json:"files,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*BackupResponse) Descriptor ¶
func (*BackupResponse) Descriptor() ([]byte, []int)
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) 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 (dst *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
}
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 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) ProtoMessage ¶
func (*Bucket) ProtoMessage()
func (*Bucket) XXX_DiscardUnknown ¶
func (m *Bucket) XXX_DiscardUnknown()
func (*Bucket) XXX_Marshal ¶
func (*Bucket) XXX_Unmarshal ¶
type CloudDynamic ¶
type CloudDynamic struct { Bucket *Bucket `protobuf:"bytes,1,opt,name=bucket" json:"bucket,omitempty"` ProviderName string `protobuf:"bytes,2,opt,name=provider_name,json=providerName,proto3" json:"provider_name,omitempty"` Attrs map[string]string `` /* 144-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) 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 (dst *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) 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 (dst *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 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 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_OneofFuncs ¶
func (*Error) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs 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,oneof"`
}
func (*Error_ClusterIdError) MarshalTo ¶
func (m *Error_ClusterIdError) MarshalTo(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,oneof"`
}
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,oneof"`
}
func (*Error_RegionError) MarshalTo ¶
func (m *Error_RegionError) MarshalTo(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) }
func NewExternalStorageClient ¶
func NewExternalStorageClient(cc *grpc.ClientConn) ExternalStorageClient
type ExternalStorageRestoreRequest ¶
type ExternalStorageRestoreRequest struct { StorageBackend *StorageBackend `protobuf:"bytes,1,opt,name=storage_backend,json=storageBackend" 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) 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 (dst *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) 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 (dst *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" 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) 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 (dst *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) 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 (dst *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) }
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"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*File) Descriptor ¶
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 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" json:"meta_files,omitempty"` // A set of files that contains user data. DataFiles []*File `protobuf:"bytes,2,rep,name=data_files,json=dataFiles" json:"data_files,omitempty"` // A set of files that contains Schemas. Schemas []*Schema `protobuf:"bytes,3,rep,name=schemas" json:"schemas,omitempty"` // A set of files that contains RawRanges. RawRanges []*RawRange `protobuf:"bytes,4,rep,name=raw_ranges,json=rawRanges" json:"raw_ranges,omitempty"` // A set of files that contains DDLs. Ddls [][]byte `protobuf:"bytes,5,rep,name=ddls" 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) ProtoMessage ¶
func (*MetaFile) ProtoMessage()
func (*MetaFile) XXX_DiscardUnknown ¶
func (m *MetaFile) XXX_DiscardUnknown()
func (*MetaFile) XXX_Marshal ¶
func (*MetaFile) 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 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) 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"` 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) GetForcePathStyle ¶
func (*S3) GetSecretAccessKey ¶
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) 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 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) 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) 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) 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 (dst *StorageBackend) XXX_Merge(src proto.Message)
func (*StorageBackend) XXX_OneofFuncs ¶
func (*StorageBackend) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs 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_CloudDynamic ¶
type StorageBackend_CloudDynamic struct {
CloudDynamic *CloudDynamic `protobuf:"bytes,5,opt,name=cloud_dynamic,json=cloudDynamic,oneof"`
}
func (*StorageBackend_CloudDynamic) MarshalTo ¶
func (m *StorageBackend_CloudDynamic) MarshalTo(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,oneof"`
}
func (*StorageBackend_Gcs) MarshalTo ¶
func (m *StorageBackend_Gcs) MarshalTo(dAtA []byte) (int, error)
func (*StorageBackend_Gcs) Size ¶
func (m *StorageBackend_Gcs) Size() (n int)
type StorageBackend_Local ¶
type StorageBackend_Local struct {
Local *Local `protobuf:"bytes,2,opt,name=local,oneof"`
}
func (*StorageBackend_Local) MarshalTo ¶
func (m *StorageBackend_Local) MarshalTo(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,oneof"`
}
func (*StorageBackend_Noop) MarshalTo ¶
func (m *StorageBackend_Noop) MarshalTo(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,oneof"`
}
func (*StorageBackend_S3) MarshalTo ¶
func (m *StorageBackend_S3) MarshalTo(dAtA []byte) (int, error)
func (*StorageBackend_S3) Size ¶
func (m *StorageBackend_S3) Size() (n int)
Click to show internal directories.
Click to hide internal directories.