public final class SerializingBlobStore<V> extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
SerializingBlobStore.Deserializer<V> |
static interface |
SerializingBlobStore.Serializer<V> |
Constructor and Description |
---|
SerializingBlobStore(BlobStore blobStore,
SerializingBlobStore.Serializer<V> serializer,
SerializingBlobStore.Deserializer<V> deserializer) |
Modifier and Type | Method and 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) |
public SerializingBlobStore(BlobStore blobStore, SerializingBlobStore.Serializer<V> serializer, SerializingBlobStore.Deserializer<V> deserializer)
public static <U> SerializingBlobStore<U> ofType(BlobStore blobStore, SerializingBlobStore.Serializer<U> serializer, SerializingBlobStore.Deserializer<U> deserializer)
public CompletableFuture<Long> putAsync(String key, V value, String context)
public CompletableFuture<Long> putAsync(String key, V value, String context, Integer ttlInSeconds)
public CompletableFuture<Optional<V>> getAsync(String key, String context)
public CompletableFuture<Optional<Optional<V>>> getIfStaleAsync(String key, String context, long timestamp)
public CompletableFuture<Map<String,V>> enumerateContextAsync(String context)
Copyright © 2020. All rights reserved.