Class 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)  
    • 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​(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)
      • 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()
      • withRoles

        public ReplicatorSettings withRoles​(scala.collection.immutable.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)
      • 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)