Package | Description |
---|---|
com.mongodb.binding |
This package contains classes that manage binding to MongoDB servers for various operations.
|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncReadWriteBinding
An asynchronous factory of connection sources to servers that can be read from or written to.
|
Modifier and Type | Class and Description |
---|---|
class |
AsyncClusterBinding
A simple ReadWriteBinding implementation that supplies write connection sources bound to a possibly different primary each time, and a
read connection source bound to a possible different server each time.
|
class |
AsyncSingleConnectionReadBinding
An asynchronous read binding that is bound to a single connection.
|
Modifier and Type | Method and Description |
---|---|
AsyncReadBinding |
AsyncReadBinding.retain() |
AsyncReadBinding |
AsyncSingleConnectionReadBinding.retain() |
Modifier and Type | Method and Description |
---|---|
void |
ListDatabasesOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListIndexesOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
ListCollectionsOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
DistinctOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
AggregateOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<AsyncBatchCursor<T>> callback) |
void |
FindOperation.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 |
AsyncReadOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<T> callback)
General execute which can return anything of type T
|
void |
CommandReadOperation.executeAsync(AsyncReadBinding binding,
SingleResultCallback<T> 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> SingleResultCallback<T> |
OperationHelper.releasingCallback(SingleResultCallback<T> wrapped,
AsyncReadBinding readBinding,
AsyncConnectionSource source,
AsyncConnection connection) |
(package private) static void |
OperationHelper.withConnection(AsyncReadBinding binding,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.withConnection(AsyncReadBinding binding,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |