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
Modifier and TypeInterfaceDescriptionstatic class
PFADD
command parameters.static class
PFCOUNT
command parameters.static class
PFMERGE
command parameters. -
Method Summary
Modifier and TypeMethodDescriptiondefault 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
Adds given value to the HyperLogLog stored at given key.- Parameters:
key
- must not be null.value
- must not be null.- Returns:
- See Also:
-
pfAdd
Adds given values to the HyperLogLog stored at given key.- Parameters:
key
- must not be null.values
- must not be null.- Returns:
- See Also:
-
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:
-
pfCount
Return the approximated cardinality of the structures observed by the HyperLogLog at key.- Parameters:
key
- must not be null.- Returns:
- See Also:
-
pfCount
Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).- Parameters:
keys
- must not be null.- Returns:
- See Also:
-
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:
-
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:
-
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:
-