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 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

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

Increment value of key by 1.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: INCR

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:

• Redis Documentation: INCR

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:

See Also:

• Redis Documentation: INCRBY
• Redis Documentation: INCRBYFLOAT

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:

• Redis Documentation: INCRBY
• Redis Documentation: INCRBYFLOAT

decr

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

Decrement value of key by 1.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: DECR

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:

• Redis Documentation: DECR

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:

See Also:

• Redis Documentation: DECRBY

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:

• Redis Documentation: HINCRBY

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:

• Redis Documentation: HINCRBY