Function NewLogStorageMetaManager

br/pkg/checkpoint/manager.go:304–319

(
	storage storage.ExternalStorage,
	cipher *backuppb.CipherInfo,
	clusterID uint64,
	prefix string,
	restoreID uint64,
)

}

func NewLogStorageMetaManager(
	storage storage.ExternalStorage,
	cipher *backuppb.CipherInfo,
	clusterID uint64,
	prefix string,
	restoreID uint64,
) LogMetaManagerT {
	return &StorageMetaManager[
		LogRestoreKeyType, LogRestoreValueType, LogRestoreValueMarshaled, CheckpointMetadataForLogRestore,
	]{
		storage:   storage,
		cipher:    cipher,
		clusterID: fmt.Sprintf("%d", clusterID),
		taskName:  fmt.Sprintf("%d/%s_%d", clusterID, prefix, restoreID),
	}
}

func (manager *StorageMetaManager[K, SV, LV, M]) String() string {
	return fmt.Sprintf("path[%s]", fmt.Sprintf(CheckpointRestoreDirFormat, manager.clusterID))