trait ReplicatedShardingExtension extends Extension
- Alphabetic
- By Inheritance
- ReplicatedShardingExtension
- Extension
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def init[M](thisReplica: ReplicaId, settings: ReplicatedEntityProvider[M]): ReplicatedSharding[M]
Init one instance sharding per replica in the given settings and return a ReplicatedSharding representing those.
Init one instance sharding per replica in the given settings and return a ReplicatedSharding representing those.
- M
The type of messages the replicated event sourced actor accepts Note, multiple calls on the same node will not start new sharding instances but will return a new instance of ReplicatedSharding
- thisReplica
If provided saves messages being forwarded to sharding for this replica
- abstract def init[M](settings: ReplicatedEntityProvider[M]): ReplicatedSharding[M]
Init one instance sharding per replica in the given settings and return a ReplicatedSharding representing those.
Init one instance sharding per replica in the given settings and return a ReplicatedSharding representing those.
- M
The type of messages the replicated event sourced actor accepts Note, multiple calls on the same node will not start new sharding instances but will return a new instance of ReplicatedSharding
Not for user extension.