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.HSetCommand
|
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<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.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)
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)
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.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.Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.