Package org.apache.pekko.cluster.ddata
package org.apache.pekko.cluster.ddata
-
ClassDescriptionJava API: Interface for implementing a
DeltaReplicatedDatain Java.AbstractReplicatedData<A extends AbstractReplicatedData<A>>Java API: Interface for implementing aReplicatedDatain Java.INTERNAL API: Used by the Replicator actor.ReplicatedDatawith additional support for delta-CRDT replication.Pekko extension for convenient configuration and use of theReplicator.An actor implementing the durable store for the Distributed DataReplicatorhas to implement the protocol with the messages defined here.Wrapper class for serialization of a data value.Request to load all entries.Request to store an entry.An actor implementing the durable store for the Distributed DataReplicatorhas to implement the protocol with the messages defined here.INTERNAL API: Rough estimate in bytes of some serialized data elements.INTERNAL API: Rough estimate in bytes of some serialized data elements.INTERNAL APIGSet<A>GSetKey<A>Key<T extends ReplicatedData>Key for the key-value data inReplicator.LWWMap<A,B> SpecializedORMapwithLWWRegistervalues.INTERNAL APILWWMapKey<A,B> LWWRegister<A>Implements a 'Last Writer Wins Register' CRDT, also called a 'LWW-Register'.ORMap<A,B extends ReplicatedData> ORMapKey<A,B extends ReplicatedData> ORMultiMap<A,B> An immutable multi-map implementation.INTERNAL APIINTERNAL APIORMultiMapKey<A,B> ORSet<A>ORSetKey<A>Implements a 'Increment/Decrement Counter' CRDT, also called a 'PN-Counter'.PNCounterMap<A>Map of named counters.INTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIINTERNAL APIReplicatedDatathat has support for pruning of data belonging to a specific node may implement this interface.Interface for implementing a state based convergent replicated data type (CvRDT).Marker trait forReplicatedDataserialized bypekko.cluster.ddata.protobuf.ReplicatedDataSerializer.The delta must implement this type.Some complex deltas grow in size for each update and above a configured threshold such deltas are discarded and sent as full state instead.A replicated in-memory data store supporting low latency and high availability requirements.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.Command<A extends ReplicatedData>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.DeleteResponse<A extends ReplicatedData>Replicator.DeleteSuccess<A extends ReplicatedData>Notify subscribers of changes now, otherwise they will be notified periodically with the configurednotify-subscribers-interval.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.INTERNAL APIGet current number of replicas, including the local replica.Replicator.GetResponse<A extends ReplicatedData>Replicator.GetSuccess<A extends ReplicatedData>Reply fromGet.INTERNAL APIReplicator.ModifyFailure<A extends ReplicatedData>If themodifyfunction of theReplicator.Updatethrows an exception the reply message will be thisModifyFailuremessage.Replicator.NotFound<A extends ReplicatedData>ReadMajoritybut with the given number ofadditionalnodes added to the majority count.Current number of replicas.Marker trait for remote messages serialized bypekko.cluster.ddata.protobuf.ReplicatorMessageSerializer.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.WriteMajoritybut with the given number ofadditionalnodes added to the majority count.param: roles Replicas are running on members tagged with these roles.Marker that specifies that the deltas must be applied in causal order.Cluster non-specific (typed vs classic) wrapper forpekko.cluster.UniqueAddress.Representation of a Vector-based clock (counting clock), inspired by Lamport logical clocks.INTERNAL APIVersionVector module with helper classes and methods.INTERNAL API