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.
param: 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.
param: 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
.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) |
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,
scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps,
scala.collection.immutable.Set<java.lang.String> durableKeys) |
Modifier and Type | Method and Description |
---|---|
static ReplicatorSettings |
apply(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.collection.immutable.Set<java.lang.String> |
durableKeys() |
scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> |
durableStoreProps() |
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 |
withDurableKeys(scala.collection.immutable.Set<java.lang.String> durableKeys)
Scala API
|
ReplicatorSettings |
withDurableKeys(java.util.Set<java.lang.String> durableKeys)
Java API
|
ReplicatorSettings |
withDurableStoreProps(Props durableStoreProps) |
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, scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps, scala.collection.immutable.Set<java.lang.String> durableKeys)
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(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 scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps()
public scala.collection.immutable.Set<java.lang.String> durableKeys()
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)
public ReplicatorSettings withDurableStoreProps(Props durableStoreProps)
public ReplicatorSettings withDurableKeys(scala.collection.immutable.Set<java.lang.String> durableKeys)
durableKeys
- (undocumented)public ReplicatorSettings withDurableKeys(java.util.Set<java.lang.String> durableKeys)
durableKeys
- (undocumented)