Package org.apache.pekko.cluster.typed

Class ClusterSingletonSettings

java.lang.Object

org.apache.pekko.cluster.typed.ClusterSingletonSettings

public final class ClusterSingletonSettings
extends Object

Constructor Summary

Constructors

Constructor	Description
ClusterSingletonSettings(scala.Option<String> role, scala.Option<String> dataCenter, scala.concurrent.duration.FiniteDuration singletonIdentificationInterval, scala.concurrent.duration.FiniteDuration removalMargin, scala.concurrent.duration.FiniteDuration handOverRetryInterval, int bufferSize, scala.Option<LeaseUsageSettings> leaseSettings)

Method Summary

Modifier and Type	Method	Description
static ClusterSingletonSettings	apply(ActorSystem<?> system)
int	bufferSize()
static ClusterSingletonSettings	create(ActorSystem<?> system)	Java API
scala.Option<String>	dataCenter()
static ClusterSingletonSettings	fromConfig(com.typesafe.config.Config config)
scala.concurrent.duration.FiniteDuration	handOverRetryInterval()
scala.Option<LeaseUsageSettings>	leaseSettings()
scala.concurrent.duration.FiniteDuration	removalMargin()
scala.Option<String>	role()
scala.concurrent.duration.FiniteDuration	singletonIdentificationInterval()
String	toString()
ClusterSingletonSettings	withBufferSize(int bufferSize)
ClusterSingletonSettings	withDataCenter(String dataCenter)
ClusterSingletonSettings	withHandoverRetryInterval(Duration handOverRetryInterval)
ClusterSingletonSettings	withHandoverRetryInterval(scala.concurrent.duration.FiniteDuration handOverRetryInterval)
ClusterSingletonSettings	withLeaseSettings(LeaseUsageSettings leaseSettings)
ClusterSingletonSettings	withNoDataCenter()
ClusterSingletonSettings	withNoRole()
ClusterSingletonSettings	withRemovalMargin(Duration removalMargin)
ClusterSingletonSettings	withRemovalMargin(scala.concurrent.duration.FiniteDuration removalMargin)
ClusterSingletonSettings	withRole(String role)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterSingletonSettings

public ClusterSingletonSettings(scala.Option<String> role,
 scala.Option<String> dataCenter,
 scala.concurrent.duration.FiniteDuration singletonIdentificationInterval,
 scala.concurrent.duration.FiniteDuration removalMargin,
 scala.concurrent.duration.FiniteDuration handOverRetryInterval,
 int bufferSize,
 scala.Option<LeaseUsageSettings> leaseSettings)

Method Details

apply

public static ClusterSingletonSettings apply(ActorSystem<?> system)

create

public static ClusterSingletonSettings create(ActorSystem<?> system)

Java API

fromConfig

public static ClusterSingletonSettings fromConfig(com.typesafe.config.Config config)

role

public scala.Option<String> role()

dataCenter

public scala.Option<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()

leaseSettings

public scala.Option<LeaseUsageSettings> leaseSettings()

withRole

public ClusterSingletonSettings withRole(String role)

withNoRole

public ClusterSingletonSettings withNoRole()

withDataCenter

public ClusterSingletonSettings withDataCenter(String dataCenter)

withNoDataCenter

public ClusterSingletonSettings withNoDataCenter()

withRemovalMargin

public ClusterSingletonSettings withRemovalMargin(scala.concurrent.duration.FiniteDuration removalMargin)

withRemovalMargin

public ClusterSingletonSettings withRemovalMargin(Duration removalMargin)

withHandoverRetryInterval

public ClusterSingletonSettings withHandoverRetryInterval(scala.concurrent.duration.FiniteDuration handOverRetryInterval)

withHandoverRetryInterval

public ClusterSingletonSettings withHandoverRetryInterval(Duration handOverRetryInterval)

withBufferSize

public ClusterSingletonSettings withBufferSize(int bufferSize)

withLeaseSettings

public ClusterSingletonSettings withLeaseSettings(LeaseUsageSettings leaseSettings)

toString

public String toString()

Overrides:

toString in class Object