Package akka.cluster.ddata

Interface Summary

Interface	Description
FastMerge	INTERNAL API
LWWRegister.Clock<A>
PruningState.PruningPhase
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.
Replicator.Command<A extends ReplicatedData>
Replicator.DeleteResponse<A extends ReplicatedData>
Replicator.ReadConsistency
Replicator.ReplicatorMessage	Marker trait for remote messages serialized by ReplicatorMessageSerializer.
Replicator.WriteConsistency
VersionVector.Ordering

Class Summary

Class	Description
AbstractReplicatedData<D extends AbstractReplicatedData<D>>	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.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.
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>	Specialized ORMap with LWWRegister values.
LWWMap$
LWWMapKey<A>
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 extends ReplicatedData>	Implements a 'Observed Remove Map' CRDT, also called a 'OR-Map'.
ORMap$
ORMapKey<A extends ReplicatedData>
ORMapKey$
ORMultiMap<A>	An immutable multi-map implementation.
ORMultiMap$
ORMultiMapKey<A>
ORMultiMapKey$
ORSet<A>	Implements a 'Observed Remove Set' CRDT, also called a 'OR-Set'.
ORSet$
ORSetKey<A>
ORSetKey$
PNCounter	Implements a 'Increment/Decrement Counter' CRDT, also called a 'PN-Counter'.
PNCounter$
PNCounterKey
PNCounterKey$
PNCounterMap	Map of named counters.
PNCounterMap$
PNCounterMapKey
PNCounterMapKey$
PruningState
PruningState.PruningInitialized
PruningState.PruningInitialized$
PruningState.PruningPerformed$
PruningState$	INTERNAL API
ReadAggregator	INTERNAL API
ReadAggregator$	INTERNAL API
ReadWriteAggregator	INTERNAL API
ReadWriteAggregator.SendToSecondary$
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.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.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	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.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.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.WriteTo
Replicator.WriteTo$
Replicator$
ReplicatorSettings	param: role Replicas are running on members tagged with this role.
ReplicatorSettings$
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
WriteAggregator$	INTERNAL API

Exception Summary

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