package scaladsl
- Source
- package.scala
- Alphabetic
- By Inheritance
- scaladsl
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- class DistributedData extends Extension
Akka extension for convenient configuration and use of the Replicator.
Akka extension for convenient configuration and use of the Replicator. Configuration settings are defined in the
akka.cluster.ddatasection, seereference.conf.This is using the same underlying
Replicatorinstance as akka.cluster.ddata.DistributedData and that means that typed and classic actors can share the same data. - class ReplicatorMessageAdapter[A, B <: ReplicatedData] extends AnyRef
When interacting with the
Replicatorfrom an actor this class provides convenient methods that adapts the response messages to the requesting actor's message protocol.When interacting with the
Replicatorfrom an actor this class provides convenient methods that adapts the response messages to the requesting actor's message protocol.One
ReplicatorMessageAdapterinstance can be used for a givenReplicatedDatatype, e.g. anOrSet[String]. Interaction with several Keys can be used via the same adapter but they must all be of the sameReplicatedDatatype. For interaction with several differentReplicatedDatatypes, e.g. anOrSet[String]and aGCounter, an adapter can be created for each type.For the default replicator in the DistributedData extension a
ReplicatorMessageAdaptercan be created with DistributedData.withReplicatorMessageAdapter.*Warning*:
ReplicatorMessageAdapteris not thread-safe and must only be used from the actor corresponding to the givenActorContext. It must not be accessed from threads other than the ordinary actor message processing thread, such as scala.concurrent.Future callbacks. It must not be shared between several actor instances.- A
Message type of the requesting actor.
- B
Type of the ReplicatedData.
- type ReplicatorSettings = ddata.ReplicatorSettings
Value Members
- object DistributedData extends ExtensionId[DistributedData]
- object Replicator
- See also
- object ReplicatorMessageAdapter
- object ReplicatorSettings