Package org.apache.pekko.cluster.sharding.typed

Class ClusterShardingSettings

java.lang.Object

org.apache.pekko.cluster.sharding.typed.ClusterShardingSettings

public final class ClusterShardingSettings
extends Object

param: numberOfShards number of shards used by the default HashCodeMessageExtractor param: role Specifies that this entity type requires cluster nodes with a specific role. If the role is not specified all nodes in the cluster are used. If the given role does not match the role of the current node the ShardRegion will be started in proxy mode. param: dataCenter The data center of the cluster nodes where the cluster sharding is running. If the dataCenter is not specified then the same data center as current node. If the given dataCenter does not match the data center of the current node the ShardRegion will be started in proxy mode. param: rememberEntities true if active entity actors shall be automatically restarted upon Shard restart. i.e. if the Shard is started on a different ShardRegion due to rebalance or crash. param: journalPluginId Absolute path to the journal plugin configuration entity that is to be used for the internal persistence of ClusterSharding. If not defined the default journal plugin is used. Note that this is not related to persistence used by the entity actors. param: passivationStrategySettings settings for automatic passivation strategy, see descriptions in reference.conf param: snapshotPluginId Absolute path to the snapshot plugin configuration entity that is to be used for the internal persistence of ClusterSharding. If not defined the default snapshot plugin is used. Note that this is not related to persistence used by the entity actors. param: tuningParameters additional tuning parameters, see descriptions in reference.conf

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ClusterShardingSettings.PassivationStrategySettings	API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.
static class	ClusterShardingSettings.PassivationStrategySettings$	API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.
static interface	ClusterShardingSettings.RememberEntitiesStoreMode
static class	ClusterShardingSettings.RememberEntitiesStoreMode$
static class	ClusterShardingSettings.RememberEntitiesStoreModeDData$
static class	ClusterShardingSettings.RememberEntitiesStoreModeEventSourced$
static interface	ClusterShardingSettings.StateStoreMode
static class	ClusterShardingSettings.StateStoreMode$
static class	ClusterShardingSettings.StateStoreModeDData$
static class	ClusterShardingSettings.StateStoreModePersistence$
static final class	ClusterShardingSettings.TuningParameters

Constructor Summary

Constructors

Constructor

Description

ClusterShardingSettings(int numberOfShards, scala.Option<String> role, scala.Option<String> dataCenter, boolean rememberEntities, String journalPluginId, String snapshotPluginId, ClusterShardingSettings.PassivationStrategySettings passivationStrategySettings, scala.concurrent.duration.FiniteDuration shardRegionQueryTimeout, ClusterShardingSettings.StateStoreMode stateStoreMode, ClusterShardingSettings.RememberEntitiesStoreMode rememberEntitiesStoreMode, ClusterShardingSettings.TuningParameters tuningParameters, boolean coordinatorSingletonOverrideRole, ClusterSingletonManagerSettings coordinatorSingletonSettings, scala.Option<LeaseUsageSettings> leaseSettings)

Method Summary

Modifier and Type	Method	Description
static ClusterShardingSettings	apply(ActorSystem<?> system)	Scala API: Creates new cluster sharding settings object
boolean	coordinatorSingletonOverrideRole()
ClusterSingletonManagerSettings	coordinatorSingletonSettings()
static ClusterShardingSettings	create(ActorSystem<?> system)	Java API: Creates new cluster sharding settings object
scala.Option<String>	dataCenter()
static ClusterShardingSettings	fromConfig(com.typesafe.config.Config config)
String	journalPluginId()
scala.Option<LeaseUsageSettings>	leaseSettings()
int	numberOfShards()
ClusterShardingSettings.PassivationStrategySettings	passivationStrategySettings()
boolean	rememberEntities()
ClusterShardingSettings.RememberEntitiesStoreMode	rememberEntitiesStoreMode()
static ClusterShardingSettings.RememberEntitiesStoreMode	rememberEntitiesStoreModeDdata()	Java API
static ClusterShardingSettings.RememberEntitiesStoreMode	rememberEntitiesStoreModeEventSourced()	Java API
scala.Option<String>	role()
scala.concurrent.duration.FiniteDuration	shardRegionQueryTimeout()
String	snapshotPluginId()
ClusterShardingSettings.StateStoreMode	stateStoreMode()
static ClusterShardingSettings.StateStoreMode	stateStoreModeDdata()	Java API
static ClusterShardingSettings.StateStoreMode	stateStoreModePersistence()	Java API
ClusterShardingSettings.TuningParameters	tuningParameters()
ClusterShardingSettings	withCoordinatorSingletonSettings(ClusterSingletonManagerSettings coordinatorSingletonSettings)	The role of the ClusterSingletonManagerSettings is not used.
ClusterShardingSettings	withDataCenter(String dataCenter)
ClusterShardingSettings	withJournalPluginId(String journalPluginId)
ClusterShardingSettings	withLeaseSettings(LeaseUsageSettings leaseSettings)
ClusterShardingSettings	withNoPassivationStrategy()
ClusterShardingSettings	withPassivationStrategy(ClusterShardingSettings.PassivationStrategySettings settings)	API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.
ClusterShardingSettings	withRememberEntities(boolean rememberEntities)
ClusterShardingSettings	withRememberEntitiesStoreMode(ClusterShardingSettings.RememberEntitiesStoreMode rememberEntitiesStoreMode)
ClusterShardingSettings	withRole(String role)
ClusterShardingSettings	withShardRegionQueryTimeout(Duration duration)
ClusterShardingSettings	withShardRegionQueryTimeout(scala.concurrent.duration.FiniteDuration duration)
ClusterShardingSettings	withSnapshotPluginId(String snapshotPluginId)
ClusterShardingSettings	withStateStoreMode(ClusterShardingSettings.StateStoreMode stateStoreMode)
ClusterShardingSettings	withTuningParameters(ClusterShardingSettings.TuningParameters tuningParameters)

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterShardingSettings

