private BsonDocument |
QueryProtocol.asFindCommandDocument(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
(package private) static java.util.List<ByteBufBsonDocument> |
ByteBufBsonDocument.create(ByteBufferBsonOutput bsonOutput,
int startPosition) |
(package private) static ByteBufBsonDocument |
ByteBufBsonDocument.createOne(ByteBufferBsonOutput bsonOutput,
int startPosition) |
protected BsonDocument |
DeleteProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected BsonDocument |
InsertProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected BsonDocument |
UpdateProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
protected abstract BsonDocument |
WriteProtocol.getAsWriteCommand(ByteBufferBsonOutput bsonOutput,
int firstDocumentPosition) |
private void |
WriteCommandProtocol.sendMessageAsync(InternalConnection connection,
ByteBufferBsonOutput buffer,
BaseWriteCommandMessage message,
long startTimeNanos,
SingleResultCallback<BulkWriteResult> clientCallback,
SingleResultCallback<BsonDocument> callback) |
private boolean |
QueryProtocol.sendQueryStartedEvent(InternalConnection connection,
QueryMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata metadata) |
private void |
WriteCommandProtocol.sendStartedEvent(InternalConnection connection,
BaseWriteCommandMessage message,
ByteBufferBsonOutput bsonOutput,
RequestMessage.EncodingMetadata encodingMetadata) |
private void |
CommandProtocol.sendStartedEvent(InternalConnection connection,
ByteBufferBsonOutput bsonOutput,
CommandMessage message,
int documentPosition) |
private void |
WriteProtocol.sendStartedEvent(InternalConnection connection,
RequestMessage message,
RequestMessage.EncodingMetadata encodingMetadata,
ByteBufferBsonOutput bsonOutput) |