org.elasticsearch.discovery.zen.fd
Class MasterFaultDetection

java.lang.Object
  extended by org.elasticsearch.common.component.AbstractComponent
      extended by org.elasticsearch.discovery.zen.fd.MasterFaultDetection

public class MasterFaultDetection
extends AbstractComponent

A fault detection that pings the master periodically to see if its alive.


Nested Class Summary
static interface MasterFaultDetection.Listener
           
 
Field Summary
 
Fields inherited from class org.elasticsearch.common.component.AbstractComponent
componentSettings, logger, settings
 
Constructor Summary
MasterFaultDetection(Settings settings, ThreadPool threadPool, TransportService transportService, DiscoveryNodesProvider nodesProvider)
           
 
Method Summary
 void addListener(MasterFaultDetection.Listener listener)
           
 void close()
           
 DiscoveryNode masterNode()
           
 void removeListener(MasterFaultDetection.Listener listener)
           
 void restart(DiscoveryNode masterNode, String reason)
           
 void start(DiscoveryNode masterNode, String reason)
           
 void stop(String reason)
           
 
Methods inherited from class org.elasticsearch.common.component.AbstractComponent
nodeName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MasterFaultDetection

public MasterFaultDetection(Settings settings,
                            ThreadPool threadPool,
                            TransportService transportService,
                            DiscoveryNodesProvider nodesProvider)
Method Detail

masterNode

public DiscoveryNode masterNode()

addListener

public void addListener(MasterFaultDetection.Listener listener)

removeListener

public void removeListener(MasterFaultDetection.Listener listener)

restart

public void restart(DiscoveryNode masterNode,
                    String reason)

start

public void start(DiscoveryNode masterNode,
                  String reason)

stop

public void stop(String reason)

close

public void close()


Copyright © 2009-2012. All Rights Reserved.