Package akka.cluster.ddata.typed.javadsl

Interface Summary

Interface	Description
Replicator.Command
Replicator.DeleteResponse<A extends ReplicatedData>
Replicator.ReadConsistency
Replicator.SubscribeResponse<A extends ReplicatedData>
Replicator.WriteConsistency

Class Summary

Class	Description
DistributedData	Akka extension for convenient configuration and use of the Replicator.
DistributedData$
DistributedDataSetup	Can be used in ActorSystemSetup when starting the ActorSystem to replace the default implementation of the DistributedData extension.
DistributedDataSetup$
Replicator
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<A extends ReplicatedData>
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.DeleteFailure<A extends ReplicatedData>
Replicator.DeleteFailure$
Replicator.DeleteSuccess<A extends ReplicatedData>
Replicator.DeleteSuccess$
Replicator.Expired<A extends ReplicatedData>
Replicator.Expired$
Replicator.FlushChanges$	INTERNAL API Obtain the instance of this class with the Replicator.flushChanges() method.
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.GetReplicaCount	Get current number of replicas, including the local replica.
Replicator.GetReplicaCount$
Replicator.GetResponse<A extends ReplicatedData>
Replicator.GetSuccess<A extends ReplicatedData>	Reply from Get.
Replicator.GetSuccess$
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.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.WriteTo
Replicator.WriteTo$
Replicator$
ReplicatorMessageAdapter<A,B extends ReplicatedData>	When interacting with the Replicator from an actor this class provides convenient methods that adapts the response messages to the requesting actor's message protocol.
ReplicatorSettings
ReplicatorSettings$