The type of the result elements. An implicit Reader[T] typeclass for handling it has to be in the scope.

if true indicates to return the information on the processing of the pipeline

if true enables writing to temporary files

if true enables to bypass document validation during the operation

the read concern

the read preference for the result (default: primary)

the batch size (for the aggregation cursor; if None use the default one)

the function to create the aggregation pipeline using the aggregation framework depending on the collection type

the result reader

The type of the result elements. An implicit Reader[T] typeclass for handling it has to be in the scope.

the first aggregation operator of the pipeline

the sequence of MongoDB aggregation operations

if true indicates to return the information on the processing of the pipeline

if true enables writing to temporary files

if true enables to bypass document validation during the operation

the read concern

the read preference for the result

the writer concern to be used

the batch size (for the aggregation cursor; if None use the default one)

the options for the result cursor

the time limit for processing operations on a cursor (maxTimeMS)

the index to use (either the index name or the index document)

the comment to annotation the aggregation command

the collation

the result reader

the size of the collection (number of bytes)

the maximum number of documents this capped collection can contain

the document selector

the maximum number of matching documents to count

the number of matching documents to skip before counting

the index to use (either the index name or the index document; see hint(..))

the read concern

the read preference for the result

the document selector

the maximum number of matching documents to count

the number of matching documents to skip before counting

the index to use (either the index name or the index document; see hint(..))

the read concern

if true fails if the collection already exists (default: false)

the size of the collection (number of bytes)

the maximum number of documents this capped collection can contain

If true should automatically add an index on the _id field. By default, regular collections will have an indexed _id field, in contrast to capped collections. This MongoDB option is deprecated and will be removed in a future release.

the name of the view to be created

the first (required) operator for the aggregation pipeline

the other pipeline operators

the view collation

the ordered behaviour

the writer concern to be used

import scala.concurrent.ExecutionContext

import reactivemongo.api.bson.BSONDocument
import reactivemongo.api.bson.collection.BSONCollection

def foo(coll: BSONCollection, query: BSONDocument)(
  implicit ec: ExecutionContext) = coll.delete(true).one(query)

the element type of the distinct values

the container, that must be a scala.collection.Iterable

the field for which to return distinct values

the document selector, that specifies the documents from which to retrieve the distinct values.

the read concern

the collation

import scala.concurrent.ExecutionContext

import reactivemongo.api.ReadConcern
import reactivemongo.api.bson.collection.BSONCollection

def distinctStates(coll: BSONCollection)(implicit ec: ExecutionContext) =
  coll.distinct[String, Set]("state", None, ReadConcern.Local, None)

the flag to request whether it should fail

The type of the selector. An implicit Writer[S] typeclass for handling it has to be in the scope.

the document selector

the projection document to select only a subset of each matching documents

the writer for the selector

the writer for the projection

A GenericQueryBuilder that you can use to to customize the query. You can obtain a cursor by calling the method reactivemongo.api.Cursor on this query builder.

the document selector

the modify operator to be applied

the document indicating the sort criteria (default: None)

the projection fields

the writer concern to be used

the time limit for processing operations on a cursor (maxTimeMS)

the collation

an array of filter documents that determines which array elements to modify for an update operation on an array field

the writer for the selector

The type of the selector. An implicit Writer[S] typeclass for handling it has to be in the scope.

the document selector

the document indicating the sort criteria

the projection fields

the writer concern to be used

the time limit for processing operations on a cursor (maxTimeMS)

the collation

an array of filter documents that determines which array elements to modify for an update operation on an array field

the writer for the selector

the document selector

the update to be applied

the command result must be the new object instead of the old one.

if true, creates a new document if no document is matching, otherwise if at least one document matches, an update is applied

the document indicating the sort criteria (default: None)

the projection fields

the writer concern to be used

the time limit for processing operations on a cursor (maxTimeMS)

the collation

an array of filter documents that determines which array elements to modify for an update operation on an array field

the writer for the selector

the writer to create the document

the index specification document

the index name

the ordered behaviour

the writer concern to be used

the flag to bypass document validation during the operation

import scala.concurrent.ExecutionContext

import reactivemongo.api.WriteConcern
import reactivemongo.api.bson.BSONDocument
import reactivemongo.api.bson.collection.BSONCollection

def withDefaultWriteConcern(coll: BSONCollection, query: BSONDocument)(
  implicit ec: ExecutionContext) =
  coll.insert(true, WriteConcern.Journaled, true).one(query)

the ordered behaviour

the writer concern to be used

import scala.concurrent.ExecutionContext

