Package | Description |
---|---|
com.mongodb.assertions |
Contains design by contract assertions
|
com.mongodb.async |
This package contains async interfaces
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.async.client.gridfs |
Contains the classes for supporting MongoDB's specification for storing very large files, GridFS.
|
com.mongodb.async.client.gridfs.helpers |
Contains helper classes to create
AsyncInputStream and
AsyncOutputStream 's from external sources. |
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.internal.async | |
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Method and Description |
---|---|
static void |
Assertions.isTrue(java.lang.String name,
boolean condition,
SingleResultCallback<?> callback)
Throw IllegalStateException if the condition if false.
|
static <T> T |
Assertions.notNull(java.lang.String name,
T value,
SingleResultCallback<?> callback)
Throw IllegalArgumentException if the value is null.
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncBatchCursor.next(SingleResultCallback<java.util.List<T>> callback)
Returns the next batch of results.
|
Modifier and Type | Field and Description |
---|---|
private Block<SingleResultCallback<java.util.List<TResult>>> |
FlatteningSingleResultCallbackSubscription.block |
private Block<SingleResultCallback<TResult>> |
SingleResultCallbackSubscription.block |
private java.util.List<SingleResultCallback<java.lang.Void>> |
AwaitingWriteOperationIterable.callbacks |
Modifier and Type | Method and Description |
---|---|
void |
AwaitingWriteOperationIterable.batchCursor(SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
OperationIterable.batchCursor(SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
MapReduceIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
FindIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
ListIndexesIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
ListCollectionsIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
DistinctIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
MongoIterable.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback)
Provide the underlying
AsyncBatchCursor allowing fine grained control of the cursor. |
void |
ListDatabasesIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
AggregateIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<TResult>> callback) |
void |
MappingIterable.batchCursor(SingleResultCallback<AsyncBatchCursor<U>> callback) |
void |
MongoCollection.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollectionImpl.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
BulkWriteOptions options,
SingleResultCallback<BulkWriteResult> callback) |
void |
MongoCollection.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback)
Executes a mix of inserts, updates, replaces, and deletes.
|
void |
MongoCollectionImpl.bulkWrite(java.util.List<? extends WriteModel<? extends TDocument>> requests,
SingleResultCallback<BulkWriteResult> callback) |
void |
MongoCollection.count(Bson filter,
CountOptions options,
SingleResultCallback<java.lang.Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollectionImpl.count(Bson filter,
CountOptions options,
SingleResultCallback<java.lang.Long> callback) |
void |
MongoCollection.count(Bson filter,
SingleResultCallback<java.lang.Long> callback)
Counts the number of documents in the collection according to the given options.
|
void |
MongoCollectionImpl.count(Bson filter,
SingleResultCallback<java.lang.Long> callback) |
void |
MongoCollection.count(SingleResultCallback<java.lang.Long> callback)
Counts the number of documents in the collection.
|
void |
MongoCollectionImpl.count(SingleResultCallback<java.lang.Long> callback) |
void |
MongoDatabase.createCollection(java.lang.String collectionName,
CreateCollectionOptions options,
SingleResultCallback<java.lang.Void> callback)
Create a new collection with the selected options
|
void |
MongoDatabaseImpl.createCollection(java.lang.String collectionName,
CreateCollectionOptions createCollectionOptions,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabase.createCollection(java.lang.String collectionName,
SingleResultCallback<java.lang.Void> callback)
Create a new collection with the given name.
|
void |
MongoDatabaseImpl.createCollection(java.lang.String collectionName,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.createIndex(Bson key,
IndexOptions options,
SingleResultCallback<java.lang.String> callback)
Creates an index.
|
void |
MongoCollectionImpl.createIndex(Bson key,
IndexOptions indexOptions,
SingleResultCallback<java.lang.String> callback) |
void |
MongoCollection.createIndex(Bson key,
SingleResultCallback<java.lang.String> callback)
Creates an index.
|
void |
MongoCollectionImpl.createIndex(Bson key,
SingleResultCallback<java.lang.String> callback) |
void |
MongoCollection.createIndexes(java.util.List<IndexModel> indexes,
SingleResultCallback<java.util.List<java.lang.String>> callback)
Create multiple indexes.
|
void |
MongoCollectionImpl.createIndexes(java.util.List<IndexModel> indexes,
SingleResultCallback<java.util.List<java.lang.String>> callback) |
void |
MongoDatabase.createView(java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions,
SingleResultCallback<java.lang.Void> callback)
Creates a view with the given name, backing collection/view name, aggregation pipeline, and options that defines the view.
|
void |
MongoDatabaseImpl.createView(java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
CreateViewOptions createViewOptions,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabase.createView(java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
SingleResultCallback<java.lang.Void> callback)
Creates a view with the given name, backing collection/view name, and aggregation pipeline that defines the view.
|
void |
MongoDatabaseImpl.createView(java.lang.String viewName,
java.lang.String viewOn,
java.util.List<? extends Bson> pipeline,
SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.delete(Bson filter,
DeleteOptions options,
boolean multi,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.deleteMany(Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback)
Removes all documents from the collection that match the given query filter.
|
void |
MongoCollectionImpl.deleteMany(Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.deleteMany(Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes all documents from the collection that match the given query filter.
|
void |
MongoCollectionImpl.deleteMany(Bson filter,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.deleteOne(Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback)
Removes at most one document from the collection that matches the given filter.
|
void |
MongoCollectionImpl.deleteOne(Bson filter,
DeleteOptions options,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.deleteOne(Bson filter,
SingleResultCallback<DeleteResult> callback)
Removes at most one document from the collection that matches the given filter.
|
void |
MongoCollectionImpl.deleteOne(Bson filter,
SingleResultCallback<DeleteResult> callback) |
void |
MongoCollection.drop(SingleResultCallback<java.lang.Void> callback)
Drops this collection from the Database.
|
void |
MongoDatabase.drop(SingleResultCallback<java.lang.Void> callback)
Drops this database.
|
void |
MongoCollectionImpl.drop(SingleResultCallback<java.lang.Void> callback) |
void |
MongoDatabaseImpl.drop(SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndex(Bson keys,
SingleResultCallback<java.lang.Void> callback)
Drops the index given the keys used to create it.
|
void |
MongoCollectionImpl.dropIndex(Bson keys,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndex(java.lang.String indexName,
SingleResultCallback<java.lang.Void> callback)
Drops the index given its name.
|
void |
MongoCollectionImpl.dropIndex(java.lang.String indexName,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.dropIndexes(SingleResultCallback<java.lang.Void> callback)
Drop all the indexes on this collection, except for the default on _id.
|
void |
MongoCollectionImpl.dropIndexes(SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.executeSingleWriteRequest(WriteRequest request,
java.lang.Boolean bypassDocumentValidation,
SingleResultCallback<BulkWriteResult> callback) |
void |
MongoCollection.findOneAndDelete(Bson filter,
FindOneAndDeleteOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollectionImpl.findOneAndDelete(Bson filter,
FindOneAndDeleteOptions options,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndDelete(Bson filter,
SingleResultCallback<TDocument> callback)
Atomically find a document and remove it.
|
void |
MongoCollectionImpl.findOneAndDelete(Bson filter,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndReplace(Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollectionImpl.findOneAndReplace(Bson filter,
TDocument replacement,
FindOneAndReplaceOptions options,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndReplace(Bson filter,
TDocument replacement,
SingleResultCallback<TDocument> callback)
Atomically find a document and replace it.
|
void |
MongoCollectionImpl.findOneAndReplace(Bson filter,
TDocument replacement,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndUpdate(Bson filter,
Bson update,
FindOneAndUpdateOptions options,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoCollectionImpl.findOneAndUpdate(Bson filter,
Bson update,
FindOneAndUpdateOptions options,
SingleResultCallback<TDocument> callback) |
void |
MongoCollection.findOneAndUpdate(Bson filter,
Bson update,
SingleResultCallback<TDocument> callback)
Atomically find a document and update it.
|
void |
MongoCollectionImpl.findOneAndUpdate(Bson filter,
Bson update,
SingleResultCallback<TDocument> callback) |
void |
AwaitingWriteOperationIterable.first(SingleResultCallback<T> callback) |
void |
OperationIterable.first(SingleResultCallback<T> callback) |
void |
MapReduceIterableImpl.first(SingleResultCallback<TResult> callback) |
void |
FindIterableImpl.first(SingleResultCallback<TResult> callback) |
void |
ListIndexesIterableImpl.first(SingleResultCallback<TResult> callback) |
void |
ListCollectionsIterableImpl.first(SingleResultCallback<TResult> callback) |
void |
DistinctIterableImpl.first(SingleResultCallback<TResult> callback) |
void |
MongoIterable.first(SingleResultCallback<TResult> callback)
Helper to return the first item in the iterator or null.
|
void |
ListDatabasesIterableImpl.first(SingleResultCallback<TResult> callback) |
void |
AggregateIterableImpl.first(SingleResultCallback<TResult> callback) |
void |
MappingIterable.first(SingleResultCallback<U> callback) |
void |
AwaitingWriteOperationIterable.forEach(Block<? super T> block,
SingleResultCallback<java.lang.Void> callback) |
void |
OperationIterable.forEach(Block<? super T> block,
SingleResultCallback<java.lang.Void> callback) |
void |
MapReduceIterableImpl.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
void |
FindIterableImpl.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
void |
ListIndexesIterableImpl.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
void |
ListCollectionsIterableImpl.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
void |
DistinctIterableImpl.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoIterable.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback)
Iterates over all documents in the view, applying the given block to each, and completing the returned future after all documents
have been iterated, or an exception has occurred.
|
void |
ListDatabasesIterableImpl.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
void |
AggregateIterableImpl.forEach(Block<? super TResult> block,
SingleResultCallback<java.lang.Void> callback) |
void |
MappingIterable.forEach(Block<? super U> block,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.insertMany(java.util.List<? extends TDocument> documents,
InsertManyOptions options,
SingleResultCallback<java.lang.Void> callback)
Inserts one or more documents.
|
void |
MongoCollectionImpl.insertMany(java.util.List<? extends TDocument> documents,
InsertManyOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.insertMany(java.util.List<? extends TDocument> documents,
SingleResultCallback<java.lang.Void> callback)
Inserts one or more documents.
|
void |
MongoCollectionImpl.insertMany(java.util.List<? extends TDocument> documents,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.insertOne(TDocument document,
InsertOneOptions options,
SingleResultCallback<java.lang.Void> callback)
Inserts the provided document.
|
void |
MongoCollectionImpl.insertOne(TDocument document,
InsertOneOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.insertOne(TDocument document,
SingleResultCallback<java.lang.Void> callback)
Inserts the provided document.
|
void |
MongoCollectionImpl.insertOne(TDocument document,
SingleResultCallback<java.lang.Void> callback) |
<A extends java.util.Collection<? super T>> |
AwaitingWriteOperationIterable.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super T>> |
OperationIterable.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super TResult>> |
MapReduceIterableImpl.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super TResult>> |
FindIterableImpl.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super TResult>> |
ListIndexesIterableImpl.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super TResult>> |
ListCollectionsIterableImpl.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super TResult>> |
DistinctIterableImpl.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super TResult>> |
MongoIterable.into(A target,
SingleResultCallback<A> callback)
Iterates over all the documents, adding each to the given target.
|
<A extends java.util.Collection<? super TResult>> |
ListDatabasesIterableImpl.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super TResult>> |
AggregateIterableImpl.into(A target,
SingleResultCallback<A> callback) |
<A extends java.util.Collection<? super U>> |
MappingIterable.into(A target,
SingleResultCallback<A> callback) |
private void |
OperationIterable.loopCursor(AsyncBatchCursor<T> batchCursor,
Block<? super T> block,
SingleResultCallback<java.lang.Void> callback) |
void |
MappingAsyncBatchCursor.next(SingleResultCallback<java.util.List<U>> callback) |
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<java.lang.Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollectionImpl.renameCollection(MongoNamespace newCollectionNamespace,
RenameCollectionOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.renameCollection(MongoNamespace newCollectionNamespace,
SingleResultCallback<java.lang.Void> callback)
Rename the collection with oldCollectionName to the newCollectionName.
|
void |
MongoCollectionImpl.renameCollection(MongoNamespace newCollectionNamespace,
SingleResultCallback<java.lang.Void> callback) |
void |
MongoCollection.replaceOne(Bson filter,
TDocument replacement,
SingleResultCallback<UpdateResult> callback)
Replace a document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.replaceOne(Bson filter,
TDocument replacement,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.replaceOne(Bson filter,
TDocument replacement,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Replace a document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.replaceOne(Bson filter,
TDocument replacement,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback) |
<TResult> void |
MongoDatabase.runCommand(Bson command,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback)
Executes the given command in the context of the current database with a read preference of
ReadPreference.primary() . |
<TResult> void |
MongoDatabaseImpl.runCommand(Bson command,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback) |
<TResult> void |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback)
Executes the given command in the context of the current database with the given read preference.
|
<TResult> void |
MongoDatabaseImpl.runCommand(Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback) |
void |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference,
SingleResultCallback<Document> callback)
Executes the given command in the context of the current database with the given read preference.
|
void |
MongoDatabaseImpl.runCommand(Bson command,
ReadPreference readPreference,
SingleResultCallback<Document> callback) |
void |
MongoDatabase.runCommand(Bson command,
SingleResultCallback<Document> callback)
Executes the given command in the context of the current database with a read preference of
ReadPreference.primary() . |
void |
MongoDatabaseImpl.runCommand(Bson command,
SingleResultCallback<Document> callback) |
void |
MapReduceIterableImpl.toCollection(SingleResultCallback<java.lang.Void> callback) |
void |
AggregateIterable.toCollection(SingleResultCallback<java.lang.Void> callback)
Aggregates documents according to the specified aggregation pipeline, which must end with a $out stage.
|
void |
MapReduceIterable.toCollection(SingleResultCallback<java.lang.Void> callback)
Aggregates documents to a collection according to the specified map-reduce function with the given options, which must specify a
non-inline result.
|
void |
AggregateIterableImpl.toCollection(SingleResultCallback<java.lang.Void> callback) |
private void |
MongoCollectionImpl.update(Bson filter,
Bson update,
UpdateOptions options,
boolean multi,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.updateMany(Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback)
Update all documents in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateMany(Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.updateMany(Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Update all documents in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateMany(Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.updateOne(Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback)
Update a single document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateOne(Bson filter,
Bson update,
SingleResultCallback<UpdateResult> callback) |
void |
MongoCollection.updateOne(Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback)
Update a single document in the collection according to the specified arguments.
|
void |
MongoCollectionImpl.updateOne(Bson filter,
Bson update,
UpdateOptions options,
SingleResultCallback<UpdateResult> callback) |
Modifier and Type | Method and Description |
---|---|
static <TResult> Observable<TResult> |
Observables.observe(Block<SingleResultCallback<TResult>> operation)
Allows the conversion of
SingleResultCallback based operations into an Observable |
static <TResult> Observable<TResult> |
Observables.observeAndFlatten(Block<SingleResultCallback<java.util.List<TResult>>> operation)
Allows the conversion of
SingleResultCallback based operations and flattens the results in an Observable . |
Constructor and Description |
---|
FlatteningSingleResultCallbackSubscription(Block<SingleResultCallback<java.util.List<TResult>>> block,
Observer<? super TResult> observer) |
SingleResultCallbackSubscription(Block<SingleResultCallback<TResult>> block,
Observer<? super TResult> observer) |
Modifier and Type | Method and Description |
---|---|
void |
GridFSUploadStream.abort(SingleResultCallback<java.lang.Void> callback)
Aborts the upload and deletes any data.
|
void |
GridFSUploadStreamImpl.abort(SingleResultCallback<java.lang.Void> callback) |
void |
GridFSFindIterableImpl.batchCursor(SingleResultCallback<AsyncBatchCursor<GridFSFile>> callback) |
private <T> void |
GridFSDownloadStreamImpl.callbackClosedException(SingleResultCallback<T> callback) |
private <T> void |
GridFSUploadStreamImpl.callbackClosedException(SingleResultCallback<T> callback) |
private <T> void |
GridFSDownloadStreamImpl.callbackIsReadingException(SingleResultCallback<T> callback) |
private <T> void |
GridFSUploadStreamImpl.callbackIsWritingException(SingleResultCallback<T> callback) |
void |
GridFSIndexCheckImpl.checkAndCreateIndex(SingleResultCallback<java.lang.Void> callback) |
void |
GridFSIndexCheck.checkAndCreateIndex(SingleResultCallback<java.lang.Void> callback) |
private void |
GridFSDownloadStreamImpl.checkAndFetchResults(int amountRead,
java.nio.ByteBuffer dst,
SingleResultCallback<java.lang.Integer> callback) |
private void |
GridFSIndexCheckImpl.checkChunksIndex(SingleResultCallback<java.lang.Void> callback) |
private void |
GridFSIndexCheckImpl.checkFilesIndex(SingleResultCallback<java.lang.Void> callback) |
void |
AsyncOutputStream.close(SingleResultCallback<java.lang.Void> callback)
Closes the output stream
|
void |
GridFSDownloadStreamImpl.close(SingleResultCallback<java.lang.Void> callback) |
void |
AsyncInputStream.close(SingleResultCallback<java.lang.Void> callback)
Closes the input stream
|
void |
GridFSUploadStreamImpl.close(SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucketImpl.delete(BsonValue id,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.delete(BsonValue id,
SingleResultCallback<java.lang.Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
void |
GridFSBucketImpl.delete(ObjectId id,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.delete(ObjectId id,
SingleResultCallback<java.lang.Void> callback)
Given a
id , delete this stored file's files collection document and associated chunks from a GridFS bucket. |
private void |
GridFSBucketImpl.downloadToAsyncOutputStream(GridFSDownloadStream downloadStream,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucketImpl.downloadToStream(BsonValue id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(BsonValue id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucketImpl.downloadToStream(ObjectId id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(ObjectId id,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the stored file specified by
id and writes the contents to the destination
AsyncOutputStream. |
void |
GridFSBucketImpl.downloadToStream(java.lang.String filename,
AsyncOutputStream destination,
GridFSDownloadOptions options,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(java.lang.String filename,
AsyncOutputStream destination,
GridFSDownloadOptions options,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the stored file specified by
filename and by the revision in options and writes the
contents to the destination Stream. |
void |
GridFSBucketImpl.downloadToStream(java.lang.String filename,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucket.downloadToStream(java.lang.String filename,
AsyncOutputStream destination,
SingleResultCallback<java.lang.Long> callback)
Downloads the contents of the latest version of the stored file specified by
filename and writes the contents to
the destination Stream. |
void |
GridFSBucketImpl.drop(SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.drop(SingleResultCallback<java.lang.Void> callback)
Drops the data associated with this bucket from the database.
|
void |
GridFSFindIterableImpl.first(SingleResultCallback<GridFSFile> callback) |
void |
GridFSFindIterableImpl.forEach(Block<? super GridFSFile> block,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSDownloadStream.getGridFSFile(SingleResultCallback<GridFSFile> callback)
Gets the corresponding
GridFSFile for the file being downloaded |
void |
GridFSDownloadStreamImpl.getGridFSFile(SingleResultCallback<GridFSFile> callback) |
private <T> void |
GridFSIndexCheckImpl.hasIndex(MongoCollection<T> collection,
Document index,
SingleResultCallback<java.lang.Boolean> callback) |
<A extends java.util.Collection<? super GridFSFile>> |
GridFSFindIterableImpl.into(A target,
SingleResultCallback<A> callback) |
private void |
GridFSDownloadStreamImpl.processResults(int previousAmountRead,
java.nio.ByteBuffer dst,
SingleResultCallback<java.lang.Integer> callback) |
void |
GridFSDownloadStreamImpl.read(java.nio.ByteBuffer dst,
SingleResultCallback<java.lang.Integer> callback) |
void |
AsyncInputStream.read(java.nio.ByteBuffer dst,
SingleResultCallback<java.lang.Integer> callback)
Reads a sequence of bytes from this stream into the given buffer.
|
private void |
GridFSBucketImpl.readAndWriteInputStream(AsyncInputStream source,
GridFSUploadStream uploadStream,
java.nio.ByteBuffer buffer,
SingleResultCallback<java.lang.Void> callback) |
private void |
GridFSBucketImpl.readAndWriteOutputStream(AsyncOutputStream destination,
GridFSDownloadStream downloadStream,
java.nio.ByteBuffer buffer,
long amountRead,
SingleResultCallback<java.lang.Long> callback) |
void |
GridFSBucketImpl.rename(BsonValue id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.rename(BsonValue id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback)
Renames the stored file with the specified
id . |
void |
GridFSBucketImpl.rename(ObjectId id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.rename(ObjectId id,
java.lang.String newFilename,
SingleResultCallback<java.lang.Void> callback)
Renames the stored file with the specified
id . |
private <T> boolean |
GridFSUploadStreamImpl.takeWritingLock(SingleResultCallback<T> errHandlingCallback) |
private <A> boolean |
GridFSDownloadStreamImpl.tryGetReadingLock(SingleResultCallback<A> callback) |
void |
GridFSBucketImpl.uploadFromStream(BsonValue id,
java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.uploadFromStream(BsonValue id,
java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<java.lang.Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucketImpl.uploadFromStream(BsonValue id,
java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<java.lang.Void> callback) |
void |
GridFSBucket.uploadFromStream(BsonValue id,
java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<java.lang.Void> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucketImpl.uploadFromStream(java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<ObjectId> callback) |
void |
GridFSBucket.uploadFromStream(java.lang.String filename,
AsyncInputStream source,
GridFSUploadOptions options,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
GridFSBucketImpl.uploadFromStream(java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<ObjectId> callback) |
void |
GridFSBucket.uploadFromStream(java.lang.String filename,
AsyncInputStream source,
SingleResultCallback<ObjectId> callback)
Uploads the contents of the given
AsyncInputStream to a GridFS bucket. |
void |
AsyncOutputStream.write(java.nio.ByteBuffer src,
SingleResultCallback<java.lang.Integer> callback)
Writes a sequence of bytes from the given buffer into this stream.
|
void |
GridFSUploadStreamImpl.write(java.nio.ByteBuffer src,
SingleResultCallback<java.lang.Integer> callback) |
private void |
GridFSUploadStreamImpl.write(int amount,
java.nio.ByteBuffer src,
SingleResultCallback<java.lang.Integer> callback) |
private void |
GridFSUploadStreamImpl.writeChunk(SingleResultCallback<java.lang.Void> callback) |
Modifier and Type | Method and Description |
---|---|
private static void |
AsyncStreamHelper.transferDataFromByteBuffers(java.nio.ByteBuffer srcByteBuffer,
java.nio.ByteBuffer dstByteBuffer,
SingleResultCallback<java.lang.Integer> callback) |
Modifier and Type | Method and Description |
---|---|
private void |
AsyncClusterBinding.getAsyncClusterBindingConnectionSource(ServerSelector serverSelector,
SingleResultCallback<AsyncConnectionSource> callback) |
void |
AsyncSingleConnectionReadBinding.AsyncSingleConnectionSource.getConnection(SingleResultCallback<AsyncConnection> callback) |
void |
AsyncConnectionSource.getConnection(SingleResultCallback<AsyncConnection> callback)
Gets a connection from this source.
|
void |
AsyncClusterBinding.AsyncClusterBindingConnectionSource.getConnection(SingleResultCallback<AsyncConnection> callback) |
void |
AsyncSingleConnectionReadBinding.getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback) |
void |
AsyncReadBinding.getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
Returns a connection source to a server that satisfies the specified read preference.
|
void |
AsyncClusterBinding.getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback) |
void |
AsyncWriteBinding.getWriteConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
Supply a connection source to a server that can be written to
|
void |
AsyncClusterBinding.getWriteConnectionSource(SingleResultCallback<AsyncConnectionSource> callback) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
CommandProtocol.CommandResultCallback |
(package private) class |
CommandResultBaseCallback<T> |
(package private) class |
CommandResultCallback<T> |
(package private) class |
GetMoreProtocol.GetMoreResultCallback |
private class |
InternalStreamConnection.ResponseBuffersCallback |
private class |
InternalStreamConnection.ResponseHeaderCallback |
private class |
InternalStreamConnection.ResponseHeaderCallback.ResponseBodyCallback |
private class |
InternalStreamConnectionInitializer.CompoundAuthenticator |
(package private) class |
QueryProtocol.QueryResultCallback |
(package private) class |
ResponseCallback |
private class |
SaslAuthenticator.Continuator |
(package private) class |
SendMessageCallback<T> |
private class |
WriteProtocol.UnacknowledgedWriteResultCallback |
private class |
WriteProtocol.WriteResultCallback |
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<T> |
CommandProtocol.CommandResultCallback.callback |
private SingleResultCallback<Server> |
BaseCluster.ServerSelectionRequest.callback |
private SingleResultCallback<T> |
SendMessageCallback.callback |
private SingleResultCallback<T> |
CommandResultCallback.callback |
private SingleResultCallback<QueryResult<T>> |
QueryProtocol.QueryResultCallback.callback |
private SingleResultCallback<java.lang.Void> |
SaslAuthenticator.Continuator.callback |
private SingleResultCallback<java.lang.Void> |
InternalStreamConnectionInitializer.CompoundAuthenticator.callback |
private SingleResultCallback<ResponseBuffers> |
InternalStreamConnection.ResponseHeaderCallback.callback |
private SingleResultCallback<java.lang.Void> |
InternalStreamConnection.SendMessageRequest.callback |
private SingleResultCallback<QueryResult<T>> |
GetMoreProtocol.GetMoreResultCallback.callback |
private SingleResultCallback<WriteConcernResult> |
WriteProtocol.WriteResultCallback.callback |
private SingleResultCallback<WriteConcernResult> |
WriteProtocol.UnacknowledgedWriteResultCallback.callback |
private SingleResultCallback<ResponseBuffers> |
SendMessageCallback.receiveMessageCallback |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.Integer,SingleResultCallback<ResponseBuffers>> |
InternalStreamConnection.readQueue |
Modifier and Type | Method and Description |
---|---|
private SingleResultCallback<ConnectionDescription> |
InternalStreamConnectionInitializer.createConnectionDescriptionCallback(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
SingleResultCallback<java.lang.Void> |
InternalStreamConnection.SendMessageRequest.getCallback() |
Modifier and Type | Method and Description |
---|---|
(package private) abstract void |
Authenticator.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) void |
X509Authenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
NativeAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
(package private) void |
SaslAuthenticator.authenticateAsync(InternalConnection connection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
<T> void |
AsyncConnection.commandAsync(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
SingleResultCallback<T> callback)
Execute the command asynchronously.
|
<T> void |
DefaultServerConnection.commandAsync(java.lang.String database,
BsonDocument command,
boolean slaveOk,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
SingleResultCallback<T> callback) |
private void |
InternalStreamConnectionInitializer.completeConnectionDescriptionInitializationAsync(InternalConnection internalConnection,
ConnectionDescription connectionDescription,
SingleResultCallback<ConnectionDescription> callback) |
private SingleResultCallback<ConnectionDescription> |
InternalStreamConnectionInitializer.createConnectionDescriptionCallback(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
void |
AsyncConnection.deleteAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<WriteConcernResult> callback)
Delete the documents using the delete wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.deleteAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<WriteConcernResult> callback) |
void |
AsyncConnection.deleteCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<BulkWriteResult> callback)
Delete the documents using the delete command asynchronously.
|
void |
DefaultServerConnection.deleteCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<DeleteRequest> deletes,
SingleResultCallback<BulkWriteResult> callback) |
void |
DeleteCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
InsertCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
UpdateCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
WriteCommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
QueryProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
void |
GetMoreProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<QueryResult<T>> callback) |
void |
CommandProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<T> callback) |
void |
Protocol.executeAsync(InternalConnection connection,
SingleResultCallback<T> callback)
Execute the protocol asynchronously.
|
void |
KillCursorProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<java.lang.Void> callback) |
void |
DeleteProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
UpdateProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
InsertProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
void |
WriteProtocol.executeAsync(InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
<T> void |
DefaultServer.DefaultServerProtocolExecutor.executeAsync(Protocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
<T> void |
ProtocolExecutor.executeAsync(Protocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
private void |
WriteProtocol.executeAsync(RequestMessage requestMessage,
InternalConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
private void |
WriteCommandProtocol.executeBatchesAsync(InternalConnection connection,
BaseWriteCommandMessage message,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
int batchNum,
int currentRangeStartIndex,
SingleResultCallback<BulkWriteResult> callback) |
private void |
InternalStreamConnection.executeCallbackAndReceiveResponse(SingleResultCallback<ResponseBuffers> callback,
ResponseBuffers result,
boolean mustRead) |
(package private) static void |
CommandHelper.executeCommandAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<BsonDocument> callback) |
private <T> void |
DefaultServerConnection.executeProtocolAsync(Protocol<T> protocol,
SingleResultCallback<T> callback) |
void |
ConnectionPool.getAsync(SingleResultCallback<InternalConnection> callback) |
void |
DefaultConnectionPool.getAsync(SingleResultCallback<InternalConnection> callback) |
void |
Server.getConnectionAsync(SingleResultCallback<AsyncConnection> callback)
Gets a connection to this server asynchronously.
|
void |
DefaultServer.getConnectionAsync(SingleResultCallback<AsyncConnection> callback) |
<T> void |
AsyncConnection.getMoreAsync(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback)
Get more result documents from a cursor asynchronously.
|
<T> void |
DefaultServerConnection.getMoreAsync(MongoNamespace namespace,
long cursorId,
int numberToReturn,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback) |
void |
InternalStreamConnectionInitializer.initializeAsync(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
void |
InternalConnectionInitializer.initializeAsync(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
private void |
InternalStreamConnectionInitializer.initializeConnectionDescriptionAsync(InternalConnection internalConnection,
SingleResultCallback<ConnectionDescription> callback) |
void |
AsyncConnection.insertAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<WriteConcernResult> callback)
Insert the documents using the insert wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.insertAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<WriteConcernResult> callback) |
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
Insert the documents using the insert command asynchronously.
|
void |
DefaultServerConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback) |
void |
AsyncConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback)
|
void |
DefaultServerConnection.insertCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<InsertRequest> inserts,
SingleResultCallback<BulkWriteResult> callback) |
void |
AsyncConnection.killCursorAsync(java.util.List<java.lang.Long> cursors,
SingleResultCallback<java.lang.Void> callback)
Deprecated.
|
void |
DefaultServerConnection.killCursorAsync(java.util.List<java.lang.Long> cursors,
SingleResultCallback<java.lang.Void> callback) |
void |
AsyncConnection.killCursorAsync(MongoNamespace namespace,
java.util.List<java.lang.Long> cursors,
SingleResultCallback<java.lang.Void> callback)
Asynchronously Kills the given list of cursors.
|
void |
DefaultServerConnection.killCursorAsync(MongoNamespace namespace,
java.util.List<java.lang.Long> cursors,
SingleResultCallback<java.lang.Void> callback) |
private void |
DefaultConnectionPool.openAsync(DefaultConnectionPool.PooledConnection pooledConnection,
SingleResultCallback<InternalConnection> callback) |
void |
UsageTrackingInternalConnection.openAsync(SingleResultCallback<java.lang.Void> callback) |
void |
InternalStreamConnection.openAsync(SingleResultCallback<java.lang.Void> callback) |
void |
InternalConnection.openAsync(SingleResultCallback<java.lang.Void> callback)
Opens the connection so its ready for use
|
void |
DefaultConnectionPool.PooledConnection.openAsync(SingleResultCallback<java.lang.Void> callback) |
<T> void |
AsyncConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int numberToReturn,
int skip,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback)
|
<T> void |
DefaultServerConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int numberToReturn,
int skip,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback) |
<T> void |
AsyncConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int skip,
int limit,
int batchSize,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback)
Execute the query asynchronously.
|
<T> void |
DefaultServerConnection.queryAsync(MongoNamespace namespace,
BsonDocument queryDocument,
BsonDocument fields,
int skip,
int limit,
int batchSize,
boolean slaveOk,
boolean tailableCursor,
boolean awaitData,
boolean noCursorTimeout,
boolean partial,
boolean oplogReplay,
Decoder<T> resultDecoder,
SingleResultCallback<QueryResult<T>> callback) |
private void |
InternalStreamConnection.readAsync(int numBytes,
SingleResultCallback<ByteBuf> callback) |
void |
UsageTrackingInternalConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback) |
void |
InternalStreamConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback) |
void |
InternalConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback)
Asynchronously receive a response to a sent message from the server.
|
void |
DefaultConnectionPool.PooledConnection.receiveMessageAsync(int responseTo,
SingleResultCallback<ResponseBuffers> callback) |
private static void |
CommandHelper.receiveReplyAsync(InternalConnection internalConnection,
CommandMessage message,
SingleResultCallback<ReplyMessage<BsonDocument>> callback) |
void |
Cluster.selectServerAsync(ServerSelector serverSelector,
SingleResultCallback<Server> callback)
Asynchronously gets a MongoDB server that matches the criteria defined by the serverSelector.
|
void |
BaseCluster.selectServerAsync(ServerSelector serverSelector,
SingleResultCallback<Server> callback) |
private void |
WriteCommandProtocol.sendMessageAsync(InternalConnection connection,
ByteBufferBsonOutput buffer,
BaseWriteCommandMessage message,
long startTimeNanos,
SingleResultCallback<BulkWriteResult> clientCallback,
SingleResultCallback<BsonDocument> callback) |
private void |
WriteCommandProtocol.sendMessageAsync(InternalConnection connection,
ByteBufferBsonOutput buffer,
BaseWriteCommandMessage message,
long startTimeNanos,
SingleResultCallback<BulkWriteResult> clientCallback,
SingleResultCallback<BsonDocument> callback) |
void |
UsageTrackingInternalConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback) |
void |
InternalStreamConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback) |
void |
InternalConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback)
Asynchronously send a message to the server.
|
void |
DefaultConnectionPool.PooledConnection.sendMessageAsync(java.util.List<ByteBuf> byteBuffers,
int lastRequestId,
SingleResultCallback<java.lang.Void> callback) |
private static void |
CommandHelper.sendMessageAsync(java.lang.String database,
BsonDocument command,
InternalConnection internalConnection,
SingleResultCallback<CommandMessage> callback) |
private void |
SaslAuthenticator.sendSaslContinueAsync(BsonInt32 conversationId,
byte[] outToken,
InternalConnection connection,
SingleResultCallback<BsonDocument> callback) |
private void |
SaslAuthenticator.sendSaslStartAsync(byte[] outToken,
InternalConnection connection,
SingleResultCallback<BsonDocument> callback) |
void |
AsyncConnection.updateAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<WriteConcernResult> callback)
Update the documents using the update wire protocol and apply the write concern asynchronously.
|
void |
DefaultServerConnection.updateAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<WriteConcernResult> callback) |
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
Update the documents using the update command asynchronously.
|
void |
DefaultServerConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback) |
void |
AsyncConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback)
|
void |
DefaultServerConnection.updateCommandAsync(MongoNamespace namespace,
boolean ordered,
WriteConcern writeConcern,
java.util.List<UpdateRequest> updates,
SingleResultCallback<BulkWriteResult> callback) |
Constructor and Description |
---|
CommandResultCallback(SingleResultCallback<T> callback,
CommandMessage message,
ConnectionDescription connectionDescription,
long startTimeNanos) |
CommandResultCallback(SingleResultCallback<T> callback,
Decoder<T> decoder,
long requestId,
ServerAddress serverAddress) |
CompoundAuthenticator(InternalConnection internalConnection,
ConnectionDescription connectionDescription,
SingleResultCallback<java.lang.Void> callback) |
Continuator(javax.security.sasl.SaslClient saslClient,
BsonDocument saslStartDocument,
InternalConnection connection,
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) |
ResponseHeaderCallback(SingleResultCallback<ResponseBuffers> callback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
int requestId,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
int requestId,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
SendMessageCallback(InternalConnection connection,
OutputBuffer buffer,
RequestMessage message,
java.lang.String commandName,
long startTimeNanos,
CommandListener commandListener,
SingleResultCallback<T> callback,
SingleResultCallback<ResponseBuffers> receiveMessageCallback) |
SendMessageRequest(java.util.List<ByteBuf> byteBuffers,
int messageId,
SingleResultCallback<java.lang.Void> callback) |
ServerSelectionRequest(ServerSelector serverSelector,
ServerSelector compositeSelector,
long maxWaitTimeNanos,
SingleResultCallback<Server> callback) |
UnacknowledgedWriteResultCallback(SingleResultCallback<WriteConcernResult> callback,
RequestMessage message,
RequestMessage nextMessage,
OutputBuffer writtenBuffer,
InternalConnection connection,
long startTimeNanos) |
WriteResultCallback(SingleResultCallback<WriteConcernResult> callback,
Decoder<BsonDocument> decoder,
RequestMessage message,
RequestMessage nextMessage,
long requestId,
InternalConnection connection,
long startTimeNanos) |
Modifier and Type | Class and Description |
---|---|
class |
ErrorHandlingResultCallback<T>
This class is not part of the public API and may be removed or changed at any time.
|
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<T> |
ErrorHandlingResultCallback.wrapped |
Modifier and Type | Method and Description |
---|---|
static <T> SingleResultCallback<T> |
ErrorHandlingResultCallback.errorHandlingCallback(SingleResultCallback<T> callback,
Logger logger) |
Modifier and Type | Method and Description |
---|---|
static <T> SingleResultCallback<T> |
ErrorHandlingResultCallback.errorHandlingCallback(SingleResultCallback<T> callback,
Logger logger) |
Constructor and Description |
---|
ErrorHandlingResultCallback(SingleResultCallback<T> wrapped,
Logger logger) |
Modifier and Type | Class and Description |
---|---|
private class |
AsyncQueryBatchCursor.CommandResultSingleResultCallback |
private class |
AsyncQueryBatchCursor.QueryResultSingleResultCallback |
private static class |
CommandOperationHelper.CommandProtocolExecutingCallback<D,R> |
private static class |
FindOperation.ExplainResultCallback |
private static class |
OperationHelper.AsyncCallableWithConnectionAndSourceCallback |
private static class |
OperationHelper.AsyncCallableWithConnectionCallback |
private static class |
OperationHelper.ReferenceCountedReleasingWrappedCallback<T> |
Modifier and Type | Field and Description |
---|---|
private SingleResultCallback<BsonDocument> |
FindOperation.ExplainResultCallback.callback |
private SingleResultCallback<R> |
CommandOperationHelper.CommandProtocolExecutingCallback.callback |
private SingleResultCallback<java.util.List<T>> |
AsyncQueryBatchCursor.CommandResultSingleResultCallback.callback |
private SingleResultCallback<java.util.List<T>> |
AsyncQueryBatchCursor.QueryResultSingleResultCallback.callback |
private SingleResultCallback<T> |
OperationHelper.ReferenceCountedReleasingWrappedCallback.wrapped |
Modifier and Type | Method and Description |
---|---|
private static <T> SingleResultCallback<T> |
FindOperation.exceptionTransformingCallback(SingleResultCallback<T> callback) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncConnection connection) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncConnectionSource source,
AsyncConnection connection) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncReadBinding readBinding,
AsyncConnectionSource source,
AsyncConnection connection) |
(package private) static SingleResultCallback<java.lang.Void> |
UserOperationHelper.userCommandCallback(SingleResultCallback<java.lang.Void> wrappedCallback) |
Modifier and Type | Method and Description |
---|---|
private static <T> SingleResultCallback<T> |
FindOperation.exceptionTransformingCallback(SingleResultCallback<T> callback) |
<T> void |
AsyncOperationExecutor.execute(AsyncReadOperation<T> operation,
ReadPreference readPreference,
SingleResultCallback<T> callback)
Execute the read operation with the given read preference.
|
<T> void |
AsyncOperationExecutor.execute(AsyncWriteOperation<T> operation,
SingleResultCallback<T> callback)
Execute the write operation.
|
(package private) void |
MixedBulkWriteOperation.Run.executeAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
void |
AggregateOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListDatabasesOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListIndexesOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
FindOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
DistinctOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListCollectionsOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
GroupOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
UserExistsOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<java.lang.Boolean> callback) |
void |
AggregateExplainOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<BsonDocument> callback) |
void |
ParallelCollectionScanOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<java.util.List<AsyncBatchCursor<T>>> callback) |
void |
CountOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<java.lang.Long> callback) |
void |
MapReduceWithInlineResultsOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<MapReduceAsyncBatchCursor<T>> callback) |
void |
CommandReadOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<T> callback) |
void |
AsyncReadOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<T> callback)
General execute which can return anything of type T
|
void |
MixedBulkWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<BulkWriteResult> callback) |
void |
MapReduceToCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<MapReduceStatistics> callback) |
void |
FindAndUpdateOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback) |
void |
CommandWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback) |
void |
FindAndReplaceOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback) |
void |
AsyncWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback)
General execute which can return anything of type T
|
void |
FindAndDeleteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback) |
void |
AggregateToCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropDatabaseOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropIndexOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateIndexesOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateViewOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
UpdateUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
RenameCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
BaseWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<WriteConcernResult> callback) |
(package private) void |
MixedBulkWriteOperation.Run.AsyncRunExecutor.executeAsync(SingleResultCallback<BulkWriteResult> callback) |
protected void |
DeleteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
InsertOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected void |
UpdateOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback) |
protected abstract void |
BaseWriteOperation.executeCommandProtocolAsync(AsyncConnection connection,
SingleResultCallback<BulkWriteResult> callback)
Asynchronously executes the write command protocol.
|
protected void |
DeleteOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected void |
InsertOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected void |
UpdateOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback) |
protected abstract void |
BaseWriteOperation.executeProtocolAsync(AsyncConnection connection,
SingleResultCallback<WriteConcernResult> callback)
Asynchronously executes the write protocol
|
private void |
MixedBulkWriteOperation.executeRunsAsync(java.util.Iterator<MixedBulkWriteOperation.Run> runs,
AsyncConnection connection,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
SingleResultCallback<BulkWriteResult> callback) |
private void |
MixedBulkWriteOperation.Run.AsyncRunExecutor.executeRunWritesAsync(int numberOfRuns,
int currentPosition,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
SingleResultCallback<BulkWriteResult> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
SingleResultCallback<T> callback) |
(package private) static void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncReadBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
AsyncConnection connection,
SingleResultCallback<BsonDocument> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
SingleResultCallback<T> callback) |
(package private) static <T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<BsonDocument> decoder,
AsyncConnection connection,
CommandOperationHelper.CommandTransformer<BsonDocument,T> transformer,
SingleResultCallback<T> callback) |
(package private) static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) static void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(AsyncWriteBinding binding,
java.lang.String database,
BsonDocument command,
SingleResultCallback<BsonDocument> callback) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) abstract void |
MixedBulkWriteOperation.Run.AsyncRunExecutor.executeWriteCommandProtocolAsync(SingleResultCallback<BulkWriteResult> callback) |
(package private) abstract void |
MixedBulkWriteOperation.Run.AsyncRunExecutor.executeWriteProtocolAsync(int index,
SingleResultCallback<WriteConcernResult> callback) |
private void |
AsyncQueryBatchCursor.getMore(AsyncConnection connection,
ServerCursor cursor,
SingleResultCallback<java.util.List<T>> callback) |
private void |
AsyncQueryBatchCursor.getMore(ServerCursor cursor,
SingleResultCallback<java.util.List<T>> callback) |
private void |
AsyncQueryBatchCursor.handleGetMoreQueryResult(AsyncConnection connection,
SingleResultCallback<java.util.List<T>> callback,
QueryResult<T> result) |
void |
ListCollectionsOperation.ProjectingAsyncBatchCursor.next(SingleResultCallback<java.util.List<T>> callback) |
void |
AsyncQueryBatchCursor.next(SingleResultCallback<java.util.List<T>> callback) |
void |
AsyncSingleBatchQueryCursor.next(SingleResultCallback<java.util.List<T>> callback) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncConnection connection) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncConnectionSource source,
AsyncConnection connection) |
(package private) static <T> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncReadBinding readBinding,
AsyncConnectionSource source,
AsyncConnection connection) |
(package private) static SingleResultCallback<java.lang.Void> |
UserOperationHelper.userCommandCallback(SingleResultCallback<java.lang.Void> wrappedCallback) |
Constructor and Description |
---|
CommandProtocolExecutingCallback(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,R> transformer,
SingleResultCallback<R> callback) |
CommandResultSingleResultCallback(AsyncConnection connection,
ServerCursor cursor,
SingleResultCallback<java.util.List<T>> callback) |
ExplainResultCallback(SingleResultCallback<BsonDocument> callback) |
QueryResultSingleResultCallback(AsyncConnection connection,
SingleResultCallback<java.util.List<T>> callback) |
ReferenceCountedReleasingWrappedCallback(SingleResultCallback<T> wrapped,
java.util.List<? extends ReferenceCounted> referenceCounted) |