Interface RedisSortedSetReactiveCommands<K,​V>

    • Method Detail

      • bzmpop

        Mono<KeyValue<K,​ScoredValue<V>>> bzmpop​(long timeout,
                                                      ZPopArgs args,
                                                      K... keys)
        Pops one or more elements, that are member-score pairs, from the first non-empty sorted set in the provided list of keys.
        Parameters:
        timeout - the timeout in seconds.
        keys - the keys.
        Returns:
        ScoredValue<V> the removed element or Value.empty().
        Since:
        6.3
      • bzmpop

        Mono<KeyValue<K,​List<ScoredValue<V>>>> bzmpop​(long timeout,
                                                            long count,
                                                            ZPopArgs args,
                                                            K... keys)
        Pops one or more elements, that are member-score pairs, from the first non-empty sorted set in the provided list of keys.
        Parameters:
        timeout - the timeout in seconds.
        count - number of elements to pop.
        args - the command args.
        keys - the keys.
        Returns:
        ScoredValue<V> the removed elements or Value.empty().
        Since:
        6.3
      • bzmpop

        Mono<KeyValue<K,​ScoredValue<V>>> bzmpop​(double timeout,
                                                      ZPopArgs args,
                                                      K... keys)
        Pops one or more elements, that are member-score pairs, from the first non-empty sorted set in the provided list of keys.
        Parameters:
        timeout - the timeout in seconds.
        keys - the keys.
        Returns:
        ScoredValue<V> the removed element or Value.empty().
        Since:
        6.3
      • bzmpop

        Mono<KeyValue<K,​List<ScoredValue<V>>>> bzmpop​(double timeout,
                                                            int count,
                                                            ZPopArgs args,
                                                            K... keys)
        Pops one or more elements, that are member-score pairs, from the first non-empty sorted set in the provided list of keys.
        Parameters:
        timeout - the timeout in seconds.
        count - number of elements to pop.
        args - the command args.
        keys - the keys.
        Returns:
        ScoredValue<V> the removed elements or Value.empty().
        Since:
        6.3
      • bzpopmin

        Mono<KeyValue<K,​ScoredValue<V>>> bzpopmin​(long timeout,
                                                        K... keys)
        Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
        Parameters:
        timeout - the timeout in seconds.
        keys - the keys.
        Returns:
        KeyValue<K, ScoredValue<V>> multi-bulk containing the name of the key, the score and the popped member.
        Since:
        5.1
      • bzpopmin

        Mono<KeyValue<K,​ScoredValue<V>>> bzpopmin​(double timeout,
                                                        K... keys)
        Removes and returns a member with the lowest scores in the sorted set stored at one of the keys.
        Parameters:
        timeout - the timeout in seconds.
        keys - the keys.
        Returns:
        KeyValue<K, ScoredValue<V>> multi-bulk containing the name of the key, the score and the popped member.
        Since:
        6.1.3
      • bzpopmax

        Mono<KeyValue<K,​ScoredValue<V>>> bzpopmax​(long timeout,
                                                        K... keys)
        Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
        Parameters:
        timeout - the timeout in seconds.
        keys - the keys.
        Returns:
        KeyValue<K, ScoredValue<V>> multi-bulk containing the name of the key, the score and the popped member.
        Since:
        5.1
      • bzpopmax

        Mono<KeyValue<K,​ScoredValue<V>>> bzpopmax​(double timeout,
                                                        K... keys)
        Removes and returns a member with the highest scores in the sorted set stored at one of the keys.
        Parameters:
        timeout - the timeout in seconds.
        keys - the keys.
        Returns:
        KeyValue<K, ScoredValue<V>> multi-bulk containing the name of the key, the score and the popped member.
        Since:
        6.1.3
      • zadd

        Mono<Long> zadd​(K key,
                        double score,
                        V member)
        Add one or more members to a sorted set, or update its score if it already exists.
        Parameters:
        key - the key.
        score - the score.
        member - the member.
        Returns:
        Long integer-reply specifically: The number of elements added to the sorted sets, not including elements already existing for which the score was updated.
      • zadd

        Mono<Long> zadd​(K key,
                        Object... scoresAndValues)
        Add one or more members to a sorted set, or update its score if it already exists.
        Parameters:
        key - the key.
        scoresAndValues - the scoresAndValue tuples (score,value,score,value,...).
        Returns:
        Long integer-reply specifically: The number of elements added to the sorted sets, not including elements already existing for which the score was updated.
      • zadd

        Mono<Long> zadd​(K key,
                        ScoredValue<V>... scoredValues)
        Add one or more members to a sorted set, or update its score if it already exists.
        Parameters:
        key - the key.
        scoredValues - the scored values.
        Returns:
        Long integer-reply specifically: The number of elements added to the sorted sets, not including elements already existing for which the score was updated.
      • zadd

        Mono<Long> zadd​(K key,
                        ZAddArgs zAddArgs,
                        double score,
                        V member)
        Add one or more members to a sorted set, or update its score if it already exists.
        Parameters:
        key - the key.
        zAddArgs - arguments for zadd.
        score - the score.
        member - the member.
        Returns:
        Long integer-reply specifically: The number of elements added to the sorted sets, not including elements already existing for which the score was updated.
      • zadd

        Mono<Long> zadd​(K key,
                        ZAddArgs zAddArgs,
                        Object... scoresAndValues)
        Add one or more members to a sorted set, or update its score if it already exists.
        Parameters:
        key - the key.
        zAddArgs - arguments for zadd.
        scoresAndValues - the scoresAndValue tuples (score,value,score,value,...).
        Returns:
        Long integer-reply specifically: The number of elements added to the sorted sets, not including elements already existing for which the score was updated.
      • zadd

        Mono<Long> zadd​(K key,
                        ZAddArgs zAddArgs,
                        ScoredValue<V>... scoredValues)
        Add one or more members to a sorted set, or update its score if it already exists.
        Parameters:
        key - the ke.
        zAddArgs - arguments for zadd.
        scoredValues - the scored values.
        Returns:
        Long integer-reply specifically: The number of elements added to the sorted sets, not including elements already existing for which the score was updated.
      • zaddincr

        Mono<Double> zaddincr​(K key,
                              double score,
                              V member)
        Add one or more members to a sorted set, or update its score if it already exists applying the INCR option. ZADD acts like ZINCRBY.
        Parameters:
        key - the key.
        score - the score.
        member - the member.
        Returns:
        Long integer-reply specifically: The total number of elements changed.
      • zaddincr

        Mono<Double> zaddincr​(K key,
                              ZAddArgs zAddArgs,
                              double score,
                              V member)
        Add one or more members to a sorted set, or update its score if it already exists applying the INCR option. ZADD acts like ZINCRBY.
        Parameters:
        key - the key.
        zAddArgs - arguments for zadd.
        score - the score.
        member - the member.
        Returns:
        Long integer-reply specifically: The total number of elements changed.
        Since:
        4.3
      • zcard

        Mono<Long> zcard​(K key)
        Get the number of members in a sorted set.
        Parameters:
        key - the key.
        Returns:
        Long integer-reply the cardinality (number of elements) of the sorted set, or false if key does not exist.
      • zcount

        @Deprecated
        Mono<Long> zcount​(K key,
                          double min,
                          double max)
        Count the members in a sorted set with scores within the given values.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        Long integer-reply the number of elements in the specified score range.
      • zcount

        @Deprecated
        Mono<Long> zcount​(K key,
                          String min,
                          String max)
        Count the members in a sorted set with scores within the given values.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        Long integer-reply the number of elements in the specified score range.
      • zcount

        Mono<Long> zcount​(K key,
                          Range<? extends Number> range)
        Count the members in a sorted set with scores within the given Range.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        Long integer-reply the number of elements in the specified score range.
        Since:
        4.3
      • zdiff

        Flux<V> zdiff​(K... keys)
        Computes the difference between the first and all successive input sorted sets.
        Parameters:
        keys - the keys.
        Returns:
        V array-reply list of elements.
        Since:
        6.1
      • zdiffstore

        Mono<Long> zdiffstore​(K destKey,
                              K... srcKeys)
        Computes the difference between the first and all successive input sorted sets and stores the result in destination.
        Parameters:
        destKey - the dest key.
        srcKeys - the src keys.
        Returns:
        Long the number of elements in the resulting sorted set at destination.
        Since:
        6.1
      • zdiffWithScores

        Flux<ScoredValue<V>> zdiffWithScores​(K... keys)
        Computes the difference between the first and all successive input sorted sets.
        Parameters:
        keys - the keys.
        Returns:
        V array-reply list of scored values.
        Since:
        6.1
      • zincrby

        Mono<Double> zincrby​(K key,
                             double amount,
                             V member)
        Increment the score of a member in a sorted set.
        Parameters:
        key - the key.
        amount - the increment type: long.
        member - the member type: value.
        Returns:
        Double bulk-string-reply the new score of member (a double precision floating point number), represented as string.
      • zinter

        Flux<V> zinter​(K... keys)
        Intersect multiple sorted sets and returns the resulting sorted.
        Parameters:
        keys - the keys.
        Returns:
        V array-reply list of elements.
        Since:
        6.1
      • zinter

        Flux<V> zinter​(ZAggregateArgs aggregateArgs,
                       K... keys)
        Intersect multiple sorted sets and returns the resulting sorted.
        Parameters:
        aggregateArgs - arguments to define aggregation and weights.
        keys - the keys.
        Returns:
        V array-reply list of elements.
        Since:
        6.1
      • zintercard

        Mono<Long> zintercard​(K... keys)
        This command is similar to zinter(java.lang.Object[]), but instead of returning the result set, it returns just the cardinality of the result.
        Parameters:
        keys - the keys.
        Returns:
        Long Integer reply the number of elements in the resulting intersection.
        Since:
        6.2
      • zintercard

        Mono<Long> zintercard​(long limit,
                              K... keys)
        This command is similar to zinter(java.lang.Object[]), but instead of returning the result set, it returns just the cardinality of the result.
        Parameters:
        limit - If the intersection cardinality reaches limit partway through the computation, the algorithm will exit and yield limit as the cardinality
        keys - the keys.
        Returns:
        Long Integer reply the number of elements in the resulting intersection.
        Since:
        6.2
      • zinterWithScores

        Flux<ScoredValue<V>> zinterWithScores​(ZAggregateArgs aggregateArgs,
                                              K... keys)
        Intersect multiple sorted sets and returns the resulting sorted.
        Parameters:
        aggregateArgs - arguments to define aggregation and weights.
        keys - the keys.
        Returns:
        V array-reply list of scored values.
        Since:
        6.1
      • zinterWithScores

        Flux<ScoredValue<V>> zinterWithScores​(K... keys)
        Intersect multiple sorted sets and returns the resulting sorted.
        Parameters:
        keys - the keys.
        Returns:
        V array-reply list of scored values.
        Since:
        6.1
      • zinterstore

        Mono<Long> zinterstore​(K destination,
                               K... keys)
        Intersect multiple sorted sets and store the resulting sorted set in a new key.
        Parameters:
        destination - the destination.
        keys - the keys.
        Returns:
        Long integer-reply the number of elements in the resulting sorted set at destination.
      • zinterstore

        Mono<Long> zinterstore​(K destination,
                               ZStoreArgs storeArgs,
                               K... keys)
        Intersect multiple sorted sets and store the resulting sorted set in a new key.
        Parameters:
        destination - the destination.
        storeArgs - arguments to define aggregation and weights.
        keys - the keys.
        Returns:
        Long integer-reply the number of elements in the resulting sorted set at destination.
      • zlexcount

        @Deprecated
        Mono<Long> zlexcount​(K key,
                             String min,
                             String max)
        Count the number of members in a sorted set between a given lexicographical range.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        Long integer-reply the number of elements in the specified score range.
      • zlexcount

        Mono<Long> zlexcount​(K key,
                             Range<? extends V> range)
        Count the number of members in a sorted set between a given lexicographical range.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        Long integer-reply the number of elements in the specified score range.
        Since:
        4.3
      • zmscore

        Mono<List<Double>> zmscore​(K key,
                                   V... members)
        Returns the scores associated with the specified members in the sorted set stored at key.
        Parameters:
        key - the key.
        members - the member type: value.
        Returns:
        Double array-reply list of scores or nil associated with the specified member values.
        Since:
        6.1
      • zmpop

        Mono<KeyValue<K,​ScoredValue<V>>> zmpop​(ZPopArgs args,
                                                     K... keys)
        Pops one or more elements, that are member-score pairs, from the first non-empty sorted set in the provided list of keys.
        Parameters:
        keys - the keys.
        Returns:
        ScoredValue<V> the removed element or Value.empty().
        Since:
        6.3
      • zmpop

        Mono<KeyValue<K,​List<ScoredValue<V>>>> zmpop​(int count,
                                                           ZPopArgs args,
                                                           K... keys)
        Pops one or more elements, that are member-score pairs, from the first non-empty sorted set in the provided list of keys.
        Parameters:
        count - number of elements to pop.
        args - the command args.
        keys - the keys.
        Returns:
        ScoredValue<V> the removed elements or Value.empty().
        Since:
        6.3
      • zpopmin

        Mono<ScoredValue<V>> zpopmin​(K key)
        Removes and returns up to count members with the lowest scores in the sorted set stored at key.
        Parameters:
        key - the key.
        Returns:
        ScoredValue<V> the removed element.
        Since:
        5.1
      • zpopmin

        Flux<ScoredValue<V>> zpopmin​(K key,
                                     long count)
        Removes and returns up to count members with the lowest scores in the sorted set stored at key.
        Parameters:
        key - the key.
        count - the number of elements to return.
        Returns:
        ScoredValue<V> array-reply list of popped scores and elements.
        Since:
        5.1
      • zpopmax

        Mono<ScoredValue<V>> zpopmax​(K key)
        Removes and returns up to count members with the highest scores in the sorted set stored at key.
        Parameters:
        key - the key.
        Returns:
        ScoredValue<V> the removed element.
        Since:
        5.1
      • zpopmax

        Flux<ScoredValue<V>> zpopmax​(K key,
                                     long count)
        Removes and returns up to count members with the highest scores in the sorted set stored at key.
        Parameters:
        key - the key.
        count - the number of elements to return.
        Returns:
        ScoredValue<V> array-reply list of popped scores and elements.
        Since:
        5.1
      • zrandmember

        Mono<V> zrandmember​(K key)
        Return a random member from the sorted set stored at key.
        Parameters:
        key - the key.
        Returns:
        element.
        Since:
        6.1
      • zrandmember

        Flux<V> zrandmember​(K key,
                            long count)
        Return count random members from the sorted set stored at key.
        Parameters:
        key - the key.
        count - the number of members to return. If the provided count argument is positive, return an array of distinct fields.
        Returns:
        ScoredValue<V> array-reply list of scores and elements.
        Since:
        6.1
      • zrandmemberWithScores

        Mono<ScoredValue<V>> zrandmemberWithScores​(K key)
        Return a random member along its value from the sorted set stored at key.
        Parameters:
        key - the key.
        Returns:
        the score and element.
        Since:
        6.1
      • zrandmemberWithScores

        Flux<ScoredValue<V>> zrandmemberWithScores​(K key,
                                                   long count)
        Return count random members along their value from the sorted set stored at key.
        Parameters:
        key - the key.
        count - the number of members to return. If the provided count argument is positive, return an array of distinct fields.
        Returns:
        ScoredValue<V> array-reply list of scores and elements.
        Since:
        6.1
      • zrange

        Flux<V> zrange​(K key,
                       long start,
                       long stop)
        Return a range of members in a sorted set, by index.
        Parameters:
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        V array-reply list of elements in the specified range.
      • zrange

        @Deprecated
        Mono<Long> zrange​(ValueStreamingChannel<V> channel,
                          K key,
                          long start,
                          long stop)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrange(K, long, long).
        Return a range of members in a sorted set, by index.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        Long count of elements in the specified range.
      • zrangeWithScores

        Flux<ScoredValue<V>> zrangeWithScores​(K key,
                                              long start,
                                              long stop)
        Return a range of members with scores in a sorted set, by index.
        Parameters:
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        V array-reply list of elements in the specified range.
      • zrangeWithScores

        @Deprecated
        Mono<Long> zrangeWithScores​(ScoredValueStreamingChannel<V> channel,
                                    K key,
                                    long start,
                                    long stop)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrangeWithScores(K, long, long).
        Stream over a range of members with scores in a sorted set, by index.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        Long count of elements in the specified range.
      • zrangebylex

        @Deprecated
        Flux<V> zrangebylex​(K key,
                            String min,
                            String max)
        Return a range of members in a sorted set, by lexicographical range.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        V array-reply list of elements in the specified range.
      • zrangebylex

        Flux<V> zrangebylex​(K key,
                            Range<? extends V> range)
        Return a range of members in a sorted set, by lexicographical range.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        V array-reply list of elements in the specified range.
        Since:
        4.3
      • zrangebylex

        @Deprecated
        Flux<V> zrangebylex​(K key,
                            String min,
                            String max,
                            long offset,
                            long count)
        Return a range of members in a sorted set, by lexicographical range.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        offset - the offset.
        count - the count.
        Returns:
        V array-reply list of elements in the specified range.
      • zrangebylex

        Flux<V> zrangebylex​(K key,
                            Range<? extends V> range,
                            Limit limit)
        Return a range of members in a sorted set, by lexicographical range.
        Parameters:
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        V array-reply list of elements in the specified range.
        Since:
        4.3
      • zrangebyscore

        @Deprecated
        Flux<V> zrangebyscore​(K key,
                              double min,
                              double max)
        Return a range of members in a sorted set, by score.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrangebyscore

        Flux<V> zrangebyscore​(K key,
                              Range<? extends Number> range)
        Return a range of members in a sorted set, by score.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        V array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrangebyscore

        @Deprecated
        Flux<V> zrangebyscore​(K key,
                              double min,
                              double max,
                              long offset,
                              long count)
        Return a range of members in a sorted set, by score.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        offset - the offset.
        count - the count.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrangebyscore

        @Deprecated
        Flux<V> zrangebyscore​(K key,
                              String min,
                              String max,
                              long offset,
                              long count)
        Return a range of members in a sorted set, by score.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        offset - the offset.
        count - the count.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrangebyscore

        Flux<V> zrangebyscore​(K key,
                              Range<? extends Number> range,
                              Limit limit)
        Return a range of members in a sorted set, by score.
        Parameters:
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        V array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrangebyscore

        @Deprecated
        Mono<Long> zrangebyscore​(ValueStreamingChannel<V> channel,
                                 K key,
                                 Range<? extends Number> range)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrangebyscore(K, double, double).
        Stream over a range of members in a sorted set, by score.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        range - the range.
        Returns:
        Long count of elements in the specified score range.
        Since:
        4.3
      • zrangebyscore

        @Deprecated
        Mono<Long> zrangebyscore​(ValueStreamingChannel<V> channel,
                                 K key,
                                 Range<? extends Number> range,
                                 Limit limit)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrangebyscore(K, double, double).
        Stream over a range of members in a sorted set, by score.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        Long count of elements in the specified score range.
        Since:
        4.3
      • zrangebyscoreWithScores

        @Deprecated
        Flux<ScoredValue<V>> zrangebyscoreWithScores​(K key,
                                                     double min,
                                                     double max)
        Return a range of members with score in a sorted set, by score.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        ScoredValue<V> array-reply list of elements in the specified score range.
      • zrangebyscoreWithScores

        Flux<ScoredValue<V>> zrangebyscoreWithScores​(K key,
                                                     Range<? extends Number> range)
        Return a range of members with score in a sorted set, by score.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        ScoredValue<V> array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrangebyscoreWithScores

        @Deprecated
        Flux<ScoredValue<V>> zrangebyscoreWithScores​(K key,
                                                     double min,
                                                     double max,
                                                     long offset,
                                                     long count)
        Return a range of members with score in a sorted set, by score.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        offset - the offset.
        count - the count.
        Returns:
        ScoredValue<V> array-reply list of elements in the specified score range.
      • zrangebyscoreWithScores

        Flux<ScoredValue<V>> zrangebyscoreWithScores​(K key,
                                                     Range<? extends Number> range,
                                                     Limit limit)
        Return a range of members with score in a sorted set, by score.
        Parameters:
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        ScoredValue<V> array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrangebyscoreWithScores

        @Deprecated
        Mono<Long> zrangebyscoreWithScores​(ScoredValueStreamingChannel<V> channel,
                                           K key,
                                           Range<? extends Number> range)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrangebyscoreWithScores(K, double, double).
        Stream over a range of members with scores in a sorted set, by score.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        range - the range.
        Returns:
        Long count of elements in the specified score range.
        Since:
        4.3
      • zrangebyscoreWithScores

        @Deprecated
        Mono<Long> zrangebyscoreWithScores​(ScoredValueStreamingChannel<V> channel,
                                           K key,
                                           Range<? extends Number> range,
                                           Limit limit)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrangebyscoreWithScores(K, double, double).
        Stream over a range of members with scores in a sorted set, by score.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        Long count of elements in the specified score range.
        Since:
        4.3
      • zrangestore

        Mono<Long> zrangestore​(K dstKey,
                               K srcKey,
                               Range<Long> range)
        Get the specified range of elements in the sorted set stored at srcKey and stores the result in the dstKey destination key.
        Parameters:
        dstKey - the dst key.
        srcKey - the src key.
        range - the rank.
        Returns:
        the number of elements in the resulting sorted set.
        Since:
        6.2.1
      • zrangestorebylex

        Mono<Long> zrangestorebylex​(K dstKey,
                                    K srcKey,
                                    Range<? extends V> range,
                                    Limit limit)
        Get the specified range of elements in the sorted set stored at srcKey and stores the result in the dstKey destination key.
        Parameters:
        dstKey - the dst key.
        srcKey - the src key.
        range - the lexicographical range.
        limit - the limit to apply.
        Returns:
        the number of elements in the resulting sorted set.
        Since:
        6.1
      • zrangestorebyscore

        Mono<Long> zrangestorebyscore​(K dstKey,
                                      K srcKey,
                                      Range<? extends Number> range,
                                      Limit limit)
        Get the specified range of elements in the sorted set stored at srcKey and stores the result in the dstKey destination key.
        Parameters:
        dstKey - the dst key.
        srcKey - the src key.
        range - the score range.
        limit - the limit to apply.
        Returns:
        the number of elements in the resulting sorted set.
        Since:
        6.1
      • zrank

        Mono<Long> zrank​(K key,
                         V member)
        Determine the index of a member in a sorted set.
        Parameters:
        key - the key.
        member - the member type: value.
        Returns:
        Long integer-reply the rank of member. If member does not exist in the sorted set or key does not exist,.
      • zrankWithScore

        Mono<ScoredValue<Long>> zrankWithScore​(K key,
                                               V member)
        Returns the rank of member in the sorted set stored at key, with the scores ordered from low to high.
        Parameters:
        key - the key.
        member - the member type: value.
        Returns:
        the rank and score
        Since:
        6.3
      • zrem

        Mono<Long> zrem​(K key,
                        V... members)
        Remove one or more members from a sorted set.
        Parameters:
        key - the key.
        members - the member type: value.
        Returns:
        Long integer-reply specifically: The number of members removed from the sorted set, not including non existing members.
      • zremrangebylex

        Mono<Long> zremrangebylex​(K key,
                                  Range<? extends V> range)
        Remove all members in a sorted set between the given lexicographical range.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        Long integer-reply the number of elements removed.
        Since:
        4.3
      • zremrangebyrank

        Mono<Long> zremrangebyrank​(K key,
                                   long start,
                                   long stop)
        Remove all members in a sorted set within the given indexes.
        Parameters:
        key - the key.
        start - the start type: long.
        stop - the stop type: long.
        Returns:
        Long integer-reply the number of elements removed.
      • zremrangebyscore

        @Deprecated
        Mono<Long> zremrangebyscore​(K key,
                                    double min,
                                    double max)
        Remove all members in a sorted set within the given scores.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        Long integer-reply the number of elements removed.
      • zremrangebyscore

        Mono<Long> zremrangebyscore​(K key,
                                    Range<? extends Number> range)
        Remove all members in a sorted set within the given scores.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        Long integer-reply the number of elements removed.
        Since:
        4.3
      • zrevrange

        Flux<V> zrevrange​(K key,
                          long start,
                          long stop)
        Return a range of members in a sorted set, by index, with scores ordered from high to low.
        Parameters:
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        V array-reply list of elements in the specified range.
      • zrevrange

        @Deprecated
        Mono<Long> zrevrange​(ValueStreamingChannel<V> channel,
                             K key,
                             long start,
                             long stop)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrevrange(K, long, long).
        Stream over a range of members in a sorted set, by index, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        Long count of elements in the specified range.
      • zrevrangeWithScores

        Flux<ScoredValue<V>> zrevrangeWithScores​(K key,
                                                 long start,
                                                 long stop)
        Return a range of members with scores in a sorted set, by index, with scores ordered from high to low.
        Parameters:
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        V array-reply list of elements in the specified range.
      • zrevrangeWithScores

        @Deprecated
        Mono<Long> zrevrangeWithScores​(ScoredValueStreamingChannel<V> channel,
                                       K key,
                                       long start,
                                       long stop)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrevrangeWithScores(K, long, long).
        Stream over a range of members with scores in a sorted set, by index, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        start - the start.
        stop - the stop.
        Returns:
        Long count of elements in the specified range.
      • zrevrangebylex

        Flux<V> zrevrangebylex​(K key,
                               Range<? extends V> range)
        Return a range of members in a sorted set, by lexicographical range ordered from high to low.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        V array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrevrangebylex

        Flux<V> zrevrangebylex​(K key,
                               Range<? extends V> range,
                               Limit limit)
        Return a range of members in a sorted set, by lexicographical range ordered from high to low.
        Parameters:
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        V array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrevrangebyscore

        @Deprecated
        Flux<V> zrevrangebyscore​(K key,
                                 double max,
                                 double min)
        Return a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrevrangebyscore

        @Deprecated
        Flux<V> zrevrangebyscore​(K key,
                                 String max,
                                 String min)
        Return a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        min - min score.
        max - max score.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrevrangebyscore

        Flux<V> zrevrangebyscore​(K key,
                                 Range<? extends Number> range)
        Return a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        V array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrevrangebyscore

        @Deprecated
        Flux<V> zrevrangebyscore​(K key,
                                 double max,
                                 double min,
                                 long offset,
                                 long count)
        Return a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        max - max score.
        min - min score.
        offset - the withscores.
        count - the number of items.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrevrangebyscore

        @Deprecated
        Flux<V> zrevrangebyscore​(K key,
                                 String max,
                                 String min,
                                 long offset,
                                 long count)
        Return a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        max - max score.
        min - min score.
        offset - the offset.
        count - the count.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrevrangebyscore

        Flux<V> zrevrangebyscore​(K key,
                                 Range<? extends Number> range,
                                 Limit limit)
        Return a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        V array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrevrangebyscore

        @Deprecated
        Mono<Long> zrevrangebyscore​(ValueStreamingChannel<V> channel,
                                    K key,
                                    double max,
                                    double min)
        Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        max - max score.
        min - min score.
        Returns:
        Long count of elements in the specified range.
      • zrevrangebyscore

        @Deprecated
        Mono<Long> zrevrangebyscore​(ValueStreamingChannel<V> channel,
                                    K key,
                                    Range<? extends Number> range)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrevrangebyscore(K, double, double).
        Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        range - the range.
        Returns:
        Long count of elements in the specified range.
        Since:
        4.3
      • zrevrangebyscore

        @Deprecated
        Mono<Long> zrevrangebyscore​(ValueStreamingChannel<V> channel,
                                    K key,
                                    double max,
                                    double min,
                                    long offset,
                                    long count)
        Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        min - min score.
        max - max score.
        offset - the offset.
        count - the count.
        Returns:
        Long count of elements in the specified range.
      • zrevrangebyscore

        @Deprecated
        Mono<Long> zrevrangebyscore​(ValueStreamingChannel<V> channel,
                                    K key,
                                    Range<? extends Number> range,
                                    Limit limit)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrevrangebyscore(K, double, double).
        Stream over a range of members in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        Long count of elements in the specified range.
        Since:
        4.3
      • zrevrangebyscoreWithScores

        @Deprecated
        Flux<ScoredValue<V>> zrevrangebyscoreWithScores​(K key,
                                                        double max,
                                                        double min)
        Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        max - max score.
        min - min score.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrevrangebyscoreWithScores

        Flux<ScoredValue<V>> zrevrangebyscoreWithScores​(K key,
                                                        Range<? extends Number> range)
        Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        range - the range.
        Returns:
        ScoredValue<V> array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrevrangebyscoreWithScores

        @Deprecated
        Flux<ScoredValue<V>> zrevrangebyscoreWithScores​(K key,
                                                        double max,
                                                        double min,
                                                        long offset,
                                                        long count)
        Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        max - max score.
        min - min score.
        offset - the offset.
        count - the count.
        Returns:
        ScoredValue<V> array-reply list of elements in the specified score range.
      • zrevrangebyscoreWithScores

        @Deprecated
        Flux<ScoredValue<V>> zrevrangebyscoreWithScores​(K key,
                                                        String max,
                                                        String min,
                                                        long offset,
                                                        long count)
        Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        max - max score.
        min - min score.
        offset - the offset.
        count - the count.
        Returns:
        V array-reply list of elements in the specified score range.
      • zrevrangebyscoreWithScores

        Flux<ScoredValue<V>> zrevrangebyscoreWithScores​(K key,
                                                        Range<? extends Number> range,
                                                        Limit limit)
        Return a range of members with scores in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        key - the key.
        range - the range.
        limit - limit.
        Returns:
        V array-reply list of elements in the specified score range.
        Since:
        4.3
      • zrevrangebyscoreWithScores

        @Deprecated
        Mono<Long> zrevrangebyscoreWithScores​(ScoredValueStreamingChannel<V> channel,
                                              K key,
                                              Range<? extends Number> range)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrevrangebyscoreWithScores(K, double, double).
        Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        range - the range.
        Returns:
        Long count of elements in the specified range.
      • zrevrangebyscoreWithScores

        @Deprecated
        Mono<Long> zrevrangebyscoreWithScores​(ScoredValueStreamingChannel<V> channel,
                                              K key,
                                              Range<? extends Number> range,
                                              Limit limit)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zrevrangebyscoreWithScores(K, double, double).
        Stream over a range of members with scores in a sorted set, by score, with scores ordered from high to low.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        range - the range.
        limit - the limit.
        Returns:
        Long count of elements in the specified range.
        Since:
        4.3
      • zrevrangestore

        Mono<Long> zrevrangestore​(K dstKey,
                                  K srcKey,
                                  Range<Long> range)
        Get the specified range of elements ordered from high to low in the sorted set stored at srcKey and stores the result in the dstKey destination key.
        Parameters:
        dstKey - the dst key.
        srcKey - the src key.
        range - the rank.
        Returns:
        the number of elements in the resulting sorted set.
        Since:
        6.2.1
      • zrevrangestorebylex

        Mono<Long> zrevrangestorebylex​(K dstKey,
                                       K srcKey,
                                       Range<? extends V> range,
                                       Limit limit)
        Get the lexicographical range ordered from high to low of elements in the sorted set stored at srcKey and stores the result in the dstKey destination key.
        Parameters:
        dstKey - the src key.
        srcKey - the dst key.
        range - the lexicographical range.
        limit - the limit to apply.
        Returns:
        the number of elements in the resulting sorted set.
        Since:
        6.1
      • zrevrangestorebyscore

        Mono<Long> zrevrangestorebyscore​(K dstKey,
                                         K srcKey,
                                         Range<? extends Number> range,
                                         Limit limit)
        Get the specified range of elements in the sorted set stored at {@code srcKey with scores ordered from high to low and stores the result in the {@code dstKey} destination key.
        Parameters:
        dstKey - the src key.
        srcKey - the dst key.
        range - the score range.
        limit - the limit to apply.
        Returns:
        the number of elements in the resulting sorted set.
        Since:
        6.1
      • zrevrank

        Mono<Long> zrevrank​(K key,
                            V member)
        Determine the index of a member in a sorted set, with scores ordered from high to low.
        Parameters:
        key - the key.
        member - the member type: value.
        Returns:
        Long integer-reply the rank of member. If member does not exist in the sorted set or key does not exist return null.
      • zrevrankWithScore

        Mono<ScoredValue<Long>> zrevrankWithScore​(K key,
                                                  V member)
        Returns the rank of member in the sorted set stored at key, with the scores ordered from high to low.
        Parameters:
        key - the key.
        member - the member type: value.
        Returns:
        the rank and score
        Since:
        6.3
      • zscan

        Mono<ScoredValueScanCursor<V>> zscan​(K key)
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        key - the key.
        Returns:
        ScoredValueScanCursor<V> scan cursor.
      • zscan

        Mono<ScoredValueScanCursor<V>> zscan​(K key,
                                             ScanArgs scanArgs)
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        key - the key.
        scanArgs - scan arguments.
        Returns:
        ScoredValueScanCursor<V> scan cursor.
      • zscan

        Mono<ScoredValueScanCursor<V>> zscan​(K key,
                                             ScanCursor scanCursor,
                                             ScanArgs scanArgs)
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        scanArgs - scan arguments.
        Returns:
        ScoredValueScanCursor<V> scan cursor.
      • zscan

        Mono<ScoredValueScanCursor<V>> zscan​(K key,
                                             ScanCursor scanCursor)
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        Returns:
        ScoredValueScanCursor<V> scan cursor.
      • zscan

        @Deprecated
        Mono<StreamScanCursor> zscan​(ScoredValueStreamingChannel<V> channel,
                                     K key)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zscan(K).
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        Returns:
        StreamScanCursor scan cursor.
      • zscan

        @Deprecated
        Mono<StreamScanCursor> zscan​(ScoredValueStreamingChannel<V> channel,
                                     K key,
                                     ScanArgs scanArgs)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zscan(K).
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        scanArgs - scan arguments.
        Returns:
        StreamScanCursor scan cursor.
      • zscan

        @Deprecated
        Mono<StreamScanCursor> zscan​(ScoredValueStreamingChannel<V> channel,
                                     K key,
                                     ScanCursor scanCursor,
                                     ScanArgs scanArgs)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zscan(K).
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        scanArgs - scan arguments.
        Returns:
        StreamScanCursor scan cursor.
      • zscan

        @Deprecated
        Mono<StreamScanCursor> zscan​(ScoredValueStreamingChannel<V> channel,
                                     K key,
                                     ScanCursor scanCursor)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by zscan(K).
        Incrementally iterate sorted sets elements and associated scores.
        Parameters:
        channel - streaming channel that receives a call for every scored value.
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        Returns:
        StreamScanCursor scan cursor.
      • zscore

        Mono<Double> zscore​(K key,
                            V member)
        Get the score associated with the given member in a sorted set.
        Parameters:
        key - the key.
        member - the member type: value.
        Returns:
        Double bulk-string-reply the score of member (a double precision floating point number), represented as string.
      • zunion

        Flux<V> zunion​(K... keys)
        Add multiple sorted sets and returns the resulting sorted set.
        Parameters:
        keys - the keys.
        Returns:
        V array-reply list of elements.
        Since:
        6.1
      • zunion

        Flux<V> zunion​(ZAggregateArgs aggregateArgs,
                       K... keys)
        Add multiple sorted sets and returns the resulting sorted set.
        Parameters:
        aggregateArgs - arguments to define aggregation and weights.
        keys - the keys.
        Returns:
        V array-reply list of elements.
        Since:
        6.1
      • zunionWithScores

        Flux<ScoredValue<V>> zunionWithScores​(ZAggregateArgs aggregateArgs,
                                              K... keys)
        Add multiple sorted sets and returns the resulting sorted set.
        Parameters:
        aggregateArgs - arguments to define aggregation and weights.
        keys - the keys.
        Returns:
        V array-reply list of scored values.
        Since:
        6.1
      • zunionWithScores

        Flux<ScoredValue<V>> zunionWithScores​(K... keys)
        Add multiple sorted sets and returns the resulting sorted set.
        Parameters:
        keys - the keys.
        Returns:
        V array-reply list of scored values.
        Since:
        6.1
      • zunionstore

        Mono<Long> zunionstore​(K destination,
                               K... keys)
        Add multiple sorted sets and store the resulting sorted set in a new key.
        Parameters:
        destination - destination key.
        keys - source keys.
        Returns:
        Long integer-reply the number of elements in the resulting sorted set at destination.
      • zunionstore

        Mono<Long> zunionstore​(K destination,
                               ZStoreArgs storeArgs,
                               K... keys)
        Add multiple sorted sets and store the resulting sorted set in a new key.
        Parameters:
        destination - the destination.
        storeArgs - arguments to define aggregation and weights.
        keys - the keys.
        Returns:
        Long integer-reply the number of elements in the resulting sorted set at destination.