final class ReplicatorSettings extends AnyRef

Source
Replicator.scala
Linear Supertypes
AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ReplicatorSettings
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ReplicatorSettings(roles: Set[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration, durableStoreProps: Either[(String, Config), Props], durableKeys: Set[KeyId], pruningMarkerTimeToLive: FiniteDuration, durablePruningMarkerTimeToLive: FiniteDuration, deltaCrdtEnabled: Boolean, maxDeltaSize: Int, preferOldest: Boolean, logDataSizeExceeding: Option[Int], expiryKeys: Map[KeyId, FiniteDuration])

    roles

    Replicas are running on members tagged with these roles. The member must have all given roles. All members are used if empty.

    gossipInterval

    How often the Replicator should send out gossip information.

    notifySubscribersInterval

    How often the subscribers will be notified of changes, if any.

    maxDeltaElements

    Maximum number of entries to transfer in one gossip message when synchronizing the replicas. Next chunk will be transferred in next round of gossip.

    dispatcher

    Id of the dispatcher to use for Replicator actors. If not specified ("") the default dispatcher is used.

    pruningInterval

    How often the Replicator checks for pruning of data associated with removed cluster nodes.

    maxPruningDissemination

    How long time it takes (worst case) to spread the data to all other replica nodes. This is used when initiating and completing the pruning process of data associated with removed cluster nodes. The time measurement is stopped when any replica is unreachable, so it should be configured to worst case in a healthy cluster.

    durableStoreProps

    Props for the durable store actor, the Left alternative is a tuple of fully qualified actor class name and the config constructor parameter of that class, the Right alternative is the Props of the actor.

    durableKeys

    Keys that are durable. Prefix matching is supported by using * at the end of a key. All entries can be made durable by including "*" in the Set.

    preferOldest

    Update and Get operations are sent to oldest nodes first.

    logDataSizeExceeding

    Log data size.

    expiryKeys

    Map of keys and inactivity duration for entries that will automatically be removed without tombstones when they have been inactive for the given duration. Prefix matching is supported by using * at the end of a key. Matching tombstones will also be removed after the expiry duration.

  2. new ReplicatorSettings(role: Option[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration, durableStoreProps: Either[(String, Config), Props], durableKeys: Set[String], pruningMarkerTimeToLive: FiniteDuration, durablePruningMarkerTimeToLive: FiniteDuration, deltaCrdtEnabled: Boolean)
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.11) use full constructor

  3. new ReplicatorSettings(role: Option[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration, durableStoreProps: Either[(String, Config), Props], durableKeys: Set[String])
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.11) use full constructor

  4. new ReplicatorSettings(role: Option[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration)
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.11) use full constructor

  5. new ReplicatorSettings(role: Option[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration, durableStoreProps: Either[(String, Config), Props], durableKeys: Set[KeyId], pruningMarkerTimeToLive: FiniteDuration, durablePruningMarkerTimeToLive: FiniteDuration, deltaCrdtEnabled: Boolean, maxDeltaSize: Int)
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.11) use full constructor

  6. new ReplicatorSettings(roles: Set[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration, durableStoreProps: Either[(String, Config), Props], durableKeys: Set[KeyId], pruningMarkerTimeToLive: FiniteDuration, durablePruningMarkerTimeToLive: FiniteDuration, deltaCrdtEnabled: Boolean, maxDeltaSize: Int)
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.11) use full constructor

  7. new ReplicatorSettings(roles: Set[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration, durableStoreProps: Either[(String, Config), Props], durableKeys: Set[KeyId], pruningMarkerTimeToLive: FiniteDuration, durablePruningMarkerTimeToLive: FiniteDuration, deltaCrdtEnabled: Boolean, maxDeltaSize: Int, preferOldest: Boolean)
    Annotations
    @deprecated
    Deprecated

    (Since version 2.6.11) use full constructor

  8. new ReplicatorSettings(roles: Set[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration, durableStoreProps: Either[(String, Config), Props], durableKeys: Set[KeyId], pruningMarkerTimeToLive: FiniteDuration, durablePruningMarkerTimeToLive: FiniteDuration, deltaCrdtEnabled: Boolean, maxDeltaSize: Int, preferOldest: Boolean, logDataSizeExceeding: Option[Int])
    Annotations
    @deprecated
    Deprecated

    (Since version 2.7.1) use full constructor

Value Members

  1. val deltaCrdtEnabled: Boolean
  2. val dispatcher: String
  3. val durableKeys: Set[KeyId]
  4. val durablePruningMarkerTimeToLive: FiniteDuration
  5. val durableStoreProps: Either[(String, Config), Props]
  6. val expiryKeys: Map[KeyId, FiniteDuration]
  7. val gossipInterval: FiniteDuration
  8. val logDataSizeExceeding: Option[Int]
  9. val maxDeltaElements: Int
  10. val maxDeltaSize: Int
  11. val maxPruningDissemination: FiniteDuration
  12. val notifySubscribersInterval: FiniteDuration
  13. val preferOldest: Boolean
  14. val pruningInterval: FiniteDuration
  15. val pruningMarkerTimeToLive: FiniteDuration
  16. def role: Option[String]
  17. val roles: Set[String]
  18. def withDeltaCrdtEnabled(deltaCrdtEnabled: Boolean): ReplicatorSettings
  19. def withDispatcher(dispatcher: String): ReplicatorSettings
  20. def withDurableKeys(durableKeys: Set[String]): ReplicatorSettings

    Java API

  21. def withDurableKeys(durableKeys: Set[KeyId]): ReplicatorSettings

    Scala API

  22. def withDurableStoreProps(durableStoreProps: Props): ReplicatorSettings
  23. def withExpiryKeys(expiryKeys: Map[String, Duration]): ReplicatorSettings

    Java API

  24. def withExpiryKeys(expiryKeys: Map[KeyId, FiniteDuration]): ReplicatorSettings

    Scala API

  25. def withGossipInterval(gossipInterval: FiniteDuration): ReplicatorSettings
  26. def withLogDataSizeExceeding(logDataSizeExceeding: Int): ReplicatorSettings
  27. def withMaxDeltaElements(maxDeltaElements: Int): ReplicatorSettings
  28. def withMaxDeltaSize(maxDeltaSize: Int): ReplicatorSettings
  29. def withNotifySubscribersInterval(notifySubscribersInterval: FiniteDuration): ReplicatorSettings
  30. def withPreferOldest(preferOldest: Boolean): ReplicatorSettings
  31. def withPruning(pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration): ReplicatorSettings
  32. def withPruningMarkerTimeToLive(pruningMarkerTimeToLive: FiniteDuration, durablePruningMarkerTimeToLive: FiniteDuration): ReplicatorSettings
  33. def withRole(role: Option[String]): ReplicatorSettings
  34. def withRole(role: String): ReplicatorSettings
  35. def withRoles(roles: String*): ReplicatorSettings
    Annotations
    @varargs()