Class Replicator
- java.lang.Object
-
- akka.cluster.ddata.typed.scaladsl.Replicator
-
public class Replicator extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Replicator.Changed$
The data value is retrieved withdd.Replicator.Changed.get
using the typed key.static interface
Replicator.Command
static class
Replicator.DataDeleted$
static class
Replicator.Delete<A extends ReplicatedData>
static class
Replicator.Delete$
static class
Replicator.Deleted$
static class
Replicator.DeleteFailure$
static class
Replicator.DeleteSuccess$
static class
Replicator.FlushChanges$
Notify subscribers of changes now, otherwise they will be notified periodically with the configurednotify-subscribers-interval
.static class
Replicator.Get<A extends ReplicatedData>
static class
Replicator.Get$
static class
Replicator.GetDataDeleted$
static class
Replicator.GetFailure$
static class
Replicator.GetReplicaCount
static class
Replicator.GetReplicaCount$
static class
Replicator.GetSuccess$
static class
Replicator.ModifyFailure$
static class
Replicator.NotFound$
static class
Replicator.ReadAll$
static class
Replicator.ReadFrom$
static class
Replicator.ReadMajority$
static class
Replicator.ReplicaCount$
static class
Replicator.StoreFailure$
static class
Replicator.Subscribe<A extends ReplicatedData>
Register a subscriber that will be notified with aChanged
message when the value of the givenkey
is changed.static class
Replicator.Subscribe$
static class
Replicator.Unsubscribe<A extends ReplicatedData>
Unregister a subscriber.static class
Replicator.Unsubscribe$
static class
Replicator.Update<A extends ReplicatedData>
static class
Replicator.Update$
static class
Replicator.UpdateDataDeleted$
static class
Replicator.UpdateFailure$
static class
Replicator.UpdateSuccess$
static class
Replicator.UpdateTimeout$
static class
Replicator.WriteAll$
static class
Replicator.WriteMajority$
static class
Replicator.WriteTo$
-
Constructor Summary
Constructors Constructor Description Replicator()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static Behavior<Replicator.Command>
behavior(ReplicatorSettings settings)
TheBehavior
for theReplicator
actor.static Behavior<Replicator.Command>
behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)
TheBehavior
for theReplicator
actor.static Replicator.ReadLocal$
ReadLocal()
static Replicator.WriteLocal$
WriteLocal()
-
-
-
Method Detail
-
behavior
public static Behavior<Replicator.Command> behavior(ReplicatorSettings settings)
TheBehavior
for theReplicator
actor.
-
behavior
public static Behavior<Replicator.Command> behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)
-
ReadLocal
public static Replicator.ReadLocal$ ReadLocal()
-
WriteLocal
public static Replicator.WriteLocal$ WriteLocal()
-
-