diff --git a/src/main/java/org/springframework/data/redis/connection/HyperLogLogCommands.java b/src/main/java/org/springframework/data/redis/connection/HyperLogLogCommands.java
index 63cb2de6e..7869202f1 100644
--- a/src/main/java/org/springframework/data/redis/connection/HyperLogLogCommands.java
+++ b/src/main/java/org/springframework/data/redis/connection/HyperLogLogCommands.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2014 the original author or authors.
+ * Copyright 2014-2017 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -19,6 +19,7 @@ package org.springframework.data.redis.connection;
* {@literal HyperLogLog} specific commands supported by Redis.
*
* @author Christoph Strobl
+ * @author Mark Paluch
* @since 1.5
*/
public interface HyperLogLogCommands {
@@ -26,25 +27,28 @@ public interface HyperLogLogCommands {
/**
* Adds given {@literal values} to the HyperLogLog stored at given {@literal key}.
*
- * @param key
- * @param values
+ * @param key must not be {@literal null}.
+ * @param values must not be {@literal null}.
* @return
+ * @see Redis Documentation: PFADD
*/
Long pfAdd(byte[] key, byte[]... values);
/**
* Return the approximated cardinality of the structures observed by the HyperLogLog at {@literal key(s)}.
*
- * @param keys
+ * @param keys must not be {@literal null}.
* @return
+ * @see Redis Documentation: PFCOUNT
*/
Long pfCount(byte[]... keys);
/**
* Merge N different HyperLogLogs at {@literal sourceKeys} into a single {@literal destinationKey}.
*
- * @param destinationKey
- * @param sourceKeys
+ * @param destinationKey must not be {@literal null}.
+ * @param sourceKeys must not be {@literal null}.
+ * @see Redis Documentation: PFMERGE
*/
void pfMerge(byte[] destinationKey, byte[]... sourceKeys);
diff --git a/src/main/java/org/springframework/data/redis/connection/ReactiveGeoCommands.java b/src/main/java/org/springframework/data/redis/connection/ReactiveGeoCommands.java
index c58e95c40..0f4018932 100644
--- a/src/main/java/org/springframework/data/redis/connection/ReactiveGeoCommands.java
+++ b/src/main/java/org/springframework/data/redis/connection/ReactiveGeoCommands.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2016 the original author or authors.
+ * Copyright 2016-2017 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -15,6 +15,9 @@
*/
package org.springframework.data.redis.connection;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.Collection;
@@ -42,9 +45,6 @@ import org.springframework.data.redis.connection.RedisGeoCommands.GeoRadiusComma
import org.springframework.data.redis.connection.RedisGeoCommands.GeoRadiusCommandArgs.Flag;
import org.springframework.util.Assert;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
-
/**
* Redis Geo commands executed using reactive infrastructure.
*
@@ -58,6 +58,7 @@ public interface ReactiveGeoCommands {
* {@code GEOADD} command parameters.
*
* @author Christoph Strobl
+ * @see Redis Documentation: GEOADD
*/
class GeoAddCommand extends KeyCommand {
@@ -121,6 +122,7 @@ public interface ReactiveGeoCommands {
* @param point must not be {@literal null}.
* @param member must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOADD
*/
default Mono geoAdd(ByteBuffer key, Point point, ByteBuffer member) {
@@ -137,6 +139,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param location must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOADD
*/
default Mono geoAdd(ByteBuffer key, GeoLocation location) {
@@ -152,6 +155,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param locations must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOADD
*/
default Mono geoAdd(ByteBuffer key, Collection> locations) {
@@ -166,6 +170,7 @@ public interface ReactiveGeoCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOADD
*/
Flux> geoAdd(Publisher commands);
@@ -173,6 +178,7 @@ public interface ReactiveGeoCommands {
* {@code GEODIST} command parameters.
*
* @author Christoph Strobl
+ * @see Redis Documentation: GEODIST
*/
class GeoDistCommand extends KeyCommand {
@@ -298,6 +304,7 @@ public interface ReactiveGeoCommands {
* @param from must not be {@literal null}.
* @param to must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEODIST
*/
default Mono geoDist(ByteBuffer key, ByteBuffer from, ByteBuffer to) {
return geoDist(key, from, to, null);
@@ -311,6 +318,7 @@ public interface ReactiveGeoCommands {
* @param to must not be {@literal null}.
* @param metric can be {@literal null} and defaults to {@link DistanceUnit#METERS}.
* @return
+ * @see Redis Documentation: GEODIST
*/
default Mono geoDist(ByteBuffer key, ByteBuffer from, ByteBuffer to, Metric metric) {
@@ -328,6 +336,7 @@ public interface ReactiveGeoCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEODIST
*/
Flux> geoDist(Publisher commands);
@@ -335,6 +344,7 @@ public interface ReactiveGeoCommands {
* {@code GEOHASH} command parameters.
*
* @author Christoph Strobl
+ * @see Redis Documentation: GEOHASH
*/
class GeoHashCommand extends KeyCommand {
@@ -400,6 +410,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param member must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOHASH
*/
default Mono geoHash(ByteBuffer key, ByteBuffer member) {
@@ -415,6 +426,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param members must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOHASH
*/
default Mono> geoHash(ByteBuffer key, Collection members) {
@@ -431,6 +443,7 @@ public interface ReactiveGeoCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOHASH
*/
Flux> geoHash(Publisher commands);
@@ -438,6 +451,7 @@ public interface ReactiveGeoCommands {
* {@code GEOPOS} command parameters.
*
* @author Christoph Strobl
+ * @see Redis Documentation: GEOPOS
*/
class GeoPosCommand extends KeyCommand {
@@ -503,6 +517,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param member must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOPOS
*/
default Mono geoPos(ByteBuffer key, ByteBuffer member) {
@@ -517,6 +532,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param members must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOPOS
*/
default Mono> geoPos(ByteBuffer key, Collection members) {
@@ -531,6 +547,7 @@ public interface ReactiveGeoCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEOPOS
*/
Flux> geoPos(Publisher commands);
@@ -538,6 +555,7 @@ public interface ReactiveGeoCommands {
* {@code GEORADIUS} command parameters.
*
* @author Christoph Strobl
+ * @see Redis Documentation: GEORADIUS
*/
class GeoRadiusCommand extends KeyCommand {
@@ -838,6 +856,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param circle must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEORADIUS
*/
default Mono>> geoRadius(ByteBuffer key, Circle circle) {
return geoRadius(key, circle, null)
@@ -851,6 +870,7 @@ public interface ReactiveGeoCommands {
* @param circle must not be {@literal null}.
* @param geoRadiusArgs can be {@literal null}.
* @return
+ * @see Redis Documentation: GEORADIUS
*/
default Mono>> geoRadius(ByteBuffer key, Circle circle,
GeoRadiusCommandArgs geoRadiusArgs) {
@@ -867,6 +887,7 @@ public interface ReactiveGeoCommands {
*
* @param commands
* @return
+ * @see Redis Documentation: GEORADIUS
*/
Flux>>> geoRadius(
Publisher commands);
@@ -875,6 +896,7 @@ public interface ReactiveGeoCommands {
* {@code GEORADIUSBYMEMBER} command parameters.
*
* @author Christoph Strobl
+ * @see Redis Documentation: GEORADIUSBYMEMBER
*/
class GeoRadiusByMemberCommand extends KeyCommand {
@@ -1159,6 +1181,7 @@ public interface ReactiveGeoCommands {
* @param key must not be {@literal null}.
* @param member must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEORADIUSBYMEMBER
*/
default Mono>> geoRadiusByMember(ByteBuffer key, ByteBuffer member, Distance distance) {
return geoRadiusByMember(key, member, distance, null)
@@ -1172,6 +1195,7 @@ public interface ReactiveGeoCommands {
* @param member must not be {@literal null}.
* @param geoRadiusArgs can be {@literal null}.
* @return
+ * @see Redis Documentation: GEORADIUSBYMEMBER
*/
default Mono>> geoRadiusByMember(ByteBuffer key, ByteBuffer member,
Distance distance, GeoRadiusCommandArgs geoRadiusArgs) {
@@ -1190,6 +1214,7 @@ public interface ReactiveGeoCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: GEORADIUSBYMEMBER
*/
Flux>>> geoRadiusByMember(
Publisher commands);
diff --git a/src/main/java/org/springframework/data/redis/connection/ReactiveHashCommands.java b/src/main/java/org/springframework/data/redis/connection/ReactiveHashCommands.java
index 988e6db6d..df64c100b 100644
--- a/src/main/java/org/springframework/data/redis/connection/ReactiveHashCommands.java
+++ b/src/main/java/org/springframework/data/redis/connection/ReactiveHashCommands.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2016 the original author or authors.
+ * Copyright 2016-2017 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -15,6 +15,9 @@
*/
package org.springframework.data.redis.connection;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
import java.nio.ByteBuffer;
import java.util.ArrayList;
import java.util.Collection;
@@ -32,9 +35,6 @@ import org.springframework.data.redis.connection.ReactiveRedisConnection.MultiVa
import org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse;
import org.springframework.util.Assert;
-import reactor.core.publisher.Flux;
-import reactor.core.publisher.Mono;
-
/**
* Redis Hash commands executed using reactive infrastructure.
*
@@ -48,6 +48,7 @@ public interface ReactiveHashCommands {
* {@literal HSET} {@link Command}.
*
* @author Christoph Strobl
+ * @see Redis Documentation: HSET
*/
class HSetCommand extends KeyCommand {
@@ -150,6 +151,7 @@ public interface ReactiveHashCommands {
* @param field must not be {@literal null}.
* @param value must not be {@literal null}.
* @return
+ * @see Redis Documentation: HSET
*/
default Mono hSet(ByteBuffer key, ByteBuffer field, ByteBuffer value) {
@@ -167,6 +169,7 @@ public interface ReactiveHashCommands {
* @param field must not be {@literal null}.
* @param value must not be {@literal null}.
* @return
+ * @see Redis Documentation: HSETNX
*/
default Mono hSetNX(ByteBuffer key, ByteBuffer field, ByteBuffer value) {
@@ -184,6 +187,7 @@ public interface ReactiveHashCommands {
* @param key must not be {@literal null}.
* @param fieldValueMap must not be {@literal null}.
* @return
+ * @see Redis Documentation: HMSET
*/
default Mono hMSet(ByteBuffer key, Map fieldValueMap) {
@@ -199,6 +203,7 @@ public interface ReactiveHashCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: HSET
*/
Flux> hSet(Publisher commands);
@@ -206,6 +211,7 @@ public interface ReactiveHashCommands {
* {@literal HGET} {@link Command}.
*
* @author Christoph Strobl
+ * @see Redis Documentation: HGET
*/
class HGetCommand extends KeyCommand {
@@ -271,6 +277,7 @@ public interface ReactiveHashCommands {
* @param key must not be {@literal null}.
* @param field must not be {@literal null}.
* @return
+ * @see Redis Documentation: HGET
*/
default Mono hGet(ByteBuffer key, ByteBuffer field) {
return hMGet(key, Collections.singletonList(field)).map(val -> val.isEmpty() ? null : val.iterator().next());
@@ -282,6 +289,7 @@ public interface ReactiveHashCommands {
* @param key must not be {@literal null}.
* @param fields must not be {@literal null}.
* @return
+ * @see Redis Documentation: HMGET
*/
default Mono> hMGet(ByteBuffer key, Collection fields) {
@@ -296,6 +304,7 @@ public interface ReactiveHashCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: HMGET
*/
Flux> hMGet(Publisher commands);
@@ -303,6 +312,7 @@ public interface ReactiveHashCommands {
* {@literal HEXISTS} {@link Command}.
*
* @author Christoph Strobl
+ * @see Redis Documentation: HEXISTS
*/
class HExistsCommand extends KeyCommand {
@@ -355,6 +365,7 @@ public interface ReactiveHashCommands {
* @param key must not be {@literal null}.
* @param field must not be {@literal null}.
* @return
+ * @see Redis Documentation: HEXISTS
*/
default Mono hExists(ByteBuffer key, ByteBuffer field) {
@@ -369,11 +380,13 @@ public interface ReactiveHashCommands {
*
* @param commands
* @return
+ * @see Redis Documentation: HEXISTS
*/
Flux> hExists(Publisher commands);
/**
* @author Christoph Strobl
+ * @see Redis Documentation: HDEL
*/
class HDelCommand extends KeyCommand {
@@ -439,6 +452,7 @@ public interface ReactiveHashCommands {
* @param key must not be {@literal null}.
* @param field must not be {@literal null}.
* @return
+ * @see Redis Documentation: HDEL
*/
default Mono hDel(ByteBuffer key, ByteBuffer field) {
@@ -453,6 +467,7 @@ public interface ReactiveHashCommands {
* @param key must not be {@literal null}.
* @param fields must not be {@literal null}.
* @return
+ * @see Redis Documentation: HDEL
*/
default Mono hDel(ByteBuffer key, Collection fields) {
@@ -467,6 +482,7 @@ public interface ReactiveHashCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: HDEL
*/
Flux> hDel(Publisher commands);
@@ -475,6 +491,7 @@ public interface ReactiveHashCommands {
*
* @param key must not be {@literal null}.
* @return
+ * @see Redis Documentation: HLEN
*/
default Mono hLen(ByteBuffer key) {
@@ -488,6 +505,7 @@ public interface ReactiveHashCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: HLEN
*/
Flux> hLen(Publisher commands);
@@ -496,6 +514,7 @@ public interface ReactiveHashCommands {
*
* @param key must not be {@literal null}.
* @return
+ * @see Redis Documentation: HKEYS
*/
default Mono> hKeys(ByteBuffer key) {
@@ -509,6 +528,7 @@ public interface ReactiveHashCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: HKEYS
*/
Flux> hKeys(Publisher commands);
@@ -517,6 +537,7 @@ public interface ReactiveHashCommands {
*
* @param key must not be {@literal null}.
* @return
+ * @see Redis Documentation: HVALS
*/
default Mono> hVals(ByteBuffer key) {
@@ -530,6 +551,7 @@ public interface ReactiveHashCommands {
*
* @param commands must not be {@literal null}.
* @return
+ * @see Redis Documentation: HVALS
*/
Flux> hVals(Publisher commands);
@@ -538,6 +560,7 @@ public interface ReactiveHashCommands {
*
* @param key must not be {@literal null}.
* @return
+ * @see Redis Documentation: HGETALL
*/
default Mono