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

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