Package org.apache.druid.discovery

Class BaseNodeRoleWatcher

java.lang.Object

org.apache.druid.discovery.BaseNodeRoleWatcher

public class BaseNodeRoleWatcher
extends Object

Common code used by various implementations of DruidNodeDiscovery. User code is supposed to arrange for following methods to be called, childAdded(DiscoveryDruidNode) childRemoved(DiscoveryDruidNode) cacheInitialized() resetNodes(Map) Then registerListener(DruidNodeDiscovery.Listener) and getAllNodes() can be delegated to the implementation here.

Constructor Summary

Constructors

Constructor	Description
BaseNodeRoleWatcher(ScheduledExecutorService listenerExecutor, NodeRole nodeRole)

Method Summary

Modifier and Type	Method	Description
void	cacheInitialized()
void	childAdded(DiscoveryDruidNode druidNode)
void	childRemoved(DiscoveryDruidNode druidNode)
void	childRemoved(DiscoveryDruidNode druidNode, boolean skipIfUnknown)	Remove a node from the discovery cache.
static BaseNodeRoleWatcher	create(ScheduledExecutorService listenerExecutor, NodeRole nodeRole)
Collection<DiscoveryDruidNode>	getAllNodes()
void	registerListener(DruidNodeDiscovery.Listener listener)
void	resetNodes(Map<String,DiscoveryDruidNode> fullNodes)

Methods inherited from class java.lang.Object

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

Constructor Details

BaseNodeRoleWatcher

public BaseNodeRoleWatcher(ScheduledExecutorService listenerExecutor,
 NodeRole nodeRole)

Method Details

create

public static BaseNodeRoleWatcher create(ScheduledExecutorService listenerExecutor,
 NodeRole nodeRole)

getAllNodes

public Collection<DiscoveryDruidNode> getAllNodes()

registerListener

public void registerListener(DruidNodeDiscovery.Listener listener)

childAdded

public void childAdded(DiscoveryDruidNode druidNode)

childRemoved

public void childRemoved(DiscoveryDruidNode druidNode)

childRemoved

public void childRemoved(DiscoveryDruidNode druidNode,
 boolean skipIfUnknown)

Remove a node from the discovery cache.

If skipIfUnknown is true, the removal is skipped if the node is not already present in the cache. If false, the removal is attempted unconditionally.

cacheInitialized

public void cacheInitialized()

resetNodes

public void resetNodes(Map<String,DiscoveryDruidNode> fullNodes)