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

Class ReplicatedShardingExtension$

java.lang.Object

org.apache.pekko.actor.typed.ExtensionId<ReplicatedShardingExtension>

org.apache.pekko.cluster.sharding.typed.ReplicatedShardingExtension$

public class ReplicatedShardingExtension$
extends ExtensionId<ReplicatedShardingExtension>

Extension for running Replicated Event Sourcing in sharding by starting one separate instance of sharding per replica. The sharding instances can be confined to datacenters or cluster roles or run on the same set of cluster nodes.

Field Summary

Fields

Modifier and Type	Field	Description
static ReplicatedShardingExtension$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ReplicatedShardingExtension$()

Method Summary

Modifier and Type	Method	Description
ReplicatedShardingExtension	createExtension(ActorSystem<?> system)	Create the extension, will be invoked at most one time per actor system where the extension is registered.
ReplicatedShardingExtension	get(ActorSystem<?> system)

Methods inherited from class org.apache.pekko.actor.typed.ExtensionId

apply, equals, hashCode, id

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final ReplicatedShardingExtension$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ReplicatedShardingExtension$

public ReplicatedShardingExtension$()

Method Detail

createExtension

public ReplicatedShardingExtension createExtension(ActorSystem<?> system)

Description copied from class: ExtensionId

Create the extension, will be invoked at most one time per actor system where the extension is registered.

Specified by:

createExtension in class ExtensionId<ReplicatedShardingExtension>

get

public ReplicatedShardingExtension get(ActorSystem<?> system)