public ClusterShardingSettings(int numberOfShards,
 scala.Option<String> role,
 scala.Option<String> dataCenter,
 boolean rememberEntities,
 String journalPluginId,
 String snapshotPluginId,
 ClusterShardingSettings.PassivationStrategySettings passivationStrategySettings,
 scala.concurrent.duration.FiniteDuration shardRegionQueryTimeout,
 ClusterShardingSettings.StateStoreMode stateStoreMode,
 ClusterShardingSettings.RememberEntitiesStoreMode rememberEntitiesStoreMode,
 ClusterShardingSettings.TuningParameters tuningParameters,
 boolean coordinatorSingletonOverrideRole,
 ClusterSingletonManagerSettings coordinatorSingletonSettings,
 scala.Option<LeaseUsageSettings> leaseSettings)

Method Details

apply

public static ClusterShardingSettings apply(ActorSystem<?> system)

Scala API: Creates new cluster sharding settings object

fromConfig

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

create

public static ClusterShardingSettings create(ActorSystem<?> system)

Java API: Creates new cluster sharding settings object

stateStoreModePersistence

public static ClusterShardingSettings.StateStoreMode stateStoreModePersistence()

Java API

stateStoreModeDdata

public static ClusterShardingSettings.StateStoreMode stateStoreModeDdata()

Java API

rememberEntitiesStoreModeEventSourced

public static ClusterShardingSettings.RememberEntitiesStoreMode rememberEntitiesStoreModeEventSourced()

Java API

rememberEntitiesStoreModeDdata

public static ClusterShardingSettings.RememberEntitiesStoreMode rememberEntitiesStoreModeDdata()

Java API

numberOfShards

public int numberOfShards()

role

public scala.Option<String> role()

dataCenter

public scala.Option<String> dataCenter()

rememberEntities

public boolean rememberEntities()

journalPluginId

public String journalPluginId()

snapshotPluginId

public String snapshotPluginId()

passivationStrategySettings

public ClusterShardingSettings.PassivationStrategySettings passivationStrategySettings()

shardRegionQueryTimeout

public scala.concurrent.duration.FiniteDuration shardRegionQueryTimeout()

stateStoreMode

public ClusterShardingSettings.StateStoreMode stateStoreMode()

rememberEntitiesStoreMode

public ClusterShardingSettings.RememberEntitiesStoreMode rememberEntitiesStoreMode()

tuningParameters

public ClusterShardingSettings.TuningParameters tuningParameters()

coordinatorSingletonOverrideRole

public boolean coordinatorSingletonOverrideRole()

coordinatorSingletonSettings

public ClusterSingletonManagerSettings coordinatorSingletonSettings()

leaseSettings

public scala.Option<LeaseUsageSettings> leaseSettings()

withRole

public ClusterShardingSettings withRole(String role)

withDataCenter

public ClusterShardingSettings withDataCenter(String dataCenter)

withRememberEntities

public ClusterShardingSettings withRememberEntities(boolean rememberEntities)

withJournalPluginId

public ClusterShardingSettings withJournalPluginId(String journalPluginId)

withSnapshotPluginId

public ClusterShardingSettings withSnapshotPluginId(String snapshotPluginId)

withTuningParameters

public ClusterShardingSettings withTuningParameters(ClusterShardingSettings.TuningParameters tuningParameters)

withStateStoreMode

public ClusterShardingSettings withStateStoreMode(ClusterShardingSettings.StateStoreMode stateStoreMode)

withRememberEntitiesStoreMode

public ClusterShardingSettings withRememberEntitiesStoreMode(ClusterShardingSettings.RememberEntitiesStoreMode rememberEntitiesStoreMode)

withPassivationStrategy

public ClusterShardingSettings withPassivationStrategy(ClusterShardingSettings.PassivationStrategySettings settings)

API MAY CHANGE: Settings for passivation strategies may change after additional testing and feedback.

withNoPassivationStrategy

public ClusterShardingSettings withNoPassivationStrategy()

withShardRegionQueryTimeout

public ClusterShardingSettings withShardRegionQueryTimeout(scala.concurrent.duration.FiniteDuration duration)

withShardRegionQueryTimeout

public ClusterShardingSettings withShardRegionQueryTimeout(Duration duration)

withLeaseSettings

public ClusterShardingSettings withLeaseSettings(LeaseUsageSettings leaseSettings)

withCoordinatorSingletonSettings

public ClusterShardingSettings withCoordinatorSingletonSettings(ClusterSingletonManagerSettings coordinatorSingletonSettings)

The role of the ClusterSingletonManagerSettings is not used. The role of the coordinator singleton will be the same as the role of ClusterShardingSettings.