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

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 configuration akka.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 API
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 API
ReplicatorSettings	withDurableKeys(scala.collection.immutable.Set<java.lang.String> durableKeys)	Scala API
ReplicatorSettings	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 API
ReplicatorSettings	withRoles(scala.collection.Seq<java.lang.String> roles)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 configuration akka.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)