reactivemongo.core

actors

package actors

Visibility
  1. Public
  2. All

Type Members

  1. case class AuthRequest(authenticate: Authenticate, promise: Promise[SuccessfulAuthentication] = Promise()) extends Product with Serializable

  2. case class CheckedWriteRequestExpectingResponse(checkedWriteRequest: CheckedWriteRequest) extends ExpectingResponse with Product with Serializable

    A checked write request expecting a response.

    A checked write request expecting a response.

    checkedWriteRequest

    The request maker.

  3. sealed trait ExpectingResponse extends AnyRef

    A message expecting a response from database.

    A message expecting a response from database. It holds a promise that will be completed by the MongoDBSystem actor. The future can be used to get the error or the successful response.

  4. class MongoDBSystem extends Actor

    Main actor that processes the requests.

  5. class MonitorActor extends Actor

    A monitor for MongoDBSystem actors.

    A monitor for MongoDBSystem actors.

    This monitor will be sent node state change events (like PrimaryAvailable, PrimaryUnavailable, etc.). See WaitForPrimary message.

  6. case class RequestMakerExpectingResponse(requestMaker: RequestMaker) extends ExpectingResponse with Product with Serializable

    A request expecting a response.

    A request expecting a response.

    requestMaker

    The request maker.

Value Members

  1. object Close extends Product with Serializable

    Message to close all active connections.

    Message to close all active connections. The MongoDBSystem actor must not be used after this message has been sent.

  2. object Closed extends Product with Serializable

    MongoDBSystem has been shut down.

  3. object Exceptions

  4. object MongoDBSystem

  5. object MonitorActor

  6. object PrimaryAvailable extends Product with Serializable

    Message sent when the primary has been discovered.

  7. object PrimaryUnavailable extends Product with Serializable

    Message sent when the primary has been lost.

  8. object RegisterMonitor extends Product with Serializable

    Register a monitor.

  9. object SetAvailable extends Product with Serializable

  10. object SetUnavailable extends Product with Serializable

  11. object WaitForPrimary extends Product with Serializable

    A message to send to a MonitorActor to be warned when a primary has been discovered.

Ungrouped