Package org.apache.pekko.cluster.ddata

Interface Summary

Interface	Description
DeltaPropagationSelector	INTERNAL API: Used by the Replicator actor.
DeltaReplicatedData	ReplicatedData with additional support for delta-CRDT replication.
FastMerge	INTERNAL API
LWWRegister.Clock<A>
ORMap.DeltaOp
ORMap.ZeroTag
ORSet.DeltaOp
PruningState	INTERNAL API
RemovedNodePruning	ReplicatedData that has support for pruning of data belonging to a specific node may implement this interface.
ReplicatedData	Interface for implementing a state based convergent replicated data type (CvRDT).
ReplicatedDataSerialization	Marker trait for ReplicatedData serialized by pekko.cluster.ddata.protobuf.ReplicatedDataSerializer.
ReplicatedDelta	The delta must implement this type.
ReplicatedDeltaSize	Some complex deltas grow in size for each update and above a configured threshold such deltas are discarded and sent as full state instead.
Replicator.Command<A extends ReplicatedData>
Replicator.DeleteResponse<A extends ReplicatedData>
Replicator.Internal$.DestinationSystemUid
Replicator.Internal$.SendingSystemUid
Replicator.ReadConsistency
Replicator.ReplicatorMessage	Marker trait for remote messages serialized by pekko.cluster.ddata.protobuf.ReplicatorMessageSerializer.
Replicator.SubscribeResponse<A extends ReplicatedData>
Replicator.WriteConsistency
RequiresCausalDeliveryOfDeltas	Marker that specifies that the deltas must be applied in causal order.
VersionVector.Ordering

Class Summary

