Package | Description |
---|---|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
CommandProtocol<T>
A protocol for executing a command against a MongoDB server using the OP_QUERY wire protocol message.
|
(package private) class |
DeleteCommandProtocol
An implementation of the delete command.
|
(package private) class |
DeleteProtocol
An implementation of the MongoDB OP_DELETE wire protocol.
|
(package private) class |
GetMoreProtocol<T>
An implementation of the OP_GET_MORE protocol.
|
(package private) class |
InsertCommandProtocol
An implementation of the insert command.
|
(package private) class |
InsertProtocol
An implementation of the insert wire protocol.
|
(package private) class |
KillCursorProtocol
An implementation of the OP_KILL_CURSOR protocol.
|
(package private) class |
QueryProtocol<T>
An implementation of the MongoDB OP_QUERY wire protocol.
|
(package private) class |
UpdateCommandProtocol
An implementation of the update command.
|
(package private) class |
UpdateProtocol
An implementation of the MongoDB OP_UPDATE wire protocol.
|
(package private) class |
WriteCommandProtocol
A base class for implementations of the bulk write commands.
|
(package private) class |
WriteProtocol
Base class for wire protocol messages that perform writes.
|
Modifier and Type | Method and Description |
---|---|
<T> T |
ProtocolExecutor.execute(Protocol<T> protocol,
InternalConnection connection) |
<T> T |
DefaultServer.DefaultServerProtocolExecutor.execute(Protocol<T> protocol,
InternalConnection connection) |
<T> void |
ProtocolExecutor.executeAsync(Protocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
<T> void |
DefaultServer.DefaultServerProtocolExecutor.executeAsync(Protocol<T> protocol,
InternalConnection connection,
SingleResultCallback<T> callback) |
private <T> T |
DefaultServerConnection.executeProtocol(Protocol<T> protocol) |
private <T> void |
DefaultServerConnection.executeProtocolAsync(Protocol<T> protocol,
SingleResultCallback<T> callback) |