Package org.apache.pekko.cluster.ddata.typed.javadsl
package org.apache.pekko.cluster.ddata.typed.javadsl
-
ClassDescriptionPekko extension for convenient configuration and use of the
Replicator.Can be used inpekko.actor.setup.ActorSystemSetupwhen starting thepekko.actor.typed.ActorSystemto replace the default implementation of theDistributedDataextension.Replicator.Changed<A extends ReplicatedData>The data value is retrieved withReplicator.Changed.get(org.apache.pekko.cluster.ddata.Key<T>)using the typed key.Replicator.DataDeleted<A extends ReplicatedData>Replicator.Delete<A extends ReplicatedData>Send this message to the localReplicatorto delete a data value for the givenkey.Replicator.Deleted<A extends ReplicatedData>Replicator.DeleteFailure<A extends ReplicatedData>Replicator.DeleteResponse<A extends ReplicatedData>Replicator.DeleteSuccess<A extends ReplicatedData>INTERNAL API Obtain the instance of this class with theReplicator.flushChanges()method.Replicator.Get<A extends ReplicatedData>Send this message to the localReplicatorto retrieve a data value for the givenkey.Replicator.GetDataDeleted<A extends ReplicatedData>TheReplicator.Getrequest couldn't be performed because the entry has been deleted.Replicator.GetFailure<A extends ReplicatedData>TheReplicator.Getrequest could not be fulfill according to the givenconsistency levelandtimeout.Get current number of replicas, including the local replica.Replicator.GetResponse<A extends ReplicatedData>Replicator.GetSuccess<A extends ReplicatedData>Reply fromGet.Replicator.ModifyFailure<A extends ReplicatedData>If themodifyfunction of theReplicator.Updatethrows an exception the reply message will be thisModifyFailuremessage.Replicator.NotFound<A extends ReplicatedData>Current number of replicas.Replicator.StoreFailure<A extends ReplicatedData>The local store or direct replication of theReplicator.Updatecould not be fulfill according to the givenconsistency leveldue to durable store errors.Replicator.Subscribe<A extends ReplicatedData>Register a subscriber that will be notified with aReplicator.Changedmessage when the value of the givenkeyis changed.Replicator.SubscribeResponse<A extends ReplicatedData>Replicator.Unsubscribe<A extends ReplicatedData>Unregister a subscriber.Replicator.Update<A extends ReplicatedData>Replicator.UpdateDataDeleted<A extends ReplicatedData>TheReplicator.Updatecouldn't be performed because the entry has been deleted.Replicator.UpdateFailure<A extends ReplicatedData>Replicator.UpdateResponse<A extends ReplicatedData>Replicator.UpdateSuccess<A extends ReplicatedData>Replicator.UpdateTimeout<A extends ReplicatedData>The direct replication of theReplicator.Updatecould not be fulfill according to the givenconsistency levelandtimeout.ReplicatorMessageAdapter<A,B extends ReplicatedData> When interacting with theReplicatorfrom an actor this class provides convenient methods that adapts the response messages to the requesting actor's message protocol.