DATAREDIS-706 - Polishing.

Add author tag. Replace JedisCluster…Commands constructors with RequiredArgsConstructor annotation.

Original pull request: #278.
This commit is contained in:
Mark Paluch
2017-11-16 15:17:44 +01:00
parent 9cf701f90e
commit 58e17d57b4
9 changed files with 41 additions and 47 deletions

View File

@@ -15,6 +15,8 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import redis.clients.jedis.GeoCoordinate;
import redis.clients.jedis.GeoUnit;
import redis.clients.jedis.params.geo.GeoRadiusParam;
@@ -37,13 +39,10 @@ import org.springframework.util.Assert;
* @author Mark Paluch
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterGeoCommands implements RedisGeoCommands {
private final JedisClusterConnection connection;
JedisClusterGeoCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)

View File

@@ -15,6 +15,8 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import redis.clients.jedis.ScanParams;
import java.util.ArrayList;
@@ -38,13 +40,10 @@ import org.springframework.util.Assert;
* @author Mark Paluch
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterHashCommands implements RedisHashCommands {
private final JedisClusterConnection connection;
JedisClusterHashCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)

View File

@@ -15,6 +15,9 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import org.springframework.dao.DataAccessException;
import org.springframework.dao.InvalidDataAccessApiUsageException;
import org.springframework.data.redis.connection.ClusterSlotHashUtil;
@@ -27,13 +30,10 @@ import org.springframework.util.Assert;
* @author Mark Paluch
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterHyperLogLogCommands implements RedisHyperLogLogCommands {
private final JedisClusterConnection connection;
JedisClusterHyperLogLogCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)

View File

@@ -15,6 +15,8 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import redis.clients.jedis.BinaryJedis;
import java.util.ArrayList;
@@ -50,13 +52,10 @@ import org.springframework.util.ObjectUtils;
* @author Mark Paluch
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterKeyCommands implements RedisKeyCommands {
private final JedisClusterConnection connection;
JedisClusterKeyCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)

View File

@@ -19,6 +19,8 @@ import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import org.springframework.dao.DataAccessException;
import org.springframework.data.redis.connection.ClusterSlotHashUtil;
import org.springframework.data.redis.connection.RedisListCommands;
@@ -31,13 +33,10 @@ import org.springframework.util.CollectionUtils;
* @author Mark Paluch
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterListCommands implements RedisListCommands {
private final JedisClusterConnection connection;
JedisClusterListCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)

View File

@@ -15,6 +15,8 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import redis.clients.jedis.BinaryJedis;
import java.util.ArrayList;
@@ -41,13 +43,10 @@ import org.springframework.util.CollectionUtils;
* @author Mark Paluch
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterServerCommands implements RedisClusterServerCommands {
private final JedisClusterConnection connection;
JedisClusterServerCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)

View File

@@ -15,6 +15,8 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import redis.clients.jedis.ScanParams;
import java.util.ArrayList;
@@ -41,13 +43,10 @@ import org.springframework.util.Assert;
* @author Mark Paluch
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterSetCommands implements RedisSetCommands {
private final JedisClusterConnection connection;
JedisClusterSetCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)

View File

@@ -15,6 +15,10 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import redis.clients.jedis.BinaryJedis;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
@@ -35,15 +39,13 @@ import org.springframework.util.ObjectUtils;
/**
* @author Christoph Strobl
* @author Mark Paluch
* @author Xiaohu Zhang
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterStringCommands implements RedisStringCommands {
private final JedisClusterConnection connection;
JedisClusterStringCommands(JedisClusterConnection jedisClusterConnection) {
this.connection = jedisClusterConnection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)
@@ -93,8 +95,7 @@ class JedisClusterStringCommands implements RedisStringCommands {
}
return connection.getClusterCommandExecutor()
.executeMultiKeyCommand((JedisMultiKeyClusterCommandCallback<byte[]>) (client, key) -> client.get(key),
Arrays.asList(keys))
.executeMultiKeyCommand((JedisMultiKeyClusterCommandCallback<byte[]>) BinaryJedis::get, Arrays.asList(keys))
.resultsAsListSortBy(keys);
}

View File

@@ -15,6 +15,8 @@
*/
package org.springframework.data.redis.connection.jedis;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;
import redis.clients.jedis.ScanParams;
import redis.clients.jedis.ZParams;
@@ -37,13 +39,10 @@ import org.springframework.util.Assert;
* @author Clement Ong
* @since 2.0
*/
@RequiredArgsConstructor
class JedisClusterZSetCommands implements RedisZSetCommands {
private final JedisClusterConnection connection;
JedisClusterZSetCommands(JedisClusterConnection connection) {
this.connection = connection;
}
private final @NonNull JedisClusterConnection connection;
/*
* (non-Javadoc)