This is an automated email from the ASF dual-hosted git repository. rouazana pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/james-project.git
commit 3df612d2b0a0765aea851e4228575f6d9014be15 Author: Rene Cordier <[email protected]> AuthorDate: Mon Jul 15 10:50:58 2019 +0700 JAMES-2829 add delete skeleton method in BlobStore API --- .../src/main/java/org/apache/james/blob/api/BlobStore.java | 2 ++ .../java/org/apache/james/blob/api/MetricableBlobStore.java | 6 ++++++ .../org/apache/james/blob/cassandra/CassandraBlobsDAO.java | 5 +++++ .../java/org/apache/james/blob/memory/MemoryBlobStore.java | 6 ++++++ .../apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java | 6 ++++++ .../main/java/org/apache/james/blob/union/UnionBlobStore.java | 6 ++++++ .../java/org/apache/james/blob/union/UnionBlobStoreTest.java | 10 ++++++++++ 7 files changed, 41 insertions(+) diff --git a/server/blob/blob-api/src/main/java/org/apache/james/blob/api/BlobStore.java b/server/blob/blob-api/src/main/java/org/apache/james/blob/api/BlobStore.java index 0d1414d..9c4f650 100644 --- a/server/blob/blob-api/src/main/java/org/apache/james/blob/api/BlobStore.java +++ b/server/blob/blob-api/src/main/java/org/apache/james/blob/api/BlobStore.java @@ -40,4 +40,6 @@ public interface BlobStore { BucketName getDefaultBucketName(); Mono<Void> deleteBucket(BucketName bucketName); + + Mono<Void> delete(BucketName bucketName, BlobId blobId); } diff --git a/server/blob/blob-api/src/main/java/org/apache/james/blob/api/MetricableBlobStore.java b/server/blob/blob-api/src/main/java/org/apache/james/blob/api/MetricableBlobStore.java index 73ccb4d..d673b97 100644 --- a/server/blob/blob-api/src/main/java/org/apache/james/blob/api/MetricableBlobStore.java +++ b/server/blob/blob-api/src/main/java/org/apache/james/blob/api/MetricableBlobStore.java @@ -23,6 +23,7 @@ import java.io.InputStream; import javax.inject.Inject; import javax.inject.Named; +import org.apache.commons.lang3.NotImplementedException; import org.apache.james.metrics.api.MetricFactory; import reactor.core.publisher.Mono; @@ -82,4 +83,9 @@ public class MetricableBlobStore implements BlobStore { public BucketName getDefaultBucketName() { return blobStoreImpl.getDefaultBucketName(); } + + @Override + public Mono<Void> delete(BucketName bucketName, BlobId blobId) { + throw new NotImplementedException("not implemented"); + } } diff --git a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobsDAO.java b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobsDAO.java index 923af0d..29cef15 100644 --- a/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobsDAO.java +++ b/server/blob/blob-cassandra/src/main/java/org/apache/james/blob/cassandra/CassandraBlobsDAO.java @@ -229,4 +229,9 @@ public class CassandraBlobsDAO implements BlobStore { public Mono<Void> deleteBucket(BucketName bucketName) { throw new NotImplementedException("not implemented"); } + + @Override + public Mono<Void> delete(BucketName bucketName, BlobId blobId) { + throw new NotImplementedException("not implemented"); + } } diff --git a/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java b/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java index d6b3a25..d28437c 100644 --- a/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java +++ b/server/blob/blob-memory/src/main/java/org/apache/james/blob/memory/MemoryBlobStore.java @@ -27,6 +27,7 @@ import java.util.Optional; import javax.inject.Inject; import org.apache.commons.io.IOUtils; +import org.apache.commons.lang3.NotImplementedException; import org.apache.james.blob.api.BlobId; import org.apache.james.blob.api.BlobStore; import org.apache.james.blob.api.BucketName; @@ -118,4 +119,9 @@ public class MemoryBlobStore implements BlobStore { return defaultBucketName; } + @Override + public Mono<Void> delete(BucketName bucketName, BlobId blobId) { + throw new NotImplementedException("not implemented"); + } + } diff --git a/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java b/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java index 1ecb646..9beebd6 100644 --- a/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java +++ b/server/blob/blob-objectstorage/src/main/java/org/apache/james/blob/objectstorage/ObjectStorageBlobsDAO.java @@ -28,6 +28,7 @@ import java.util.function.Supplier; import javax.annotation.PreDestroy; import org.apache.commons.io.IOUtils; +import org.apache.commons.lang3.NotImplementedException; import org.apache.james.blob.api.BlobId; import org.apache.james.blob.api.BlobStore; import org.apache.james.blob.api.BucketName; @@ -201,4 +202,9 @@ public class ObjectStorageBlobsDAO implements BlobStore { .doOnNext(blobStore::deleteContainer) .then(); } + + @Override + public Mono<Void> delete(BucketName bucketName, BlobId blobId) { + throw new NotImplementedException("not implemented"); + } } diff --git a/server/blob/blob-union/src/main/java/org/apache/james/blob/union/UnionBlobStore.java b/server/blob/blob-union/src/main/java/org/apache/james/blob/union/UnionBlobStore.java index 9c765e5..7fd0aa6 100644 --- a/server/blob/blob-union/src/main/java/org/apache/james/blob/union/UnionBlobStore.java +++ b/server/blob/blob-union/src/main/java/org/apache/james/blob/union/UnionBlobStore.java @@ -26,6 +26,7 @@ import java.util.Optional; import java.util.function.BiFunction; import java.util.function.Function; +import org.apache.commons.lang3.NotImplementedException; import org.apache.james.blob.api.BlobId; import org.apache.james.blob.api.BlobStore; import org.apache.james.blob.api.BucketName; @@ -197,6 +198,11 @@ public class UnionBlobStore implements BlobStore { } @Override + public Mono<Void> delete(BucketName bucketName, BlobId blobId) { + throw new NotImplementedException("not implemented"); + } + + @Override public String toString() { return MoreObjects.toStringHelper(this) .add("currentBlobStore", currentBlobStore) diff --git a/server/blob/blob-union/src/test/java/org/apache/james/blob/union/UnionBlobStoreTest.java b/server/blob/blob-union/src/test/java/org/apache/james/blob/union/UnionBlobStoreTest.java index ab197cb..d7ea4e8 100644 --- a/server/blob/blob-union/src/test/java/org/apache/james/blob/union/UnionBlobStoreTest.java +++ b/server/blob/blob-union/src/test/java/org/apache/james/blob/union/UnionBlobStoreTest.java @@ -92,6 +92,11 @@ class UnionBlobStoreTest implements BlobStoreContract { } @Override + public Mono<Void> delete(BucketName bucketName, BlobId blobId) { + return Mono.error(new RuntimeException("broken everywhere")); + } + + @Override public String toString() { return MoreObjects.toStringHelper(this) .toString(); @@ -136,6 +141,11 @@ class UnionBlobStoreTest implements BlobStoreContract { } @Override + public Mono<Void> delete(BucketName bucketName, BlobId blobId) { + return Mono.error(new RuntimeException("broken everywhere")); + } + + @Override public String toString() { return MoreObjects.toStringHelper(this) .toString(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
