org.springframework.data.redis.connection

Interface ReactiveNumberCommands

All Known Subinterfaces:

ReactiveClusterNumberCommands

All Known Implementing Classes:

LettuceReactiveClusterNumberCommands, LettuceReactiveNumberCommands

public interface ReactiveNumberCommands

Redis numeric commands executed using reactive infrastructure.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static 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 Type	Method and Description
default 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 Detail

incr

default reactor.core.publisher.Mono<Long> incr(ByteBuffer key)

Increment value of key by 1.

Parameters:

key - must not be null.

Returns:

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:

incrBy

default <T extends Number> reactor.core.publisher.Mono<T> incrBy(ByteBuffer key,
                                                                 T value)

Increment value of key by value.

Parameters:

key - must not be null.

value - must not be null.

Returns:

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:

decr

default reactor.core.publisher.Mono<Long> decr(ByteBuffer key)

Decrement value of key by 1.

Parameters:

key - must not be null.

Returns:

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:

decrBy

default <T extends Number> reactor.core.publisher.Mono<T> decrBy(ByteBuffer key,
                                                                 T value)

Decrement value of key by value.

Parameters:

key - must not be null.

value - must not be null.

Returns:

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:

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: