com.enremmeta.rtb.dao.impl.redis

Class RedisService

java.lang.Object

com.enremmeta.rtb.dao.impl.redis.RedisService

All Implemented Interfaces:

DbService, Runnable

public class RedisService
extends Object
implements DbService, Runnable

Redis service.

Author:

Gregory Golberg (grisha@alum.mit.edu)

Copyright © Enremmeta LLC 2015. All Rights Reserved.

Field Summary

Fields

Modifier and Type	Field and Description
private com.lambdaworks.redis.RedisClient	client
private RedisServiceConfig	config
private int	curVarzaPtr
private int	poolSize
private int	poolTtlMinutes
private com.lambdaworks.redis.RedisAsyncConnection<String,String>[]	varzas

Constructor Summary

Constructors

Constructor and Description
RedisService()

Method Summary

Modifier and Type	Method and Description
void	close()
(package private) RedisServiceConfig	getConfig()
(package private) com.lambdaworks.redis.RedisAsyncConnection<String,String>	getConnection()
int	getCurVarzaPtr() Completely threadunsafe.
<T> DaoCache<T>	getDaoCache(DaoCacheLoader<T> loader, T nullValue, long ttl, long maxItems)
<T> DaoCacheLoader<T>	getDaoCacheLoader()
DaoCounters	getDaoCounters()
DaoMapOfUserAttributes	getDaoMapOfUserAttributes()
DaoMapOfUserSegments	getDaoMapOfUserSegments()
<T> DaoShortLivedMap<T>	getDaoShortLivedMap()
<T> DaoShortLivedMap<T>	getDaoShortLivedMap(Class<T> type)
void	init(DbConfig config)
void	refreshPool()
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

config

private RedisServiceConfig config

client

private com.lambdaworks.redis.RedisClient client

poolSize

private int poolSize

poolTtlMinutes

private int poolTtlMinutes

curVarzaPtr

private int curVarzaPtr

varzas

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

Constructor Detail

RedisService

public RedisService()

Method Detail

run

public void run()

Specified by:

run in interface Runnable

init

public void init(DbConfig config)
          throws Lot49Exception

Specified by:

init in interface DbService

Throws:

Lot49Exception

getCurVarzaPtr

public int getCurVarzaPtr()

Completely threadunsafe.

getConnection

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

refreshPool

public void refreshPool()

close

public void close()

getDaoShortLivedMap

public <T> DaoShortLivedMap<T> getDaoShortLivedMap(Class<T> type)

Specified by:

getDaoShortLivedMap in interface DbService

getConfig

RedisServiceConfig getConfig()

getDaoShortLivedMap

public <T> DaoShortLivedMap<T> getDaoShortLivedMap()

Specified by:

getDaoShortLivedMap in interface DbService

getDaoCacheLoader

public <T> DaoCacheLoader<T> getDaoCacheLoader()

Specified by:

getDaoCacheLoader in interface DbService

getDaoCache

public <T> DaoCache<T> getDaoCache(DaoCacheLoader<T> loader,
                                   T nullValue,
                                   long ttl,
                                   long maxItems)

Specified by:

getDaoCache in interface DbService

getDaoCounters

public DaoCounters getDaoCounters()

Specified by:

getDaoCounters in interface DbService

getDaoMapOfUserAttributes

public DaoMapOfUserAttributes getDaoMapOfUserAttributes()

Specified by:

getDaoMapOfUserAttributes in interface DbService

getDaoMapOfUserSegments

public DaoMapOfUserSegments getDaoMapOfUserSegments()

Specified by:

getDaoMapOfUserSegments in interface DbService