Package | Description |
---|---|
com.mongodb |
The core mongodb package
|
com.mongodb.async.client |
This packages contains classes for the new async client
|
com.mongodb.async.client.gridfs |
Contains the classes for supporting MongoDB's specification for storing very large files, GridFS.
|
com.mongodb.binding |
This package contains classes that manage binding to MongoDB servers for various operations.
|
com.mongodb.client |
This package contains classes for the new client api for MongoDatabase and MongoCollection
|
com.mongodb.client.gridfs |
This package contains the new GridFS implementation
|
com.mongodb.client.model |
This package contains models and options that help describe MongoCollection operations
|
com.mongodb.connection |
Contains classes that manage connecting to MongoDB servers.
|
com.mongodb.operation |
The core of the MongoDB driver works via operations, using the command pattern.
|
com.mongodb.selector |
Contains classes that determine how to select the server to connect to in order to send commands or queries.
|
Modifier and Type | Class and Description |
---|---|
private static class |
ReadPreference.PrimaryReadPreference
Preference to read from primary only.
|
class |
TaggableReadPreference
Abstract class for all preference which can be combined with tags
|
(package private) static class |
TaggableReadPreference.NearestReadPreference
Read from nearest node respective of tags.
|
(package private) static class |
TaggableReadPreference.PrimaryPreferredReadPreference
Read from primary if available, otherwise a secondary.
|
(package private) static class |
TaggableReadPreference.SecondaryPreferredReadPreference
Read from secondary if available, otherwise from primary, irrespective of tags.
|
(package private) static class |
TaggableReadPreference.SecondaryReadPreference
Read from secondary
|
Modifier and Type | Field and Description |
---|---|
private static ReadPreference |
ReadPreference.NEAREST |
private static ReadPreference |
ReadPreference.PRIMARY |
private static ReadPreference |
ReadPreference.PRIMARY_PREFERRED |
private ReadPreference |
MapReduceIterableImpl.readPreference |
private ReadPreference |
Mongo.readPreference |
private ReadPreference |
FindIterableImpl.readPreference |
private ReadPreference |
FindIterableImpl.FindOperationIterable.readPreference |
private ReadPreference |
ParallelScanOptions.readPreference |
private ReadPreference |
ParallelScanOptions.Builder.readPreference |
private ReadPreference |
ListIndexesIterableImpl.readPreference |
private ReadPreference |
MongoCollectionImpl.readPreference |
private ReadPreference |
MongoDatabaseImpl.readPreference |
private ReadPreference |
MongoClientOptions.readPreference |
private ReadPreference |
MongoClientOptions.Builder.readPreference |
private ReadPreference |
MapReduceCommand.readPreference |
private ReadPreference |
OperationIterable.readPreference |
private ReadPreference |
ListCollectionsIterableImpl.readPreference |
private ReadPreference |
DBCollection.readPreference |
private ReadPreference |
DistinctIterableImpl.readPreference |
private ReadPreference |
DB.readPreference |
ReadPreference |
MongoOptions.readPreference
Deprecated.
Specifies the read preference.
|
private ReadPreference |
ListDatabasesIterableImpl.readPreference |
private ReadPreference |
AggregateIterableImpl.readPreference |
private ReadPreference |
ConnectionString.readPreference |
private static ReadPreference |
ReadPreference.SECONDARY |
private static ReadPreference |
ReadPreference.SECONDARY_PREFERRED |
Modifier and Type | Method and Description |
---|---|
private ReadPreference |
ConnectionString.buildReadPreference(java.lang.String readPreferenceType,
java.util.List<TagSet> tagSetList,
long maxStalenessSeconds) |
private ReadPreference |
ConnectionString.createReadPreference(java.util.Map<java.lang.String,java.util.List<java.lang.String>> optionsMap) |
(package private) ReadPreference |
DB.getCommandReadPreference(DBObject command,
ReadPreference requestedPreference)
Determines the read preference that should be used for the given command.
|
ReadPreference |
Mongo.getReadPreference()
Gets the default read preference
|
ReadPreference |
ParallelScanOptions.getReadPreference()
Gets the read preference to use.
|
ReadPreference |
MongoCollectionImpl.getReadPreference() |
ReadPreference |
MongoDatabaseImpl.getReadPreference() |
ReadPreference |
MongoClientOptions.getReadPreference()
The read preference to use for queries, map-reduce, aggregation, and count.
|
ReadPreference |
MapReduceCommand.getReadPreference()
Gets the read preference
|
ReadPreference |
DBCollection.getReadPreference()
Gets the
ReadPreference . |
ReadPreference |
DB.getReadPreference()
Gets the read preference for this database.
|
ReadPreference |
DBCursor.getReadPreference()
Gets the default read preference.
|
ReadPreference |
MongoOptions.getReadPreference()
Deprecated.
Gets the read preference.
|
ReadPreference |
ConnectionString.getReadPreference()
Gets the read preference specified in the connection string.
|
private ReadPreference |
DBCursor.getReadPreferenceForCursor() |
static ReadPreference |
ReadPreference.nearest()
Gets a read preference that forces reads to a primary or a secondary.
|
static ReadPreference |
ReadPreference.nearest(long maxStaleness,
java.util.concurrent.TimeUnit timeUnit)
Gets a read preference that forces reads to a primary or a secondary that is less stale than the given maximum.
|
static ReadPreference |
ReadPreference.primary()
Gets a read preference that forces read to the primary.
|
static ReadPreference |
ReadPreference.primaryPreferred()
Gets a read preference that forces reads to the primary if available, otherwise to a secondary.
|
static ReadPreference |
ReadPreference.primaryPreferred(long maxStaleness,
java.util.concurrent.TimeUnit timeUnit)
Gets a read preference that forces reads to the primary if available, otherwise to a secondary.
|
static ReadPreference |
ReadPreference.secondary()
Gets a read preference that forces reads to a secondary.
|
static ReadPreference |
ReadPreference.secondary(long maxStaleness,
java.util.concurrent.TimeUnit timeUnit)
Gets a read preference that forces reads to a secondary that is less stale than the given maximum.
|
static ReadPreference |
ReadPreference.secondaryPreferred()
Gets a read preference that forces reads to a secondary if one is available, otherwise to the primary.
|
static ReadPreference |
ReadPreference.secondaryPreferred(long maxStaleness,
java.util.concurrent.TimeUnit timeUnit)
Gets a read preference that forces reads to a secondary that is less stale than the given maximumm if one is available,
otherwise to the primary.
|
static ReadPreference |
ReadPreference.valueOf(java.lang.String name)
Creates a read preference from the given read preference name.
|
Modifier and Type | Method and Description |
---|---|
Cursor |
DBCollection.aggregate(java.util.List<? extends DBObject> pipeline,
AggregationOptions options,
ReadPreference readPreference)
Method implements aggregation framework.
|
private Cursor |
DBCollection.aggregate(java.util.List<? extends DBObject> pipeline,
AggregationOptions options,
ReadPreference readPreference,
boolean returnCursorForOutCollection) |
AggregationOutput |
DBCollection.aggregate(java.util.List<? extends DBObject> pipeline,
ReadPreference readPreference)
Deprecated.
|
CommandResult |
DB.command(DBObject command,
ReadPreference readPreference)
Executes the command against the database with the given read preference.
|
CommandResult |
DB.command(DBObject command,
ReadPreference readPreference,
DBEncoder encoder)
Executes a database command with the selected readPreference, and encodes the command using the given encoder.
|
CommandResult |
DB.command(java.lang.String command,
ReadPreference readPreference)
Executes a database command.
|
long |
DBCollection.count(DBObject query,
ReadPreference readPreference)
Get the count of documents in collection that would match a criteria.
|
java.util.List |
DBCollection.distinct(java.lang.String fieldName,
DBObject query,
ReadPreference readPreference)
Find the distinct values for a specified field across a collection and returns the results in an array.
|
java.util.List |
DBCollection.distinct(java.lang.String fieldName,
ReadPreference readPreference)
Find the distinct values for a specified field across a collection and returns the results in an array.
|
(package private) <T> T |
Mongo.execute(ReadOperation<T> operation,
ReadPreference readPreference) |
(package private) CommandResult |
DB.executeCommand(BsonDocument commandDocument,
ReadPreference readPreference) |
DBObject |
DBCollection.findOne(DBObject query,
DBObject projection,
DBObject sort,
ReadPreference readPreference)
Get a single document from collection.
|
DBObject |
DBCollection.findOne(DBObject query,
DBObject projection,
ReadPreference readPreference)
Get a single document from collection.
|
(package private) ReadPreference |
DB.getCommandReadPreference(DBObject command,
ReadPreference requestedPreference)
Determines the read preference that should be used for the given command.
|
long |
DBCollection.getCount(DBObject query,
DBObject projection,
long limit,
long skip,
ReadPreference readPreference)
Get the count of documents in collection that would match a criteria.
|
long |
DBCollection.getCount(DBObject query,
DBObject projection,
ReadPreference readPreference)
Get the count of documents in collection that would match a criteria.
|
long |
DBCollection.getCount(ReadPreference readPreference)
Get the count of documents in collection.
|
(package private) ReadBinding |
Mongo.getReadBinding(ReadPreference readPreference) |
private ReadWriteBinding |
Mongo.getReadWriteBinding(ReadPreference readPreference) |
DBObject |
DBCollection.group(DBObject key,
DBObject cond,
DBObject initial,
java.lang.String reduce,
java.lang.String finalize,
ReadPreference readPreference)
Group documents in a collection by the specified key and performs simple aggregation functions such as computing counts and sums.
|
DBObject |
DBCollection.group(GroupCommand cmd,
ReadPreference readPreference)
Group documents in a collection by the specified key and performs simple aggregation functions such as computing counts and sums.
|
MapReduceOutput |
DBCollection.mapReduce(java.lang.String map,
java.lang.String reduce,
java.lang.String outputTarget,
MapReduceCommand.OutputType outputType,
DBObject query,
ReadPreference readPreference)
Allows you to run map-reduce aggregation operations over a collection and saves to a named collection.
|
ParallelScanOptions.Builder |
ParallelScanOptions.Builder.readPreference(ReadPreference readPreference)
The read preference to use.
|
MongoClientOptions.Builder |
MongoClientOptions.Builder.readPreference(ReadPreference readPreference)
Sets the read preference.
|
Document |
MongoDatabaseImpl.runCommand(Bson command,
ReadPreference readPreference) |
<TResult> TResult |
MongoDatabaseImpl.runCommand(Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass) |
void |
Mongo.setReadPreference(ReadPreference readPreference)
Deprecated.
Set the default read preference with either
MongoClientURI or MongoClientOptions |
void |
MapReduceCommand.setReadPreference(ReadPreference preference)
Sets the read preference for this command.
|
void |
DBCollection.setReadPreference(ReadPreference preference)
Sets the
ReadPreference for this collection. |
void |
DB.setReadPreference(ReadPreference readPreference)
Sets the read preference for this database.
|
DBCursor |
DBCursor.setReadPreference(ReadPreference readPreference)
Sets the read preference for this cursor.
|
void |
MongoOptions.setReadPreference(ReadPreference readPreference)
Deprecated.
Specifies the read preference.
|
MongoCollection<TDocument> |
MongoCollectionImpl.withReadPreference(ReadPreference readPreference) |
MongoDatabase |
MongoDatabaseImpl.withReadPreference(ReadPreference readPreference) |
Constructor and Description |
---|
AggregateIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
OperationExecutor executor,
java.util.List<? extends Bson> pipeline) |
DBCursor(DBCollection collection,
DBObject query,
DBObject fields,
ReadPreference readPreference)
Initializes a new database cursor.
|
DistinctIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
OperationExecutor executor,
java.lang.String fieldName,
Bson filter) |
FindIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
OperationExecutor executor,
Bson filter,
FindOptions findOptions) |
FindOperationIterable(FindOperation<TResult> operation,
ReadPreference readPreference,
OperationExecutor executor) |
ListCollectionsIterableImpl(java.lang.String databaseName,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
OperationExecutor executor) |
ListDatabasesIterableImpl(java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
OperationExecutor executor) |
ListIndexesIterableImpl(MongoNamespace namespace,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
OperationExecutor executor) |
MapReduceIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
OperationExecutor executor,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
MongoCollectionImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
OperationExecutor executor) |
MongoDatabaseImpl(java.lang.String name,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
OperationExecutor executor) |
OperationIterable(ReadOperation<? extends BatchCursor<T>> operation,
ReadPreference readPreference,
OperationExecutor executor) |
Modifier and Type | Field and Description |
---|---|
private ReadPreference |
MapReduceIterableImpl.readPreference |
private ReadPreference |
MongoClientSettings.readPreference |
private ReadPreference |
MongoClientSettings.Builder.readPreference |
private ReadPreference |
FindIterableImpl.readPreference |
private ReadPreference |
ListIndexesIterableImpl.readPreference |
private ReadPreference |
MongoCollectionImpl.readPreference |
private ReadPreference |
MongoDatabaseImpl.readPreference |
private ReadPreference |
OperationIterable.readPreference |
private ReadPreference |
ListCollectionsIterableImpl.readPreference |
private ReadPreference |
DistinctIterableImpl.readPreference |
private ReadPreference |
ListDatabasesIterableImpl.readPreference |
private ReadPreference |
AggregateIterableImpl.readPreference |
Modifier and Type | Method and Description |
---|---|
ReadPreference |
MongoCollection.getReadPreference()
Get the read preference for the MongoCollection.
|
ReadPreference |
MongoClientSettings.getReadPreference()
The read preference to use for queries, map-reduce, aggregation, and count.
|
ReadPreference |
MongoDatabase.getReadPreference()
Get the read preference for the MongoDatabase.
|
ReadPreference |
MongoCollectionImpl.getReadPreference() |
ReadPreference |
MongoDatabaseImpl.getReadPreference() |
Modifier and Type | Method and Description |
---|---|
private static AsyncReadWriteBinding |
MongoClientImpl.getReadWriteBinding(ReadPreference readPreference,
Cluster cluster) |
MongoClientSettings.Builder |
MongoClientSettings.Builder.readPreference(ReadPreference readPreference)
Sets the read preference.
|
<TResult> void |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback)
Executes the given command in the context of the current database with the given read preference.
|
<TResult> void |
MongoDatabaseImpl.runCommand(Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass,
SingleResultCallback<TResult> callback) |
void |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference,
SingleResultCallback<Document> callback)
Executes the given command in the context of the current database with the given read preference.
|
void |
MongoDatabaseImpl.runCommand(Bson command,
ReadPreference readPreference,
SingleResultCallback<Document> callback) |
MongoCollection<TDocument> |
MongoCollection.withReadPreference(ReadPreference readPreference)
Create a new MongoCollection instance with a different read preference.
|
MongoDatabase |
MongoDatabase.withReadPreference(ReadPreference readPreference)
Create a new MongoDatabase instance with a different read preference.
|
MongoCollection<TDocument> |
MongoCollectionImpl.withReadPreference(ReadPreference readPreference) |
MongoDatabase |
MongoDatabaseImpl.withReadPreference(ReadPreference readPreference) |
Constructor and Description |
---|
AggregateIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
AsyncOperationExecutor executor,
java.util.List<? extends Bson> pipeline) |
DistinctIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
AsyncOperationExecutor executor,
java.lang.String fieldName,
Bson filter) |
FindIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
AsyncOperationExecutor executor,
Bson filter,
FindOptions findOptions) |
ListCollectionsIterableImpl(java.lang.String databaseName,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
ListDatabasesIterableImpl(java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
ListIndexesIterableImpl(MongoNamespace namespace,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
MapReduceIterableImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
java.lang.Class<TResult> resultClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
ReadConcern readConcern,
WriteConcern writeConcern,
AsyncOperationExecutor executor,
java.lang.String mapFunction,
java.lang.String reduceFunction) |
MongoCollectionImpl(MongoNamespace namespace,
java.lang.Class<TDocument> documentClass,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
AsyncOperationExecutor executor) |
MongoDatabaseImpl(java.lang.String name,
CodecRegistry codecRegistry,
ReadPreference readPreference,
WriteConcern writeConcern,
ReadConcern readConcern,
AsyncOperationExecutor executor) |
OperationIterable(AsyncReadOperation<? extends AsyncBatchCursor<T>> operation,
ReadPreference readPreference,
AsyncOperationExecutor executor) |
Modifier and Type | Method and Description |
---|---|
ReadPreference |
GridFSBucketImpl.getReadPreference() |
ReadPreference |
GridFSBucket.getReadPreference()
Get the read preference for the GridFSBucket.
|
Modifier and Type | Method and Description |
---|---|
GridFSBucket |
GridFSBucketImpl.withReadPreference(ReadPreference readPreference) |
GridFSBucket |
GridFSBucket.withReadPreference(ReadPreference readPreference)
Create a new GridFSBucket instance with a different read preference.
|
Modifier and Type | Field and Description |
---|---|
private ReadPreference |
SingleConnectionReadBinding.readPreference |
private ReadPreference |
AsyncSingleConnectionReadBinding.readPreference |
private ReadPreference |
ClusterBinding.readPreference |
private ReadPreference |
SingleServerBinding.readPreference |
private ReadPreference |
AsyncClusterBinding.readPreference |
Modifier and Type | Method and Description |
---|---|
ReadPreference |
SingleConnectionReadBinding.getReadPreference() |
ReadPreference |
AsyncSingleConnectionReadBinding.getReadPreference() |
ReadPreference |
ClusterBinding.getReadPreference() |
ReadPreference |
AsyncReadBinding.getReadPreference()
The read preference that all connection sources returned by this instance will satisfy.
|
ReadPreference |
SingleServerBinding.getReadPreference() |
ReadPreference |
AsyncClusterBinding.getReadPreference() |
ReadPreference |
ReadBinding.getReadPreference()
The read preference that all connection sources returned by this instance will satisfy.
|
Constructor and Description |
---|
AsyncClusterBinding(Cluster cluster,
ReadPreference readPreference)
Creates an instance.
|
AsyncSingleConnectionReadBinding(ReadPreference readPreference,
ServerDescription serverDescription,
AsyncConnection connection)
Construct an instance.
|
ClusterBinding(Cluster cluster,
ReadPreference readPreference)
Creates an instance.
|
SingleConnectionReadBinding(ReadPreference readPreference,
ServerDescription serverDescription,
Connection connection)
Construct an instance.
|
SingleServerBinding(Cluster cluster,
ServerAddress serverAddress,
ReadPreference readPreference)
Creates an instance.
|
Modifier and Type | Method and Description |
---|---|
ReadPreference |
MongoCollection.getReadPreference()
Get the read preference for the MongoCollection.
|
ReadPreference |
MongoDatabase.getReadPreference()
Get the read preference for the MongoDatabase.
|
Modifier and Type | Method and Description |
---|---|
Document |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference)
Executes the given command in the context of the current database with the given read preference.
|
<TResult> TResult |
MongoDatabase.runCommand(Bson command,
ReadPreference readPreference,
java.lang.Class<TResult> resultClass)
Executes the given command in the context of the current database with the given read preference.
|
MongoCollection<TDocument> |
MongoCollection.withReadPreference(ReadPreference readPreference)
Create a new MongoCollection instance with a different read preference.
|
MongoDatabase |
MongoDatabase.withReadPreference(ReadPreference readPreference)
Create a new MongoDatabase instance with a different read preference.
|
Modifier and Type | Method and Description |
---|---|
ReadPreference |
GridFSBucketImpl.getReadPreference() |
ReadPreference |
GridFSBucket.getReadPreference()
Get the read preference for the GridFSBucket.
|
Modifier and Type | Method and Description |
---|---|
GridFSBucket |
GridFSBucketImpl.withReadPreference(ReadPreference readPreference) |
GridFSBucket |
GridFSBucket.withReadPreference(ReadPreference readPreference)
Create a new GridFSBucket instance with a different read preference.
|
Modifier and Type | Field and Description |
---|---|
private ReadPreference |
DBCollectionDistinctOptions.readPreference |
private ReadPreference |
DBCollectionCountOptions.readPreference |
private ReadPreference |
DBCollectionFindOptions.readPreference |
Modifier and Type | Method and Description |
---|---|
ReadPreference |
DBCollectionDistinctOptions.getReadPreference()
Returns the readPreference
|
ReadPreference |
DBCollectionCountOptions.getReadPreference()
Returns the readPreference
|
ReadPreference |
DBCollectionFindOptions.getReadPreference()
Returns the readPreference
|
Modifier and Type | Method and Description |
---|---|
DBCollectionDistinctOptions |
DBCollectionDistinctOptions.readPreference(ReadPreference readPreference)
Sets the readPreference
|
DBCollectionCountOptions |
DBCollectionCountOptions.readPreference(ReadPreference readPreference)
Sets the readPreference
|
DBCollectionFindOptions |
DBCollectionFindOptions.readPreference(ReadPreference readPreference)
Sets the readPreference
|
Modifier and Type | Method and Description |
---|---|
boolean |
ClusterDescription.hasReadableServer(ReadPreference readPreference)
Returns true if this cluster has at least one server that satisfies the given read preference.
|
Modifier and Type | Field and Description |
---|---|
private ReadPreference |
CommandOperationHelper.CommandProtocolExecutingCallback.readPreference |
Modifier and Type | Method and Description |
---|---|
private BsonDocument |
FindOperation.asDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
private BsonDocument |
ListIndexesOperation.asQueryDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
private BsonDocument |
ListCollectionsOperation.asQueryDocument(ConnectionDescription connectionDescription,
ReadPreference readPreference) |
<T> void |
AsyncOperationExecutor.execute(AsyncReadOperation<T> operation,
ReadPreference readPreference,
SingleResultCallback<T> callback)
Execute the read operation with the given read preference.
|
<T> T |
OperationExecutor.execute(ReadOperation<T> operation,
ReadPreference readPreference)
Execute the read operation with the given read preference.
|
private static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
Connection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
Connection connection,
ReadPreference readPreference) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
Decoder<T> decoder,
ConnectionSource source,
ReadPreference readPreference) |
private static <D,T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
Connection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer) |
private static <T> T |
CommandOperationHelper.executeWrappedCommandProtocol(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<T> decoder,
ConnectionSource source,
ReadPreference readPreference) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
private static <D,T> void |
CommandOperationHelper.executeWrappedCommandProtocolAsync(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
AsyncConnection connection,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,T> transformer,
SingleResultCallback<T> callback) |
(package private) static BsonDocument |
CommandOperationHelper.wrapCommand(BsonDocument command,
ReadPreference readPreference,
ConnectionDescription connectionDescription) |
Constructor and Description |
---|
CommandProtocolExecutingCallback(java.lang.String database,
BsonDocument command,
FieldNameValidator fieldNameValidator,
Decoder<D> decoder,
ReadPreference readPreference,
CommandOperationHelper.CommandTransformer<D,R> transformer,
SingleResultCallback<R> callback) |
Modifier and Type | Field and Description |
---|---|
private ReadPreference |
ReadPreferenceServerSelector.readPreference |
Modifier and Type | Method and Description |
---|---|
ReadPreference |
ReadPreferenceServerSelector.getReadPreference()
Gets the read preference.
|
Constructor and Description |
---|
ReadPreferenceServerSelector(ReadPreference readPreference)
Gets the read preference.
|