orestes.bloomfilter.redis.helper

Class RedisPool

java.lang.Object

orestes.bloomfilter.redis.helper.RedisPool

public class RedisPool
extends java.lang.Object

Encapsulates a Connection Pool and offers convenience methods for safe access through Java 8 Lambdas.

Constructor Summary

Constructors

Constructor and Description
RedisPool(java.lang.String host, int port, int redisConnections)
RedisPool(java.lang.String host, int port, int redisConnections, java.util.Set<java.util.Map.Entry<java.lang.String,java.lang.Integer>> readSlaves)

Method Summary

Modifier and Type	Method and Description
RedisPool	allowingSlaves()
void	destroy()
void	safelyDo(java.util.function.Consumer<redis.clients.jedis.Jedis> f)
<T> T	safelyReturn(java.util.function.Function<redis.clients.jedis.Jedis,T> f)
<T> java.util.List<T>	transactionallyDo(java.util.function.Consumer<redis.clients.jedis.Pipeline> f, java.lang.String... watch)
<T> java.util.List<T>	transactionallyRetry(java.util.function.Consumer<redis.clients.jedis.Pipeline> f, java.lang.String... watch)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RedisPool

public RedisPool(java.lang.String host,
                 int port,
                 int redisConnections)

RedisPool

public RedisPool(java.lang.String host,
                 int port,
                 int redisConnections,
                 java.util.Set<java.util.Map.Entry<java.lang.String,java.lang.Integer>> readSlaves)

Method Detail

allowingSlaves

public RedisPool allowingSlaves()

safelyDo

public void safelyDo(java.util.function.Consumer<redis.clients.jedis.Jedis> f)

safelyReturn

public <T> T safelyReturn(java.util.function.Function<redis.clients.jedis.Jedis,T> f)

transactionallyDo

public <T> java.util.List<T> transactionallyDo(java.util.function.Consumer<redis.clients.jedis.Pipeline> f,
                                               java.lang.String... watch)

transactionallyRetry

public <T> java.util.List<T> transactionallyRetry(java.util.function.Consumer<redis.clients.jedis.Pipeline> f,
                                                  java.lang.String... watch)

destroy

public void destroy()