public class DefaultReactiveHashOperations<H,HK,HV> extends Object implements ReactiveHashOperations<H,HK,HV>
ReactiveHashOperations
.Constructor and Description |
---|
DefaultReactiveHashOperations(ReactiveRedisTemplate<?,?> template,
RedisSerializationContext<H,?> serializationContext)
Creates new instance of
DefaultReactiveHashOperations . |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<Boolean> |
delete(H key)
Removes the given key.
|
reactor.core.publisher.Flux<Map.Entry<HK,HV>> |
entries(H key)
Get entire hash stored at
key . |
reactor.core.publisher.Mono<HV> |
get(H key,
Object hashKey)
Get value for given
hashKey from hash at key . |
reactor.core.publisher.Mono<Boolean> |
hasKey(H key,
Object hashKey)
Determine if given hash
hashKey exists. |
reactor.core.publisher.Mono<Double> |
increment(H key,
HK hashKey,
double delta)
Increment
value of a hash hashKey by the given delta . |
reactor.core.publisher.Mono<Long> |
increment(H key,
HK hashKey,
long delta)
Increment
value of a hash hashKey by the given delta . |
reactor.core.publisher.Flux<HK> |
keys(H key)
Get key set (fields) of hash at
key . |
reactor.core.publisher.Mono<List<HV>> |
multiGet(H key,
Collection<HK> hashKeys)
Get values for given
hashKeys from hash at key . |
reactor.core.publisher.Mono<Boolean> |
put(H key,
HK hashKey,
HV value)
Set the
value of a hash hashKey . |
reactor.core.publisher.Mono<Boolean> |
putAll(H key,
Map<? extends HK,? extends HV> map)
Set multiple hash fields to multiple values using data provided in
m . |
reactor.core.publisher.Mono<Boolean> |
putIfAbsent(H key,
HK hashKey,
HV value)
Set the
value of a hash hashKey only if hashKey does not exist. |
reactor.core.publisher.Mono<Long> |
remove(H key,
Object... hashKeys)
Delete given hash
hashKeys from the hash at key. |
reactor.core.publisher.Mono<Long> |
size(H key)
Get size of hash at
key . |
reactor.core.publisher.Flux<HV> |
values(H key)
Get entry set (values) of hash at
key . |
public DefaultReactiveHashOperations(ReactiveRedisTemplate<?,?> template, RedisSerializationContext<H,?> serializationContext)
DefaultReactiveHashOperations
.template
- must not be null.serializationContext
- must not be null.public reactor.core.publisher.Mono<Long> remove(H key, Object... hashKeys)
ReactiveHashOperations
hashKeys
from the hash at key.remove
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKeys
- must not be null.public reactor.core.publisher.Mono<Boolean> hasKey(H key, Object hashKey)
ReactiveHashOperations
hashKey
exists.hasKey
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKey
- must not be null.public reactor.core.publisher.Mono<HV> get(H key, Object hashKey)
ReactiveHashOperations
hashKey
from hash at key
.get
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKey
- must not be null.public reactor.core.publisher.Mono<List<HV>> multiGet(H key, Collection<HK> hashKeys)
ReactiveHashOperations
hashKeys
from hash at key
.multiGet
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKeys
- must not be null.public reactor.core.publisher.Mono<Long> increment(H key, HK hashKey, long delta)
ReactiveHashOperations
value
of a hash hashKey
by the given delta
.increment
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKey
- must not be null.public reactor.core.publisher.Mono<Double> increment(H key, HK hashKey, double delta)
ReactiveHashOperations
value
of a hash hashKey
by the given delta
.increment
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKey
- must not be null.public reactor.core.publisher.Flux<HK> keys(H key)
ReactiveHashOperations
key
.keys
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.public reactor.core.publisher.Mono<Long> size(H key)
ReactiveHashOperations
key
.size
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> putAll(H key, Map<? extends HK,? extends HV> map)
ReactiveHashOperations
m
.putAll
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.map
- must not be null.public reactor.core.publisher.Mono<Boolean> put(H key, HK hashKey, HV value)
ReactiveHashOperations
value
of a hash hashKey
.put
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKey
- must not be null.public reactor.core.publisher.Mono<Boolean> putIfAbsent(H key, HK hashKey, HV value)
ReactiveHashOperations
value
of a hash hashKey
only if hashKey
does not exist.putIfAbsent
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.hashKey
- must not be null.public reactor.core.publisher.Flux<HV> values(H key)
ReactiveHashOperations
key
.values
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.public reactor.core.publisher.Flux<Map.Entry<HK,HV>> entries(H key)
ReactiveHashOperations
key
.entries
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.public reactor.core.publisher.Mono<Boolean> delete(H key)
ReactiveHashOperations
delete
in interface ReactiveHashOperations<H,HK,HV>
key
- must not be null.Copyright © 2011–2017 Pivotal Software, Inc.. All rights reserved.