public final class ReplicatorSettings
extends java.lang.Object
""
) the default dispatcher is used.
param: pruningInterval How often the Replicator checks for pruning of
data associated with removed cluster nodes.
param: 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.Constructor and Description |
---|
ReplicatorSettings(scala.Option<java.lang.String> role,
scala.concurrent.duration.FiniteDuration gossipInterval,
scala.concurrent.duration.FiniteDuration notifySubscribersInterval,
int maxDeltaElements,
java.lang.String dispatcher,
scala.concurrent.duration.FiniteDuration pruningInterval,
scala.concurrent.duration.FiniteDuration maxPruningDissemination) |
Modifier and Type | Method and Description |
---|---|
static ReplicatorSettings |
apply(akka.actor.ActorSystem system)
Create settings from the default configuration
akka.cluster.distributed-data . |
static ReplicatorSettings |
apply(com.typesafe.config.Config config)
Create settings from a configuration with the same layout as
the default configuration
akka.cluster.distributed-data . |
java.lang.String |
dispatcher() |
scala.concurrent.duration.FiniteDuration |
gossipInterval() |
int |
maxDeltaElements() |
scala.concurrent.duration.FiniteDuration |
maxPruningDissemination() |
scala.concurrent.duration.FiniteDuration |
notifySubscribersInterval() |
scala.concurrent.duration.FiniteDuration |
pruningInterval() |
scala.Option<java.lang.String> |
role() |
static scala.Option<java.lang.String> |
roleOption(java.lang.String role)
INTERNAL API
|
ReplicatorSettings |
withDispatcher(java.lang.String dispatcher) |
ReplicatorSettings |
withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval) |
ReplicatorSettings |
withMaxDeltaElements(int maxDeltaElements) |
ReplicatorSettings |
withNotifySubscribersInterval(scala.concurrent.duration.FiniteDuration notifySubscribersInterval) |
ReplicatorSettings |
withPruning(scala.concurrent.duration.FiniteDuration pruningInterval,
scala.concurrent.duration.FiniteDuration maxPruningDissemination) |
ReplicatorSettings |
withRole(scala.Option<java.lang.String> role) |
ReplicatorSettings |
withRole(java.lang.String role) |
public ReplicatorSettings(scala.Option<java.lang.String> role, scala.concurrent.duration.FiniteDuration gossipInterval, scala.concurrent.duration.FiniteDuration notifySubscribersInterval, int maxDeltaElements, java.lang.String dispatcher, scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination)
public static ReplicatorSettings apply(akka.actor.ActorSystem system)
akka.cluster.distributed-data
.system
- (undocumented)public static ReplicatorSettings apply(com.typesafe.config.Config config)
akka.cluster.distributed-data
.config
- (undocumented)public static scala.Option<java.lang.String> roleOption(java.lang.String role)
role
- (undocumented)public scala.Option<java.lang.String> role()
public scala.concurrent.duration.FiniteDuration gossipInterval()
public scala.concurrent.duration.FiniteDuration notifySubscribersInterval()
public int maxDeltaElements()
public java.lang.String dispatcher()
public scala.concurrent.duration.FiniteDuration pruningInterval()
public scala.concurrent.duration.FiniteDuration maxPruningDissemination()
public ReplicatorSettings withRole(java.lang.String role)
public ReplicatorSettings withRole(scala.Option<java.lang.String> role)
public ReplicatorSettings withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval)
public ReplicatorSettings withNotifySubscribersInterval(scala.concurrent.duration.FiniteDuration notifySubscribersInterval)
public ReplicatorSettings withMaxDeltaElements(int maxDeltaElements)
public ReplicatorSettings withDispatcher(java.lang.String dispatcher)
public ReplicatorSettings withPruning(scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination)