public interface Discovery extends LifecycleComponent<Discovery>
Modifier and Type | Interface and Description |
---|---|
static interface |
Discovery.AckListener |
Modifier and Type | Method and Description |
---|---|
void |
addListener(InitialStateDiscoveryListener listener) |
DiscoveryNode |
localNode() |
String |
nodeDescription() |
void |
publish(ClusterState clusterState,
Discovery.AckListener ackListener)
Publish all the changes to the cluster from the master (can be called just by the master).
|
void |
removeListener(InitialStateDiscoveryListener listener) |
void |
setAllocationService(AllocationService allocationService)
Another hack to solve dep injection problem..., note, this will be called before
any start is called.
|
void |
setNodeService(NodeService nodeService)
Here as a hack to solve dep injection problem...
|
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop
close
DiscoveryNode localNode()
void addListener(InitialStateDiscoveryListener listener)
void removeListener(InitialStateDiscoveryListener listener)
String nodeDescription()
void setNodeService(@Nullable NodeService nodeService)
void setAllocationService(AllocationService allocationService)
void publish(ClusterState clusterState, 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.Copyright © 2009–2015. All rights reserved.