Package akka.cluster.typed
Class ClusterSingletonSettings
- java.lang.Object
-
- akka.cluster.typed.ClusterSingletonSettings
-
- All Implemented Interfaces:
NoSerializationVerificationNeeded
public final class ClusterSingletonSettings extends java.lang.Object implements NoSerializationVerificationNeeded
INTERNAL API:
-
-
Constructor Summary
Constructors Constructor Description ClusterSingletonSettings(scala.Option<java.lang.String> role, scala.Option<java.lang.String> dataCenter, scala.concurrent.duration.FiniteDuration singletonIdentificationInterval, scala.concurrent.duration.FiniteDuration removalMargin, scala.concurrent.duration.FiniteDuration handOverRetryInterval, int bufferSize)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static ClusterSingletonSettings
apply(ActorSystem<?> system)
int
bufferSize()
static ClusterSingletonSettings
create(ActorSystem<?> system)
Java APIscala.Option<java.lang.String>
dataCenter()
static ClusterSingletonSettings
fromConfig(com.typesafe.config.Config config)
scala.concurrent.duration.FiniteDuration
handOverRetryInterval()
scala.concurrent.duration.FiniteDuration
removalMargin()
scala.Option<java.lang.String>
role()
boolean
shouldRunManager(Cluster cluster)
INTERNAL API:scala.concurrent.duration.FiniteDuration
singletonIdentificationInterval()
ClusterSingletonManagerSettings
toManagerSettings(java.lang.String singletonName)
INTERNAL API:ClusterSingletonProxySettings
toProxySettings(java.lang.String singletonName)
INTERNAL API:java.lang.String
toString()
ClusterSingletonSettings
withBufferSize(int bufferSize)
ClusterSingletonSettings
withDataCenter(java.lang.String dataCenter)
ClusterSingletonSettings
withHandoverRetryInterval(java.time.Duration handOverRetryInterval)
ClusterSingletonSettings
withHandoverRetryInterval(scala.concurrent.duration.FiniteDuration handOverRetryInterval)
ClusterSingletonSettings
withNoDataCenter()
ClusterSingletonSettings
withNoRole()
ClusterSingletonSettings
withRemovalMargin(java.time.Duration removalMargin)
ClusterSingletonSettings
withRemovalMargin(scala.concurrent.duration.FiniteDuration removalMargin)
ClusterSingletonSettings
withRole(java.lang.String role)
-
-
-
Constructor Detail
-
ClusterSingletonSettings
public ClusterSingletonSettings(scala.Option<java.lang.String> role, scala.Option<java.lang.String> dataCenter, scala.concurrent.duration.FiniteDuration singletonIdentificationInterval, scala.concurrent.duration.FiniteDuration removalMargin, scala.concurrent.duration.FiniteDuration handOverRetryInterval, int bufferSize)
-
-
Method Detail
-
apply
public static ClusterSingletonSettings apply(ActorSystem<?> system)
-
create
public static ClusterSingletonSettings create(ActorSystem<?> system)
Java API- Parameters:
system
- (undocumented)- Returns:
- (undocumented)
-
fromConfig
public static ClusterSingletonSettings fromConfig(com.typesafe.config.Config config)
-
role
public scala.Option<java.lang.String> role()
-
dataCenter
public scala.Option<java.lang.String> dataCenter()
-
singletonIdentificationInterval
public scala.concurrent.duration.FiniteDuration singletonIdentificationInterval()
-
removalMargin
public scala.concurrent.duration.FiniteDuration removalMargin()
-
handOverRetryInterval
public scala.concurrent.duration.FiniteDuration handOverRetryInterval()
-
bufferSize
public int bufferSize()
-
withRole
public ClusterSingletonSettings withRole(java.lang.String role)
-
withNoRole
public ClusterSingletonSettings withNoRole()
-
withDataCenter
public ClusterSingletonSettings withDataCenter(java.lang.String dataCenter)
-
withNoDataCenter
public ClusterSingletonSettings withNoDataCenter()
-
withRemovalMargin
public ClusterSingletonSettings withRemovalMargin(scala.concurrent.duration.FiniteDuration removalMargin)
-
withRemovalMargin
public ClusterSingletonSettings withRemovalMargin(java.time.Duration removalMargin)
-
withHandoverRetryInterval
public ClusterSingletonSettings withHandoverRetryInterval(scala.concurrent.duration.FiniteDuration handOverRetryInterval)
-
withHandoverRetryInterval
public ClusterSingletonSettings withHandoverRetryInterval(java.time.Duration handOverRetryInterval)
-
withBufferSize
public ClusterSingletonSettings withBufferSize(int bufferSize)
-
toManagerSettings
public ClusterSingletonManagerSettings toManagerSettings(java.lang.String singletonName)
INTERNAL API:- Parameters:
singletonName
- (undocumented)- Returns:
- (undocumented)
-
toProxySettings
public ClusterSingletonProxySettings toProxySettings(java.lang.String singletonName)
INTERNAL API:- Parameters:
singletonName
- (undocumented)- Returns:
- (undocumented)
-
shouldRunManager
public boolean shouldRunManager(Cluster cluster)
INTERNAL API:- Parameters:
cluster
- (undocumented)- Returns:
- (undocumented)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-