Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
DeleteCommandMessage
A message for the delete command.
|
(package private) class |
InsertCommandMessage
An insert command message.
|
(package private) class |
UpdateCommandMessage
A message for the update command.
|
Modifier and Type | Method and Description |
---|---|
protected abstract BaseWriteCommandMessage |
WriteCommandProtocol.createRequestMessage(MessageSettings messageSettings) |
BaseWriteCommandMessage |
BaseWriteCommandMessage.encode(BsonOutput outputStream) |
protected BaseWriteCommandMessage |
BaseWriteCommandMessage.encodeMessageBody(BsonOutput outputStream,
int messageStartPosition) |
private BaseWriteCommandMessage |
WriteCommandProtocol.sendMessage(InternalConnection connection,
BaseWriteCommandMessage message,
int batchNum) |
protected BaseWriteCommandMessage |
DeleteCommandMessage.writeTheWrites(BsonOutput bsonOutput,
int commandStartPosition,
BsonBinaryWriter writer) |
protected abstract BaseWriteCommandMessage |
BaseWriteCommandMessage.writeTheWrites(BsonOutput bsonOutput,
int commandStartPosition,
BsonBinaryWriter writer)
Write the list of writes to the output after the write command prologue has been written.
|
Modifier and Type | Method and Description |
---|---|
private void |
WriteCommandProtocol.executeBatchesAsync(InternalConnection connection,
BaseWriteCommandMessage message,
BulkWriteBatchCombiner bulkWriteBatchCombiner,
int batchNum,
int currentRangeStartIndex,
SingleResultCallback<BulkWriteResult> callback) |
private void |
WriteCommandProtocol.sendFailedEvent(InternalConnection connection,
BaseWriteCommandMessage message,
long startTimeNanos,
java.lang.Throwable t) |
private BaseWriteCommandMessage |
WriteCommandProtocol.sendMessage(InternalConnection connection,
BaseWriteCommandMessage message,
int batchNum) |
private void |
WriteCommandProtocol.sendMessageAsync(InternalConnection connection,
ByteBufferBsonOutput buffer,
BaseWriteCommandMessage message,
long startTimeNanos,
SingleResultCallback<BulkWriteResult> clientCallback,
SingleResultCallback<BsonDocument> callback) |
private void |
WriteCommandProtocol.sendStartedEvent(InternalConnection connection,
BaseWriteCommandMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata encodingMetadata) |
private void |
WriteCommandProtocol.sendSucceededEvent(InternalConnection connection,
BaseWriteCommandMessage message,
long startTimeNanos,
BsonDocument result) |