public interface Discovery extends LifecycleComponent<Discovery >
| Modifier and Type | Interface and Description |
|---|---|
static interface |
Discovery
|
| Modifier and Type | Method and Description |
|---|---|
void |
addListener(InitialStateDiscoveryListener
|
DiscoveryNode |
localNode()
|
String |
nodeDescription()
|
void |
publish(ClusterState
Publish all the changes to the cluster from the master (can be called just by the master).
|
void |
removeListener(InitialStateDiscoveryListener
|
void |
setNodeService(NodeService
Here as a hack to solve dep injection problem...
|
void |
setRoutingService(RoutingService
Another hack to solve dep injection problem..., note, this will be called before any start is called.
|
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stopcloseDiscoveryNodelocalNode()
void addListener(InitialStateDiscoveryListenerlistener)
void removeListener(InitialStateDiscoveryListenerlistener)
StringnodeDescription()
void setNodeService(@Nullable NodeServicenodeService)
void setRoutingService(RoutingServiceroutingService)
void publish(ClusterStateclusterState, Discovery .AckListener ackListener)
Discovery.AckListener allows to keep track of the ack received from nodes, and verify whether they updated their own cluster state or not.