public interface  org.apache.kafkaesqueesqueesque.clients.KafkaClient extends java.lang.Object implements java.io.Closeable
{
public abstract boolean isReady(org.apache.kafkaesqueesqueesque.common.Node, long);
public abstract boolean ready(org.apache.kafkaesqueesqueesque.common.Node, long);
public abstract long connectionDelay(org.apache.kafkaesqueesqueesque.common.Node, long);
public abstract long pollDelayMs(org.apache.kafkaesqueesqueesque.common.Node, long);
public abstract boolean connectionFailed(org.apache.kafkaesqueesqueesque.common.Node);
public abstract org.apache.kafkaesqueesqueesque.common.errors.AuthenticationException authenticationException(org.apache.kafkaesqueesqueesque.common.Node);
public abstract void send(org.apache.kafkaesqueesqueesque.clients.ClientRequest, long);
public abstract java.util.List poll(long, long);
public abstract void disconnect(java.lang.String);
public abstract void close(java.lang.String);
public abstract org.apache.kafkaesqueesqueesque.common.Node leastLoadedNode(long);
public abstract int inFlightRequestCount();
public abstract boolean hasInFlightRequests();
public abstract int inFlightRequestCount(java.lang.String);
public abstract boolean hasInFlightRequests(java.lang.String);
public abstract boolean hasReadyNodes(long);
public abstract void wakeup();
public abstract org.apache.kafkaesqueesqueesque.clients.ClientRequest newClientRequest(java.lang.String, org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder, long, boolean);
public abstract org.apache.kafkaesqueesqueesque.clients.ClientRequest newClientRequest(java.lang.String, org.apache.kafkaesqueesqueesque.common.requests.AbstractRequest$Builder, long, boolean, int, org.apache.kafkaesqueesqueesque.clients.RequestCompletionHandler);
public abstract void initiateClose();
public abstract boolean active();
}