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 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
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)

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(String key,
                V value,
                String context)

put

public long put(String key,
                V value,
                String context,
                Integer ttlInSeconds)

get

public Optional<V> get(String key,
                       String context)

getIfStale

public Optional<Optional<V>> getIfStale(String key,
                                        String context,
                                        long timestamp)

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)

enumerateContext

public Map<String,V> enumerateContext(String context)

enumerateContextAsync

public CompletableFuture<Map<String,V>> enumerateContextAsync(String context)