Package | Description |
---|---|
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.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Field and Description |
---|---|
private ConnectionDescription |
GetMoreProtocol.GetMoreResultCallback.connectionDescription |
private ConnectionDescription |
QueryProtocol.QueryResultCallback.connectionDescription |
private ConnectionDescription |
InternalStreamConnectionInitializer.CompoundAuthenticator.connectionDescription |
private ConnectionDescription |
InternalStreamConnection.description |
Modifier and Type | Method and Description |
---|---|
private ConnectionDescription |
InternalStreamConnectionInitializer.applyGetLastErrorResult(BsonDocument getLastErrorResult,
ConnectionDescription connectionDescription) |
private ConnectionDescription |
InternalStreamConnectionInitializer.completeConnectionDescriptionInitialization(InternalConnection internalConnection,
ConnectionDescription connectionDescription) |
(package private) static ConnectionDescription |
DescriptionHelper.createConnectionDescription(ConnectionId connectionId,
BsonDocument isMasterResult,
BsonDocument buildInfoResult) |
ConnectionDescription |
InternalConnection.getDescription()
Gets the description of this connection.
|
ConnectionDescription |
DefaultConnectionPool.PooledConnection.getDescription() |
ConnectionDescription |
DefaultServerConnection.getDescription() |
ConnectionDescription |
Connection.getDescription()
Gets the description of the connection.
|
ConnectionDescription |
AsyncConnection.getDescription()
Gets the description of the connection.
|
ConnectionDescription |
InternalStreamConnection.getDescription() |
ConnectionDescription |
UsageTrackingInternalConnection.getDescription() |
ConnectionDescription |
InternalConnectionInitializer.initialize(InternalConnection internalConnection) |
ConnectionDescription |
InternalStreamConnectionInitializer.initialize(InternalConnection internalConnection) |
private ConnectionDescription |
InternalStreamConnectionInitializer.initializeConnectionDescription(InternalConnection internalConnection) |
(package private) ConnectionDescription |
ConnectionDescription.withConnectionId(ConnectionId connectionId) |
Modifier and Type | Method and Description |
---|---|
private SingleResultCallback<ConnectionDescription> |
InternalStreamConnectionInitializer.createConnectionDescriptionCallback(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
Modifier and Type | Method and Description |
---|---|
private ConnectionDescription |
InternalStreamConnectionInitializer.applyGetLastErrorResult(BsonDocument getLastErrorResult,
ConnectionDescription connectionDescription) |
void |
NativeAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) void |
X509Authenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) void |
DefaultAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
(package private) abstract void |
Authenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
void |
SaslAuthenticator.authenticate(InternalConnection connection,
ConnectionDescription connectionDescription) |
private void |
InternalStreamConnectionInitializer.authenticateAll(InternalConnection internalConnection,
ConnectionDescription connectionDescription) |
(package private) void |
NativeAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
X509Authenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
DefaultAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) abstract void |
Authenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
SaslAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
private ConnectionDescription |
InternalStreamConnectionInitializer.completeConnectionDescriptionInitialization(InternalConnection internalConnection,
ConnectionDescription connectionDescription) |
private void |
InternalStreamConnectionInitializer.completeConnectionDescriptionInitializationAsync(InternalConnection internalConnection,
ConnectionDescription connectionDescription,
SingleResultCallback<ConnectionDescription> callback) |
(package private) Authenticator |
DefaultAuthenticator.createAuthenticator(ConnectionDescription connectionDescription) |
private QueryMessage |
QueryProtocol.createQueryMessage(ConnectionDescription connectionDescription) |
private Compressor |
InternalStreamConnection.findSendCompressor(ConnectionDescription description) |
(package private) static MessageSettings |
ProtocolHelper.getMessageSettings(ConnectionDescription connectionDescription) |
(package private) static void |
ProtocolHelper.sendCommandFailedEvent(RequestMessage message,
java.lang.String commandName,
ConnectionDescription connectionDescription,
long startTimeNanos,
java.lang.Throwable throwable,
CommandListener commandListener) |
(package private) static void |
ProtocolHelper.sendCommandStartedEvent(RequestMessage message,
java.lang.String databaseName,
java.lang.String commandName,
BsonDocument command,
ConnectionDescription connectionDescription,
CommandListener commandListener) |
(package private) static void |
ProtocolHelper.sendCommandSucceededEvent(RequestMessage message,
java.lang.String commandName,
BsonDocument response,
ConnectionDescription connectionDescription,
long startTimeNanos,
CommandListener commandListener) |
private void |
QueryProtocol.sendQuerySucceededEvent(ConnectionDescription connectionDescription,
long startTimeNanos,
QueryMessage message,
boolean isExplainEvent,
ResponseBuffers responseBuffers,
QueryResult<T> queryResult) |
private void |
X509Authenticator.validateUserName(ConnectionDescription connectionDescription) |
Constructor and Description |
---|
CompoundAuthenticator(InternalConnection internalConnection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
GetMoreResultCallback(SingleResultCallback<QueryResult<T>> callback,
long cursorId,
GetMoreMessage message,
ConnectionDescription connectionDescription,
CommandListener commandListener,
long startTimeNanos) |
QueryResultCallback(SingleResultCallback<QueryResult<T>> callback,
int requestId,
long startTimeNanos,
QueryMessage message,
boolean isExplainEvent,
ConnectionDescription connectionDescription) |
Modifier and Type | Field and Description |
---|---|
private ConnectionDescription |
CommandEvent.connectionDescription |
Modifier and Type | Method and Description |
---|---|
ConnectionDescription |
CommandEvent.getConnectionDescription()
Gets the description of the connection to which the operation will be sent.
|
Constructor and Description |
---|
CommandEvent(int requestId,
ConnectionDescription connectionDescription,
java.lang.String commandName)
Construct an instance.
|
CommandFailedEvent(int requestId,
ConnectionDescription connectionDescription,
java.lang.String commandName,
long elapsedTimeNanos,
java.lang.Throwable throwable)
Construct an instance.
|
CommandStartedEvent(int requestId,
ConnectionDescription connectionDescription,
java.lang.String databaseName,
java.lang.String commandName,
BsonDocument command)
Construct an instance.
|
CommandSucceededEvent(int requestId,
ConnectionDescription connectionDescription,
java.lang.String commandName,
BsonDocument response,
long elapsedTimeNanos)
Construct an instance.
|
Modifier and Type | Field and Description |
---|---|
private ConnectionDescription |
BulkWriteBatch.connectionDescription |
Modifier and Type | Method and Description |
---|---|
(package private) static void |
WriteConcernHelper.appendWriteConcernToCommand(WriteConcern writeConcern,
BsonDocument commandDocument,
ConnectionDescription description) |
private BsonDocument |
FindOperation.asDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
private BsonDocument |
ListCollectionsOperation.asQueryDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
private BsonDocument |
ListIndexesOperation.asQueryDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
private CommandOperationHelper.CommandTransformer<BsonDocument,AsyncBatchCursor<T>> |
DistinctOperation.asyncTransformer(ConnectionDescription connectionDescription) |
(package private) static boolean |
OperationHelper.canRetryWrite(ServerDescription serverDescription,
ConnectionDescription connectionDescription) |
(package private) static void |
OperationHelper.checkBypassDocumentValidationIsSupported(ConnectionDescription connectionDescription,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern) |
BsonDocument |
CommandOperationHelper.CommandCreator.create(ServerDescription serverDescription,
ConnectionDescription connectionDescription) |
static BulkWriteBatch |
BulkWriteBatch.createBulkWriteBatch(MongoNamespace namespace,
ServerDescription serverDescription,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
java.util.List<? extends WriteRequest> writeRequests,
SessionContext sessionContext) |
private QueryResult<T> |
DistinctOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
GroupOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
ListDatabasesOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
AggregateOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private QueryResult<T> |
MapReduceWithInlineResultsOperation.createQueryResult(BsonDocument result,
ConnectionDescription description) |
private BsonDocument |
MapReduceToCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateViewOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
AggregateToCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
RenameCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropIndexOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropDatabaseOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
UpdateUserOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateIndexesOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
DropUserOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateUserOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
CreateCollectionOperation.getCommand(ConnectionDescription description) |
private BsonDocument |
AggregateOperation.getCommand(ConnectionDescription description,
SessionContext sessionContext) |
private boolean |
AggregateOperation.isInline(ConnectionDescription description) |
(package private) static boolean |
OperationHelper.isRetryableWrite(boolean retryWrites,
WriteConcern writeConcern,
ServerDescription serverDescription,
ConnectionDescription connectionDescription) |
(package private) static boolean |
OperationHelper.serverIsAtLeastVersion(ConnectionDescription description,
ServerVersion serverVersion) |
(package private) static boolean |
OperationHelper.serverIsAtLeastVersionThreeDotFour(ConnectionDescription description) |
(package private) static boolean |
OperationHelper.serverIsAtLeastVersionThreeDotSix(ConnectionDescription description) |
(package private) static boolean |
OperationHelper.serverIsAtLeastVersionThreeDotTwo(ConnectionDescription description) |
(package private) static boolean |
OperationHelper.serverIsAtLeastVersionThreeDotZero(ConnectionDescription description) |
(package private) static void |
OperationHelper.validateCollation(ConnectionDescription connectionDescription,
Collation collation) |
(package private) static void |
OperationHelper.validateCollationAndWriteConcern(ConnectionDescription connectionDescription,
Collation collation,
WriteConcern writeConcern) |
(package private) static void |
OperationHelper.validateWriteRequestCollations(ConnectionDescription connectionDescription,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern) |
(package private) static void |
OperationHelper.validateWriteRequests(ConnectionDescription connectionDescription,
java.lang.Boolean bypassDocumentValidation,
java.util.List<? extends WriteRequest> requests,
WriteConcern writeConcern) |
Constructor and Description |
---|
BulkWriteBatch(MongoNamespace namespace,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
IndexMap indexMap,
WriteRequest.Type batchType,
BsonDocument command,
SplittablePayload payload,
java.util.List<BulkWriteBatch.WriteRequestWithIndex> unprocessed,
SessionContext sessionContext) |
BulkWriteBatch(MongoNamespace namespace,
ConnectionDescription connectionDescription,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
boolean retryWrites,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
java.util.List<BulkWriteBatch.WriteRequestWithIndex> writeRequestsWithIndices,
SessionContext sessionContext) |