Package akka.cluster.ddata
Class ReplicatorSettings
- java.lang.Object
-
- akka.cluster.ddata.ReplicatorSettings
-
public final class ReplicatorSettings extends java.lang.Object
INTERNAL API
-
-
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)
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)
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)
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)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ReplicatorSettings
apply(ActorSystem system)
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()
int
maxDeltaElements()
int
maxDeltaSize()
scala.concurrent.duration.FiniteDuration
maxPruningDissemination()
static java.lang.String
name(ActorSystem system, scala.Option<java.lang.String> modifier)
INTERNAL API The name of the actor used in DistributedData extensions.scala.concurrent.duration.FiniteDuration
notifySubscribersInterval()
scala.concurrent.duration.FiniteDuration
pruningInterval()
scala.concurrent.duration.FiniteDuration
pruningMarkerTimeToLive()
scala.Option<java.lang.String>
role()
static scala.Option<java.lang.String>
roleOption(java.lang.String role)
INTERNAL APIscala.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
withMaxDeltaElements(int maxDeltaElements)
ReplicatorSettings
withMaxDeltaSize(int maxDeltaSize)
ReplicatorSettings
withNotifySubscribersInterval(scala.concurrent.duration.FiniteDuration notifySubscribersInterval)
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.Set<java.lang.String> roles)
INTERNAL APIReplicatorSettings
withRoles(scala.collection.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)
-
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)
-
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)
-
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)
-
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)
-
-
Method Detail
-
apply
public static ReplicatorSettings apply(ActorSystem system)
-
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
.- Parameters:
config
- (undocumented)- Returns:
- (undocumented)
-
roleOption
public static scala.Option<java.lang.String> roleOption(java.lang.String role)
INTERNAL API- Parameters:
role
- (undocumented)- Returns:
- (undocumented)
-
name
public static java.lang.String name(ActorSystem system, scala.Option<java.lang.String> modifier)
INTERNAL API The name of the actor used in DistributedData extensions.- Parameters:
system
- (undocumented)modifier
- (undocumented)- Returns:
- (undocumented)
-
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()
-
withRole
public ReplicatorSettings withRole(java.lang.String role)
-
withRole
public ReplicatorSettings withRole(scala.Option<java.lang.String> role)
-
withRoles
public ReplicatorSettings withRoles(scala.collection.Seq<java.lang.String> roles)
-
withRoles
public ReplicatorSettings withRoles(scala.collection.immutable.Set<java.lang.String> roles)
INTERNAL API- Parameters:
roles
- (undocumented)- Returns:
- (undocumented)
-
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- Parameters:
durableKeys
- (undocumented)- Returns:
- (undocumented)
-
withDurableKeys
public ReplicatorSettings withDurableKeys(java.util.Set<java.lang.String> durableKeys)
Java API- Parameters:
durableKeys
- (undocumented)- Returns:
- (undocumented)
-
withDeltaCrdtEnabled
public ReplicatorSettings withDeltaCrdtEnabled(boolean deltaCrdtEnabled)
-
withMaxDeltaSize
public ReplicatorSettings withMaxDeltaSize(int maxDeltaSize)
-
-