org.apache.pekko.stream.connectors.mongodb.scaladsl

MongoFlow

object MongoFlow

Source: MongoFlow.scala

Linear Supertypes

AnyRef, Any

Ordering

Alphabetic
By Inheritance

Inherited

MongoFlow
AnyRef
Any

Hide All
Show All

Visibility

Public
Protected

Value Members

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
def deleteMany[T](collection: MongoCollection[T], options: DeleteOptions = DefaultDeleteOptions): Flow[Bson, (DeleteResult, Bson), NotUsed]
A Flow that will delete many documents as defined by a Bson filter query.
A Flow that will delete many documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
def deleteOne[T](collection: MongoCollection[T], options: DeleteOptions = DefaultDeleteOptions): Flow[Bson, (DeleteResult, Bson), NotUsed]
A Flow that will delete individual documents as defined by a Bson filter query.
A Flow that will delete individual documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native()
def insertMany[T](collection: MongoCollection[T], options: InsertManyOptions = DefaultInsertManyOptions): Flow[Seq[T], Seq[T], NotUsed]
A Flow that will insert batches documents into a collection.
A Flow that will insert batches documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
def insertOne[T](collection: MongoCollection[T], options: InsertOneOptions = DefaultInsertOneOptions): Flow[T, T, NotUsed]
A Flow that will insert documents into a collection.
A Flow that will insert documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
def replaceOne[T](collection: MongoCollection[T], options: ReplaceOptions = DefaultReplaceOptions): Flow[DocumentReplace[T], (UpdateResult, DocumentReplace[T]), NotUsed]
A Flow that will replace document as defined by a DocumentReplace.
A Flow that will replace document as defined by a DocumentReplace.
collection
the mongo db collection to update.
options
options to apply to the operation
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
def updateMany[T](collection: MongoCollection[T], options: UpdateOptions = DefaultUpdateOptions): Flow[DocumentUpdate, (UpdateResult, DocumentUpdate), NotUsed]
A Flow that will update many documents as defined by a DocumentUpdate.
A Flow that will update many documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateOne[T](collection: MongoCollection[T], options: UpdateOptions = DefaultUpdateOptions): Flow[DocumentUpdate, (UpdateResult, DocumentUpdate), NotUsed]
A Flow that will update documents as defined by a DocumentUpdate.
A Flow that will update documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Ungrouped

final def !=(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def ##: Int
Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean
Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0
Definition Classes
Any
def clone(): AnyRef
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.CloneNotSupportedException]) @native()
def deleteMany[T](collection: MongoCollection[T], options: DeleteOptions = DefaultDeleteOptions): Flow[Bson, (DeleteResult, Bson), NotUsed]
A Flow that will delete many documents as defined by a Bson filter query.
A Flow that will delete many documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
def deleteOne[T](collection: MongoCollection[T], options: DeleteOptions = DefaultDeleteOptions): Flow[Bson, (DeleteResult, Bson), NotUsed]
A Flow that will delete individual documents as defined by a Bson filter query.
A Flow that will delete individual documents as defined by a Bson filter query.
collection
the mongo db collection to update.
options
options to apply to the operation
final def eq(arg0: AnyRef): Boolean
Definition Classes
AnyRef
def equals(arg0: AnyRef): Boolean
Definition Classes
AnyRef → Any
def finalize(): Unit
Attributes
protected[lang]
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.Throwable])
final def getClass(): Class[_ <: AnyRef]
Definition Classes
AnyRef → Any
Annotations
@native()
def hashCode(): Int
Definition Classes
AnyRef → Any
Annotations
@native()
def insertMany[T](collection: MongoCollection[T], options: InsertManyOptions = DefaultInsertManyOptions): Flow[Seq[T], Seq[T], NotUsed]
A Flow that will insert batches documents into a collection.
A Flow that will insert batches documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
def insertOne[T](collection: MongoCollection[T], options: InsertOneOptions = DefaultInsertOneOptions): Flow[T, T, NotUsed]
A Flow that will insert documents into a collection.
A Flow that will insert documents into a collection.
collection
mongo db collection to insert to.
options
options to apply to the operation
final def isInstanceOf[T0]: Boolean
Definition Classes
Any
final def ne(arg0: AnyRef): Boolean
Definition Classes
AnyRef
final def notify(): Unit
Definition Classes
AnyRef
Annotations
@native()
final def notifyAll(): Unit
Definition Classes
AnyRef
Annotations
@native()
def replaceOne[T](collection: MongoCollection[T], options: ReplaceOptions = DefaultReplaceOptions): Flow[DocumentReplace[T], (UpdateResult, DocumentReplace[T]), NotUsed]
A Flow that will replace document as defined by a DocumentReplace.
A Flow that will replace document as defined by a DocumentReplace.
collection
the mongo db collection to update.
options
options to apply to the operation
final def synchronized[T0](arg0: => T0): T0
Definition Classes
AnyRef
def toString(): String
Definition Classes
AnyRef → Any
def updateMany[T](collection: MongoCollection[T], options: UpdateOptions = DefaultUpdateOptions): Flow[DocumentUpdate, (UpdateResult, DocumentUpdate), NotUsed]
A Flow that will update many documents as defined by a DocumentUpdate.
A Flow that will update many documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
def updateOne[T](collection: MongoCollection[T], options: UpdateOptions = DefaultUpdateOptions): Flow[DocumentUpdate, (UpdateResult, DocumentUpdate), NotUsed]
A Flow that will update documents as defined by a DocumentUpdate.
A Flow that will update documents as defined by a DocumentUpdate.
collection
the mongo db collection to update.
options
options to apply to the operation
final def wait(): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long, arg1: Int): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException])
final def wait(arg0: Long): Unit
Definition Classes
AnyRef
Annotations
@throws(classOf[java.lang.InterruptedException]) @native()

Packages

MongoFlow

object MongoFlow

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

Packages

MongoFlow

object MongoFlow

Value Members

Inherited from AnyRef

Value Members

Inherited from Any

Value Members

Ungrouped

MongoFlow