Package akka.cluster.ddata.typed.scaladsl
-
Interface Summary Interface Description Replicator.Command -
Class Summary Class Description DistributedData ActorRef
of theReplicator
.DistributedData$ Replicator TheBehavior
for theReplicator
actor.Replicator.Changed$ Replicator.Delete<A extends ReplicatedData> Replicator.Delete$ Convenience forask
.Replicator.FlushChanges$ Notify subscribers of changes now, otherwise they will be notified periodically with the configurednotify-subscribers-interval
.Replicator.Get<A extends ReplicatedData> Replicator.Get$ Replicator.GetReplicaCount Replicator.GetReplicaCount$ Convenience forask
.Replicator.GetSuccess$ Replicator.Subscribe<A extends ReplicatedData> Register a subscriber that will be notified with aChanged
message when the value of the givenkey
is changed.Replicator.Subscribe$ Replicator.Unsubscribe<A extends ReplicatedData> Replicator.Unsubscribe$ Replicator.Update<A extends ReplicatedData> Replicator.Update$ Modify value of localReplicator
and replicate with givenwriteConsistency
.Replicator$ TheBehavior
for theReplicator
actor.ReplicatorSettings Create settings from the default configurationakka.cluster.distributed-data
.ReplicatorSettings$ Create settings from the default configurationakka.cluster.distributed-data
.