Interface ReactiveNumberCommands
- All Known Subinterfaces:
ReactiveClusterNumberCommands
public interface ReactiveNumberCommands
Redis numeric commands executed using reactive infrastructure.
- Since:
- 2.0
- Author:
- Christoph Strobl, Mark Paluch
-
Nested Class Summary
Modifier and TypeInterfaceDescriptionstatic class
ReactiveNumberCommands.DecrByCommand<T extends Number>
DECRBY
command parameters.static class
ReactiveNumberCommands.HIncrByCommand<T extends Number>
HINCRBY
command parameters.static class
ReactiveNumberCommands.IncrByCommand<T extends Number>
INCRBY
command parameters. -
Method Summary
Modifier and TypeMethodDescriptiondefault reactor.core.publisher.Mono<Long>
decr
(ByteBuffer key) Decrement value of key by 1.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> decr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Decrement value of key by 1.default <T extends Number>
reactor.core.publisher.Mono<T>decrBy
(ByteBuffer key, T value) Decrement value of key by value.<T extends Number>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>> decrBy
(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands) Decrement value of key by value.default <T extends Number>
reactor.core.publisher.Mono<T>hIncrBy
(ByteBuffer key, ByteBuffer field, T value) Increment value of a hash field by the given value.<T extends Number>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>> hIncrBy
(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands) Increment value of a hash field by the given value.default reactor.core.publisher.Mono<Long>
incr
(ByteBuffer key) Increment value of key by 1.reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,
Long>> incr
(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Increment value of key by 1.default <T extends Number>
reactor.core.publisher.Mono<T>incrBy
(ByteBuffer key, T value) Increment value of key by value.<T extends Number>
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>> incrBy
(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands) Increment value of key by value.
-
Method Details
-
incr
Increment value of key by 1.- Parameters:
key
- must not be null.- Returns:
- See Also:
-
incr
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> incr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Increment value of key by 1.- Parameters:
keys
- must not be null.- Returns:
- See Also:
-
incrBy
Increment value of key by value.- Parameters:
key
- must not be null.value
- must not be null.- Returns:
- See Also:
-
incrBy
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>> incrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands) Increment value of key by value.- Parameters:
commands
- must not be null.- Returns:
- See Also:
-
decr
Decrement value of key by 1.- Parameters:
key
- must not be null.- Returns:
- See Also:
-
decr
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> decr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Decrement value of key by 1.- Parameters:
keys
- must not be null.- Returns:
- See Also:
-
decrBy
Decrement value of key by value.- Parameters:
key
- must not be null.value
- must not be null.- Returns:
- See Also:
-
decrBy
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>> decrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands) Decrement value of key by value.- Parameters:
commands
- must not be null.- Returns:
-
hIncrBy
default <T extends Number> reactor.core.publisher.Mono<T> hIncrBy(ByteBuffer key, ByteBuffer field, T value) Increment value of a hash field by the given value.- Parameters:
key
- must not be null.field
- must not be null.value
- must not be null.- Returns:
- See Also:
-
hIncrBy
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>> hIncrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands) Increment value of a hash field by the given value.- Returns:
- See Also:
-