Package org.springframework.data.redis.connection

Interface ReactiveHyperLogLogCommands

All Known Subinterfaces:

ReactiveClusterHyperLogLogCommands

public interface ReactiveHyperLogLogCommands

Redis HyperLogLog 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	ReactiveHyperLogLogCommands.PfAddCommand	PFADD command parameters.
static class	ReactiveHyperLogLogCommands.PfCountCommand	PFCOUNT command parameters.
static class	ReactiveHyperLogLogCommands.PfMergeCommand	PFMERGE command parameters.

Method Summary

Modifier and Type	Method	Description
default reactor.core.publisher.Mono<Long>	pfAdd(ByteBuffer key, ByteBuffer value)	Adds given value to the HyperLogLog stored at given key.
default reactor.core.publisher.Mono<Long>	pfAdd(ByteBuffer key, Collection<ByteBuffer> values)	Adds given values to the HyperLogLog stored at given key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,Long>>	pfAdd(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands)	Adds given values to the HyperLogLog stored at given key.
default reactor.core.publisher.Mono<Long>	pfCount(ByteBuffer key)	Return the approximated cardinality of the structures observed by the HyperLogLog at key.
default reactor.core.publisher.Mono<Long>	pfCount(Collection<ByteBuffer> keys)	Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>>	pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands)	Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).
default reactor.core.publisher.Mono<Boolean>	pfMerge(ByteBuffer destinationKey, Collection<ByteBuffer> sourceKeys)	Merge N different HyperLogLogs at sourceKeys into a single destinationKey.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHyperLogLogCommands.PfMergeCommand>>	pfMerge(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfMergeCommand> commands)	Merge N different HyperLogLogs at sourceKeys into a single destinationKey.

Method Details

pfAdd

default reactor.core.publisher.Mono<Long> pfAdd(ByteBuffer key,
 ByteBuffer value)

Adds given value to the HyperLogLog stored at given key.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: PFADD

pfAdd

default reactor.core.publisher.Mono<Long> pfAdd(ByteBuffer key,
 Collection<ByteBuffer> values)

Adds given values to the HyperLogLog stored at given key.

Parameters:

key - must not be null.

values - must not be null.

Returns:

See Also:

• Redis Documentation: PFADD

pfAdd

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,Long>> pfAdd(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands)

Adds given values to the HyperLogLog stored at given key.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: PFADD

pfCount

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

Return the approximated cardinality of the structures observed by the HyperLogLog at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: PFCOUNT

pfCount

default reactor.core.publisher.Mono<Long> pfCount(Collection<ByteBuffer> keys)

Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).

Parameters:

keys - must not be null.

Returns:

See Also:

• Redis Documentation: PFCOUNT

pfCount

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>> pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands)

Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: PFCOUNT

pfMerge

default reactor.core.publisher.Mono<Boolean> pfMerge(ByteBuffer destinationKey,
 Collection<ByteBuffer> sourceKeys)

Merge N different HyperLogLogs at sourceKeys into a single destinationKey.

Parameters:

destinationKey - must not be null.

sourceKeys - must not be null.

Returns:

See Also:

• Redis Documentation: PFMERGE

pfMerge

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveHyperLogLogCommands.PfMergeCommand>> pfMerge(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfMergeCommand> commands)

Merge N different HyperLogLogs at sourceKeys into a single destinationKey.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: PFMERGE