diff --git a/src/main/java/org/warp/filesponge/DiskCache.java b/src/main/java/org/warp/filesponge/DiskCache.java index fac2eef..abcb038 100644 --- a/src/main/java/org/warp/filesponge/DiskCache.java +++ b/src/main/java/org/warp/filesponge/DiskCache.java @@ -24,6 +24,7 @@ import static org.warp.filesponge.FileSponge.BLOCK_SIZE; import io.netty5.buffer.api.Buffer; import io.netty5.util.Resource; import io.netty5.util.Send; +import it.cavallium.dbengine.client.IBackuppable; import it.cavallium.dbengine.database.BufSupplier; import it.cavallium.dbengine.database.ColumnUtils; import it.cavallium.dbengine.database.LLDatabaseConnection; @@ -47,7 +48,7 @@ import reactor.core.scheduler.Schedulers; import reactor.util.function.Tuple2; import reactor.util.function.Tuples; -public class DiskCache implements URLsDiskHandler, URLsWriter { +public class DiskCache implements URLsDiskHandler, URLsWriter, IBackuppable { private final DiskMetadataSerializer diskMetadataSerializer; @@ -294,4 +295,19 @@ public class DiskCache implements URLsDiskHandler, URLsWriter { public Mono close() { return db.close(); } + + @Override + public Mono pauseForBackup() { + return db.pauseForBackup(); + } + + @Override + public Mono resumeAfterBackup() { + return db.resumeAfterBackup(); + } + + @Override + public boolean isPaused() { + return db.isPaused(); + } }