Package org.apache.pekko.cluster.ddata.typed.scaladsl

package org.apache.pekko.cluster.ddata.typed.scaladsl

Class	Description
DistributedData	Pekko extension for convenient configuration and use of the Replicator.
DistributedData$
Replicator
Replicator.Changed$	The data value is retrieved with pekko.cluster.ddata.Replicator.Changed.get using the typed key.
Replicator.Command
Replicator.DataDeleted$
Replicator.Delete<A extends ReplicatedData>
Replicator.Delete$
Replicator.Deleted$
Replicator.DeleteFailure$
Replicator.DeleteSuccess$
Replicator.FlushChanges$	Notify subscribers of changes now, otherwise they will be notified periodically with the configured notify-subscribers-interval.
Replicator.Get<A extends ReplicatedData>
Replicator.Get$
Replicator.GetDataDeleted$
Replicator.GetFailure$
Replicator.GetReplicaCount
Replicator.GetReplicaCount$
Replicator.GetSuccess$
Replicator.ModifyFailure$
Replicator.NotFound$
Replicator.ReadAll$
Replicator.ReadFrom$
Replicator.ReadMajority$
Replicator.ReplicaCount$
Replicator.StoreFailure$
Replicator.Subscribe<A extends ReplicatedData>	Register a subscriber that will be notified with a Changed message when the value of the given key is changed.
Replicator.Subscribe$
Replicator.Unsubscribe<A extends ReplicatedData>	Unregister a subscriber.
Replicator.Unsubscribe$
Replicator.Update<A extends ReplicatedData>
Replicator.Update$
Replicator.UpdateDataDeleted$
Replicator.UpdateFailure$
Replicator.UpdateSuccess$
Replicator.UpdateTimeout$
Replicator.WriteAll$
Replicator.WriteMajority$
Replicator.WriteTo$
Replicator$
ReplicatorMessageAdapter<A,B extends ReplicatedData>	When interacting with the Replicator from an actor this class provides convenient methods that adapts the response messages to the requesting actor's message protocol.
ReplicatorMessageAdapter$
ReplicatorSettings
ReplicatorSettings$