reactivemongo.api.collections.buffer

ChannelCollection

case class ChannelCollection(db: DB, name: String, failoverStrategy: FailoverStrategy) extends GenericCollection[WritableBuffer, RawBSONDocumentDeserializer, RawBSONDocumentSerializer] with BufferGenericHandlers with Product with Serializable

Linear Supertypes
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. ChannelCollection
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. BufferGenericHandlers
  7. GenericCollection
  8. GenericHandlers
  9. Collection
  10. AnyRef
  11. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new ChannelCollection(db: DB, name: String, failoverStrategy: FailoverStrategy)

Type Members

  1. case class BufferStructureReader[T](reader: RawBSONDocumentDeserializer[T]) extends GenericReader[WritableBuffer, T] with Product with Serializable

    Definition Classes
    BufferGenericHandlers
  2. case class BufferStructureWriter[T](writer: RawBSONDocumentSerializer[T]) extends GenericWriter[T, WritableBuffer] with Product with Serializable

    Definition Classes
    BufferGenericHandlers
  3. case class GenericBufferReader[T](reader: Reader[T]) extends BufferReader[T] with Product with Serializable

    Definition Classes
    GenericHandlers
  4. case class GenericBufferWriter[T](writer: Writer[T]) extends BufferWriter[T] with Product with Serializable

    Definition Classes
    GenericHandlers

