Class SerializingBlobStore<V>
- java.lang.Object
-
- org.opennms.features.distributed.kvstore.api.SerializingBlobStore<V>
-
public final class SerializingBlobStore<V> extends Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
SerializingBlobStore.Deserializer<V>
static interface
SerializingBlobStore.Serializer<V>
-
Constructor Summary
Constructors Constructor Description SerializingBlobStore(BlobStore blobStore, SerializingBlobStore.Serializer<V> serializer, SerializingBlobStore.Deserializer<V> deserializer)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<String,V>
enumerateContext(String context)
CompletableFuture<Map<String,V>>
enumerateContextAsync(String context)
Optional<V>
get(String key, String context)
CompletableFuture<Optional<V>>
getAsync(String key, String context)
Optional<Optional<V>>
getIfStale(String key, String context, long timestamp)
CompletableFuture<Optional<Optional<V>>>
getIfStaleAsync(String key, String context, long timestamp)
static <U> SerializingBlobStore<U>
ofType(BlobStore blobStore, SerializingBlobStore.Serializer<U> serializer, SerializingBlobStore.Deserializer<U> deserializer)
long
put(String key, V value, String context)
long
put(String key, V value, String context, Integer ttlInSeconds)
CompletableFuture<Long>
putAsync(String key, V value, String context)
CompletableFuture<Long>
putAsync(String key, V value, String context, Integer ttlInSeconds)
-
-
-
Constructor Detail
-
SerializingBlobStore
public SerializingBlobStore(BlobStore blobStore, SerializingBlobStore.Serializer<V> serializer, SerializingBlobStore.Deserializer<V> deserializer)
-
-
Method Detail
-
ofType
public static <U> SerializingBlobStore<U> ofType(BlobStore blobStore, SerializingBlobStore.Serializer<U> serializer, SerializingBlobStore.Deserializer<U> deserializer)
-
putAsync
public CompletableFuture<Long> putAsync(String key, V value, String context)
-
putAsync
public CompletableFuture<Long> putAsync(String key, V value, String context, Integer ttlInSeconds)
-
getAsync
public CompletableFuture<Optional<V>> getAsync(String key, String context)
-
getIfStaleAsync
public CompletableFuture<Optional<Optional<V>>> getIfStaleAsync(String key, String context, long timestamp)
-
enumerateContextAsync
public CompletableFuture<Map<String,V>> enumerateContextAsync(String context)
-
-