Package | Description |
---|---|
com.allanbank.mongodb.client.connection |
Provides interfaces for managing connections to different MongoDB server configurations.
|
com.allanbank.mongodb.client.connection.proxy |
Support for connection that delegate to a lower level connection.
|
com.allanbank.mongodb.client.connection.rs |
Support for connections to Replica Sets.
|
com.allanbank.mongodb.client.connection.sharded |
Support for connections to Sharded Configurations.
|
com.allanbank.mongodb.client.connection.socket |
Low level socket connection to a single MongoDB server.
|
com.allanbank.mongodb.client.state |
Support for tracking the state of a set of MongoDB servers.
|
Modifier and Type | Method and Description |
---|---|
void |
ReconnectStrategy.setState(Cluster state)
Sets the state of the cluster to be used by the reconnection strategy.
|
Modifier and Type | Field and Description |
---|---|
protected Cluster |
AbstractProxyMultipleConnection.myCluster
The state of the cluster for finding secondary connections.
|
Constructor and Description |
---|
AbstractProxyMultipleConnection(Connection proxiedConnection,
K server,
Cluster cluster,
ProxiedConnectionFactory factory,
MongoClientConfiguration config)
Creates a new
AbstractProxyMultipleConnection . |
Modifier and Type | Method and Description |
---|---|
protected Cluster |
ReplicaSetConnectionFactory.getCluster()
Returns the clusterState value.
|
Modifier and Type | Method and Description |
---|---|
protected ConnectionInfo<Server> |
ReplicaSetReconnectStrategy.checkForReply(Cluster state,
Map<Server,Future<Reply>> answers,
Map<Server,Connection> connections,
long deadline)
Checks for a reply from a server.
|
Constructor and Description |
---|
ReplicaSetConnection(Connection proxiedConnection,
Server server,
Cluster cluster,
ProxiedConnectionFactory factory,
MongoClientConfiguration config,
ReplicaSetReconnectStrategy strategy)
Creates a new
ReplicaSetConnection . |
Modifier and Type | Field and Description |
---|---|
protected Cluster |
ShardedConnectionFactory.myCluster
The state of the cluster.
|
Modifier and Type | Method and Description |
---|---|
protected Cluster |
ShardedConnectionFactory.createCluster(MongoClientConfiguration config)
Creates a
Cluster object to track the state of the servers across
the cluster. |
protected Cluster |
ShardedConnectionFactory.getCluster()
Returns the clusterState value.
|
Constructor and Description |
---|
ShardedConnection(Connection proxiedConnection,
Server server,
Cluster cluster,
ServerSelector selector,
ProxiedConnectionFactory factory,
MongoClientConfiguration config)
Creates a new
ShardedConnection . |
Modifier and Type | Method and Description |
---|---|
Cluster |
SocketConnectionFactory.getCluster()
Returns the cluster state.
|
Modifier and Type | Field and Description |
---|---|
protected Cluster |
AbstractReconnectStrategy.myState
The state of the cluster.
|
Modifier and Type | Method and Description |
---|---|
Cluster |
AbstractReconnectStrategy.getState()
Returns the state of the cluster.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterPinger.addCluster(Cluster cluster)
Adds a new cluster to the set of tracked clusters.
|
void |
ClusterPinger.initialSweep(Cluster cluster)
Performs a single sweep through the servers sending a ping with a
callback to set the latency and tags for each server.
|
void |
AbstractReconnectStrategy.setState(Cluster state)
Sets the state of the cluster to be used by the reconnection strategy.
|
Constructor and Description |
---|
ClusterPinger(Cluster cluster,
ProxiedConnectionFactory factory,
MongoClientConfiguration config)
Creates a new ClusterPinger.
|
LatencyServerSelector(Cluster cluster,
boolean writableOnly)
Creates a new LatencyServerSelector.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.