| Package | Description |
|---|---|
| com.mongodb |
Main package with core files.
|
| Modifier and Type | Field and Description |
|---|---|
private ServerDescription |
DefaultServer.description |
private ServerDescription |
MultiServerCluster.ServerTuple.description |
| Modifier and Type | Field and Description |
|---|---|
private java.util.Set<ServerDescription> |
ClusterDescription.all |
private java.util.Map<ChangeListener<ServerDescription>,java.lang.Boolean> |
DefaultServer.changeListeners |
private ChangeListener<ServerDescription> |
ServerMonitor.serverStateListener |
private ChangeListener<ServerDescription> |
DefaultServer.serverStateListener |
| Modifier and Type | Method and Description |
|---|---|
ServerDescription |
ServerDescription.Builder.build() |
(package private) static ServerDescription |
ServerMonitor.createDescription(CommandResult commandResult,
ServerVersion serverVersion,
long averageLatencyNanos) |
ServerDescription |
ClusterDescription.getByServerAddress(ServerAddress serverAddress) |
private ServerDescription |
MultiServerCluster.getConnectingServerDescription(ServerAddress serverAddress) |
private ServerDescription |
ServerMonitor.getConnectingServerDescription(java.lang.Throwable throwable) |
ServerDescription |
Server.getDescription()
Gets the description of this server.
|
ServerDescription |
DefaultServer.getDescription() |
ServerDescription |
BaseCluster.WrappedServer.getDescription() |
(package private) ServerDescription |
DBTCPConnector.getServerDescription(ServerAddress address)
Deprecated.
|
private ServerDescription |
ServerMonitor.lookupServerDescription(DBPort connection) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ServerDescription> |
MongosHAServerSelector.choose(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
ServerSelector.choose(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
AnyServerSelector.choose(ClusterDescription clusterDescription) |
(package private) abstract java.util.List<ServerDescription> |
ReadPreference.choose(ClusterDescription clusterDescription) |
(package private) java.util.List<ServerDescription> |
ReadPreference.PrimaryReadPreference.choose(ClusterDescription clusterDescription) |
(package private) java.util.List<ServerDescription> |
ReadPreference.TaggedReadPreference.choose(ClusterDescription clusterDescription)
Deprecated.
|
java.util.List<ServerDescription> |
LatencyMinimizingServerSelector.choose(ClusterDescription clusterDescription) |
(package private) java.util.List<ServerDescription> |
TaggableReadPreference.choose(ClusterDescription clusterDescription) |
(package private) java.util.List<ServerDescription> |
TaggableReadPreference.SecondaryPreferredReadPreference.choose(ClusterDescription clusterDescription) |
(package private) java.util.List<ServerDescription> |
TaggableReadPreference.PrimaryPreferredReadPreference.choose(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
ServerAddressSelector.choose(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
CompositeServerSelector.choose(ClusterDescription clusterDescription) |
java.util.List<ServerDescription> |
ReadPreferenceServerSelector.choose(ClusterDescription clusterDescription) |
java.util.Set<ServerDescription> |
ClusterDescription.getAll()
Returns the Set of all server descriptions in this cluster, sorted by the String value of the ServerAddress of each one.
|
java.util.List<ServerDescription> |
ClusterDescription.getAny() |
java.util.List<ServerDescription> |
ClusterDescription.getAnyPrimaryOrSecondary() |
java.util.List<ServerDescription> |
ClusterDescription.getAnyPrimaryOrSecondary(TagSet tags) |
private java.util.List<ServerDescription> |
MultiServerCluster.getNewServerDescriptionList() |
java.util.List<ServerDescription> |
ClusterDescription.getPrimaries()
While it may seem counter-intuitive that a MongoDb cluster can have more than one primary, it can in the case where the client's view
of the cluster is a set of mongos servers, any of which can serve as the primary.
|
java.util.List<ServerDescription> |
ClusterDescription.getSecondaries() |
java.util.List<ServerDescription> |
ClusterDescription.getSecondaries(TagSet tags) |
(package private) abstract java.util.List<ServerDescription> |
TaggableReadPreference.getServers(ClusterDescription clusterDescription) |
(package private) java.util.List<ServerDescription> |
TaggableReadPreference.SecondaryReadPreference.getServers(ClusterDescription clusterDescription) |
(package private) java.util.List<ServerDescription> |
TaggableReadPreference.NearestReadPreference.getServers(ClusterDescription clusterDescription) |
private java.util.List<ServerDescription> |
ClusterDescription.getServersByPredicate(ClusterDescription.Predicate predicate) |
(package private) abstract java.util.List<ServerDescription> |
TaggableReadPreference.getServersForTags(ClusterDescription clusterDescription,
TagSet tags) |
(package private) java.util.List<ServerDescription> |
TaggableReadPreference.SecondaryReadPreference.getServersForTags(ClusterDescription clusterDescription,
TagSet tags) |
(package private) java.util.List<ServerDescription> |
TaggableReadPreference.NearestReadPreference.getServersForTags(ClusterDescription clusterDescription,
TagSet tags) |
private java.util.List<ServerDescription> |
LatencyMinimizingServerSelector.getServersWithAcceptableLatencyDifference(java.util.Set<ServerDescription> servers,
long bestPingTime) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
ClusterDescription.Predicate.apply(ServerDescription serverDescription) |
(package private) static boolean |
ServerMonitor.descriptionHasChanged(ServerDescription previousServerDescription,
ServerDescription currentServerDescription) |
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 |
ServerMonitor.ServerMonitorRunnable.logStateChange(ServerDescription previousServerDescription,
java.lang.Throwable previousException,
ServerDescription currentServerDescription,
java.lang.Throwable currentException) |
private void |
SingleServerCluster.publishDescription(ServerDescription serverDescription) |
private void |
MultiServerCluster.removeExtraHosts(ServerDescription serverDescription) |
private void |
ServerMonitor.ServerMonitorRunnable.sendStateChangedEvent(ServerDescription previousServerDescription,
ServerDescription currentServerDescription) |
(package private) static boolean |
ServerMonitor.stateHasChanged(ServerDescription previousServerDescription,
ServerDescription currentServerDescription) |
| Modifier and Type | Method and Description |
|---|---|
void |
DefaultServer.addChangeListener(ChangeListener<ServerDescription> changeListener) |
void |
ClusterableServer.addChangeListener(ChangeListener<ServerDescription> changeListener)
Adds a change listener to this server.
|
protected ClusterableServer |
BaseCluster.createServer(ServerAddress serverAddress,
ChangeListener<ServerDescription> serverStateListener) |
private long |
LatencyMinimizingServerSelector.getBestLatencyNanos(java.util.Set<ServerDescription> members) |
private ClusterableServer |
BaseCluster.getRandomServer(java.util.List<ServerDescription> serverDescriptions) |
private java.util.List<ServerDescription> |
LatencyMinimizingServerSelector.getServersWithAcceptableLatencyDifference(java.util.Set<ServerDescription> servers,
long bestPingTime) |
private void |
MultiServerCluster.onChange(ChangeEvent<ServerDescription> event) |
void |
DefaultServer.DefaultServerStateListener.stateChanged(ChangeEvent<ServerDescription> event) |
void |
MultiServerCluster.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) |
ServerMonitor(ServerAddress serverAddress,
ChangeListener<ServerDescription> serverStateListener,
SocketSettings socketSettings,
ServerSettings settings,
java.lang.String clusterId,
Mongo mongo,
PooledConnectionProvider connectionProvider) |