io.druid.discovery

Class DruidLeaderClient

java.lang.Object

io.druid.discovery.DruidLeaderClient

public class DruidLeaderClient
extends Object

This class facilitates interaction with Coordinator/Overlord leader nodes. Instance of this class is injected via Guice with annotations @Coordinator or @IndexingService . Usage: Request request = druidLeaderClient.makeRequest(HttpMethod, requestPath) request.setXXX(..) FullResponseHolder responseHolder = druidLeaderClient.go(request)

Constructor Summary

Constructors

Constructor and Description
DruidLeaderClient(HttpClient httpClient, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, String nodeTypeToWatch, String leaderRequestPath, ServerDiscoverySelector serverDiscoverySelector)

Method Summary

Modifier and Type	Method and Description
String	findCurrentLeader()
FullResponseHolder	go(Request request)
FullResponseHolder	go(Request request, HttpResponseHandler<FullResponseHolder,FullResponseHolder> responseHandler) Executes a Request object aimed at the leader.
Request	makeRequest(org.jboss.netty.handler.codec.http.HttpMethod httpMethod, String urlPath) Make a Request object aimed at the leader.
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

DruidLeaderClient

public DruidLeaderClient(HttpClient httpClient,
                         DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
                         String nodeTypeToWatch,
                         String leaderRequestPath,
                         ServerDiscoverySelector serverDiscoverySelector)

Method Detail

start

public void start()

stop

public void stop()

makeRequest

public Request makeRequest(org.jboss.netty.handler.codec.http.HttpMethod httpMethod,
                           String urlPath)
                    throws IOException

Make a Request object aimed at the leader. Throws IOException if the leader cannot be located.

Throws:

IOException

go

public FullResponseHolder go(Request request)
                      throws IOException,
                             InterruptedException

Throws:

IOException

InterruptedException

go

public FullResponseHolder go(Request request,
                             HttpResponseHandler<FullResponseHolder,FullResponseHolder> responseHandler)
                      throws IOException,
                             InterruptedException

Executes a Request object aimed at the leader. Throws IOException if the leader cannot be located.

Throws:

IOException

InterruptedException

findCurrentLeader

public String findCurrentLeader()