public class DruidLeaderClient extends Object
Constructor and Description |
---|
DruidLeaderClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
String nodeTypeToWatch,
String leaderRequestPath,
ServerDiscoverySelector serverDiscoverySelector) |
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() |
public DruidLeaderClient(HttpClient httpClient, DruidNodeDiscoveryProvider druidNodeDiscoveryProvider, String nodeTypeToWatch, String leaderRequestPath, ServerDiscoverySelector serverDiscoverySelector)
public void start()
public void stop()
public Request makeRequest(org.jboss.netty.handler.codec.http.HttpMethod httpMethod, String urlPath) throws IOException
IOException
public FullResponseHolder go(Request request) throws IOException, InterruptedException
IOException
InterruptedException
public FullResponseHolder go(Request request, HttpResponseHandler<FullResponseHolder,FullResponseHolder> responseHandler) throws IOException, InterruptedException
IOException
InterruptedException
public String findCurrentLeader()
Copyright © 2011–2018. All rights reserved.