Value Members

  1. final def !=(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Definition Classes
    AnyRef → Any
  3. def +(other: String): String

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to any2stringadd[ChannelCollection] performed by method any2stringadd in scala.Predef.
    Definition Classes
    any2stringadd
  4. def ->[B](y: B): (ChannelCollection, B)

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to ArrowAssoc[ChannelCollection] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc
    Annotations
    @inline()
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  6. def BufferReaderInstance[T](reader: RawBSONDocumentDeserializer[T]): GenericBufferReader[T]

    Definition Classes
    GenericHandlers
  7. def BufferWriterInstance[T](writer: RawBSONDocumentSerializer[T]): GenericBufferWriter[T]

    Definition Classes
    GenericHandlers
  8. object StructureBufferReader extends BufferReader[WritableBuffer]

    As seen from class P, the missing signatures are as follows.

    As seen from class P, the missing signatures are as follows. * For convenience, these are usable as stub implementations.

    Definition Classes
    BufferGenericHandlersGenericHandlers
  9. object StructureBufferWriter extends BufferWriter[WritableBuffer]

    Definition Classes
    BufferGenericHandlersGenericHandlers
  10. def StructureReader[T](reader: RawBSONDocumentDeserializer[T]): BufferStructureReader[T]

    Definition Classes
    BufferGenericHandlersGenericHandlers
  11. def StructureWriter[T](writer: RawBSONDocumentSerializer[T]): GenericWriter[T, WritableBuffer]

    Definition Classes
    BufferGenericHandlersGenericHandlers
  12. def as[C <: Collection](failoverStrategy: FailoverStrategy = failoverStrategy)(implicit producer: CollectionProducer[C] = ...): C

    Gets another implementation of this collection.

    Gets another implementation of this collection. An implicit CollectionProducer[C] must be present in the scope, or it will be the default implementation (reactivemongo.api.collections.default.BSONCollection).

    failoverStrategy

    Overrides the default strategy.

    Definition Classes
    Collection
  13. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  14. def bulkInsert[T](enumerator: Enumerator[T], writeConcern: GetLastError = GetLastError(), bulkSize: Int = bulk.MaxDocs, bulkByteSize: Int = bulk.MaxBulkSize)(implicit writer: RawBSONDocumentSerializer[T], ec: ExecutionContext): Future[Int]

    Definition Classes
    GenericCollection
  15. def bulkInsertIteratee[T](writeConcern: GetLastError = GetLastError(), bulkSize: Int = bulk.MaxDocs, bulkByteSize: Int = bulk.MaxBulkSize)(implicit writer: RawBSONDocumentSerializer[T], ec: ExecutionContext): Iteratee[T, Int]

    Definition Classes
    GenericCollection
  16. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  17. val db: DB

    The database which this collection belong to.

    The database which this collection belong to.

    Definition Classes
    ChannelCollectionCollection
  18. def ensuring(cond: (ChannelCollection) ⇒ Boolean, msg: ⇒ Any): ChannelCollection

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to Ensuring[ChannelCollection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  19. def ensuring(cond: (ChannelCollection) ⇒ Boolean): ChannelCollection

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to Ensuring[ChannelCollection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  20. def ensuring(cond: Boolean, msg: ⇒ Any): ChannelCollection

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to Ensuring[ChannelCollection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  21. def ensuring(cond: Boolean): ChannelCollection

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to Ensuring[ChannelCollection] performed by method Ensuring in scala.Predef.
    Definition Classes
    Ensuring
  22. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  23. val failoverStrategy: FailoverStrategy

    The default failover strategy for the methods of this collection.

    The default failover strategy for the methods of this collection.

    Definition Classes
    ChannelCollectionGenericCollectionCollection
  24. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  25. def find[S, P](selector: S, projection: P)(implicit swriter: RawBSONDocumentSerializer[S], pwriter: RawBSONDocumentSerializer[P]): GenericQueryBuilder[WritableBuffer, RawBSONDocumentDeserializer, RawBSONDocumentSerializer]

    Find the documents matching the given criteria.

    Find the documents matching the given criteria.

    This method accepts any query and projection object, provided that there is an implicit Writer[S] typeclass for handling them in the scope.

    Please take a look to the mongodb documentation to know how querying works.

    S

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

    P

    the type of the projection object. An implicit Writer[P] typeclass for handling it has to be in the scope.

    projection

    Get only a subset of each matched documents. Defaults to None.

    returns

    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.

    Definition Classes
    GenericCollection
  26. def find[S](selector: S)(implicit swriter: RawBSONDocumentSerializer[S]): GenericQueryBuilder[WritableBuffer, RawBSONDocumentDeserializer, RawBSONDocumentSerializer]

    Find the documents matching the given criteria.

    Find the documents matching the given criteria.

    This method accepts any query and projection object, provided that there is an implicit Writer[S] typeclass for handling them in the scope.

    Please take a look to the mongodb documentation to know how querying works.

    S

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

    returns

    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.

    Definition Classes
    GenericCollection
  27. def formatted(fmtstr: String): String

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to StringFormat[ChannelCollection] performed by method StringFormat in scala.Predef.
    Definition Classes
    StringFormat
    Annotations
    @inline()
  28. def fullCollectionName: String

    Gets the full qualified name of this collection.

    Gets the full qualified name of this collection.

    Definition Classes
    Collection
  29. def genericQueryBuilder: GenericQueryBuilder[WritableBuffer, RawBSONDocumentDeserializer, RawBSONDocumentSerializer]

    Definition Classes
    ChannelCollectionGenericCollection
  30. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  31. def insert(document: WritableBuffer)(implicit ec: ExecutionContext): Future[LastError]

    Inserts a document into the collection and wait for the reactivemongo.core.commands.LastError result.

    Inserts a document into the collection and wait for the reactivemongo.core.commands.LastError result.

    document

    the document to insert.

    returns

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

    Definition Classes
    GenericCollection
  32. def insert(document: WritableBuffer, writeConcern: GetLastError)(implicit ec: ExecutionContext): Future[LastError]

    Inserts a document into the collection and wait for the reactivemongo.core.commands.LastError result.

    Inserts a document into the collection and wait for the reactivemongo.core.commands.LastError result.

    Please read the documentation about reactivemongo.core.commands.GetLastError to know how to use it properly.

    document

    the document to insert.

    writeConcern

    the reactivemongo.core.commands.GetLastError command message to send in order to control how the document is inserted. Defaults to GetLastError().

    returns

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

    Definition Classes
    GenericCollection
  33. def insert[T](document: T, writeConcern: GetLastError = GetLastError())(implicit writer: RawBSONDocumentSerializer[T], ec: ExecutionContext): Future[LastError]

    Inserts a document into the collection and wait for the reactivemongo.core.commands.LastError result.

    Inserts a document into the collection and wait for the reactivemongo.core.commands.LastError result.

    Please read the documentation about reactivemongo.core.commands.GetLastError to know how to use it properly.

    T

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

    document

    the document to insert.

    writeConcern

    the reactivemongo.core.commands.GetLastError command message to send in order to control how the document is inserted. Defaults to GetLastError().

    returns

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

    Definition Classes
    GenericCollection
  34. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  35. val name: String

    The name of the collection.

    The name of the collection.

    Definition Classes
    ChannelCollectionCollection
  36. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  37. final def notify(): Unit

    Definition Classes
    AnyRef
  38. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  39. def remove[T](query: T, writeConcern: GetLastError = GetLastError(), firstMatchOnly: Boolean = false)(implicit writer: RawBSONDocumentSerializer[T], ec: ExecutionContext): Future[LastError]

    Remove the matched document(s) from the collection and wait for the reactivemongo.core.commands.LastError result.

    Remove the matched document(s) from the collection and wait for the reactivemongo.core.commands.LastError result.

    Please read the documentation about reactivemongo.core.commands.GetLastError to know how to use it properly.

    T

    the type of the selector of documents to remove. An implicit Writer[T] typeclass for handling it has to be in the scope.

    query

    the selector of documents to remove.

    writeConcern

    the reactivemongo.core.commands.GetLastError command message to send in order to control how the documents are removed. Defaults to GetLastError().

    firstMatchOnly

    states whether only the first matched documents has to be removed from this collection.

    returns

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

    Definition Classes
    GenericCollection
  40. def sibling[C <: Collection](name: String, failoverStrategy: FailoverStrategy = failoverStrategy)(implicit producer: CollectionProducer[C] = ...): C

    Gets another collection in the current database.

    Gets another collection in the current database. An implicit CollectionProducer[C] must be present in the scope, or it will be the default implementation (reactivemongo.api.collections.default.BSONCollection).

    name

    The other collection name.

    failoverStrategy

    Overrides the default strategy.

    Definition Classes
    Collection
  41. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  42. def uncheckedInsert[T](document: T)(implicit writer: RawBSONDocumentSerializer[T]): Unit

    Inserts a document into the collection without writeConcern.

    Inserts a document into the collection without writeConcern.

    Please note that you cannot be sure that the document has been effectively written and when (hence the Unit return type).

    T

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

    document

    the document to insert.

    Definition Classes
    GenericCollection
  43. def uncheckedRemove[T](query: T, firstMatchOnly: Boolean = false)(implicit writer: RawBSONDocumentSerializer[T], ec: ExecutionContext): Unit

    Remove the matched document(s) from the collection without writeConcern.

    Remove the matched document(s) from the collection without writeConcern.

    Please note that you cannot be sure that the matched documents have been effectively removed and when (hence the Unit return type).

    T

    the type of the selector of documents to remove. An implicit Writer[T] typeclass for handling it has to be in the scope.

    query

    the selector of documents to remove.

    firstMatchOnly

    states whether only the first matched documents has to be removed from this collection.

    Definition Classes
    GenericCollection
  44. def uncheckedUpdate[S, U](selector: S, update: U, upsert: Boolean = false, multi: Boolean = false)(implicit selectorWriter: RawBSONDocumentSerializer[S], updateWriter: RawBSONDocumentSerializer[U]): Unit

    Updates one or more documents matching the given selector with the given modifier or update object.

    Updates one or more documents matching the given selector with the given modifier or update object.

    Please note that you cannot be sure that the matched documents have been effectively updated and when (hence the Unit return type).

    S

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

    U

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

    selector

    the selector object, for finding the documents to update.

    update

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

    upsert

    states whether the update objet should be inserted if no match found. Defaults to false.

    multi

    states whether the update may be done on all the matching documents.

    Definition Classes
    GenericCollection
  45. def update[S, U](selector: S, update: U, writeConcern: GetLastError = GetLastError(), upsert: Boolean = false, multi: Boolean = false)(implicit selectorWriter: RawBSONDocumentSerializer[S], updateWriter: RawBSONDocumentSerializer[U], ec: ExecutionContext): Future[LastError]

    Updates one or more documents matching the given selector with the given modifier or update object.

    Updates one or more documents matching the given selector with the given modifier or update object.

    S

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

    U

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

    selector

    the selector object, for finding the documents to update.

    update

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

    writeConcern

    the reactivemongo.core.commands.GetLastError command message to send in order to control how the documents are updated. Defaults to GetLastError().

    upsert

    states whether the update objet should be inserted if no match found. Defaults to false.

    multi

    states whether the update may be done on all the matching documents.

    returns

    a future reactivemongo.core.commands.LastError that can be used to check whether the update was successful.

    Definition Classes
    GenericCollection
  46. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  47. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  48. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. def watchFailure[T](future: ⇒ Future[T]): Future[T]

    Attributes
    protected
    Definition Classes
    GenericCollection
  50. def [B](y: B): (ChannelCollection, B)

    Implicit information
    This member is added by an implicit conversion from ChannelCollection to ArrowAssoc[ChannelCollection] performed by method ArrowAssoc in scala.Predef.
    Definition Classes
    ArrowAssoc

Deprecated Value Members

  1. def sister[C <: Collection](name: String, failoverStrategy: FailoverStrategy = failoverStrategy)(implicit producer: CollectionProducer[C] = ...): C

    Gets another collection in the current database.

    Gets another collection in the current database. An implicit CollectionProducer[C] must be present in the scope, or it will be the default implementation (reactivemongo.api.collections.default.BSONCollection).

    name

    The other collection name.

    failoverStrategy

    Overrides the default strategy.

    Definition Classes
    Collection
    Annotations
    @deprecated
    Deprecated

    (Since version 0.10) Consider using sibling instead

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from BufferGenericHandlers

Inherited from Collection

Inherited from AnyRef

Inherited from Any

Inherited by implicit conversion any2stringadd from ChannelCollection to any2stringadd[ChannelCollection]

Inherited by implicit conversion StringFormat from ChannelCollection to StringFormat[ChannelCollection]

Inherited by implicit conversion Ensuring from ChannelCollection to Ensuring[ChannelCollection]

Inherited by implicit conversion ArrowAssoc from ChannelCollection to ArrowAssoc[ChannelCollection]

Ungrouped