Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.binding |
This package contains classes that manage binding to MongoDB servers for various operations.
|
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 | Method and Description |
---|---|
private ServerDescription |
TaggableReadPreference.findMostUpToDateSecondary(ClusterDescription clusterDescription) |
private ServerDescription |
TaggableReadPreference.findPrimary(ClusterDescription clusterDescription) |
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 java.util.List<ServerDescription> |
TaggableReadPreference.chooseForNonReplicaSet(ClusterDescription clusterDescription) |
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.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 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.selectFreshServers(ClusterDescription clusterDescription,
java.util.List<ServerDescription> servers) |
Modifier and Type | Method and Description |
---|---|
private long |
TaggableReadPreference.getStalenessOfSecondaryRelativeToPrimary(ServerDescription primary,
ServerDescription serverDescription,
long heartbeatFrequencyMS) |
Modifier and Type | Method and Description |
---|---|
protected static ClusterDescription |
TaggableReadPreference.copyClusterDescription(ClusterDescription clusterDescription,
java.util.List<ServerDescription> selectedServers) |
protected java.util.List<ServerDescription> |
TaggableReadPreference.selectFreshServers(ClusterDescription clusterDescription,
java.util.List<ServerDescription> servers) |
Modifier and Type | Field and Description |
---|---|
private ServerDescription |
AsyncSingleConnectionReadBinding.serverDescription |
private ServerDescription |
SingleConnectionReadBinding.serverDescription |
Modifier and Type | Method and Description |
---|---|
ServerDescription |
AsyncClusterBinding.AsyncClusterBindingConnectionSource.getServerDescription() |
ServerDescription |
AsyncConnectionSource.getServerDescription()
Gets the current description of this source.
|
ServerDescription |
ClusterBinding.ClusterBindingConnectionSource.getServerDescription() |
ServerDescription |
AsyncSingleConnectionReadBinding.AsyncSingleConnectionSource.getServerDescription() |
ServerDescription |
SingleServerBinding.SingleServerBindingConnectionSource.getServerDescription() |
ServerDescription |
ConnectionSource.getServerDescription()
Gets the current description of this source.
|
ServerDescription |
SingleConnectionReadBinding.SingleConnectionSource.getServerDescription() |
Constructor and Description |
---|
AsyncSingleConnectionReadBinding(ReadPreference readPreference,
ServerDescription serverDescription,
AsyncConnection connection)
Construct an instance.
|
SingleConnectionReadBinding(ReadPreference readPreference,
ServerDescription serverDescription,
Connection connection)
Construct an instance.
|
Modifier and Type | Field and Description |
---|---|
private ServerDescription |
DefaultServer.description |
private ServerDescription |
MultiServerCluster.ServerTuple.description |
Modifier and Type | Field and Description |
---|---|
private java.util.List<ServerDescription> |
ClusterDescription.serverDescriptions |
private ChangeListener<ServerDescription> |
DefaultServer.serverStateListener |
private ChangeListener<ServerDescription> |
DefaultServerMonitor.serverStateListener |
Modifier and Type | Method and Description |
---|---|
ServerDescription |
ServerDescription.Builder.build()
Create a new ServerDescription from the settings in this builder.
|
(package private) static ServerDescription |
DescriptionHelper.createServerDescription(ServerAddress serverAddress,
BsonDocument isMasterResult,
ServerVersion serverVersion,
long roundTripTime) |
ServerDescription |
ClusterDescription.getByServerAddress(ServerAddress serverAddress)
Deprecated.
Replace with a filter on ServerDescription in the caller
|
private ServerDescription |
MultiServerCluster.getConnectingServerDescription(ServerAddress serverAddress) |
private ServerDescription |
DefaultServerMonitor.ServerMonitorRunnable.getConnectingServerDescription(java.lang.Throwable exception) |
ServerDescription |
Server.getDescription()
Gets the description of this server.
|
ServerDescription |
DefaultServer.getDescription() |
private ServerDescription |
DefaultServerMonitor.ServerMonitorRunnable.lookupServerDescription(InternalConnection connection) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<ServerDescription> |
ClusterDescription.getAll()
Deprecated.
Use
ClusterDescription.getServerDescriptions() instead |
java.util.List<ServerDescription> |
ClusterDescription.getAny()
Deprecated.
Replace with a filter on ServerDescription in the caller
|
java.util.List<ServerDescription> |
ClusterDescription.getAnyPrimaryOrSecondary()
Deprecated.
Replace with a filter on ServerDescription in the caller
|
java.util.List<ServerDescription> |
ClusterDescription.getAnyPrimaryOrSecondary(TagSet tagSet)
Deprecated.
Replace with a filter on ServerDescription in the caller
|
private java.util.List<ServerDescription> |
MultiServerCluster.getNewServerDescriptionList() |
java.util.List<ServerDescription> |
ClusterDescription.getPrimaries()
Deprecated.
Replace with a filter on ServerDescription in the caller
|
java.util.List<ServerDescription> |
ClusterDescription.getSecondaries()
Deprecated.
Replace with a filter on ServerDescription in the caller
|
java.util.List<ServerDescription> |
ClusterDescription.getSecondaries(TagSet tagSet)
Deprecated.
Replace with a filter on ServerDescription in the caller
|
java.util.List<ServerDescription> |
ClusterDescription.getServerDescriptions()
Returns an unmodifiable list of the server descriptions in this cluster description.
|
private java.util.List<ServerDescription> |
ClusterDescription.getServersByPredicate(ClusterDescription.Predicate predicate) |
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterDescription.Predicate.apply(ServerDescription serverDescription) |
private void |
MultiServerCluster.ensureServers(ServerDescription description) |
private java.util.Set<ServerAddress> |
MultiServerCluster.getAllServerAddresses(ServerDescription serverDescription) |
private boolean |
MultiServerCluster.handleReplicaSetMemberChanged(ServerDescription newDescription) |
private boolean |
MultiServerCluster.handleShardRouterChanged(ServerDescription newDescription) |
private boolean |
MultiServerCluster.handleStandAloneChanged(ServerDescription newDescription) |
private boolean |
MultiServerCluster.isStalePrimary(ServerDescription newDescription) |
private void |
DefaultServerMonitor.ServerMonitorRunnable.logStateChange(ServerDescription previousServerDescription,
ServerDescription currentServerDescription) |
private void |
SingleServerCluster.publishDescription(ServerDescription serverDescription) |
private void |
MultiServerCluster.removeExtraHosts(ServerDescription serverDescription) |
(package private) static boolean |
DefaultServerMonitor.shouldLogStageChange(ServerDescription previous,
ServerDescription current) |
Modifier and Type | Method and Description |
---|---|
ServerMonitor |
DefaultServerMonitorFactory.create(ChangeListener<ServerDescription> serverStateListener) |
ServerMonitor |
ServerMonitorFactory.create(ChangeListener<ServerDescription> serverStateListener) |
private ClusterableServer |
BaseCluster.getRandomServer(java.util.List<ServerDescription> serverDescriptions) |
void |
DefaultServer.DefaultServerStateListener.stateChanged(ChangeEvent<ServerDescription> event) |
Constructor and Description |
---|
ServerTuple(ClusterableServer server,
ServerDescription description) |
Constructor and Description |
---|
ClusterDescription(ClusterConnectionMode connectionMode,
ClusterType type,
java.util.List<ServerDescription> serverDescriptions)
Creates a new ClusterDescription.
|
ClusterDescription(ClusterConnectionMode connectionMode,
ClusterType type,
java.util.List<ServerDescription> serverDescriptions,
ClusterSettings clusterSettings,
ServerSettings serverSettings)
Creates a new ClusterDescription.
|
DefaultServerMonitor(ServerId serverId,
ServerSettings settings,
ChangeListener<ServerDescription> serverStateListener,
InternalConnectionFactory internalConnectionFactory,
ConnectionPool connectionPool) |
Modifier and Type | Field and Description |
---|---|
private ServerDescription |
ServerDescriptionChangedEvent.newDescription |
private ServerDescription |
ServerDescriptionChangedEvent.previousDescription |
Modifier and Type | Method and Description |
---|---|
ServerDescription |
ServerDescriptionChangedEvent.getNewDescription()
Gets the new server description.
|
ServerDescription |
ServerDescriptionChangedEvent.getPreviousDescription()
Gets the previous server description.
|
Constructor and Description |
---|
ServerDescriptionChangedEvent(ServerId serverId,
ServerDescription newDescription,
ServerDescription previousDescription)
Construct an instance.
|
Modifier and Type | Method and Description |
---|---|
private java.util.List<ServerDescription> |
LatencyMinimizingServerSelector.getServersWithAcceptableLatencyDifference(java.util.List<ServerDescription> servers,
long bestPingTime) |
java.util.List<ServerDescription> |
ReadPreferenceServerSelector.select(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
CompositeServerSelector.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> |
ServerAddressSelector.select(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
PrimaryServerSelector.select(ClusterDescription clusterDescription)
Deprecated.
|
java.util.List<ServerDescription> |
WritableServerSelector.select(ClusterDescription clusterDescription) |
Modifier and Type | Method and Description |
---|---|
private long |
LatencyMinimizingServerSelector.getFastestRoundTripTimeNanos(java.util.List<ServerDescription> members) |
private java.util.List<ServerDescription> |
LatencyMinimizingServerSelector.getServersWithAcceptableLatencyDifference(java.util.List<ServerDescription> servers,
long bestPingTime) |