refactor(@xen-orchestra/backups): rename delta writers to incremental writers
This commit is contained in:
@@ -14,8 +14,8 @@ const { defer } = require('golike-defer')
|
|||||||
const { formatDateTime } = require('@xen-orchestra/xapi')
|
const { formatDateTime } = require('@xen-orchestra/xapi')
|
||||||
const { pipeline } = require('node:stream')
|
const { pipeline } = require('node:stream')
|
||||||
|
|
||||||
const { DeltaBackupWriter } = require('./writers/DeltaBackupWriter.js')
|
const { IncrementalBackupWriter } = require('./writers/IncrementalBackupWriter.js')
|
||||||
const { DeltaReplicationWriter } = require('./writers/DeltaReplicationWriter.js')
|
const { IncrementalReplicationWriter } = require('./writers/IncrementalReplicationWriter.js')
|
||||||
const { exportDeltaVm } = require('./_deltaVm.js')
|
const { exportDeltaVm } = require('./_deltaVm.js')
|
||||||
const { forkStreamUnpipe } = require('./_forkStreamUnpipe.js')
|
const { forkStreamUnpipe } = require('./_forkStreamUnpipe.js')
|
||||||
const { FullBackupWriter } = require('./writers/FullBackupWriter.js')
|
const { FullBackupWriter } = require('./writers/FullBackupWriter.js')
|
||||||
@@ -108,7 +108,7 @@ class VmBackup {
|
|||||||
this._writers = writers
|
this._writers = writers
|
||||||
|
|
||||||
const [BackupWriter, ReplicationWriter] = this._isIncremental
|
const [BackupWriter, ReplicationWriter] = this._isIncremental
|
||||||
? [DeltaBackupWriter, DeltaReplicationWriter]
|
? [IncrementalBackupWriter, IncrementalReplicationWriter]
|
||||||
: [FullBackupWriter, FullReplicationWriter]
|
: [FullBackupWriter, FullReplicationWriter]
|
||||||
|
|
||||||
const allSettings = job.settings
|
const allSettings = job.settings
|
||||||
|
|||||||
@@ -16,14 +16,14 @@ const { getOldEntries } = require('../_getOldEntries.js')
|
|||||||
const { Task } = require('../Task.js')
|
const { Task } = require('../Task.js')
|
||||||
|
|
||||||
const { MixinBackupWriter } = require('./_MixinBackupWriter.js')
|
const { MixinBackupWriter } = require('./_MixinBackupWriter.js')
|
||||||
const { AbstractDeltaWriter } = require('./_AbstractDeltaWriter.js')
|
const { AbstractIncrementalWriter } = require('./_AbstractIncrementalWriter.js')
|
||||||
const { checkVhd } = require('./_checkVhd.js')
|
const { checkVhd } = require('./_checkVhd.js')
|
||||||
const { packUuid } = require('./_packUuid.js')
|
const { packUuid } = require('./_packUuid.js')
|
||||||
const { Disposable } = require('promise-toolbox')
|
const { Disposable } = require('promise-toolbox')
|
||||||
|
|
||||||
const { warn } = createLogger('xo:backups:DeltaBackupWriter')
|
const { warn } = createLogger('xo:backups:DeltaBackupWriter')
|
||||||
|
|
||||||
class DeltaBackupWriter extends MixinBackupWriter(AbstractDeltaWriter) {
|
class IncrementalBackupWriter extends MixinBackupWriter(AbstractIncrementalWriter) {
|
||||||
async checkBaseVdis(baseUuidToSrcVdi) {
|
async checkBaseVdis(baseUuidToSrcVdi) {
|
||||||
const { handler } = this._adapter
|
const { handler } = this._adapter
|
||||||
const backup = this._backup
|
const backup = this._backup
|
||||||
@@ -227,6 +227,6 @@ class DeltaBackupWriter extends MixinBackupWriter(AbstractDeltaWriter) {
|
|||||||
// TODO: run cleanup?
|
// TODO: run cleanup?
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
exports.DeltaBackupWriter = decorateClass(DeltaBackupWriter, {
|
exports.IncrementalBackupWriter = decorateClass(IncrementalBackupWriter, {
|
||||||
_transfer: defer,
|
_transfer: defer,
|
||||||
})
|
})
|
||||||
@@ -9,11 +9,13 @@ const { getOldEntries } = require('../_getOldEntries.js')
|
|||||||
const { importDeltaVm, TAG_COPY_SRC } = require('../_deltaVm.js')
|
const { importDeltaVm, TAG_COPY_SRC } = require('../_deltaVm.js')
|
||||||
const { Task } = require('../Task.js')
|
const { Task } = require('../Task.js')
|
||||||
|
|
||||||
const { AbstractDeltaWriter } = require('./_AbstractDeltaWriter.js')
|
const { AbstractIncrementalWriter } = require('./_AbstractIncrementalWriter.js')
|
||||||
const { MixinReplicationWriter } = require('./_MixinReplicationWriter.js')
|
const { MixinReplicationWriter } = require('./_MixinReplicationWriter.js')
|
||||||
const { listReplicatedVms } = require('./_listReplicatedVms.js')
|
const { listReplicatedVms } = require('./_listReplicatedVms.js')
|
||||||
|
|
||||||
exports.DeltaReplicationWriter = class DeltaReplicationWriter extends MixinReplicationWriter(AbstractDeltaWriter) {
|
exports.IncrementalReplicationWriter = class IncrementalReplicationWriter extends (
|
||||||
|
MixinReplicationWriter(AbstractIncrementalWriter)
|
||||||
|
) {
|
||||||
async checkBaseVdis(baseUuidToSrcVdi, baseVm) {
|
async checkBaseVdis(baseUuidToSrcVdi, baseVm) {
|
||||||
const sr = this._sr
|
const sr = this._sr
|
||||||
const replicatedVm = listReplicatedVms(sr.$xapi, this._backup.job.id, sr.uuid, this._backup.vm.uuid).find(
|
const replicatedVm = listReplicatedVms(sr.$xapi, this._backup.job.id, sr.uuid, this._backup.vm.uuid).find(
|
||||||
@@ -2,7 +2,7 @@
|
|||||||
|
|
||||||
const { AbstractWriter } = require('./_AbstractWriter.js')
|
const { AbstractWriter } = require('./_AbstractWriter.js')
|
||||||
|
|
||||||
exports.AbstractDeltaWriter = class AbstractDeltaWriter extends AbstractWriter {
|
exports.AbstractIncrementalWriter = class AbstractIncrementalWriter extends AbstractWriter {
|
||||||
checkBaseVdis(baseUuidToSrcVdi, baseVm) {
|
checkBaseVdis(baseUuidToSrcVdi, baseVm) {
|
||||||
throw new Error('Not implemented')
|
throw new Error('Not implemented')
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user