Class	Description
AbstractDeltaReplicatedData<A extends AbstractDeltaReplicatedData<A,B>,B extends ReplicatedDelta>	Java API: Interface for implementing a DeltaReplicatedData in Java.
AbstractReplicatedData<A extends AbstractReplicatedData<A>>	Java API: Interface for implementing a ReplicatedData in Java.
DistributedData	Pekko extension for convenient configuration and use of the Replicator.
DistributedData$
DurableStore	An actor implementing the durable store for the Distributed Data Replicator has to implement the protocol with the messages defined here.
DurableStore.DurableDataEnvelope	Wrapper class for serialization of a data value.
DurableStore.LoadAll$	Request to load all entries.
DurableStore.LoadAllCompleted$
DurableStore.LoadData
DurableStore.LoadData$
DurableStore.Store	Request to store an entry.
DurableStore.Store$
DurableStore.StoreReply
DurableStore.StoreReply$
DurableStore$	An actor implementing the durable store for the Distributed Data Replicator has to implement the protocol with the messages defined here.
EstimatedSize	INTERNAL API: Rough estimate in bytes of some serialized data elements.
EstimatedSize$	INTERNAL API: Rough estimate in bytes of some serialized data elements.
Flag
Flag$
FlagKey
FlagKey$
GCounter
GCounter$
GCounterKey
GCounterKey$
GSet<A>
GSet$
GSetKey<A>
GSetKey$
Key<T extends ReplicatedData>	Key for the key-value data in Replicator.
Key$
LmdbDurableStore
LmdbDurableStore$
LWWMap<A,B>	Specialized ORMap with LWWRegister values.
LWWMap.LWWMapTag$	INTERNAL API
LWWMap$
LWWMapKey<A,B>
LWWMapKey$
LWWRegister<A>	Implements a 'Last Writer Wins Register' CRDT, also called a 'LWW-Register'.
LWWRegister$
LWWRegisterKey<A>
LWWRegisterKey$
ManyVersionVector
ManyVersionVector$
OneVersionVector
OneVersionVector$
ORMap<A,B extends ReplicatedData>
ORMap.DeltaGroup$
ORMap.PutDeltaOp$
ORMap.RemoveDeltaOp$
ORMap.RemoveKeyDeltaOp$
ORMap.UpdateDeltaOp$
ORMap.VanillaORMapTag$
ORMap$
ORMapKey<A,B extends ReplicatedData>
ORMapKey$
ORMultiMap<A,B>	An immutable multi-map implementation.
ORMultiMap.ORMultiMapTag$	INTERNAL API
ORMultiMap.ORMultiMapWithValueDeltasTag$	INTERNAL API
ORMultiMap$
ORMultiMapKey<A,B>
ORMultiMapKey$
ORSet<A>
ORSet.AddDeltaOp$
ORSet.DeltaGroup$
ORSet.FullStateDeltaOp$
ORSet.RemoveDeltaOp$
ORSet$
ORSetKey<A>
ORSetKey$
PNCounter	Implements a 'Increment/Decrement Counter' CRDT, also called a 'PN-Counter'.
PNCounter$
PNCounterKey
PNCounterKey$
PNCounterMap<A>	Map of named counters.
PNCounterMap.PNCounterMapTag$	INTERNAL API
PNCounterMap$
PNCounterMapKey<A>
PNCounterMapKey$
PruningState.PruningInitialized
PruningState.PruningInitialized$
PruningState.PruningPerformed
PruningState.PruningPerformed$
PruningState$	INTERNAL API
ReadAggregator$	INTERNAL API
ReadWriteAggregator$	INTERNAL API
Replicator	A replicated in-memory data store supporting low latency and high availability requirements.
Replicator.Changed<A extends ReplicatedData>	The data value is retrieved with Replicator.Changed.get(org.apache.pekko.cluster.ddata.Key<T>) using the typed key.
Replicator.Changed$
Replicator.DataDeleted$
Replicator.Delete<A extends ReplicatedData>	Send this message to the local Replicator to delete a data value for the given key.
Replicator.Delete$
Replicator.Deleted<A extends ReplicatedData>
Replicator.Deleted$
Replicator.DeleteSuccess<A extends ReplicatedData>
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>	Send this message to the local Replicator to retrieve a data value for the given key.
Replicator.Get$
Replicator.GetDataDeleted<A extends ReplicatedData>	The Replicator.Get request couldn't be performed because the entry has been deleted.
Replicator.GetDataDeleted$
Replicator.GetFailure<A extends ReplicatedData>	The Replicator.Get request could not be fulfill according to the given consistency level and timeout.
Replicator.GetFailure$
Replicator.GetKeyIds$	INTERNAL API
Replicator.GetKeyIdsResult$
Replicator.GetReplicaCount$	Get current number of replicas, including the local replica.
Replicator.GetResponse<A extends ReplicatedData>
Replicator.GetSuccess<A extends ReplicatedData>	Reply from Get.
Replicator.GetSuccess$
Replicator.Internal$	INTERNAL API
Replicator.ModifyFailure<A extends ReplicatedData>	If the modify function of the Replicator.Update throws an exception the reply message will be this ModifyFailure message.
Replicator.ModifyFailure$
Replicator.NotFound<A extends ReplicatedData>
Replicator.NotFound$
Replicator.ReadAll
Replicator.ReadAll$
Replicator.ReadFrom
Replicator.ReadFrom$
Replicator.ReadLocal$
Replicator.ReadMajority
Replicator.ReadMajority$
Replicator.ReadMajorityPlus	ReadMajority but with the given number of additional nodes added to the majority count.
Replicator.ReadMajorityPlus$
Replicator.ReplicaCount	Current number of replicas.
Replicator.ReplicaCount$
Replicator.ReplicationDeleteFailure<A extends ReplicatedData>
Replicator.ReplicationDeleteFailure$
Replicator.StoreFailure<A extends ReplicatedData>	The local store or direct replication of the Replicator.Update could not be fulfill according to the given consistency level due to durable store errors.
Replicator.StoreFailure$
Replicator.Subscribe<A extends ReplicatedData>	Register a subscriber that will be notified with a Replicator.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<A extends ReplicatedData>	The Replicator.Update couldn't be performed because the entry has been deleted.
Replicator.UpdateDataDeleted$
Replicator.UpdateFailure<A extends ReplicatedData>
Replicator.UpdateResponse<A extends ReplicatedData>
Replicator.UpdateSuccess<A extends ReplicatedData>
Replicator.UpdateSuccess$
Replicator.UpdateTimeout<A extends ReplicatedData>	The direct replication of the Replicator.Update could not be fulfill according to the given consistency level and timeout.
Replicator.UpdateTimeout$
Replicator.WriteAll
Replicator.WriteAll$
Replicator.WriteLocal$
Replicator.WriteMajority
Replicator.WriteMajority$
Replicator.WriteMajorityPlus	WriteMajority but with the given number of additional nodes added to the majority count.
Replicator.WriteMajorityPlus$
Replicator.WriteTo
Replicator.WriteTo$
Replicator$
ReplicatorSettings	param: roles Replicas are running on members tagged with these roles.
ReplicatorSettings$
SelfUniqueAddress	Cluster non-specific (typed vs classic) wrapper for pekko.cluster.UniqueAddress.
SelfUniqueAddress$
VersionVector	Representation of a Vector-based clock (counting clock), inspired by Lamport logical clocks.
VersionVector.After$
VersionVector.Before$
VersionVector.Concurrent$
VersionVector.Same$
VersionVector.Timestamp$	INTERNAL API
VersionVector$	VersionVector module with helper classes and methods.
WriteAggregator$	INTERNAL API

Exception Summary

Exception	Description
DurableStore.LoadFailed
Replicator.DataDeleted<A extends ReplicatedData>