Versions in this module Expand all Collapse all v0 v0.1.0 Jun 15, 2023 Changes in this version + var CompressionType_name = map[int32]string + var CompressionType_value = map[string]int32 + var ErrIntOverflowBrpb = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthBrpb = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupBrpb = fmt.Errorf("proto: unexpected end of group") + var FileType_name = map[int32]string + var FileType_value = map[string]int32 + var MetaVersion_name = map[int32]string + var MetaVersion_value = map[string]int32 + func RegisterBackupServer(s *grpc.Server, srv BackupServer) + func RegisterExternalStorageServer(s *grpc.Server, srv ExternalStorageServer) + type AzureBlobStorage struct + AccessSig string + AccountName string + Bucket string + EncryptionScope string + Endpoint string + Prefix string + SharedKey string + StorageClass string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*AzureBlobStorage) Descriptor() ([]byte, []int) + func (*AzureBlobStorage) ProtoMessage() + 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 (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 interface + Backup func(ctx context.Context, in *BackupRequest, opts ...grpc.CallOption) (Backup_BackupClient, error) + CheckPendingAdminOp func(ctx context.Context, in *CheckAdminRequest, opts ...grpc.CallOption) (Backup_CheckPendingAdminOpClient, error) + func NewBackupClient(cc *grpc.ClientConn) BackupClient + type BackupMeta struct + ApiVersion kvrpcpb.APIVersion + BackupResult string + BrVersion string + ClusterId uint64 + ClusterVersion string + DbMaps []*PitrDBMap + DdlIndexes *MetaFile + Ddls []byte + EndVersion uint64 + FileIndex *MetaFile + Files []*File + IsRawKv bool + IsTxnKv bool + NewCollationsEnabled string + Policies []*PlacementPolicy + RawRangeIndex *MetaFile + RawRanges []*RawRange + SchemaIndex *MetaFile + Schemas []*Schema + StartVersion uint64 + Version int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BackupMeta) Descriptor() ([]byte, []int) + func (*BackupMeta) ProtoMessage() + 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 (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 struct + Cf string + CipherInfo *CipherInfo + ClusterId uint64 + CompressionLevel int32 + CompressionType CompressionType + Concurrency uint32 + DstApiVersion kvrpcpb.APIVersion + EndKey []byte + EndVersion uint64 + IsRawKv bool + RateLimit uint64 + ReplicaRead bool + StartKey []byte + StartVersion uint64 + StorageBackend *StorageBackend + SubRanges []*kvrpcpb.KeyRange + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BackupRequest) Descriptor() ([]byte, []int) + func (*BackupRequest) ProtoMessage() + 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 (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 struct + ApiVersion kvrpcpb.APIVersion + EndKey []byte + Error *Error + Files []*File + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BackupResponse) Descriptor() ([]byte, []int) + func (*BackupResponse) ProtoMessage() + 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 (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 interface + Backup func(*BackupRequest, Backup_BackupServer) error + CheckPendingAdminOp func(*CheckAdminRequest, Backup_CheckPendingAdminOpServer) error + type Backup_BackupClient interface + Recv func() (*BackupResponse, error) + type Backup_BackupServer interface + Send func(*BackupResponse) error + type Backup_CheckPendingAdminOpClient interface + Recv func() (*CheckAdminResponse, error) + type Backup_CheckPendingAdminOpServer interface + Send func(*CheckAdminResponse) error + type Bucket struct + Bucket string + Endpoint string + Prefix string + Region string + StorageClass string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Bucket) Descriptor() ([]byte, []int) + func (*Bucket) ProtoMessage() + 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 (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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CheckAdminRequest) Descriptor() ([]byte, []int) + func (*CheckAdminRequest) ProtoMessage() + 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 (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 struct + Error *Error + HasPendingAdmin bool + Region *metapb.Region + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CheckAdminResponse) Descriptor() ([]byte, []int) + func (*CheckAdminResponse) ProtoMessage() + 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 (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 struct + CipherKey []byte + CipherType encryptionpb.EncryptionMethod + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CipherInfo) Descriptor() ([]byte, []int) + func (*CipherInfo) ProtoMessage() + 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 (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 struct + Attrs map[string]string + Bucket *Bucket + ProviderName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CloudDynamic) Descriptor() ([]byte, []int) + func (*CloudDynamic) ProtoMessage() + 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 (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 struct + Current uint64 + Request uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterIDError) Descriptor() ([]byte, []int) + func (*ClusterIDError) ProtoMessage() + 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 (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 int32 + const CompressionType_LZ4 + const CompressionType_SNAPPY + const CompressionType_UNKNOWN + const CompressionType_ZSTD + func (CompressionType) EnumDescriptor() ([]byte, []int) + func (x CompressionType) String() string + type DataFileGroup struct + DataFilesInfo []*DataFileInfo + Length uint64 + MaxTs uint64 + MinResolvedTs uint64 + MinTs uint64 + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataFileGroup) Descriptor() ([]byte, []int) + func (*DataFileGroup) ProtoMessage() + 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 (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 struct + Cf string + CompressionType CompressionType + EndKey []byte + IsMeta bool + Length uint64 + MaxTs uint64 + MinBeginTsInDefaultCf uint64 + MinTs uint64 + NumberOfEntries int64 + Path string + RangeLength uint64 + RangeOffset uint64 + RegionId int64 + ResolvedTs uint64 + Sha256 []byte + StartKey []byte + TableId int64 + Type FileType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DataFileInfo) Descriptor() ([]byte, []int) + func (*DataFileInfo) ProtoMessage() + 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 (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 struct + Detail isError_Detail + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + func (*Error) XXX_OneofWrappers() []interface{} + 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 (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 (m *Error) XXX_Size() int + func (m *Error) XXX_Unmarshal(b []byte) error + type Error_ClusterIdError struct + ClusterIdError *ClusterIDError + func (m *Error_ClusterIdError) MarshalTo(dAtA []byte) (int, error) + func (m *Error_ClusterIdError) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error_ClusterIdError) Size() (n int) + type Error_KvError struct + KvError *kvrpcpb.KeyError + func (m *Error_KvError) MarshalTo(dAtA []byte) (int, error) + func (m *Error_KvError) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error_KvError) Size() (n int) + type Error_RegionError struct + RegionError *errorpb.Error + func (m *Error_RegionError) MarshalTo(dAtA []byte) (int, error) + func (m *Error_RegionError) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Error_RegionError) Size() (n int) + type ExternalStorageClient interface + Restore func(ctx context.Context, in *ExternalStorageRestoreRequest, ...) (*ExternalStorageRestoreResponse, error) + Save func(ctx context.Context, in *ExternalStorageSaveRequest, opts ...grpc.CallOption) (*ExternalStorageSaveResponse, error) + func NewExternalStorageClient(cc *grpc.ClientConn) ExternalStorageClient + type ExternalStorageRestoreRequest struct + ContentLength uint64 + ObjectName string + RestoreName string + StorageBackend *StorageBackend + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExternalStorageRestoreRequest) Descriptor() ([]byte, []int) + func (*ExternalStorageRestoreRequest) ProtoMessage() + 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 (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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExternalStorageRestoreResponse) Descriptor() ([]byte, []int) + func (*ExternalStorageRestoreResponse) ProtoMessage() + 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 (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 struct + ContentLength uint64 + ObjectName string + StorageBackend *StorageBackend + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExternalStorageSaveRequest) Descriptor() ([]byte, []int) + func (*ExternalStorageSaveRequest) ProtoMessage() + 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 (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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ExternalStorageSaveResponse) Descriptor() ([]byte, []int) + func (*ExternalStorageSaveResponse) ProtoMessage() + 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 (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 interface + Restore func(context.Context, *ExternalStorageRestoreRequest) (*ExternalStorageRestoreResponse, error) + Save func(context.Context, *ExternalStorageSaveRequest) (*ExternalStorageSaveResponse, error) + type File struct + Cf string + CipherIv []byte + Crc64Xor uint64 + EndKey []byte + EndVersion uint64 + Name string + Sha256 []byte + Size_ uint64 + StartKey []byte + StartVersion uint64 + TotalBytes uint64 + TotalKvs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*File) Descriptor() ([]byte, []int) + func (*File) ProtoMessage() + 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 (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 int32 + const FileType_Delete + const FileType_Put + func (FileType) EnumDescriptor() ([]byte, []int) + func (x FileType) String() string + type GCS struct + Bucket string + CredentialsBlob string + Endpoint string + PredefinedAcl string + Prefix string + StorageClass string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GCS) Descriptor() ([]byte, []int) + func (*GCS) ProtoMessage() + 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 (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 struct + Remote string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*HDFS) Descriptor() ([]byte, []int) + func (*HDFS) ProtoMessage() + 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 (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 struct + DownstreamId int64 + UpstreamId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*IDMap) Descriptor() ([]byte, []int) + func (*IDMap) ProtoMessage() + 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 (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 struct + Path string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Local) Descriptor() ([]byte, []int) + func (*Local) ProtoMessage() + 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 (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 struct + DataFiles []*File + Ddls [][]byte + MetaFiles []*File + RawRanges []*RawRange + Schemas []*Schema + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MetaFile) Descriptor() ([]byte, []int) + func (*MetaFile) ProtoMessage() + 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 (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 int32 + const MetaVersion_V1 + const MetaVersion_V2 + func (MetaVersion) EnumDescriptor() ([]byte, []int) + func (x MetaVersion) String() string + type Metadata struct + FileGroups []*DataFileGroup + Files []*DataFileInfo + MaxTs uint64 + MetaVersion MetaVersion + MinTs uint64 + ResolvedTs uint64 + StoreId int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Metadata) Descriptor() ([]byte, []int) + func (*Metadata) ProtoMessage() + 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 (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 struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Noop) Descriptor() ([]byte, []int) + func (*Noop) ProtoMessage() + 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 (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 struct + IdMap *IDMap + Name string + Tables []*PitrTableMap + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PitrDBMap) Descriptor() ([]byte, []int) + func (*PitrDBMap) ProtoMessage() + 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 (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 struct + IdMap *IDMap + Name string + Partitions []*IDMap + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PitrTableMap) Descriptor() ([]byte, []int) + func (*PitrTableMap) ProtoMessage() + 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 (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 struct + Info []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PlacementPolicy) Descriptor() ([]byte, []int) + func (*PlacementPolicy) ProtoMessage() + 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 (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 struct + Cf string + EndKey []byte + StartKey []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RawRange) Descriptor() ([]byte, []int) + func (*RawRange) ProtoMessage() + 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 (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 struct + AccessKey string + Acl string + Bucket string + Endpoint string + ExternalId string + ForcePathStyle bool + ObjectLockEnabled bool + Prefix string + Provider string + Region string + RoleArn string + SecretAccessKey string + SessionToken string + Sse string + SseKmsKeyId string + StorageClass string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*S3) Descriptor() ([]byte, []int) + func (*S3) ProtoMessage() + 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 (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 struct + Crc64Xor uint64 + Db []byte + Stats []byte + Table []byte + TiflashReplicas uint32 + TotalBytes uint64 + TotalKvs uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Schema) Descriptor() ([]byte, []int) + func (*Schema) ProtoMessage() + 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 (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 struct + Backend isStorageBackend_Backend + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StorageBackend) Descriptor() ([]byte, []int) + func (*StorageBackend) ProtoMessage() + func (*StorageBackend) XXX_OneofWrappers() []interface{} + 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 (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 (m *StorageBackend) XXX_Size() int + func (m *StorageBackend) XXX_Unmarshal(b []byte) error + type StorageBackend_AzureBlobStorage struct + AzureBlobStorage *AzureBlobStorage + func (m *StorageBackend_AzureBlobStorage) MarshalTo(dAtA []byte) (int, error) + func (m *StorageBackend_AzureBlobStorage) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageBackend_AzureBlobStorage) Size() (n int) + type StorageBackend_CloudDynamic struct + CloudDynamic *CloudDynamic + func (m *StorageBackend_CloudDynamic) MarshalTo(dAtA []byte) (int, error) + func (m *StorageBackend_CloudDynamic) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageBackend_CloudDynamic) Size() (n int) + type StorageBackend_Gcs struct + Gcs *GCS + func (m *StorageBackend_Gcs) MarshalTo(dAtA []byte) (int, error) + func (m *StorageBackend_Gcs) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageBackend_Gcs) Size() (n int) + type StorageBackend_Hdfs struct + Hdfs *HDFS + func (m *StorageBackend_Hdfs) MarshalTo(dAtA []byte) (int, error) + func (m *StorageBackend_Hdfs) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageBackend_Hdfs) Size() (n int) + type StorageBackend_Local struct + Local *Local + func (m *StorageBackend_Local) MarshalTo(dAtA []byte) (int, error) + func (m *StorageBackend_Local) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageBackend_Local) Size() (n int) + type StorageBackend_Noop struct + Noop *Noop + func (m *StorageBackend_Noop) MarshalTo(dAtA []byte) (int, error) + func (m *StorageBackend_Noop) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageBackend_Noop) Size() (n int) + type StorageBackend_S3 struct + S3 *S3 + func (m *StorageBackend_S3) MarshalTo(dAtA []byte) (int, error) + func (m *StorageBackend_S3) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *StorageBackend_S3) Size() (n int) + type StreamBackupError struct + ErrorCode string + ErrorMessage string + HappenAt uint64 + StoreId uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamBackupError) Descriptor() ([]byte, []int) + func (*StreamBackupError) ProtoMessage() + 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 (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 struct + CompressionType CompressionType + EndTs uint64 + Name string + StartTs uint64 + Storage *StorageBackend + TableFilter []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*StreamBackupTaskInfo) Descriptor() ([]byte, []int) + func (*StreamBackupTaskInfo) ProtoMessage() + 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 (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 struct + func (*UnimplementedBackupServer) Backup(req *BackupRequest, srv Backup_BackupServer) error + func (*UnimplementedBackupServer) CheckPendingAdminOp(req *CheckAdminRequest, srv Backup_CheckPendingAdminOpServer) error + type UnimplementedExternalStorageServer struct + func (*UnimplementedExternalStorageServer) Restore(ctx context.Context, req *ExternalStorageRestoreRequest) (*ExternalStorageRestoreResponse, error) + func (*UnimplementedExternalStorageServer) Save(ctx context.Context, req *ExternalStorageSaveRequest) (*ExternalStorageSaveResponse, error)
Go to main page