org.elasticsearch.discovery.jgroups
Class JgroupsDiscovery
java.lang.Object
org.elasticsearch.util.component.AbstractComponent
org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
org.elasticsearch.discovery.jgroups.JgroupsDiscovery
- All Implemented Interfaces:
- org.elasticsearch.discovery.Discovery, org.elasticsearch.util.component.CloseableComponent, org.elasticsearch.util.component.LifecycleComponent<org.elasticsearch.discovery.Discovery>, org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver
public class JgroupsDiscovery
- extends org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
- implements org.elasticsearch.discovery.Discovery, org.jgroups.Receiver
Fields inherited from class org.elasticsearch.util.component.AbstractLifecycleComponent |
lifecycle |
Fields inherited from class org.elasticsearch.util.component.AbstractComponent |
componentSettings, logger, settings |
Constructor Summary |
JgroupsDiscovery(org.elasticsearch.util.settings.Settings settings,
org.elasticsearch.env.Environment environment,
org.elasticsearch.cluster.ClusterName clusterName,
org.elasticsearch.transport.TransportService transportService,
org.elasticsearch.cluster.ClusterService clusterService,
org.elasticsearch.util.network.NetworkService networkService)
|
Methods inherited from class org.elasticsearch.util.component.AbstractLifecycleComponent |
addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop |
Methods inherited from class org.elasticsearch.util.component.AbstractComponent |
nodeName |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.elasticsearch.util.component.LifecycleComponent |
addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop |
Methods inherited from interface org.elasticsearch.util.component.CloseableComponent |
close |
JgroupsDiscovery
@Inject
public JgroupsDiscovery(org.elasticsearch.util.settings.Settings settings,
org.elasticsearch.env.Environment environment,
org.elasticsearch.cluster.ClusterName clusterName,
org.elasticsearch.transport.TransportService transportService,
org.elasticsearch.cluster.ClusterService clusterService,
org.elasticsearch.util.network.NetworkService networkService)
addListener
public void addListener(org.elasticsearch.discovery.InitialStateDiscoveryListener listener)
- Specified by:
addListener
in interface org.elasticsearch.discovery.Discovery
removeListener
public void removeListener(org.elasticsearch.discovery.InitialStateDiscoveryListener listener)
- Specified by:
removeListener
in interface org.elasticsearch.discovery.Discovery
doStart
protected void doStart()
throws org.elasticsearch.ElasticSearchException
- Specified by:
doStart
in class org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
- Throws:
org.elasticsearch.ElasticSearchException
doStop
protected void doStop()
throws org.elasticsearch.ElasticSearchException
- Specified by:
doStop
in class org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
- Throws:
org.elasticsearch.ElasticSearchException
doClose
protected void doClose()
throws org.elasticsearch.ElasticSearchException
- Specified by:
doClose
in class org.elasticsearch.util.component.AbstractLifecycleComponent<org.elasticsearch.discovery.Discovery>
- Throws:
org.elasticsearch.ElasticSearchException
nodeDescription
public java.lang.String nodeDescription()
- Specified by:
nodeDescription
in interface org.elasticsearch.discovery.Discovery
firstMaster
public boolean firstMaster()
- Specified by:
firstMaster
in interface org.elasticsearch.discovery.Discovery
publish
public void publish(org.elasticsearch.cluster.ClusterState clusterState)
- Specified by:
publish
in interface org.elasticsearch.discovery.Discovery
receive
public void receive(org.jgroups.Message msg)
- Specified by:
receive
in interface org.jgroups.MessageListener
getState
public byte[] getState()
- Specified by:
getState
in interface org.jgroups.MessageListener
setState
public void setState(byte[] state)
- Specified by:
setState
in interface org.jgroups.MessageListener
viewAccepted
public void viewAccepted(org.jgroups.View newView)
- Specified by:
viewAccepted
in interface org.jgroups.MembershipListener
suspect
public void suspect(org.jgroups.Address suspectedMember)
- Specified by:
suspect
in interface org.jgroups.MembershipListener
block
public void block()
- Specified by:
block
in interface org.jgroups.MembershipListener