Versions in this module Expand all Collapse all v7 v7.0.4 Jan 30, 2023 v7.0.2 Jan 30, 2023 v7.0.1 Jan 30, 2023 v7.0.0 Jan 30, 2023 Changes in this version + const CheckpointChecksumDir + const CheckpointDataDir + const CheckpointDir + const CheckpointLockPath + const CheckpointMetaPath + const MaxChecksumTotalCost + func SaveCheckpointMetadata(ctx context.Context, s storage.ExternalStorage, meta *CheckpointMetadata) error + func WalkCheckpointFile(ctx context.Context, s storage.ExternalStorage, cipher *backuppb.CipherInfo, ...) (time.Duration, error) + type CheckpointData struct + DureTime time.Duration + RangeGroupMetas []*RangeGroupData + type CheckpointLock struct + ExpireAt int64 + LockId uint64 + type CheckpointMessage struct + Group *rtree.Range + GroupKey string + type CheckpointMetadata struct + BackupTS uint64 + CheckpointChecksum map[int64]*ChecksumItem + CheckpointDataMap map[string]rtree.RangeTree + ConfigHash []byte + GCServiceId string + Ranges []rtree.Range + func LoadCheckpointMetadata(ctx context.Context, s storage.ExternalStorage) (*CheckpointMetadata, error) + type CheckpointRunner struct + func StartCheckpointRunner(ctx context.Context, storage storage.ExternalStorage, ...) (*CheckpointRunner, error) + func StartCheckpointRunnerForTest(ctx context.Context, storage storage.ExternalStorage, ...) (*CheckpointRunner, error) + func (r *CheckpointRunner) Append(ctx context.Context, groupKey string, startKey []byte, endKey []byte, ...) error + func (r *CheckpointRunner) FlushChecksum(ctx context.Context, tableID int64, crc64xor uint64, totalKvs uint64, ...) error + func (r *CheckpointRunner) WaitForFinish(ctx context.Context) + type ChecksumInfo struct + Checksum []byte + Content []byte + type ChecksumItem struct + Crc64xor uint64 + TableID int64 + TotalBytes uint64 + TotalKvs uint64 + type ChecksumItems struct + Items []*ChecksumItem + type ChecksumRunner struct + func NewChecksumRunner() *ChecksumRunner + func (cr *ChecksumRunner) FlushChecksum(ctx context.Context, s storage.ExternalStorage, tableID int64, crc64xor uint64, ...) error + func (cr *ChecksumRunner) RecordError(err error) + type GlobalTimer interface + GetTS func(context.Context) (int64, int64, error) + type RangeGroupData struct + Checksum []byte + CipherIv []byte + RangeGroupsEncriptedData []byte + Size int + type RangeGroups struct + GroupKey string + Groups []*rtree.Range
Go to main page