public class DefaultReactiveValueOperations<K,V> extends Object implements ReactiveValueOperations<K,V>
ReactiveValueOperations
.Constructor and Description |
---|
DefaultReactiveValueOperations(ReactiveRedisTemplate<?,?> template,
RedisSerializationContext<K,V> serializationContext)
Creates new
DefaultReactiveValueOperations . |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Long> |
append(K key,
String value)
Append a
value to key . |
reactor.core.publisher.Mono<Boolean> |
delete(K key)
Removes the given key.
|
reactor.core.publisher.Mono<String> |
get(K key,
long start,
long end)
Get a substring of value of
key between begin and end . |
reactor.core.publisher.Mono<V> |
get(Object key)
Get the value of
key . |
reactor.core.publisher.Mono<V> |
getAndSet(K key,
V value)
Set
value of key and return its old value. |
reactor.core.publisher.Mono<Boolean> |
getBit(K key,
long offset)
« Get the bit value at
offset of value at key . |
reactor.core.publisher.Mono<List<V>> |
multiGet(Collection<K> keys)
Get multiple
keys . |
reactor.core.publisher.Mono<Boolean> |
multiSet(Map<? extends K,? extends V> map)
Set multiple keys to multiple values using key-value pairs provided in
tuple . |
reactor.core.publisher.Mono<Boolean> |
multiSetIfAbsent(Map<? extends K,? extends V> map)
Set multiple keys to multiple values using key-value pairs provided in
tuple only if the provided key does
not exist. |
reactor.core.publisher.Mono<Boolean> |
set(K key,
V value)
Set
value for key . |
reactor.core.publisher.Mono<Boolean> |
set(K key,
V value,
Duration timeout)
Set the
value and expiration timeout for key . |
reactor.core.publisher.Mono<Long> |
set(K key,
V value,
long offset)
Overwrite parts of
key starting at the specified offset with given value . |
reactor.core.publisher.Mono<Boolean> |
setBit(K key,
long offset,
boolean value)
Sets the bit at
offset in value stored at key . |
reactor.core.publisher.Mono<Boolean> |
setIfAbsent(K key,
V value)
Set
key to hold the string value if key is absent. |
reactor.core.publisher.Mono<Boolean> |
setIfPresent(K key,
V value)
Set
key to hold the string value if key is present. |
reactor.core.publisher.Mono<Long> |
size(K key)
Get the length of the value stored at
key . |
public DefaultReactiveValueOperations(ReactiveRedisTemplate<?,?> template, RedisSerializationContext<K,V> serializationContext)
DefaultReactiveValueOperations
.template
- must not be null.serializationContext
- must not be null.public reactor.core.publisher.Mono<Boolean> set(K key, V value)
ReactiveValueOperations
value
for key
.set
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> set(K key, V value, Duration timeout)
ReactiveValueOperations
value
and expiration timeout
for key
.set
in interface ReactiveValueOperations<K,V>
key
- must not be null.timeout
- must not be null.public reactor.core.publisher.Mono<Boolean> setIfAbsent(K key, V value)
ReactiveValueOperations
key
to hold the string value
if key
is absent.setIfAbsent
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> setIfPresent(K key, V value)
ReactiveValueOperations
key
to hold the string value
if key
is present.setIfPresent
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> multiSet(Map<? extends K,? extends V> map)
ReactiveValueOperations
tuple
.multiSet
in interface ReactiveValueOperations<K,V>
map
- must not be null.public reactor.core.publisher.Mono<Boolean> multiSetIfAbsent(Map<? extends K,? extends V> map)
ReactiveValueOperations
tuple
only if the provided key does
not exist.multiSetIfAbsent
in interface ReactiveValueOperations<K,V>
map
- must not be null.public reactor.core.publisher.Mono<V> get(Object key)
ReactiveValueOperations
key
.get
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<V> getAndSet(K key, V value)
ReactiveValueOperations
value
of key
and return its old value.getAndSet
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<List<V>> multiGet(Collection<K> keys)
ReactiveValueOperations
keys
. Values are returned in the order of the requested keys.multiGet
in interface ReactiveValueOperations<K,V>
keys
- must not be null.public reactor.core.publisher.Mono<Long> append(K key, String value)
ReactiveValueOperations
value
to key
.append
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<String> get(K key, long start, long end)
ReactiveValueOperations
key
between begin
and end
.get
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Long> set(K key, V value, long offset)
ReactiveValueOperations
key
starting at the specified offset
with given value
.set
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Long> size(K key)
ReactiveValueOperations
key
.size
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> setBit(K key, long offset, boolean value)
ReactiveValueOperations
offset
in value stored at key
.setBit
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> getBit(K key, long offset)
ReactiveValueOperations
offset
of value at key
.getBit
in interface ReactiveValueOperations<K,V>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> delete(K key)
ReactiveValueOperations
delete
in interface ReactiveValueOperations<K,V>
key
- must not be null.Copyright © 2011–2017 Pivotal Software, Inc.. All rights reserved.