class LatencyMinimizingServerSelector extends java.lang.Object implements ServerSelector
| Modifier and Type | Field and Description |
|---|---|
private long |
acceptableLatencyDifferenceNanos |
| Constructor and Description |
|---|
LatencyMinimizingServerSelector(long acceptableLatencyDifference,
java.util.concurrent.TimeUnit timeUnit) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ServerDescription> |
choose(ClusterDescription clusterDescription) |
private long |
getBestLatencyNanos(java.util.Set<ServerDescription> members) |
private java.util.List<ServerDescription> |
getServersWithAcceptableLatencyDifference(java.util.Set<ServerDescription> servers,
long bestPingTime) |
java.lang.String |
toString() |
LatencyMinimizingServerSelector(long acceptableLatencyDifference,
java.util.concurrent.TimeUnit timeUnit)
public java.util.List<ServerDescription> choose(ClusterDescription clusterDescription)
choose in interface ServerSelectorpublic java.lang.String toString()
toString in class java.lang.Objectprivate long getBestLatencyNanos(java.util.Set<ServerDescription> members)
private java.util.List<ServerDescription> getServersWithAcceptableLatencyDifference(java.util.Set<ServerDescription> servers, long bestPingTime)