package protocol

Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. protocol
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. trait ChannelBufferReadable[T] extends AnyRef

    A constructor of T instances from a ByteBuf.

    A constructor of T instances from a ByteBuf.

    T

    type which instances can be constructed with this.

  2. trait ChannelBufferWritable extends AnyRef

    Something that can be written into a ByteBuf.

  3. sealed trait CollectionAwareRequestOp extends RequestOp

    A request that needs to know the full collection name.

  4. case class Delete(fullCollectionName: String, flags: Int) extends WriteRequestOp with Product with Serializable

    Delete operation.

    Delete operation.

    flags

    operation flags.

  5. case class GetMore(fullCollectionName: String, numberToReturn: Int, cursorID: Long) extends CollectionAwareRequestOp with Product with Serializable

    GetMore operation.

    GetMore operation.

    Allows to get more data from a cursor.

    numberToReturn

    number of documents to return in the response. 0 means the server will choose.

  6. case class Insert(flags: Int, fullCollectionName: String) extends WriteRequestOp with Product with Serializable

    Insert operation.

    Insert operation.

    flags

    Operation flags.

  7. case class KillCursors(cursorIDs: Set[Long]) extends RequestOp with Product with Serializable

    KillCursors operation.

    KillCursors operation.

    cursorIDs

    ids of the cursors to kill. Should not be empty.

  8. case class MessageHeader(messageLength: Int, requestID: Int, responseTo: Int, opCode: Int) extends ChannelBufferWritable with Product with Serializable

    Header of a Mongo Wire Protocol message.

    Header of a Mongo Wire Protocol message.

    messageLength

    length of this message.

    requestID

    id of this request (> 0 for request operations, else 0).

    responseTo

    id of the request that the message including this a response to (> 0 for reply operation, else 0).

    opCode

    operation code of this message.

  9. sealed trait MongoWireVersion extends Ordered[MongoWireVersion]
  10. sealed trait Op extends AnyRef

    A Mongo Wire Protocol operation

  11. case class Query(flags: Int, fullCollectionName: String, numberToSkip: Int, numberToReturn: Int) extends CollectionAwareRequestOp with Product with Serializable

    Query operation.

    Query operation.

    flags

    the operation flags

    fullCollectionName

    the full name of the queried collection

    numberToSkip

    the number of documents to skip in the response.

    numberToReturn

    The number of documents to return in the response. 0 means the server will choose.

  12. case class Reply(flags: Int, cursorID: Long, startingFrom: Int, numberReturned: Int) extends Op with Product with Serializable

    Reply operation.

    Reply operation.

    flags

    The flags of this response.

    cursorID

    The cursor id. Strictly positive if a cursor has been created server side, 0 if none or exhausted.

    startingFrom

    The index the returned documents start from.

    numberReturned

    The number of documents that are present in this reply.

  13. case class ReplyDocumentIteratorExhaustedException(cause: Exception) extends Exception with Product with Serializable
  14. case class Request(requestID: Int, responseTo: Int, op: RequestOp, documents: BufferSequence, readPreference: ReadPreference = ReadPreference.primary, channelIdHint: Option[ChannelId] = None) extends ChannelBufferWritable with Product with Serializable

    Request message.

    Request message.

    requestID

    the ID of this request, so that the response may be identifiable. Should be strictly positive.

    op

    request operation.

    documents

    body of this request, a ByteBuf containing 0, 1, or many documents.

    channelIdHint

    a hint for sending this request on a particular channel.

  15. case class RequestMaker(op: RequestOp, documents: BufferSequence = BufferSequence.empty, readPreference: ReadPreference = ReadPreference.primary, channelIdHint: Option[ChannelId] = None) extends Product with Serializable

    A helper to build requests.

    A helper to build requests.

    op

    write operation.

    documents

    body of this request, a ByteBuf containing 0, 1, or many documents.

    channelIdHint

    a hint for sending this request on a particular channel.

  16. sealed trait RequestOp extends Op with ChannelBufferWritable

    A Mongo Wire Protocol request operation.

    A Mongo Wire Protocol request operation.

    Actually, all operations excepted Reply are requests.

  17. implicit final class RichBuffer extends AnyVal
  18. case class Update(fullCollectionName: String, flags: Int) extends WriteRequestOp with Product with Serializable

    Update operation.

    Update operation.

    flags

    Operation flags.

  19. sealed trait WriteRequestOp extends CollectionAwareRequestOp

    A request that will perform a write on the database

  20. case class CheckedWriteRequest(op: WriteRequestOp, documents: BufferSequence, getLastError: GetLastError) extends Product with Serializable

    A helper to build write request which result needs to be checked (by sending a reactivemongo.api.commands.GetLastError command after).

    A helper to build write request which result needs to be checked (by sending a reactivemongo.api.commands.GetLastError command after).

    op

    write operation.

    documents

    body of this request, a ByteBuf containing 0, 1, or many documents.

    getLastError

    a GetLastError command message.

    Annotations
    @deprecated
    Deprecated

    (Since version 0.16.0) Unused

  21. sealed abstract class Response extends Product4[MessageHeader, Reply, ByteBuf, ResponseInfo] with Serializable

    A Mongo Wire Protocol Response messages.

    A Mongo Wire Protocol Response messages.

    Annotations
    @deprecated
    Deprecated

    (Since version 0.16.0) Will be private/internal

Value Members

  1. object MessageHeader extends ChannelBufferReadable[MessageHeader] with Serializable

    Header deserializer from a ByteBuf.

  2. object MongoWireVersion
  3. object QueryFlags

    Query flags.

  4. object Reply extends ChannelBufferReadable[Reply] with Serializable
  5. object ReplyDocumentIterator
  6. object Request extends Serializable

  7. object UpdateFlags

Deprecated Value Members

  1. object Response extends Serializable
    Annotations
    @deprecated
    Deprecated

    (Since version 0.16.0) Will be private/internal

  2. object ResponseInfo extends AbstractFunction1[ChannelId, ResponseInfo]
    Annotations
    @deprecated
    Deprecated

    (Since version 0.16.0) Will be private/internal

Inherited from AnyRef

Inherited from Any

Ungrouped