import reactivemongo.api.WriteConcern
import reactivemongo.api.bson.BSONDocument
import reactivemongo.api.bson.collection.BSONCollection

def withDefaultWriteConcern(coll: BSONCollection, query: BSONDocument)(
  implicit ec: ExecutionContext) =
  coll.insert(true, WriteConcern.Journaled).one(query)

the ordered behaviour

import scala.concurrent.ExecutionContext

import reactivemongo.api.bson.BSONDocument
import reactivemongo.api.bson.collection.BSONCollection

def one(coll: BSONCollection, singleDoc: BSONDocument)(
  implicit ec: ExecutionContext) =
  coll.insert(ordered = true).one(singleDoc)

def many(coll: BSONCollection, multiInserts: Iterable[BSONDocument])(
  implicit ec: ExecutionContext) =
  coll.insert(ordered = true).many(multiInserts)

the scale factor (for example, to get all the sizes in kilobytes)

the ordered behaviour

the writer concern to be used

the flag to bypass document validation during the operation

the ordered behaviour

the writer concern to be used

the ordered behaviour

the update to be applied

the command result must be the new object instead of the old one.

if true, creates a new document if no document is matching, otherwise if at least one document matches, an update is applied

the type into which Change Events are deserialized

The id of the last known Change Event, if any. The stream will resume just after that event.

The operation time before which all Change Events are known. Must be in the time range of the oplog. (since MongoDB 4.0)

The sequence of aggregation stages to apply on events in the stream (see MongoDB documentation for a list of valid stages for a change stream).

The maximum amount of time in milliseconds the server waits for new data changes before returning an empty batch. In practice, this parameter controls the duration of the long-polling behavior of the cursor.

if set to UpdateLookup, every update change event will be joined with the current version of the relevant document.

the reader of the resulting change events

The type of the result elements. An implicit Reader[T] typeclass for handling it has to be in the scope.

if true indicates to return the information on the processing of the pipeline

if true enables writing to temporary files

if true enables to bypass document validation during the operation

the read concern

the read preference for the result (default: primary)

the batch size (for the aggregation cursor; if None use the default one)

the function to create the aggregation pipeline using the aggregation framework depending on the collection type

the result reader

the cursor flattener (by default use the builtin one)

the failover strategy to override the default one

The type of hint. An implicit H => Hint conversion has to be in the scope.

the document selector (default: None to count all)

the maximum number of matching documents to count

the number of matching documents to skip before counting

the index to use (either the index name or the index document)

The type of the selector. An implicit Writer[S] typeclass for handling it has to be in the scope.

the document selector

the projection document to select only a subset of each matching documents

the writer for the selector

the writer for the projection

A GenericQueryBuilder that you can use to to customize the query. You can obtain a cursor by calling the method reactivemongo.api.Cursor on this query builder.

The type of the selector. An implicit Writer[S] typeclass for handling it has to be in the scope.

the document selector

the writer for the selector

A GenericQueryBuilder that you can use to to customize the query. You can obtain a cursor by calling the method reactivemongo.api.Cursor on this query builder.

The type of the document to insert. An implicit Writer[T] typeclass for handling it has to be in the scope.

the document to insert

the writer concern to be used

the writer to create the document to be inserted

a future reactivemongo.api.commands.WriteResult that can be used to check whether the insertion was successful

import scala.concurrent.ExecutionContext

import reactivemongo.api.bson.BSONDocument
import reactivemongo.api.bson.collection.BSONCollection

def withDefaultWriteConcern(coll: BSONCollection, myDoc: BSONDocument)(
  implicit ec: ExecutionContext) = coll.insert(myDoc)

The type of the selector. An implicit Writer[S] typeclass for handling it has to be in the scope.

the writer concern to be used

the writer for the selector

a future reactivemongo.api.commands.WriteResult that can be used to check whether the removal was successful

the new name of this collection

if a collection of name to already exists, then drops that collection before renaming this one

A failure if the dropExisting option is false and the target collection already exists.

the name of another collection

the failover strategy to override the default one

The type of the selector. An implicit Writer[S] typeclass for handling it has to be in the scope.

The type of the modifier or update object. An implicit Writer[T] typeclass for handling it has to be in the scope.

the selector object, for finding the documents to update.

the modifier object (with special keys like $set) or replacement object.

the writer concern to be used

if true, creates a new document if no document is matching, otherwise if at least one document matches, an update is applied (defaults: false)

states whether the update may be done on all the matching documents (default: false)

the writer for the selector

the writer to create the document

a future reactivemongo.api.commands.WriteResult that can be used to check whether the insertion was successful