private static <T,R> SingleResultCallback<T> |
CommandOperationHelper.createCommandCallback(AsyncWriteBinding binding,
AsyncConnectionSource oldSource,
AsyncConnection oldConnection,
java.lang.String database,
ReadPreference readPreference,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
CommandOperationHelper.CommandTransformer<T,R> transformer,
SingleResultCallback<R> callback) |
void |
MixedBulkWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<BulkWriteResult> callback) |
void |
MapReduceToCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<MapReduceStatistics> callback) |
void |
CommandWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback) |
void |
BaseFindAndModifyOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback) |
void |
AsyncWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<T> callback)
General execute which can return anything of type T
|
void |
UpdateUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
RenameCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropIndexOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropDatabaseOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
DropCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateViewOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateUserOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateIndexesOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
CreateCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
AggregateToCollectionOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<java.lang.Void> callback) |
void |
BaseWriteOperation.executeAsync(AsyncWriteBinding binding,
SingleResultCallback<WriteConcernResult> callback) |
private void |
MixedBulkWriteOperation.executeBatchesAsync(AsyncWriteBinding binding,
AsyncConnection connection,
BulkWriteBatch batch,
boolean retryWrites,
OperationHelper.ConnectionReleasingWrappedCallback<BulkWriteResult> callback) |
private void |
MixedBulkWriteOperation.executeCommandAsync(AsyncWriteBinding binding,
AsyncConnection connection,
BulkWriteBatch batch,
OperationHelper.ConnectionReleasingWrappedCallback<BulkWriteResult> callback,
SingleResultCallback<BsonDocument> commandCallback) |
(package private) static <T,R> void |
CommandOperationHelper.executeRetryableCommand(AsyncWriteBinding binding,
java.lang.String database,
ReadPreference readPreference,
FieldNameValidator fieldNameValidator,
Decoder<T> commandResultDecoder,
CommandOperationHelper.CommandCreator commandCreator,
CommandOperationHelper.CommandTransformer<T,R> transformer,
SingleResultCallback<R> originalCallback) |
(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 SingleResultCallback<BsonDocument> |
MixedBulkWriteOperation.getCommandCallback(AsyncWriteBinding binding,
AsyncConnection connection,
BulkWriteBatch batch,
boolean retryWrites,
boolean canRetryIfError,
OperationHelper.ConnectionReleasingWrappedCallback<BulkWriteResult> callback) |
private void |
MixedBulkWriteOperation.retryExecuteBatchesAsync(AsyncWriteBinding binding,
BulkWriteBatch retryBatch,
java.lang.Throwable originalError,
SingleResultCallback<BulkWriteResult> callback) |
(package private) static void |
OperationHelper.withConnection(AsyncWriteBinding binding,
OperationHelper.AsyncCallableWithConnection callable) |
(package private) static void |
OperationHelper.withConnection(AsyncWriteBinding binding,
OperationHelper.AsyncCallableWithConnectionAndSource callable) |