Package org.opennms.features.distributed.kvstore.api

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

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)