| Package | Description |
|---|---|
| com.mongodb |
Main package with core files.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DBAddress
Represents a database address, which includes the properties of ServerAddress (host and port) and adds a database name.
|
| Modifier and Type | Field and Description |
|---|---|
(package private) ServerAddress |
DBPortPool._addr
Deprecated.
|
private ServerAddress |
DBPort._addr
Deprecated.
|
private ServerAddress |
CommandResult._host |
private ServerAddress |
QueryResultIterator._host |
(package private) ServerAddress |
Response._host |
private ServerAddress |
DBPort._sa
Deprecated.
|
private ServerAddress |
ServerDescription.address |
private ServerAddress |
ServerDescription.Builder.address |
private ServerAddress |
ServerAddressSelector.address |
private ServerAddress |
QueryResultIterator.OptionalFinalizer.host |
(package private) ServerAddress |
DBApiLayer.DeadCursor.host |
private ServerAddress |
BulkWriteBatchCombiner.serverAddress |
private ServerAddress |
ServerMonitor.serverAddress |
private ServerAddress |
DefaultServer.serverAddress |
private ServerAddress |
MongoCursorNotFoundException.serverAddress |
private ServerAddress |
ConnectionPoolStatistics.serverAddress |
private ServerAddress |
BulkWriteException.serverAddress |
private ServerAddress |
ConnectionEvent.serverAddress |
private ServerAddress |
JMXConnectionPoolListener.ClusterIdServerAddressPair.serverAddress |
private ServerAddress |
ConnectionPoolEvent.serverAddress |
private ServerAddress |
PooledConnectionProvider.serverAddress |
private ServerAddress |
MongosHAServerSelector.stickTo |
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.ConcurrentMap<ServerAddress,MultiServerCluster.ServerTuple> |
MultiServerCluster.addressToServerTupleMap |
private java.util.Set<ServerAddress> |
MongosHAServerSelector.consideredServers |
private java.util.List<ServerAddress> |
ClusterSettings.hosts |
private java.util.List<ServerAddress> |
ClusterSettings.Builder.hosts |
private java.util.List<ServerAddress> |
MongoAuthority.serverAddresses |
| Modifier and Type | Method and Description |
|---|---|
ServerAddress |
Mongo.getAddress()
Gets the address of the current master
|
ServerAddress |
DBTCPConnector.getAddress()
Deprecated.
|
ServerAddress |
ServerDescription.getAddress() |
(package private) ServerAddress |
DBPort.getAddress()
Deprecated.
|
ServerAddress |
ReplicaSetStatus.getMaster()
Gets the ServerAddress of the master server in this replica set.
|
ServerAddress |
DBPortPool.getServerAddress()
Deprecated.
|
ServerAddress |
Cursor.getServerAddress()
Gets the address of the server that data is pulled from.
|
ServerAddress |
QueryResultIterator.getServerAddress() |
ServerAddress |
MongoCursorNotFoundException.getServerAddress()
The server address where the cursor is.
|
ServerAddress |
MongoCommandException.getServerAddress()
Gets the address of the server that this command failed on.
|
ServerAddress |
WriteConcernException.getServerAddress()
Gets the address of the server that the write executed on.
|
ServerAddress |
BulkWriteException.getServerAddress()
The address of the server which performed the bulk write operation.
|
ServerAddress |
ConnectionEvent.getServerAddress()
Gets the server address associated with this connection.
|
ServerAddress |
ConnectionPoolEvent.getServerAddress()
Gets the server address associated with this connection pool
|
ServerAddress |
DBCursor.getServerAddress()
Gets the Server Address of the server that data is pulled from.
|
ServerAddress |
AggregationOutput.getServerUsed()
Deprecated.
there is no replacement for this method
|
ServerAddress |
CommandResult.getServerUsed()
Deprecated.
there is no replacement for this method
|
ServerAddress |
MapReduceOutput.getServerUsed()
Deprecated.
this method will be removed in the next major release
|
ServerAddress |
DBPort.serverAddress()
Deprecated.
|
ServerAddress |
Response.serverUsed() |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<ServerAddress> |
Mongo.getAllAddress()
Gets a list of all server addresses used when this Mongo was created
|
java.util.List<ServerAddress> |
DBTCPConnector.getAllAddress()
Deprecated.
Gets the list of seed server addresses
|
private java.util.Set<ServerAddress> |
MultiServerCluster.getAllServerAddresses(ServerDescription serverDescription) |
java.util.List<ServerAddress> |
ClusterSettings.getHosts()
Gets the seed list of hosts for the cluster.
|
private java.util.Set<ServerAddress> |
MongosHAServerSelector.getOkServers(ClusterDescription clusterDescription) |
java.util.List<ServerAddress> |
MongoAuthority.getServerAddresses()
Returns the list of server addresses.
|
java.util.List<ServerAddress> |
Mongo.getServerAddressList()
Gets the list of server addresses currently seen by this client.
|
java.util.List<ServerAddress> |
DBTCPConnector.getServerAddressList()
Deprecated.
Gets the list of server addresses currently seen by the connector.
|
| Modifier and Type | Method and Description |
|---|---|
ServerDescription.Builder |
ServerDescription.Builder.address(ServerAddress address) |
private void |
MultiServerCluster.addServer(ServerAddress serverAddress) |
Response |
DBConnector.call(DB db,
DBCollection coll,
OutMessage m,
ServerAddress hostNeeded,
DBDecoder decoder)
Deprecated.
does a read operation on the database
|
Response |
DBTCPConnector.call(DB db,
DBCollection coll,
OutMessage m,
ServerAddress hostNeeded,
DBDecoder decoder)
Deprecated.
|
Response |
DBConnector.call(DB db,
DBCollection coll,
OutMessage m,
ServerAddress hostNeeded,
int retries)
Deprecated.
does a read operation on the database
|
Response |
DBTCPConnector.call(DB db,
DBCollection coll,
OutMessage m,
ServerAddress hostNeeded,
int retries)
Deprecated.
|
Response |
DBConnector.call(DB db,
DBCollection coll,
OutMessage m,
ServerAddress hostNeeded,
int retries,
ReadPreference readPref,
DBDecoder decoder)
Deprecated.
does a read operation on the database
|
Response |
DBTCPConnector.call(DB db,
DBCollection coll,
OutMessage m,
ServerAddress hostNeeded,
int retries,
ReadPreference readPref,
DBDecoder decoder)
Deprecated.
|
ClusterableServer |
ClusterableServerFactory.create(ServerAddress serverAddress) |
ClusterableServer |
DefaultClusterableServerFactory.create(ServerAddress serverAddress) |
Connection |
DBPortFactory.create(ServerAddress serverAddress,
PooledConnectionProvider provider,
int generation) |
Connection |
ConnectionFactory.create(ServerAddress serverAddress,
PooledConnectionProvider provider,
int generation) |
protected ClusterableServer |
BaseCluster.createServer(ServerAddress serverAddress,
ChangeListener<ServerDescription> serverStateListener) |
static MongoAuthority |
MongoAuthority.direct(ServerAddress serverAddress) |
static MongoAuthority |
MongoAuthority.direct(ServerAddress serverAddress,
MongoCredential credentials) |
static MongoAuthority |
MongoAuthority.direct(ServerAddress serverAddress,
MongoCredentialsStore credentialsStore) |
(package private) DBPort |
DBTCPConnector.MyPort.get(boolean keep,
ReadPreference readPref,
ServerAddress hostNeeded) |
ServerDescription |
ClusterDescription.getByServerAddress(ServerAddress serverAddress) |
private ServerDescription |
MultiServerCluster.getConnectingServerDescription(ServerAddress serverAddress) |
DBPortPool |
DBTCPConnector.getDBPortPool(ServerAddress addr)
Deprecated.
Gets the DBPortPool associated with a ServerAddress.
|
ConnectionPoolStatisticsMBean |
JMXConnectionPoolListener.getMBean(java.lang.String clusterId,
ServerAddress serverAddress) |
java.lang.String |
JMXConnectionPoolListener.getMBeanObjectName(java.lang.String clusterId,
ServerAddress serverAddress) |
protected ClusterableServer |
MultiServerCluster.getServer(ServerAddress serverAddress) |
protected ClusterableServer |
SingleServerCluster.getServer(ServerAddress serverAddress) |
protected abstract ClusterableServer |
BaseCluster.getServer(ServerAddress serverAddress)
Return the server at the given address.
|
(package private) ServerDescription |
DBTCPConnector.getServerDescription(ServerAddress address)
Deprecated.
|
private ConnectionPoolStatistics |
JMXConnectionPoolListener.getStatistics(java.lang.String clusterId,
ServerAddress serverAddress) |
private Response |
DBTCPConnector.innerCall(DB db,
DBCollection coll,
OutMessage m,
ServerAddress hostNeeded,
int remainingRetries,
ReadPreference readPref,
DBDecoder decoder)
Deprecated.
|
private void |
MultiServerCluster.invalidateOldPrimaries(ServerAddress newPrimary) |
boolean |
ReplicaSetStatus.isMaster(ServerAddress serverAddress)
Checks to see if a given server is the primary server in this replica set.
|
private boolean |
MultiServerCluster.isNotAlreadyPrimary(ServerAddress address) |
(package private) void |
DBApiLayer.killCursors(ServerAddress addr,
java.util.List<java.lang.Long> all)
Deprecated.
|
private void |
MultiServerCluster.removeServer(ServerAddress serverAddress) |
WriteResult |
DBConnector.say(DB db,
OutMessage m,
WriteConcern concern,
ServerAddress hostNeeded)
Deprecated.
does a write operation
|
WriteResult |
DBTCPConnector.say(DB db,
OutMessage m,
WriteConcern concern,
ServerAddress hostNeeded)
Deprecated.
|
private WriteResult |
DBCollectionImpl.translateBulkWriteResult(BulkWriteResult bulkWriteResult,
WriteRequest.Type type,
WriteConcern writeConcern,
ServerAddress serverAddress) |
void |
DBTCPConnector.updatePortPool(ServerAddress addr)
Deprecated.
Assigns a new DBPortPool for a given ServerAddress.
|
| Modifier and Type | Method and Description |
|---|---|
private void |
MultiServerCluster.addHostsToSet(java.util.Set<java.lang.String> hosts,
java.util.Set<ServerAddress> retVal) |
static MongoAuthority |
MongoAuthority.dynamicSet(java.util.List<ServerAddress> serverAddresses) |
static MongoAuthority |
MongoAuthority.dynamicSet(java.util.List<ServerAddress> serverAddresses,
MongoCredential credentials) |
static MongoAuthority |
MongoAuthority.dynamicSet(java.util.List<ServerAddress> serverAddresses,
MongoCredentialsStore credentialsStore) |
ClusterSettings.Builder |
ClusterSettings.Builder.hosts(java.util.List<ServerAddress> hosts)
Sets the hosts for the cluster.
|
| Constructor and Description |
|---|
BulkWriteBatchCombiner(ServerAddress serverAddress,
WriteConcern writeConcern) |
BulkWriteException(BulkWriteResult writeResult,
java.util.List<BulkWriteError> writeErrors,
WriteConcernError writeConcernError,
ServerAddress serverAddress)
Constructs a new instance.
|
ClusterIdServerAddressPair(java.lang.String clusterId,
ServerAddress serverAddress) |
CommandResult(ServerAddress serverAddress) |
ConnectionEvent(java.lang.String clusterId,
ServerAddress serverAddress)
Constructs a new instance of the event.
|
ConnectionPoolEvent(java.lang.String clusterId,
ServerAddress serverAddress)
Constructs a new instance of the event.
|
ConnectionPoolOpenedEvent(java.lang.String clusterId,
ServerAddress serverAddress,
ConnectionPoolSettings settings)
Constructs a new instance of the event.
|
ConnectionPoolWaitQueueEvent(java.lang.String clusterId,
ServerAddress serverAddress,
long threadId)
Constructs a new instance of the event.
|
CursorNotFound(long cursorId,
ServerAddress serverAddress)
Deprecated.
|
DBPort(ServerAddress addr)
Deprecated.
creates a new DBPort
|
DBPort(ServerAddress addr,
Mongo mongo,
MongoOptions options)
Deprecated.
|
DBPort(ServerAddress addr,
PooledConnectionProvider pool,
Mongo mongo,
int generation)
Deprecated.
|
DBPort(ServerAddress addr,
PooledConnectionProvider pool,
Mongo mongo,
MongoOptions options,
int generation)
Deprecated.
|
DBPortPool(ServerAddress addr,
MongoOptions options)
Deprecated.
|
DeadCursor(long a,
ServerAddress b) |
DefaultServer(ServerAddress serverAddress,
ServerSettings settings,
java.lang.String clusterId,
PooledConnectionProvider connectionProvider,
Mongo mongo) |
Mongo(ServerAddress addr)
Deprecated.
Replaced by
MongoClient(ServerAddress) |
Mongo(ServerAddress addr,
MongoOptions options)
Deprecated.
Replaced by
MongoClient(ServerAddress, MongoClientOptions) |
Mongo(ServerAddress left,
ServerAddress right)
Deprecated.
|
Mongo(ServerAddress left,
ServerAddress right,
MongoOptions options)
Deprecated.
Please use
MongoClient(java.util.List, MongoClientOptions) instead. |
MongoAuthority(ServerAddress serverAddress,
MongoCredentialsStore credentialsStore)
Constructs an instance with a single server address and a store of authentication credentials.
|
MongoClient(ServerAddress addr)
Creates a Mongo instance based on a (single) mongodb node
|
MongoClient(ServerAddress addr,
java.util.List<MongoCredential> credentialsList)
Creates a Mongo instance based on a (single) mongodb node and a list of credentials
|
MongoClient(ServerAddress addr,
java.util.List<MongoCredential> credentialsList,
MongoClientOptions options)
Creates a Mongo instance based on a (single) mongo node using a given ServerAddress and default options.
|
MongoClient(ServerAddress addr,
MongoClientOptions options)
Creates a Mongo instance based on a (single) mongo node using a given ServerAddress and default options.
|
MongoCursorNotFoundException(long cursorId,
ServerAddress serverAddress)
Construct a new instance.
|
OptionalFinalizer(DBApiLayer db,
ServerAddress host) |
PooledConnectionProvider(java.lang.String clusterId,
ServerAddress serverAddress,
ConnectionFactory connectionFactory,
ConnectionPoolSettings settings,
ConnectionPoolListener connectionPoolListener) |
QueryResultIterator(DBObject cursorDocument,
Mongo mongo,
int batchSize,
DBDecoder decoder,
ServerAddress serverAddress) |
Response(ServerAddress addr,
DBCollection collection,
java.io.InputStream in,
DBDecoder decoder) |
ServerAddressSelector(ServerAddress address) |
ServerMonitor(ServerAddress serverAddress,
ChangeListener<ServerDescription> serverStateListener,
SocketSettings socketSettings,
ServerSettings settings,
java.lang.String clusterId,
Mongo mongo,
PooledConnectionProvider connectionProvider) |
| Constructor and Description |
|---|
Mongo(java.util.List<ServerAddress> seeds)
Deprecated.
Replaced by
MongoClient(java.util.List) |
Mongo(java.util.List<ServerAddress> seeds,
MongoOptions options)
Deprecated.
Replaced by
MongoClient(java.util.List, MongoClientOptions) |
MongoAuthority(java.util.List<ServerAddress> serverAddresses,
MongoAuthority.Type type,
MongoCredentialsStore credentialsStore)
Constructs an instance with a list of server addresses, which may either be a list of mongos servers
or a list of members of a replica set, and a store of authentication credentials.
|
MongoClient(java.util.List<ServerAddress> seeds)
Creates a Mongo based on a list of replica set members or a list of mongos.
|
MongoClient(java.util.List<ServerAddress> seeds,
java.util.List<MongoCredential> credentialsList)
Creates a Mongo based on a list of replica set members or a list of mongos.
|
MongoClient(java.util.List<ServerAddress> seeds,
java.util.List<MongoCredential> credentialsList,
MongoClientOptions options)
Creates a Mongo based on a list of replica set members or a list of mongos.
|
MongoClient(java.util.List<ServerAddress> seeds,
MongoClientOptions options)
Creates a Mongo based on a list of replica set members or a list of mongos.
|