com.enremmeta.rtb.dao.impl.redis

Class RedisL2Cache<T>

java.lang.Object

com.enremmeta.rtb.dao.impl.redis.RedisL2Cache<T>

All Implemented Interfaces:

L2Cache<T>, Runnable

public class RedisL2Cache<T>
extends Object
implements L2Cache<T>

Redis implementation.

Author:

Gregory Golberg (grisha@alum.mit.edu)

Copyright © Enremmeta LLC 2015. All Rights Reserved.

Field Summary

Fields

Modifier and Type	Field and Description
private int	curVarzaPtr
(package private) RedisFetchOp<T>	fetchOp
private int	poolSize
private int	poolTtlMinutes
private RedisServiceConfig	redisConfig
private com.lambdaworks.redis.RedisAsyncConnection<String,String>[]	varzas

Constructor Summary

Constructors

Constructor and Description
RedisL2Cache(RedisServiceConfig redisConfig, RedisFetchOp<T> fetchOp)

Method Summary

Modifier and Type	Method and Description
void	close()
Future<T>	get(String key)
private com.lambdaworks.redis.RedisAsyncConnection<String,String>	getConnection()
int	getCurVarzaPtr() Completely threadunsafe.
void	refreshPool() Disconnect and reconnect.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.enremmeta.rtb.dao.L2Cache

run

Field Detail

redisConfig

private final RedisServiceConfig redisConfig

fetchOp

final RedisFetchOp<T> fetchOp

poolSize

private final int poolSize

poolTtlMinutes

private final int poolTtlMinutes

curVarzaPtr

private int curVarzaPtr

varzas

private final com.lambdaworks.redis.RedisAsyncConnection<String,String>[] varzas

Constructor Detail

RedisL2Cache

public RedisL2Cache(RedisServiceConfig redisConfig,
                    RedisFetchOp<T> fetchOp)

Method Detail

getCurVarzaPtr

public int getCurVarzaPtr()

Completely threadunsafe.

getConnection

private com.lambdaworks.redis.RedisAsyncConnection<String,String> getConnection()

get

public Future<T> get(String key)

Specified by:

get in interface L2Cache<T>

refreshPool

public void refreshPool()

Description copied from interface: L2Cache

Disconnect and reconnect.

Specified by:

refreshPool in interface L2Cache<T>

close

public void close()

Specified by:

close in interface L2Cache<T>