Package akka.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 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 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	Akka 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.Expire	Request to expire (remove) entries.
DurableStore.Expire$
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.UnspecificKey
Key.UnspecificKey$
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(akka.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.Expired<A extends ReplicatedData>
Replicator.Expired$
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 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>