Class SerializingBlobStore<V>
- java.lang.Object
-
- org.opennms.features.distributed.kvstore.api.SerializingBlobStore<V>
-
public final class SerializingBlobStore<V> extends java.lang.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 java.util.Map<java.lang.String,V>
enumerateContext(java.lang.String context)
java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,V>>
enumerateContextAsync(java.lang.String context)
java.util.Optional<V>
get(java.lang.String key, java.lang.String context)
java.util.concurrent.CompletableFuture<java.util.Optional<V>>
getAsync(java.lang.String key, java.lang.String context)
java.util.Optional<java.util.Optional<V>>
getIfStale(java.lang.String key, java.lang.String context, long timestamp)
java.util.concurrent.CompletableFuture<java.util.Optional<java.util.Optional<V>>>
getIfStaleAsync(java.lang.String key, java.lang.String context, long timestamp)
static <U> SerializingBlobStore<U>
ofType(BlobStore blobStore, SerializingBlobStore.Serializer<U> serializer, SerializingBlobStore.Deserializer<U> deserializer)
long
put(java.lang.String key, V value, java.lang.String context)
long
put(java.lang.String key, V value, java.lang.String context, java.lang.Integer ttlInSeconds)
java.util.concurrent.CompletableFuture<java.lang.Long>
putAsync(java.lang.String key, V value, java.lang.String context)
java.util.concurrent.CompletableFuture<java.lang.Long>
putAsync(java.lang.String key, V value, java.lang.String context, java.lang.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)
-
put
public long put(java.lang.String key, V value, java.lang.String context)
-
put
public long put(java.lang.String key, V value, java.lang.String context, java.lang.Integer ttlInSeconds)
-
get
public java.util.Optional<V> get(java.lang.String key, java.lang.String context)
-
getIfStale
public java.util.Optional<java.util.Optional<V>> getIfStale(java.lang.String key, java.lang.String context, long timestamp)
-
putAsync
public java.util.concurrent.CompletableFuture<java.lang.Long> putAsync(java.lang.String key, V value, java.lang.String context)
-
putAsync
public java.util.concurrent.CompletableFuture<java.lang.Long> putAsync(java.lang.String key, V value, java.lang.String context, java.lang.Integer ttlInSeconds)
-
getAsync
public java.util.concurrent.CompletableFuture<java.util.Optional<V>> getAsync(java.lang.String key, java.lang.String context)
-
getIfStaleAsync
public java.util.concurrent.CompletableFuture<java.util.Optional<java.util.Optional<V>>> getIfStaleAsync(java.lang.String key, java.lang.String context, long timestamp)
-
enumerateContext
public java.util.Map<java.lang.String,V> enumerateContext(java.lang.String context)
-
enumerateContextAsync
public java.util.concurrent.CompletableFuture<java.util.Map<java.lang.String,V>> enumerateContextAsync(java.lang.String context)
-
-