public interface ReactiveHashCommands
Modifier and Type | Interface and Description |
---|---|
static class |
ReactiveHashCommands.HDelCommand |
static class |
ReactiveHashCommands.HExistsCommand
HEXISTS
ReactiveRedisConnection.Command . |
static class |
ReactiveHashCommands.HGetCommand
|
static class |
ReactiveHashCommands.HRandFieldCommand
HRANDFIELD
ReactiveRedisConnection.Command . |
static class |
ReactiveHashCommands.HSetCommand
|
static class |
ReactiveHashCommands.HStrLenCommand |
Modifier and Type | Method and Description |
---|---|
default reactor.core.publisher.Mono<Boolean> |
hDel(ByteBuffer key,
ByteBuffer field)
Delete given hash field.
|
default reactor.core.publisher.Mono<Long> |
hDel(ByteBuffer key,
Collection<ByteBuffer> fields)
Delete given hash fields.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,Long>> |
hDel(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands)
Delete given hash fields.
|
default reactor.core.publisher.Mono<Boolean> |
hExists(ByteBuffer key,
ByteBuffer field)
Determine if given hash field exists.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HExistsCommand>> |
hExists(org.reactivestreams.Publisher<ReactiveHashCommands.HExistsCommand> commands)
Determine if given hash field exists.
|
default reactor.core.publisher.Mono<ByteBuffer> |
hGet(ByteBuffer key,
ByteBuffer field)
Get value for given field from hash at key.
|
default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> |
hGetAll(ByteBuffer key)
Get entire hash stored at key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>> |
hGetAll(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
Get entire hash stored at key.
|
default reactor.core.publisher.Flux<ByteBuffer> |
hKeys(ByteBuffer key)
Get key set (fields) of hash at key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> |
hKeys(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
Get key set (fields) of hash at key.
|
default reactor.core.publisher.Mono<Long> |
hLen(ByteBuffer key)
Get size of hash at key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> |
hLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
Get size of hash at key.
|
default reactor.core.publisher.Mono<List<ByteBuffer>> |
hMGet(ByteBuffer key,
Collection<ByteBuffer> fields)
Get values for given fields from hash at key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveHashCommands.HGetCommand,ByteBuffer>> |
hMGet(org.reactivestreams.Publisher<ReactiveHashCommands.HGetCommand> commands)
Get values for given fields from hash at key.
|
default reactor.core.publisher.Mono<Boolean> |
hMSet(ByteBuffer key,
Map<ByteBuffer,ByteBuffer> fieldValueMap)
Set multiple hash fields to multiple values using data provided in fieldValueMap.
|
default reactor.core.publisher.Mono<ByteBuffer> |
hRandField(ByteBuffer key)
Return a random field from the hash stored at
key . |
default reactor.core.publisher.Flux<ByteBuffer> |
hRandField(ByteBuffer key,
long count)
Return a random field from the hash stored at
key . |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<ByteBuffer>>> |
hRandField(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands)
Get random fields of hash at key.
|
default reactor.core.publisher.Mono<Map.Entry<ByteBuffer,ByteBuffer>> |
hRandFieldWithValues(ByteBuffer key)
Return a random field from the hash along with its value stored at
key . |
default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> |
hRandFieldWithValues(ByteBuffer key,
long count)
Return a random field from the hash along with its value stored at
key . |
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>> |
hRandFieldWithValues(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands)
Get random fields along their values of hash at key.
|
default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> |
hScan(ByteBuffer key)
Use a
Flux to iterate over entries in the hash at key . |
default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> |
hScan(ByteBuffer key,
ScanOptions options)
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>> |
hScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)
Use a
Flux to iterate over entries in the hash at key . |
default reactor.core.publisher.Mono<Boolean> |
hSet(ByteBuffer key,
ByteBuffer field,
ByteBuffer value)
Set the value of a hash field.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HSetCommand>> |
hSet(org.reactivestreams.Publisher<ReactiveHashCommands.HSetCommand> commands)
Set the value of a hash field.
|
default reactor.core.publisher.Mono<Boolean> |
hSetNX(ByteBuffer key,
ByteBuffer field,
ByteBuffer value)
Set the value of a hash field.
|
default reactor.core.publisher.Mono<Long> |
hStrLen(ByteBuffer key,
ByteBuffer field)
Get the length of the value associated with
field . |
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HStrLenCommand,Long>> |
hStrLen(org.reactivestreams.Publisher<ReactiveHashCommands.HStrLenCommand> commands)
Get the length of the value associated with
field . |
default reactor.core.publisher.Flux<ByteBuffer> |
hVals(ByteBuffer key)
Get entry set (values) of hash at key.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> |
hVals(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
Get entry set (values) of hash at key.
|
default reactor.core.publisher.Mono<Boolean> hSet(ByteBuffer key, ByteBuffer field, ByteBuffer value)
key
- must not be null.field
- must not be null.value
- must not be null.default reactor.core.publisher.Mono<Boolean> hSetNX(ByteBuffer key, ByteBuffer field, ByteBuffer value)
key
- must not be null.field
- must not be null.value
- must not be null.default reactor.core.publisher.Mono<Boolean> hMSet(ByteBuffer key, Map<ByteBuffer,ByteBuffer> fieldValueMap)
key
- must not be null.fieldValueMap
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HSetCommand>> hSet(org.reactivestreams.Publisher<ReactiveHashCommands.HSetCommand> commands)
commands
- must not be null.default reactor.core.publisher.Mono<ByteBuffer> hGet(ByteBuffer key, ByteBuffer field)
key
- must not be null.field
- must not be null.default reactor.core.publisher.Mono<List<ByteBuffer>> hMGet(ByteBuffer key, Collection<ByteBuffer> fields)
null
in the resulting List
.key
- must not be null.fields
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveHashCommands.HGetCommand,ByteBuffer>> hMGet(org.reactivestreams.Publisher<ReactiveHashCommands.HGetCommand> commands)
null
in the resulting List
.commands
- must not be null.default reactor.core.publisher.Mono<Boolean> hExists(ByteBuffer key, ByteBuffer field)
key
- must not be null.field
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHashCommands.HExistsCommand>> hExists(org.reactivestreams.Publisher<ReactiveHashCommands.HExistsCommand> commands)
commands
- default reactor.core.publisher.Mono<Boolean> hDel(ByteBuffer key, ByteBuffer field)
key
- must not be null.field
- must not be null.default reactor.core.publisher.Mono<Long> hDel(ByteBuffer key, Collection<ByteBuffer> fields)
key
- must not be null.fields
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,Long>> hDel(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands)
commands
- must not be null.default reactor.core.publisher.Mono<Long> hLen(ByteBuffer key)
key
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> hLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
commands
- must not be null.default reactor.core.publisher.Mono<ByteBuffer> hRandField(ByteBuffer key)
key
.key
- must not be null.default reactor.core.publisher.Mono<Map.Entry<ByteBuffer,ByteBuffer>> hRandFieldWithValues(ByteBuffer key)
key
.key
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> hRandField(ByteBuffer key, long count)
key
. If the provided count
argument is positive,
return a list of distinct fields, capped either at count
or the hash size. If count
is negative,
the behavior changes and the command is allowed to return the same field multiple times. In this case, the number
of returned fields is the absolute value of the specified count.key
- must not be null.count
- number of fields to return.default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> hRandFieldWithValues(ByteBuffer key, long count)
key
. If the provided count
argument is positive, return a list of distinct fields, capped either at count
or the hash size. If
count
is negative, the behavior changes and the command is allowed to return the same field multiple times.
In this case, the number of returned fields is the absolute value of the specified count.key
- must not be null.count
- number of fields to return.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<ByteBuffer>>> hRandField(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands)
commands
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>> hRandFieldWithValues(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands)
commands
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> hKeys(ByteBuffer key)
key
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> hKeys(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
commands
- must not be null.default reactor.core.publisher.Flux<ByteBuffer> hVals(ByteBuffer key)
key
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>> hVals(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
commands
- must not be null.default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> hGetAll(ByteBuffer key)
key
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>> hGetAll(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
commands
- must not be null.default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> hScan(ByteBuffer key)
Flux
to iterate over entries in the hash at key
. The resulting Flux
acts as a cursor
and issues HSCAN
commands itself as long as the subscriber signals demand.key
- must not be null.Flux
emitting entries
one by one.IllegalArgumentException
- in case the given key is null.default reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>> hScan(ByteBuffer key, ScanOptions options)
Flux
to iterate over entries in the hash at key
given ScanOptions
. The resulting
Flux
acts as a cursor and issues HSCAN
commands itself as long as the subscriber signals demand.key
- must not be null.options
- must not be null. Use ScanOptions.NONE
instead.Flux
emitting the raw entries
one by one.IllegalArgumentException
- in case one of the required arguments is null.reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>> hScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)
Flux
to iterate over entries in the hash at key
. The resulting Flux
acts as a cursor
and issues HSCAN
commands itself as long as the subscriber signals demand.commands
- must not be null.Flux
emitting ReactiveRedisConnection.CommandResponse
one by one.default reactor.core.publisher.Mono<Long> hStrLen(ByteBuffer key, ByteBuffer field)
field
. If either the key
or the field
do not
exist, 0
is emitted.key
- must not be null.field
- must not be null.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HStrLenCommand,Long>> hStrLen(org.reactivestreams.Publisher<ReactiveHashCommands.HStrLenCommand> commands)
field
. If either the key
or the field
do not
exist, 0
is emitted.commands
- must not be null.Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.