Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.event |
This package contains cluster and connection event related classes
|
com.mongodb.selector |
Contains classes that determine how to select the server to connect to in order to send commands or queries.
|
Modifier and Type | Field and Description |
---|---|
private ClusterDescription |
MongoIncompatibleDriverException.clusterDescription |
Modifier and Type | Method and Description |
---|---|
protected static ClusterDescription |
TaggableReadPreference.copyClusterDescription(ClusterDescription clusterDescription,
java.util.List<ServerDescription> selectedServers) |
ClusterDescription |
MongoIncompatibleDriverException.getClusterDescription()
The cluster description which was determined to be incompatible.
|
private ClusterDescription |
ReplicaSetStatus.getClusterDescription() |
private ClusterDescription |
Mongo.getClusterDescription() |
private ClusterDescription |
Mongo.getConnectedClusterDescription() |
Modifier and Type | Method and Description |
---|---|
java.util.List<ServerDescription> |
ReadPreference.choose(ClusterDescription clusterDescription)
Chooses the servers from the given cluster than match this read preference.
|
protected abstract java.util.List<ServerDescription> |
ReadPreference.chooseForNonReplicaSet(ClusterDescription clusterDescription) |
protected java.util.List<ServerDescription> |
ReadPreference.PrimaryReadPreference.chooseForNonReplicaSet(ClusterDescription clusterDescription) |
protected java.util.List<ServerDescription> |
TaggableReadPreference.chooseForNonReplicaSet(ClusterDescription clusterDescription) |
protected abstract java.util.List<ServerDescription> |
ReadPreference.chooseForReplicaSet(ClusterDescription clusterDescription) |
protected java.util.List<ServerDescription> |
ReadPreference.PrimaryReadPreference.chooseForReplicaSet(ClusterDescription clusterDescription) |
protected java.util.List<ServerDescription> |
TaggableReadPreference.SecondaryReadPreference.chooseForReplicaSet(ClusterDescription clusterDescription) |
protected java.util.List<ServerDescription> |
TaggableReadPreference.SecondaryPreferredReadPreference.chooseForReplicaSet(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
TaggableReadPreference.NearestReadPreference.chooseForReplicaSet(ClusterDescription clusterDescription) |
protected java.util.List<ServerDescription> |
TaggableReadPreference.PrimaryPreferredReadPreference.chooseForReplicaSet(ClusterDescription clusterDescription) |
protected static ClusterDescription |
TaggableReadPreference.copyClusterDescription(ClusterDescription clusterDescription,
java.util.List<ServerDescription> selectedServers) |
private ServerDescription |
TaggableReadPreference.findMostUpToDateSecondary(ClusterDescription clusterDescription) |
private ServerDescription |
TaggableReadPreference.findPrimary(ClusterDescription clusterDescription) |
private java.util.List<ServerDescription> |
Mongo.getServerDescriptionListToConsiderForSessionSupport(ClusterDescription clusterDescription) |
protected java.util.List<ServerDescription> |
TaggableReadPreference.selectFreshServers(ClusterDescription clusterDescription,
java.util.List<ServerDescription> servers) |
private boolean |
TaggableReadPreference.serversAreAllThreeDotFour(ClusterDescription clusterDescription) |
Constructor and Description |
---|
MongoIncompatibleDriverException(java.lang.String message,
ClusterDescription clusterDescription)
Construct a new instance.
|
Modifier and Type | Method and Description |
---|---|
private java.util.List<ServerDescription> |
ClientSessionHelper.getServerDescriptionListToConsiderForSessionSupport(ClusterDescription clusterDescription) |
Modifier and Type | Field and Description |
---|---|
private ClusterDescription |
BaseCluster.description |
Modifier and Type | Method and Description |
---|---|
ClusterDescription |
BaseCluster.getCurrentDescription() |
ClusterDescription |
Cluster.getCurrentDescription()
Get the current description of this cluster.
|
ClusterDescription |
BaseCluster.getDescription() |
ClusterDescription |
Cluster.getDescription()
Get the description of this cluster.
|
private ClusterDescription |
SingleServerCluster.getInitialDescription() |
private ClusterDescription |
MultiServerCluster.updateDescription() |
Modifier and Type | Method and Description |
---|---|
private MongoIncompatibleDriverException |
BaseCluster.createIncompatibleException(ClusterDescription curDescription) |
private MongoTimeoutException |
BaseCluster.createTimeoutException(ServerSelector serverSelector,
ClusterDescription curDescription) |
private boolean |
BaseCluster.handleServerSelectionRequest(BaseCluster.ServerSelectionRequest request,
java.util.concurrent.CountDownLatch currentPhase,
ClusterDescription description) |
private void |
BaseCluster.logServerSelectionFailure(ServerSelector serverSelector,
ClusterDescription curDescription) |
private Server |
BaseCluster.selectRandomServer(ServerSelector serverSelector,
ClusterDescription clusterDescription) |
private void |
BaseCluster.throwIfIncompatible(ClusterDescription curDescription) |
protected void |
BaseCluster.updateDescription(ClusterDescription newDescription) |
Modifier and Type | Field and Description |
---|---|
private ClusterDescription |
ClusterDescriptionChangedEvent.newDescription |
private ClusterDescription |
ClusterDescriptionChangedEvent.previousDescription |
Modifier and Type | Method and Description |
---|---|
ClusterDescription |
ClusterDescriptionChangedEvent.getNewDescription()
Gets the new cluster description.
|
ClusterDescription |
ClusterDescriptionChangedEvent.getPreviousDescription()
Gets the previous cluster description.
|
Constructor and Description |
---|
ClusterDescriptionChangedEvent(ClusterId clusterId,
ClusterDescription newDescription,
ClusterDescription previousDescription)
Constructs a new instance of the event.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<ServerDescription> |
ServerAddressSelector.select(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
CompositeServerSelector.select(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
PrimaryServerSelector.select(ClusterDescription clusterDescription)
Deprecated.
|
java.util.List<ServerDescription> |
WritableServerSelector.select(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
LatencyMinimizingServerSelector.select(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
ServerSelector.select(ClusterDescription clusterDescription)
Select a list of server descriptions from the given cluster description according to some criteria.
|
java.util.List<ServerDescription> |
ReadPreferenceServerSelector.select(ClusterDescription clusterDescription) |