com.orbitz.consul.cache

Class ConsulCache<K,V>

java.lang.Object

com.orbitz.consul.cache.ConsulCache<K,V>

Type Parameters:

V -

Direct Known Subclasses:

KVCache, ServiceHealthCache

public class ConsulCache<K,V>
extends Object

A cache structure that can provide an up-to-date read-only map backed by consul data

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	ConsulCache.CallbackConsumer<V> passed in by creators to vary the content of the cached values
static interface	ConsulCache.Listener<K,V> Implementers can register a listener to receive a new map when it changes

Method Summary

Modifier and Type	Method and Description
boolean	addListener(ConsulCache.Listener<K,V> listener)
boolean	awaitInitialized(long timeout, TimeUnit unit)
com.google.common.collect.ImmutableMap<K,V>	getMap()
protected com.orbitz.consul.cache.ConsulCache.State	getState()
boolean	removeListener(ConsulCache.Listener<K,V> listener)
void	start()
void	stop()
protected static QueryOptions	watchParams(BigInteger index, int blockSeconds)

Methods inherited from class java.lang.Object

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

Method Detail

start

public void start()
           throws Exception

Throws:

Exception

stop

public void stop()
          throws Exception

Throws:

Exception

awaitInitialized

public boolean awaitInitialized(long timeout,
                                TimeUnit unit)
                         throws InterruptedException

Throws:

InterruptedException

getMap

public com.google.common.collect.ImmutableMap<K,V> getMap()

watchParams

protected static QueryOptions watchParams(BigInteger index,
                                          int blockSeconds)

addListener

public boolean addListener(ConsulCache.Listener<K,V> listener)

removeListener

public boolean removeListener(ConsulCache.Listener<K,V> listener)

getState

protected com.orbitz.consul.cache.ConsulCache.State getState()