org.eligosource.eventsourced.journal.mongodb.reactive

MongodbReactiveJournalProps

case class MongodbReactiveJournalProps(nodes: List[String], authentications: List[Authenticate] = immutable.this.List.empty[Nothing], nbChannelsPerNode: Int = 10, mongoDBSystemName: Option[String] = scala.None, dbName: String = ..., collName: String = ..., writeConcern: GetLastError = ..., name: Option[String] = scala.None, dispatcherName: Option[String] = scala.None, initTimeout: FiniteDuration = ..., replayChunkSize: Int = 16.*(100), snapshotPath: Path = ..., snapshotSerializer: SnapshotSerializer = ..., snapshotLoadTimeout: FiniteDuration = ..., snapshotSaveTimeout: FiniteDuration = ..., snapshotFilesystem: FileSystem = ..., readOnly: Boolean = false) extends JournalProps with HadoopFilesystemSnapshottingProps[MongodbReactiveJournalProps] with Product with Serializable

Configuration object for an Mongodb/Reactive based journal.

Journal actors can be created from a configuration object as follows:

import akka.actor._

import org.eligosource.eventsourced.core.Journal
import org.eligosource.eventsourced.journal.mongodb.reactive.MongodbReactiveJournalProps

implicit val system: ActorSystem = ...

