object ReplicatedEntityProvider
- Source
- ReplicatedEntityProvider.scala
- Alphabetic
- By Inheritance
- ReplicatedEntityProvider
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- def apply[M](typeName: String, allReplicaIds: Set[ReplicaId])(settingsPerReplicaFactory: (EntityTypeKey[M], ) => ReplicatedEntity[M])(implicit arg0: ClassTag[M]): ReplicatedEntityProvider[M]
Scala API:
Scala API:
Provides full control over the ReplicatedEntity and the Entity Most use cases can use the and perRole
- M
The type of messages the replicated entity accepts
- typeName
The type name used in the EntityTypeKey
- def create[M](messageClass: Class[M], typeName: String, allReplicaIds: [ReplicaId], settingsPerReplicaFactory: [EntityTypeKey[M], , ReplicatedEntity[M]]): ReplicatedEntityProvider[M]
Java API:
Java API:
Provides full control over the ReplicatedEntity and the Entity Most use cases can use the and createPerRole
- M
The type of messages the replicated entity accepts
- def createPerRole[M](messageClass: Class[M], typeName: String, allReplicaIds: [ReplicaId], createBehavior: [, Behavior[M]]): ReplicatedEntityProvider[M]
Java API
Java API
Create a ReplicatedEntityProvider that uses the defaults for Entity when running in ClusterSharding.
Map replicas to roles and then there will be a replica per role e.g. to match to availability zones/racks
- def perRole[M, E](typeName: String, allReplicaIds: Set[ReplicaId])(create: () => Behavior[M])(implicit arg0: ClassTag[M]): ReplicatedEntityProvider[M]
Scala API
Scala API
Create a ReplicatedEntityProvider that uses the defaults for Entity when running in ClusterSharding. The replicas in allReplicaIds should be roles used by nodes. A replica for each entity will run on each role.
Deprecated Value Members
- def createPerDataCenter[M](messageClass: Class[M], typeName: String, allReplicaIds: [ReplicaId], createBehavior: [, Behavior[M]]): ReplicatedEntityProvider[M]
Java API
Java API
Create a ReplicatedEntityProvider that uses the defaults for Entity when running in ClusterSharding. A replica will be run per data center.
- Annotations
- @deprecated
- Deprecated
(Since version 2.10.0) Use Akka Distributed Cluster instead
- def perDataCenter[M, E](typeName: String, allReplicaIds: Set[ReplicaId])(create: () => Behavior[M])(implicit arg0: ClassTag[M]): ReplicatedEntityProvider[M]
Scala API
Scala API
Create a ReplicatedEntityProvider that uses the defaults for Entity when running in ClusterSharding. A replica will be run per data center.
- Annotations
- @deprecated
- Deprecated
(Since version 2.10.0) Use Akka Distributed Cluster instead