Package akka.cluster.ddata
Class ReplicatorSettings
- java.lang.Object
-
- akka.cluster.ddata.ReplicatorSettings
-
public final class ReplicatorSettings extends java.lang.Object
param: roles Replicas are running on members tagged with these roles. The member must have all given roles. All members are used if empty. param: gossipInterval How often the Replicator should send out gossip information. param: notifySubscribersInterval How often the subscribers will be notified of changes, if any. param: 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. param: dispatcher Id of the dispatcher to use for Replicator actors. If not specified (""
) 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, theLeft
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. 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 theSet
. param: preferOldest Update and Get operations are sent to oldest nodes first. param: logDataSizeExceeding Log data size.
-
-
Constructor Summary
Constructors Constructor Description ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, 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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize)
Deprecated.use full constructor.ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, 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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize, boolean preferOldest)
Deprecated.use full constructor.ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, 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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize, boolean preferOldest, scala.Option<java.lang.Object> logDataSizeExceeding)
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)
Deprecated.use full constructor.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)
Deprecated.use full constructor.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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled)
Deprecated.use full constructor.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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize)
Deprecated.use full constructor.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ReplicatorSettings
apply(ActorSystem system)
Create settings from the default configurationakka.cluster.distributed-data
.static ReplicatorSettings
apply(com.typesafe.config.Config config)
Create settings from a configuration with the same layout as the default configurationakka.cluster.distributed-data
.boolean
deltaCrdtEnabled()
java.lang.String
dispatcher()
scala.collection.immutable.Set<java.lang.String>
durableKeys()
scala.concurrent.duration.FiniteDuration
durablePruningMarkerTimeToLive()
scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props>
durableStoreProps()
scala.concurrent.duration.FiniteDuration
gossipInterval()
scala.Option<java.lang.Object>
logDataSizeExceeding()
int
maxDeltaElements()
int
maxDeltaSize()
scala.concurrent.duration.FiniteDuration
maxPruningDissemination()
scala.concurrent.duration.FiniteDuration
notifySubscribersInterval()
boolean
preferOldest()
scala.concurrent.duration.FiniteDuration
pruningInterval()
scala.concurrent.duration.FiniteDuration
pruningMarkerTimeToLive()
scala.Option<java.lang.String>
role()
scala.collection.immutable.Set<java.lang.String>
roles()
ReplicatorSettings
withDeltaCrdtEnabled(boolean deltaCrdtEnabled)
ReplicatorSettings
withDispatcher(java.lang.String dispatcher)
ReplicatorSettings
withDurableKeys(java.util.Set<java.lang.String> durableKeys)
Java APIReplicatorSettings
withDurableKeys(scala.collection.immutable.Set<java.lang.String> durableKeys)
Scala APIReplicatorSettings
withDurableStoreProps(Props durableStoreProps)
ReplicatorSettings
withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval)
ReplicatorSettings
withLogDataSizeExceeding(int logDataSizeExceeding)
ReplicatorSettings
withMaxDeltaElements(int maxDeltaElements)
ReplicatorSettings
withMaxDeltaSize(int maxDeltaSize)
ReplicatorSettings
withNotifySubscribersInterval(scala.concurrent.duration.FiniteDuration notifySubscribersInterval)
ReplicatorSettings
withPreferOldest(boolean preferOldest)
ReplicatorSettings
withPruning(scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination)
ReplicatorSettings
withPruningMarkerTimeToLive(scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive)
ReplicatorSettings
withRole(java.lang.String role)
ReplicatorSettings
withRole(scala.Option<java.lang.String> role)
ReplicatorSettings
withRoles(java.lang.String... roles)
ReplicatorSettings
withRoles(scala.collection.immutable.Seq<java.lang.String> roles)
-
-
-
Constructor Detail
-
ReplicatorSettings
public ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, 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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize, boolean preferOldest, scala.Option<java.lang.Object> logDataSizeExceeding)
-
ReplicatorSettings
public ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, 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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize, boolean preferOldest)
Deprecated.use full constructor. Since 2.6.11.
-
ReplicatorSettings
public ReplicatorSettings(scala.collection.immutable.Set<java.lang.String> roles, 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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize)
Deprecated.use full constructor. Since 2.6.11.
-
ReplicatorSettings
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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled, int maxDeltaSize)
Deprecated.use full constructor. Since 2.6.11.
-
ReplicatorSettings
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)
Deprecated.use full constructor. Since 2.6.11.
-
ReplicatorSettings
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)
Deprecated.use full constructor. Since 2.6.11.
-
ReplicatorSettings
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, scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive, boolean deltaCrdtEnabled)
Deprecated.use full constructor. Since 2.6.11.
-
-
Method Detail
-
apply
public static ReplicatorSettings apply(ActorSystem system)
Create settings from the default configurationakka.cluster.distributed-data
.
-
apply
public static ReplicatorSettings apply(com.typesafe.config.Config config)
Create settings from a configuration with the same layout as the default configurationakka.cluster.distributed-data
.
-
withRoles
public ReplicatorSettings withRoles(java.lang.String... roles)
-
roles
public scala.collection.immutable.Set<java.lang.String> roles()
-
gossipInterval
public scala.concurrent.duration.FiniteDuration gossipInterval()
-
notifySubscribersInterval
public scala.concurrent.duration.FiniteDuration notifySubscribersInterval()
-
maxDeltaElements
public int maxDeltaElements()
-
dispatcher
public java.lang.String dispatcher()
-
pruningInterval
public scala.concurrent.duration.FiniteDuration pruningInterval()
-
maxPruningDissemination
public scala.concurrent.duration.FiniteDuration maxPruningDissemination()
-
durableStoreProps
public scala.util.Either<scala.Tuple2<java.lang.String,com.typesafe.config.Config>,Props> durableStoreProps()
-
durableKeys
public scala.collection.immutable.Set<java.lang.String> durableKeys()
-
pruningMarkerTimeToLive
public scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive()
-
durablePruningMarkerTimeToLive
public scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive()
-
deltaCrdtEnabled
public boolean deltaCrdtEnabled()
-
maxDeltaSize
public int maxDeltaSize()
-
preferOldest
public boolean preferOldest()
-
logDataSizeExceeding
public scala.Option<java.lang.Object> logDataSizeExceeding()
-
withRole
public ReplicatorSettings withRole(java.lang.String role)
-
withRole
public ReplicatorSettings withRole(scala.Option<java.lang.String> role)
-
withRoles
public ReplicatorSettings withRoles(scala.collection.immutable.Seq<java.lang.String> roles)
-
role
public scala.Option<java.lang.String> role()
-
withGossipInterval
public ReplicatorSettings withGossipInterval(scala.concurrent.duration.FiniteDuration gossipInterval)
-
withNotifySubscribersInterval
public ReplicatorSettings withNotifySubscribersInterval(scala.concurrent.duration.FiniteDuration notifySubscribersInterval)
-
withMaxDeltaElements
public ReplicatorSettings withMaxDeltaElements(int maxDeltaElements)
-
withDispatcher
public ReplicatorSettings withDispatcher(java.lang.String dispatcher)
-
withPruning
public ReplicatorSettings withPruning(scala.concurrent.duration.FiniteDuration pruningInterval, scala.concurrent.duration.FiniteDuration maxPruningDissemination)
-
withPruningMarkerTimeToLive
public ReplicatorSettings withPruningMarkerTimeToLive(scala.concurrent.duration.FiniteDuration pruningMarkerTimeToLive, scala.concurrent.duration.FiniteDuration durablePruningMarkerTimeToLive)
-
withDurableStoreProps
public ReplicatorSettings withDurableStoreProps(Props durableStoreProps)
-
withDurableKeys
public ReplicatorSettings withDurableKeys(scala.collection.immutable.Set<java.lang.String> durableKeys)
Scala API
-
withDurableKeys
public ReplicatorSettings withDurableKeys(java.util.Set<java.lang.String> durableKeys)
Java API
-
withDeltaCrdtEnabled
public ReplicatorSettings withDeltaCrdtEnabled(boolean deltaCrdtEnabled)
-
withMaxDeltaSize
public ReplicatorSettings withMaxDeltaSize(int maxDeltaSize)
-
withPreferOldest
public ReplicatorSettings withPreferOldest(boolean preferOldest)
-
withLogDataSizeExceeding
public ReplicatorSettings withLogDataSizeExceeding(int logDataSizeExceeding)
-
-