org.graylog2.lookup

Class LookupTableService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

org.graylog2.lookup.LookupTableService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

@Singleton
public class LookupTableService
extends com.google.common.util.concurrent.AbstractIdleService

This service maintains the in-memory adapters, caches and lookup table instances.

It initially loads all entities and starts them, and later reacts on event bus messages to reflect the current system state.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LookupTableService.Builder
protected class	LookupTableService.DataAdapterListener
static class	LookupTableService.Function

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Constructor Summary

Constructors

Constructor and Description
LookupTableService(LookupTableConfigService configService, Map<String,LookupCache.Factory> cacheFactories, Map<String,LookupDataAdapter.Factory> adapterFactories, Map<String,LookupDataAdapter.Factory2> adapterFactories2, ScheduledExecutorService scheduler, com.google.common.eventbus.EventBus eventBus)

Method Summary

Modifier and Type	Method and Description
protected void	addListeners(LookupDataAdapter adapter, DataAdapterDto dto)
protected LookupDataAdapter	createAdapter(DataAdapterDto dto)
protected CountDownLatch	createAndStartAdapters()
Collection<LookupCache>	getCaches(Set<String> cacheNames)
protected LookupTableConfigService	getConfigService()
Collection<LookupDataAdapter>	getDataAdapters(Set<String> adapterNames)
protected ScheduledExecutorService	getScheduler()
LookupTable	getTable(String name)
void	handleAdapterDelete(DataAdaptersDeleted deleted)
void	handleAdapterSharedStoreUpdate(AdapterSharedStoresUpdated updated)
void	handleAdapterUpdate(DataAdaptersUpdated updated)
void	handleCacheDelete(CachesDeleted deleted)
void	handleCacheUpdate(CachesUpdated updated)
void	handleLookupTableDelete(LookupTablesDeleted deleted)
void	handleLookupTableUpdate(LookupTablesUpdated updated)
boolean	hasTable(String name)
LookupTableService.Builder	newBuilder()
Optional<CachePurge>	newCachePurge(String tableName)
protected void	shutDown()
protected void	startUp()

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, awaitRunning, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, serviceName, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupTableService

@Inject
public LookupTableService(LookupTableConfigService configService,
                                  Map<String,LookupCache.Factory> cacheFactories,
                                  Map<String,LookupDataAdapter.Factory> adapterFactories,
                                  Map<String,LookupDataAdapter.Factory2> adapterFactories2,
                                  @Named(value="daemonScheduler")
                                  ScheduledExecutorService scheduler,
                                  com.google.common.eventbus.EventBus eventBus)

Method Detail

getConfigService

protected LookupTableConfigService getConfigService()

getScheduler

protected ScheduledExecutorService getScheduler()

startUp

protected void startUp()
                throws Exception

Specified by:

startUp in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

shutDown

protected void shutDown()
                 throws Exception

Specified by:

shutDown in class com.google.common.util.concurrent.AbstractIdleService

Throws:

Exception

handleAdapterUpdate

public void handleAdapterUpdate(DataAdaptersUpdated updated)

handleAdapterDelete

public void handleAdapterDelete(DataAdaptersDeleted deleted)

handleCacheUpdate

public void handleCacheUpdate(CachesUpdated updated)

handleAdapterSharedStoreUpdate

public void handleAdapterSharedStoreUpdate(AdapterSharedStoresUpdated updated)

handleCacheDelete

public void handleCacheDelete(CachesDeleted deleted)

handleLookupTableUpdate

public void handleLookupTableUpdate(LookupTablesUpdated updated)

handleLookupTableDelete

public void handleLookupTableDelete(LookupTablesDeleted deleted)

createAndStartAdapters

protected CountDownLatch createAndStartAdapters()

createAdapter

protected LookupDataAdapter createAdapter(DataAdapterDto dto)

addListeners

protected void addListeners(LookupDataAdapter adapter,
                            DataAdapterDto dto)

newCachePurge

public Optional<CachePurge> newCachePurge(String tableName)

newBuilder

public LookupTableService.Builder newBuilder()

getTable

@Nullable
public LookupTable getTable(String name)

hasTable

public boolean hasTable(String name)

getDataAdapters

public Collection<LookupDataAdapter> getDataAdapters(Set<String> adapterNames)

getCaches

public Collection<LookupCache> getCaches(Set<String> cacheNames)