| Package | Description |
|---|---|
| com.allanbank.mongodb |
Provides a Java driver for the MongoDB document store that allows asynchronous invocation of requests.
|
| com.allanbank.mongodb.client |
Provides implementations of the main client interfaces and classes to translate the
Reply(s) from the server. |
| com.allanbank.mongodb.client.callback |
Provides implementation for various transformations, implemented in the form of
Callbacks, that are used by the driver. |
| com.allanbank.mongodb.client.state |
Support for tracking the state of a set of MongoDB servers.
|
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync()
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(Count count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.countAsync(ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.deleteAsync(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.deleteAsync(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.distinctAsync(Distinct.Builder command)
Invokes a distinct command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.distinctAsync(Distinct command)
Invokes a distinct command on the server.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Find.Builder query)
Explains the way that the document will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.explainAsync(Find query)
Explains the way that the document will be performed.
|
ListenableFuture<Document> |
AsyncMongoCollection.findAndModifyAsync(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
ListenableFuture<Document> |
AsyncMongoCollection.findAndModifyAsync(FindAndModify command)
Invokes a findAndModify command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.findAsync(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.findAsync(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.findAsync(Find query)
Finds the set of documents matching the query in the collection.
|
ListenableFuture<Document> |
AsyncMongoCollection.findOneAsync(DocumentAssignable query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AsyncMongoCollection.findOneAsync(Find.Builder query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AsyncMongoCollection.findOneAsync(Find query)
Finds a single matching document in the collection.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.groupByAsync(GroupBy.Builder command)
Invokes a group command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AsyncMongoCollection.groupByAsync(GroupBy command)
Invokes a group command on the server.
|
ListenableFuture<Integer> |
AsyncMongoCollection.insertAsync(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AsyncMongoCollection.insertAsync(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AsyncMongoCollection.insertAsync(DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AsyncMongoCollection.insertAsync(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AsyncMongoCollection.mapReduceAsync(MapReduce command)
Invokes a mapReduce command on the server.
|
ListenableFuture<Collection<MongoIterator<Document>>> |
AsyncMongoCollection.parallelScanAsync(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AsyncMongoCollection.parallelScanAsync(ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(DocumentAssignable command)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String command)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String command,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabase.runCommandAsync(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Integer> |
AsyncMongoCollection.saveAsync(DocumentAssignable document)
Saves the
document to the collection. |
ListenableFuture<Integer> |
AsyncMongoCollection.saveAsync(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
ListenableFuture<MongoIterator<TextResult>> |
AsyncMongoCollection.textSearchAsync(Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<MongoIterator<TextResult>> |
AsyncMongoCollection.textSearchAsync(Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<Long> |
AsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AsyncMongoCollection.writeAsync(BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
ListenableFuture<Long> |
AsyncMongoCollection.writeAsync(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FutureCallback<V>
Implementation of a
Callback and ListenableFuture interfaces. |
| Modifier and Type | Method and Description |
|---|---|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.aggregateAsync(Aggregate.Builder command)
Invokes a aggregate command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.aggregateAsync(Aggregate command)
Invokes a aggregate command on the server.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync()
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(Count.Builder count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(Count count)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(DocumentAssignable query)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(DocumentAssignable query,
ReadPreference readPreference)
Counts the set of documents matching the query document in the
collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.countAsync(ReadPreference readPreference)
Counts the set of documents in the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.deleteAsync(DocumentAssignable query)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.deleteAsync(DocumentAssignable query,
boolean singleDelete,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.deleteAsync(DocumentAssignable query,
Durability durability)
Deletes a set of documents matching a query from the collection.
|
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.distinctAsync(Distinct.Builder command)
Invokes a distinct command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.distinctAsync(Distinct command)
Invokes a distinct command on the server.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Aggregate.Builder aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Aggregate aggregation)
Explains the way that the aggregation will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Find.Builder query)
Explains the way that the document will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.explainAsync(Find query)
Explains the way that the document will be performed.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findAndModifyAsync(FindAndModify.Builder command)
Invokes a findAndModify command on the server.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findAndModifyAsync(FindAndModify command)
Invokes a findAndModify command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.findAsync(DocumentAssignable query)
Finds the set of documents matching the query document in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.findAsync(Find.Builder query)
Finds the set of documents matching the query in the collection.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.findAsync(Find query)
Finds the set of documents matching the query in the collection.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findOneAsync(DocumentAssignable query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findOneAsync(Find.Builder query)
Finds a single matching document in the collection.
|
ListenableFuture<Document> |
AbstractAsyncMongoCollection.findOneAsync(Find query)
Finds a single matching document in the collection.
|
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.groupByAsync(GroupBy.Builder command)
Invokes a group command on the server.
|
ListenableFuture<MongoIterator<Element>> |
AbstractAsyncMongoCollection.groupByAsync(GroupBy command)
Invokes a group command on the server.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.insertAsync(boolean continueOnError,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.insertAsync(boolean continueOnError,
Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.insertAsync(DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.insertAsync(Durability durability,
DocumentAssignable... documents)
Inserts a set of documents into the collection.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.mapReduceAsync(MapReduce.Builder command)
Invokes a mapReduce command on the server.
|
ListenableFuture<MongoIterator<Document>> |
AbstractAsyncMongoCollection.mapReduceAsync(MapReduce command)
Invokes a mapReduce command on the server.
|
ListenableFuture<Collection<MongoIterator<Document>>> |
AbstractAsyncMongoCollection.parallelScanAsync(ParallelScan.Builder parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Collection<MongoIterator<Document>>> |
AbstractAsyncMongoCollection.parallelScanAsync(ParallelScan parallelScan)
Uses the
parallelCollectionScan command to open multiple
iterators over the collection each configured to scan a distinct regions
of the collection. |
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(DocumentAssignable command)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String command)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String command,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String commandName,
int commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Document> |
MongoDatabaseImpl.runCommandAsync(String commandName,
String commandValue,
DocumentAssignable options)
Runs a command against the database.
|
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.saveAsync(DocumentAssignable document)
Saves the
document to the collection. |
ListenableFuture<Integer> |
AbstractAsyncMongoCollection.saveAsync(DocumentAssignable document,
Durability durability)
Saves the
document to the collection. |
ListenableFuture<MongoIterator<TextResult>> |
AbstractAsyncMongoCollection.textSearchAsync(Text.Builder command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<MongoIterator<TextResult>> |
AbstractAsyncMongoCollection.textSearchAsync(Text command)
Deprecated.
Support for the
text command was deprecated in the
2.6 version of MongoDB. Use the
$text query operator
instead. This method will not be removed until two releases
after the MongoDB 2.6 release (e.g. 2.10 if the releases are
2.8 and 2.10). |
ListenableFuture<Long> |
AbstractAsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
boolean multiUpdate,
boolean upsert,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.updateAsync(DocumentAssignable query,
DocumentAssignable update,
Durability durability)
Applies updates to a set of documents within the collection.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.writeAsync(BatchedWrite.Builder write)
Constructs the appropriate set of write commands to send to the server.
|
ListenableFuture<Long> |
AbstractAsyncMongoCollection.writeAsync(BatchedWrite write)
Constructs the appropriate set of write commands to send to the server.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FutureReplyCallback
FutureReplyCallback provides a
FutureCallback that also implements
the ReplyCallback interface. |
| Modifier and Type | Class and Description |
|---|---|
class |
ServerUpdateCallback
ServerUpdateCallback provides a special callback update the server with the
first document in the reply.
|
Copyright © 2011–2014 Allanbank Consulting, Inc.. All rights reserved.