final class ReplicatorSettings extends AnyRef
- Alphabetic
- By Inheritance
- ReplicatorSettings
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new ReplicatorSettings(role: Option[String], gossipInterval: FiniteDuration, notifySubscribersInterval: FiniteDuration, maxDeltaElements: Int, dispatcher: String, pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration)
-
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])
- role
Replicas are running on members tagged with this role. All members are used if undefined.
- 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, theRight
alternative is theProps
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 theSet
.
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to any2stringadd[ReplicatorSettings] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
->[B](y: B): (ReplicatorSettings, B)
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to ArrowAssoc[ReplicatorSettings] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- val dispatcher: String
- val durableKeys: Set[String]
- val durableStoreProps: Either[(String, Config), Props]
-
def
ensuring(cond: (ReplicatorSettings) ⇒ Boolean, msg: ⇒ Any): ReplicatorSettings
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to Ensuring[ReplicatorSettings] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (ReplicatorSettings) ⇒ Boolean): ReplicatorSettings
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to Ensuring[ReplicatorSettings] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): ReplicatorSettings
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to Ensuring[ReplicatorSettings] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): ReplicatorSettings
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to Ensuring[ReplicatorSettings] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to StringFormat[ReplicatorSettings] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- val gossipInterval: FiniteDuration
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxDeltaElements: Int
- val maxPruningDissemination: FiniteDuration
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- val notifySubscribersInterval: FiniteDuration
- val pruningInterval: FiniteDuration
- val role: Option[String]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
- def withDispatcher(dispatcher: String): ReplicatorSettings
-
def
withDurableKeys(durableKeys: Set[String]): ReplicatorSettings
Java API
-
def
withDurableKeys(durableKeys: Set[String]): ReplicatorSettings
Scala API
- def withDurableStoreProps(durableStoreProps: Props): ReplicatorSettings
- def withGossipInterval(gossipInterval: FiniteDuration): ReplicatorSettings
- def withMaxDeltaElements(maxDeltaElements: Int): ReplicatorSettings
- def withNotifySubscribersInterval(notifySubscribersInterval: FiniteDuration): ReplicatorSettings
- def withPruning(pruningInterval: FiniteDuration, maxPruningDissemination: FiniteDuration): ReplicatorSettings
- def withRole(role: Option[String]): ReplicatorSettings
- def withRole(role: String): ReplicatorSettings
-
def
→[B](y: B): (ReplicatorSettings, B)
- Implicit
- This member is added by an implicit conversion from ReplicatorSettings to ArrowAssoc[ReplicatorSettings] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc