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

Modifier and Type	Method	Description
static ClusterSingletonSettings	apply(ActorSystem<?> system)
int	bufferSize()
static ClusterSingletonSettings	create(ActorSystem<?> system)	Java API
scala.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)

Methods inherited from class java.lang.Object

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

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 class java.lang.Object