Package org.springframework.data.redis.connection

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

Nested Classes

Modifier and Type	Interface	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	Description
default Mono<Long>	decr(ByteBuffer key)	Decrement value of key by 1.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	decr(Publisher<ReactiveRedisConnection.KeyCommand> keys)	Decrement value of key by 1.
default <T extends Number> Mono<T>	decrBy(ByteBuffer key, T value)	Decrement value of key by value.
<T extends Number> Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>>	decrBy(Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands)	Decrement value of key by value.
default <T extends Number> Mono<T>	hIncrBy(ByteBuffer key, ByteBuffer field, T value)	Increment value of a hash field by the given value.
<T extends Number> Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>>	hIncrBy(Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands)	Increment value of a hash field by the given value.
default Mono<Long>	incr(ByteBuffer key)	Increment value of key by 1.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	incr(Publisher<ReactiveRedisConnection.KeyCommand> keys)	Increment value of key by 1.
default <T extends Number> Mono<T>	incrBy(ByteBuffer key, T value)	Increment value of key by value.
<T extends Number> Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>>	incrBy(Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands)	Increment value of key by value.

Method Details

incr

default Mono<Long> incr(ByteBuffer key)

Increment value of key by 1.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: INCR

incr

Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> incr(Publisher<ReactiveRedisConnection.KeyCommand> keys)

Increment value of key by 1.

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: INCR

incrBy

default <T extends Number> 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:

See Also:

• Redis Documentation: INCRBY
• Redis Documentation: INCRBYFLOAT

incrBy

<T extends Number>
Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>> incrBy(Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands)

Increment value of key by value.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: INCRBY
• Redis Documentation: INCRBYFLOAT

decr

default Mono<Long> decr(ByteBuffer key)

Decrement value of key by 1.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: DECR

decr

Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> decr(Publisher<ReactiveRedisConnection.KeyCommand> keys)

Decrement value of key by 1.

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: DECR

decrBy

default <T extends Number> 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:

See Also:

• Redis Documentation: DECRBY

decrBy

<T extends Number>
Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>> decrBy(Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands)

Decrement value of key by value.

Parameters:

commands - must not be null.

Returns:

hIncrBy

default <T extends Number> 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:

• Redis Documentation: HINCRBY

hIncrBy

<T extends Number>
Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>> hIncrBy(Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands)

Increment value of a hash field by the given value.

Returns:

See Also:

• Redis Documentation: HINCRBY