com.enremmeta.rtb.dao.impl.hazelcast

Class HazelcastService

java.lang.Object

com.enremmeta.rtb.dao.impl.hazelcast.HazelcastService

All Implemented Interfaces:

DbService

public class HazelcastService
extends Object
implements DbService

Shared caches across all instances - as Hazelcast. This will provide the following maps:

1. short-lived map -- evictions based on TTL. Used for things such as storing state

Author:

Gregory Golberg (grisha@alum.mit.edu) Copyright © Enremmeta LLC 2014. All Rights Reserved.

Field Summary

Fields

Modifier and Type	Field and Description
private static AtomicLong	BYTES_WRITTEN
private HazelcastServiceConfig	config
private com.hazelcast.core.HazelcastInstance	hazelcastInstance
private com.hazelcast.client.config.ClientConfig	hazelClientConfig
private com.hazelcast.config.Config	hazelConfig
static String	ID
private com.hazelcast.core.IdGenerator	idGenerator
static String	MAP_NAME_LONG_LIVED
static String	MAP_NAME_SHORT_LIVED
private com.hazelcast.core.IMap<Object,Object>	shortLivedMap
private Map<Class<?>,DaoShortLivedMap<? extends Object>>	slMapOfMaps

Constructor Summary

Constructors

Constructor and Description
HazelcastService(ServiceRunner runner, HazelcastServiceConfig config)
HazelcastService(ServiceRunner runner, HazelcastServiceConfig config, boolean noInit)

Method Summary

Modifier and Type	Method and Description
HazelcastServiceConfig	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.hazelcast.core.HazelcastInstance	getHazelcastInstance()
long	getNextId()
com.hazelcast.core.IMap<Object,Object>	getShortLivedMap() For persisting items short term, e.g., NUrl contents, LostAuctionTasks, etc.) without any need for backing store.
static void	incrBytesWritten(long l)
void	init(DbConfig config)
void	makeHazelConfig(Orchestrator orch)
private com.hazelcast.config.MapConfig	makeLongLivedMapConfig(String name)
static long	resetBytesWritten()

Methods inherited from class java.lang.Object

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

Field Detail

idGenerator

private final com.hazelcast.core.IdGenerator idGenerator

config

private final HazelcastServiceConfig config

BYTES_WRITTEN

private static final AtomicLong BYTES_WRITTEN

hazelConfig

private com.hazelcast.config.Config hazelConfig

hazelClientConfig

private com.hazelcast.client.config.ClientConfig hazelClientConfig

ID

public static final String ID

See Also:

Constant Field Values

MAP_NAME_LONG_LIVED

public static final String MAP_NAME_LONG_LIVED

See Also:

Constant Field Values

MAP_NAME_SHORT_LIVED

public static final String MAP_NAME_SHORT_LIVED

See Also:

Constant Field Values

hazelcastInstance

private final com.hazelcast.core.HazelcastInstance hazelcastInstance

shortLivedMap

private final com.hazelcast.core.IMap<Object,Object> shortLivedMap

slMapOfMaps

private final Map<Class<?>,DaoShortLivedMap<? extends Object>> slMapOfMaps

Constructor Detail

HazelcastService

public HazelcastService(ServiceRunner runner,
                        HazelcastServiceConfig config)
                 throws Lot49Exception

Throws:

Lot49Exception

HazelcastService

public HazelcastService(ServiceRunner runner,
                        HazelcastServiceConfig config,
                        boolean noInit)
                 throws Lot49Exception

Throws:

Lot49Exception

Method Detail

incrBytesWritten

public static final void incrBytesWritten(long l)

resetBytesWritten

public static final long resetBytesWritten()

makeHazelConfig

public void makeHazelConfig(Orchestrator orch)
                     throws Lot49Exception

Throws:

Lot49Exception

makeLongLivedMapConfig

private com.hazelcast.config.MapConfig makeLongLivedMapConfig(String name)

getConfig

public HazelcastServiceConfig getConfig()

getHazelcastInstance

public com.hazelcast.core.HazelcastInstance getHazelcastInstance()

getShortLivedMap

public com.hazelcast.core.IMap<Object,Object> getShortLivedMap()

For persisting items short term, e.g., NUrl contents, LostAuctionTasks, etc.) without any need for backing store.

getNextId

public long getNextId()

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