val journal: ActorRef = Journal(MongodbReactiveJournalProps(List("localhost:27017"))
nodes

Required nodes to connect to.

authentications

Optional authentication list. Defaults to List.empty.

nbChannelsPerNode

Optional number of channels to open per node. Defaults to 10.

mongoDBSystemName

Optional name of the newly created {@see MongoDBSystem} actor, if needed

dbName

Optional mongoDB database name. Defaults to {@see DefaultDatabaseName}

collName

Optional mongoDB collection name. Defaults to {@see DefaultCollectionName}

writeConcern

Optional GetLastError. Defaults to awaitJournalCommit = false, waitForReplicatedOn = None, fsync = false.

name

Optional journal actor name.

dispatcherName

Optional journal actor dispatcher name.

initTimeout

Timeout for journal initialization. During initialization the highest stored sequence number is loaded from the event message table.

replayChunkSize

Maximum number of event messages to keep in memory during replay.

Linear Supertypes
Serializable, Serializable, Product, Equals, HadoopFilesystemSnapshottingProps[MongodbReactiveJournalProps], JournalProps, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. MongodbReactiveJournalProps
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. HadoopFilesystemSnapshottingProps
  7. JournalProps
  8. AnyRef
  9. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MongodbReactiveJournalProps(nodes: List[String], authentications: List[Authenticate] = immutable.this.List.empty[Nothing], nbChannelsPerNode: Int = 10, mongoDBSystemName: Option[String] = scala.None, dbName: String = ..., collName: String = ..., writeConcern: GetLastError = ..., name: Option[String] = scala.None, dispatcherName: Option[String] = scala.None, initTimeout: FiniteDuration = ..., replayChunkSize: Int = 16.*(100), snapshotPath: Path = ..., snapshotSerializer: SnapshotSerializer = ..., snapshotLoadTimeout: FiniteDuration = ..., snapshotSaveTimeout: FiniteDuration = ..., snapshotFilesystem: FileSystem = ..., readOnly: Boolean = false)

    nodes

    Required nodes to connect to.

    authentications

    Optional authentication list. Defaults to List.empty.

    nbChannelsPerNode

    Optional number of channels to open per node. Defaults to 10.

    mongoDBSystemName

    Optional name of the newly created {@see MongoDBSystem} actor, if needed

    dbName

    Optional mongoDB database name. Defaults to {@see DefaultDatabaseName}

    collName

    Optional mongoDB collection name. Defaults to {@see DefaultCollectionName}

    writeConcern

    Optional GetLastError. Defaults to awaitJournalCommit = false, waitForReplicatedOn = None, fsync = false.

    name

    Optional journal actor name.

    dispatcherName

    Optional journal actor dispatcher name.

    initTimeout

    Timeout for journal initialization. During initialization the highest stored sequence number is loaded from the event message table.

    replayChunkSize

    Maximum number of event messages to keep in memory during replay.

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  7. val authentications: List[Authenticate]

    Optional authentication list.

    Optional authentication list. Defaults to List.empty.

  8. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  9. val collName: String

    Optional mongoDB collection name.

    Optional mongoDB collection name. Defaults to {@see DefaultCollectionName}

  10. def createJournal(implicit actorRefFactory: ActorRefFactory): ActorRef

    Creates and starts a new journal using the settings of this configuration object.

    Creates and starts a new journal using the settings of this configuration object.

    Definition Classes
    JournalProps
  11. def createJournalActor: Actor

    Returns a new MongodbRactiveJournal.

    Returns a new MongodbRactiveJournal.

    Definition Classes
    MongodbReactiveJournalPropsJournalProps
  12. val dbName: String

    Optional mongoDB database name.

    Optional mongoDB database name. Defaults to {@see DefaultDatabaseName}

  13. val dispatcherName: Option[String]

    Optional journal actor dispatcher name.

    Optional journal actor dispatcher name.

    Definition Classes
    MongodbReactiveJournalPropsJournalProps
  14. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  15. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  17. val initTimeout: FiniteDuration

    Timeout for journal initialization.

    Timeout for journal initialization. During initialization the highest stored sequence number is loaded from the event message table.

  18. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  19. val mongoDBSystemName: Option[String]

    Optional name of the newly created {@see MongoDBSystem} actor, if needed

  20. val name: Option[String]

    Optional journal actor name.

    Optional journal actor name.

    Definition Classes
    MongodbReactiveJournalPropsJournalProps
  21. val nbChannelsPerNode: Int

    Optional number of channels to open per node.

    Optional number of channels to open per node. Defaults to 10.

  22. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  23. val nodes: List[String]

    Required nodes to connect to.

  24. final def notify(): Unit

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

    Definition Classes
    AnyRef
  26. val readOnly: Boolean

    Make journal read only (e.

    Make journal read only (e.g. offline snapshot)

    Definition Classes
    MongodbReactiveJournalPropsJournalProps
  27. val replayChunkSize: Int

    Maximum number of event messages to keep in memory during replay.

  28. val snapshotFilesystem: FileSystem

    Hadoop filesystem for storing snapshots.

    Hadoop filesystem for storing snapshots.

    Definition Classes
    MongodbReactiveJournalPropsHadoopFilesystemSnapshottingProps
  29. val snapshotLoadTimeout: FiniteDuration

    Timeout for loading a snapshot.

    Timeout for loading a snapshot.

    Definition Classes
    MongodbReactiveJournalPropsHadoopFilesystemSnapshottingProps
  30. val snapshotPath: Path

    Path where snapshots are stored on snapshotFilesystem.

    Path where snapshots are stored on snapshotFilesystem. A relative path is relative to snapshotFilesystem's working directory.

    Definition Classes
    MongodbReactiveJournalPropsHadoopFilesystemSnapshottingProps
  31. val snapshotSaveTimeout: FiniteDuration

    Timeout for saving a snapshot.

    Timeout for saving a snapshot.

    Definition Classes
    MongodbReactiveJournalPropsHadoopFilesystemSnapshottingProps
  32. val snapshotSerializer: SnapshotSerializer

    Serializer for writing and reading snapshots.

    Serializer for writing and reading snapshots.

    Definition Classes
    MongodbReactiveJournalPropsHadoopFilesystemSnapshottingProps
  33. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  34. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  37. def withAuthentications(authentications: List[Authenticate]): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified list of authentications.

  38. def withCollName(collName: String): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified collection name.

  39. def withDbName(dbName: String): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified database name.

  40. def withDispatcherName(dispatcherName: String): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified journal actor dispatcher name.

  41. def withInitTimeout(initTimeout: FiniteDuration): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified init timeout.

  42. def withMongoDBSystemName(mongoDBSystemName: String): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified journal actor name.

  43. def withName(name: String): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified journal actor name.

  44. def withNbChannelsPerNode(nbChannelsPerNode: Int): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified number of channels per node

  45. def withReadOnly(ro: Boolean): MongodbReactiveJournalProps

    Java API.

  46. def withReplayChunkSize(replayChunkSize: Int): MongodbReactiveJournalProps

    Returns a new MongodbReactiveJournalProps with specified replay chunk size.

  47. def withSnapshotFilesystem(snapshotFilesystem: FileSystem): MongodbReactiveJournalProps

    Java API.

  48. def withSnapshotLoadTimeout(snapshotLoadTimeout: FiniteDuration): MongodbReactiveJournalProps

    Java API.

  49. def withSnapshotPath(snapshotPath: Path): MongodbReactiveJournalProps

    Java API.

  50. def withSnapshotSaveTimeout(snapshotSaveTimeout: FiniteDuration): MongodbReactiveJournalProps

    Java API.

  51. def withSnapshotSerializer(snapshotSerializer: SnapshotSerializer): MongodbReactiveJournalProps

    Java API.

  52. val writeConcern: GetLastError

    Optional GetLastError.

    Optional GetLastError. Defaults to awaitJournalCommit = false, waitForReplicatedOn = None, fsync = false.

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from JournalProps

Inherited from AnyRef

Inherited from Any

Ungrouped