com.netflix.nicobar.core.persistence

Class ArchiveRepositoryPoller

java.lang.Object

com.netflix.nicobar.core.persistence.ArchiveRepositoryPoller

public class ArchiveRepositoryPoller
extends java.lang.Object

Poller which periodically scans a list of ArchiveRepository for updates and publishes them to a ScriptModuleLoader

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ArchiveRepositoryPoller.Builder
protected static class	ArchiveRepositoryPoller.RepositoryPollerContext used for book-keeping of repositories that are being polled

Field Summary

Fields

Modifier and Type	Field and Description
protected ScriptModuleLoader	moduleLoader
protected java.util.concurrent.ScheduledExecutorService	pollerThreadPool Thread pool used by the pollers
protected java.util.concurrent.ConcurrentHashMap<ArchiveRepository,ArchiveRepositoryPoller.RepositoryPollerContext>	repositoryContexts Contains transient state required for calculating deltas

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ArchiveRepositoryPoller(java.util.concurrent.ScheduledExecutorService pollerThreadPool, ScriptModuleLoader moduleLoader)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addRepository(ArchiveRepository archiveRepository, int pollInterval, java.util.concurrent.TimeUnit timeUnit, boolean waitForInitialPoll) Add a repository and schedule polling
protected void	pollRepository(ArchiveRepository archiveRepository)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

repositoryContexts

protected final java.util.concurrent.ConcurrentHashMap<ArchiveRepository,ArchiveRepositoryPoller.RepositoryPollerContext> repositoryContexts

Contains transient state required for calculating deltas

pollerThreadPool

protected final java.util.concurrent.ScheduledExecutorService pollerThreadPool

Thread pool used by the pollers

moduleLoader

protected final ScriptModuleLoader moduleLoader

Constructor Detail

ArchiveRepositoryPoller

protected ArchiveRepositoryPoller(java.util.concurrent.ScheduledExecutorService pollerThreadPool,
                       ScriptModuleLoader moduleLoader)

Method Detail

addRepository

public boolean addRepository(ArchiveRepository archiveRepository,
                    int pollInterval,
                    java.util.concurrent.TimeUnit timeUnit,
                    boolean waitForInitialPoll)

Add a repository and schedule polling

Parameters:

archiveRepository - repository to scan

pollInterval - how often this repository should be scanned

timeUnit - unit of the pollInterval param

waitForInitialPoll - whether or not to block until the initial poll is complete

Returns:

true if the repository was added. false if it already exists

pollRepository

protected void pollRepository(ArchiveRepository archiveRepository)

shutdown

public void shutdown()