Package akka.cluster.ddata

Interface Summary

Interface	Description
DeltaPropagationSelector	INTERNAL API: Used by the Replicator actor.
DeltaReplicatedData	The type of the delta.
FastMerge	INTERNAL API: should be called from "updating" methods, and `resetDelta`
LWWRegister.Clock<A>
ORMap.DeltaOp
ORMap.ZeroTag
ORSet.DeltaOp
PruningState	INTERNAL API
RemovedNodePruning	The nodes that have changed the state for this data and would need pruning when such node is no longer part of the cluster.
ReplicatedData	The type of the concrete implementation, e.g.
ReplicatedDataSerialization	Marker trait for ReplicatedData serialized by ReplicatedDataSerializer.
ReplicatedDelta	The empty full state.
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.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>	Delegates to AbstractDeltaReplicatedData.deltaData(), which must be implemented by subclass.
AbstractReplicatedData<A extends AbstractReplicatedData<A>>	Delegates to AbstractReplicatedData.mergeData(A), which must be implemented by subclass.
DistributedData	ActorRef of the Replicator .
DistributedData$
DurableStore	Request to store an entry.
DurableStore.DurableDataEnvelope
DurableStore.LoadAll$
DurableStore.LoadAllCompleted$
DurableStore.LoadData
DurableStore.LoadData$
DurableStore.Store
DurableStore.Store$
DurableStore.StoreReply
DurableStore.StoreReply$
DurableStore$	Request to store an entry.
Flag
Flag$	Flag that is initialized to false.
FlagKey
FlagKey$
GCounter
GCounter$	Java API
GCounterKey
GCounterKey$
GSet<A>
GSet$	Java API
GSetKey<A>
GSetKey$
Key<T extends ReplicatedData>	Key for the key-value data in Replicator.
Key$	Extract the Key.id().
LmdbDurableStore
LmdbDurableStore$	Wrapper class for serialization of a data value.
LWWMap<A,B>	Scala API: All entries of the map.
LWWMap.LWWMapTag$
LWWMap$	INTERNAL API
LWWMapKey<A,B>
LWWMapKey$	INTERNAL API
LWWRegister<A>	Java API
LWWRegister$	param: currentTimestamp the current timestamp value of the LWWRegister param: value the register value to set and associate with the returned timestamp
LWWRegisterKey<A>
LWWRegisterKey$	INTERNAL API
ManyVersionVector	INTERNAL API
ManyVersionVector$
OneVersionVector	INTERNAL API
OneVersionVector$
ORMap<A,B extends ReplicatedData>
ORMap.AtomicDeltaOp<A,B extends ReplicatedData>
ORMap.DeltaGroup<A,B extends ReplicatedData>
ORMap.DeltaGroup$
ORMap.PutDeltaOp<A,B extends ReplicatedData>
ORMap.PutDeltaOp$
ORMap.RemoveDeltaOp<A,B extends ReplicatedData>
ORMap.RemoveDeltaOp$
ORMap.RemoveKeyDeltaOp<A,B extends ReplicatedData>
ORMap.RemoveKeyDeltaOp$
ORMap.UpdateDeltaOp<A,B extends ReplicatedData>
ORMap.UpdateDeltaOp$
ORMap.VanillaORMapTag$
ORMap$	Java API
ORMapKey<A,B extends ReplicatedData>
ORMapKey$
ORMultiMap<A,B>	Scala API: All entries of a multimap where keys are strings and values are sets.
ORMultiMap.ORMultiMapTag$
ORMultiMap.ORMultiMapWithValueDeltasTag$
ORMultiMap$	INTERNAL API
ORMultiMapKey<A,B>
ORMultiMapKey$	INTERNAL API
ORSet<A>
ORSet.AddDeltaOp<A>
ORSet.AddDeltaOp$
ORSet.AtomicDeltaOp<A>
ORSet.DeltaGroup<A>
ORSet.DeltaGroup$
ORSet.FullStateDeltaOp<A>
ORSet.FullStateDeltaOp$
ORSet.RemoveDeltaOp<A>
ORSet.RemoveDeltaOp$
ORSet$	Java API
ORSetKey<A>
ORSetKey$
PNCounter	Scala API: Current total value of the counter.
PNCounter$	Java API
PNCounterKey
PNCounterKey$	Internal API
PNCounterMap<A>	Scala API
PNCounterMap.PNCounterMapTag$
PNCounterMap$	INTERNAL API
PNCounterMapKey<A>
PNCounterMapKey$	INTERNAL API
PruningState.PruningInitialized
PruningState.PruningInitialized$
PruningState.PruningPerformed
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>
Replicator.Changed$
Replicator.DataDeleted$
Replicator.Delete<A extends ReplicatedData>
Replicator.Delete$
Replicator.Deleted<A extends ReplicatedData>
Replicator.Deleted$
Replicator.DeleteSuccess<A extends ReplicatedData>
Replicator.DeleteSuccess$
Replicator.FlushChanges$
Replicator.Get<A extends ReplicatedData>
Replicator.Get$
Replicator.GetFailure<A extends ReplicatedData>
Replicator.GetFailure$
Replicator.GetKeyIds$	INTERNAL API
Replicator.GetKeyIdsResult
Replicator.GetKeyIdsResult$
Replicator.GetReplicaCount$
Replicator.GetResponse<A extends ReplicatedData>
Replicator.GetSuccess<A extends ReplicatedData>
Replicator.GetSuccess$
Replicator.Internal$
Replicator.ModifyFailure<A extends ReplicatedData>
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>
Replicator.StoreFailure$
Replicator.Subscribe<A extends ReplicatedData>
Replicator.Subscribe$
Replicator.Unsubscribe<A extends ReplicatedData>
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>
Replicator.UpdateTimeout$
Replicator.WriteAll
Replicator.WriteAll$
Replicator.WriteLocal$
Replicator.WriteMajority
Replicator.WriteMajority$
Replicator.WriteTo
Replicator.WriteTo$
Replicator$	Factory method for the Props of the Replicator actor.
ReplicatorSettings	INTERNAL API
ReplicatorSettings$	Create settings from the default configuration akka.cluster.distributed-data.
SelfUniqueAddress	Cluster non-specific (typed vs untyped) wrapper for UniqueAddress.
SelfUniqueAddress$
VersionVector	Increment the version for the node passed as argument.
VersionVector.After$
VersionVector.Before$
VersionVector.Concurrent$
VersionVector.Same$
VersionVector.Timestamp$	INTERNAL API
VersionVector$	INTERNAL API
WriteAggregator	INTERNAL API
WriteAggregator$	INTERNAL API

Exception Summary

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