com.enremmeta.rtb.dao.impl.aerospike

Class AerospikeDBService

java.lang.Object

com.enremmeta.rtb.dao.impl.aerospike.AerospikeDBService

All Implemented Interfaces:

DbService

public class AerospikeDBService
extends Object
implements DbService

Field Summary

Fields

Modifier and Type	Field and Description
private com.aerospike.client.async.AsyncClient	client
private AerospikeDBServiceConfig	config
private AerospikeDaoMapOfUserAttributes	daoMapOfUserAttributes
private AerospikeDaoMapOfUserSegments	daoMapOfUserSegments
private com.aerospike.client.async.AsyncClientPolicy	policy

Constructor Summary

Constructors

Constructor and Description
AerospikeDBService()

Method Summary

Modifier and Type	Method and Description
com.aerospike.client.async.AsyncClient	getClient()
AerospikeDBServiceConfig	getConfig()
<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)
com.aerospike.client.async.AsyncClientPolicy	getPolicy()
void	init(DbConfig config)
void	setClient(com.aerospike.client.async.AsyncClient client)
void	setConfig(AerospikeDBServiceConfig config)
void	setPolicy(com.aerospike.client.async.AsyncClientPolicy policy)

Methods inherited from class java.lang.Object

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

Field Detail

client

private com.aerospike.client.async.AsyncClient client

config

private AerospikeDBServiceConfig config

policy

private com.aerospike.client.async.AsyncClientPolicy policy

daoMapOfUserAttributes

private AerospikeDaoMapOfUserAttributes daoMapOfUserAttributes

daoMapOfUserSegments

private AerospikeDaoMapOfUserSegments daoMapOfUserSegments

Constructor Detail

AerospikeDBService

public AerospikeDBService()

Method Detail

init

public void init(DbConfig config)
          throws Lot49Exception

Specified by:

init in interface DbService

Throws:

Lot49Exception

getDaoShortLivedMap

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

Specified by:

getDaoShortLivedMap in interface DbService

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

getClient

public com.aerospike.client.async.AsyncClient getClient()

setClient

public void setClient(com.aerospike.client.async.AsyncClient client)

getPolicy

public com.aerospike.client.async.AsyncClientPolicy getPolicy()

Returns:

the policy

setPolicy

public void setPolicy(com.aerospike.client.async.AsyncClientPolicy policy)

Parameters:

policy - the policy to set

getConfig

public AerospikeDBServiceConfig getConfig()

Returns:

the config

setConfig

public void setConfig(AerospikeDBServiceConfig config)

Parameters:

config - the config to set