Package org.apache.pekko.cluster.singleton

Class ClusterSingletonManagerSettings

java.lang.Object

org.apache.pekko.cluster.singleton.ClusterSingletonManagerSettings

All Implemented Interfaces:

NoSerializationVerificationNeeded

public final class ClusterSingletonManagerSettings
extends Object
implements NoSerializationVerificationNeeded

param: singletonName The actor name of the child singleton actor.

param: role Singleton among the nodes tagged with specified role. If the role is not specified it's a singleton among all nodes in the cluster.

param: removalMargin Margin until the singleton instance that belonged to a downed/removed partition is created in surviving partition. The purpose of this margin is that in case of a network partition the singleton actors in the non-surviving partitions must be stopped before corresponding actors are started somewhere else. This is especially important for persistent actors.

param: handOverRetryInterval When a node is becoming oldest it sends hand-over request to previous oldest, that might be leaving the cluster. This is retried with this interval until the previous oldest confirms that the hand over has started or the previous oldest member is removed from the cluster (+ removalMargin).

param: leaseSettings LeaseSettings for acquiring before creating the singleton actor

Constructor Summary

Constructors

Constructor	Description
ClusterSingletonManagerSettings(String singletonName, scala.Option<String> role, scala.concurrent.duration.FiniteDuration removalMargin, scala.concurrent.duration.FiniteDuration handOverRetryInterval)
ClusterSingletonManagerSettings(String singletonName, scala.Option<String> role, scala.concurrent.duration.FiniteDuration removalMargin, scala.concurrent.duration.FiniteDuration handOverRetryInterval, scala.Option<LeaseUsageSettings> leaseSettings)

Method Summary

Modifier and Type	Method	Description
static ClusterSingletonManagerSettings	apply(com.typesafe.config.Config config)	Create settings from a configuration with the same layout as the default configuration pekko.cluster.singleton.
static ClusterSingletonManagerSettings	apply(ActorSystem system)	Create settings from the default configuration pekko.cluster.singleton.
static ClusterSingletonManagerSettings	create(com.typesafe.config.Config config)	Java API: Create settings from a configuration with the same layout as the default configuration pekko.cluster.singleton.
static ClusterSingletonManagerSettings	create(ActorSystem system)	Java API: Create settings from the default configuration pekko.cluster.singleton.
scala.concurrent.duration.FiniteDuration	handOverRetryInterval()
scala.Option<LeaseUsageSettings>	leaseSettings()
scala.concurrent.duration.FiniteDuration	removalMargin()
scala.Option<String>	role()
String	singletonName()
ClusterSingletonManagerSettings	withHandOverRetryInterval(scala.concurrent.duration.FiniteDuration retryInterval)
ClusterSingletonManagerSettings	withLeaseSettings(LeaseUsageSettings leaseSettings)
ClusterSingletonManagerSettings	withRemovalMargin(scala.concurrent.duration.FiniteDuration removalMargin)
ClusterSingletonManagerSettings	withRole(String role)
ClusterSingletonManagerSettings	withRole(scala.Option<String> role)
ClusterSingletonManagerSettings	withSingletonName(String name)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterSingletonManagerSettings

public ClusterSingletonManagerSettings(String singletonName,
 scala.Option<String> role,
 scala.concurrent.duration.FiniteDuration removalMargin,
 scala.concurrent.duration.FiniteDuration handOverRetryInterval,
 scala.Option<LeaseUsageSettings> leaseSettings)

ClusterSingletonManagerSettings

public ClusterSingletonManagerSettings(String singletonName,
 scala.Option<String> role,
 scala.concurrent.duration.FiniteDuration removalMargin,
 scala.concurrent.duration.FiniteDuration handOverRetryInterval)

Method Details

apply

public static ClusterSingletonManagerSettings apply(ActorSystem system)

Create settings from the default configuration pekko.cluster.singleton.

apply

public static ClusterSingletonManagerSettings apply(com.typesafe.config.Config config)

Create settings from a configuration with the same layout as the default configuration pekko.cluster.singleton.

create

public static ClusterSingletonManagerSettings create(ActorSystem system)

Java API: Create settings from the default configuration pekko.cluster.singleton.

create

public static ClusterSingletonManagerSettings create(com.typesafe.config.Config config)

Java API: Create settings from a configuration with the same layout as the default configuration pekko.cluster.singleton.

singletonName

public String singletonName()

role

public scala.Option<String> role()

removalMargin

public scala.concurrent.duration.FiniteDuration removalMargin()

handOverRetryInterval

public scala.concurrent.duration.FiniteDuration handOverRetryInterval()

leaseSettings

public scala.Option<LeaseUsageSettings> leaseSettings()

withSingletonName

public ClusterSingletonManagerSettings withSingletonName(String name)

withRole

public ClusterSingletonManagerSettings withRole(String role)

withRole

public ClusterSingletonManagerSettings withRole(scala.Option<String> role)

withRemovalMargin

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

withHandOverRetryInterval

public ClusterSingletonManagerSettings withHandOverRetryInterval(scala.concurrent.duration.FiniteDuration retryInterval)

withLeaseSettings

public ClusterSingletonManagerSettings withLeaseSettings(LeaseUsageSettings leaseSettings)