JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
All Classes
SEARCH:
JavaScript is disabled on your browser.
Package org.apache.pekko.cluster.ddata.typed.scaladsl
Interface Summary
Interface
Description
Replicator.Command
Class Summary
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.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$