Package | Description |
---|---|
org.apache.tinkerpop.gremlin.driver |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<Host,org.apache.tinkerpop.gremlin.driver.ConnectionPool> |
Client.ClusteredClient.hostConnectionPools |
Modifier and Type | Method and Description |
---|---|
Host |
ResultSet.getHost() |
Modifier and Type | Method and Description |
---|---|
Collection<Host> |
Cluster.allHosts()
Gets a list of all the configured hosts.
|
Iterator<Host> |
LoadBalancingStrategy.select(RequestMessage msg)
Provide an ordered list of hosts to send the given
RequestMessage to. |
Iterator<Host> |
LoadBalancingStrategy.RoundRobin.select(RequestMessage msg) |
Modifier and Type | Method and Description |
---|---|
void |
LoadBalancingStrategy.RoundRobin.onAvailable(Host host) |
void |
Host.Listener.onAvailable(Host host) |
void |
LoadBalancingStrategy.RoundRobin.onNew(Host host) |
void |
Host.Listener.onNew(Host host) |
void |
LoadBalancingStrategy.RoundRobin.onRemove(Host host) |
void |
Host.Listener.onRemove(Host host) |
void |
LoadBalancingStrategy.RoundRobin.onUnavailable(Host host) |
void |
Host.Listener.onUnavailable(Host host) |
boolean |
Client.ClusteredClient.tryReInitializeHost(Host host)
Attempt to re-initialize the
Host that was previously marked as unavailable. |
Modifier and Type | Method and Description |
---|---|
void |
LoadBalancingStrategy.initialize(Cluster cluster,
Collection<Host> hosts)
Initialize the strategy with the
Cluster instance and the expected host list. |
void |
LoadBalancingStrategy.RoundRobin.initialize(Cluster cluster,
Collection<Host> hosts) |
Constructor and Description |
---|
ResultSet(org.apache.tinkerpop.gremlin.driver.ResultQueue resultQueue,
ExecutorService executor,
CompletableFuture<Void> readCompleted,
RequestMessage originalRequestMessage,
Host host) |
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.