Class Replicator
- java.lang.Object
-
- akka.cluster.ddata.typed.scaladsl.Replicator
-
public class Replicator extends java.lang.Object
TheBehavior
for theReplicator
actor.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Replicator.Changed$
static interface
Replicator.Command
static class
Replicator.Delete<A extends ReplicatedData>
static class
Replicator.Delete$
Convenience forask
.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.GetReplicaCount
static class
Replicator.GetReplicaCount$
Convenience forask
.static class
Replicator.GetSuccess$
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>
static class
Replicator.Unsubscribe$
static class
Replicator.Update<A extends ReplicatedData>
static class
Replicator.Update$
Modify value of localReplicator
and replicate with givenwriteConsistency
.
-
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)
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)
-
behavior
public static Behavior<Replicator.Command> behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)
- Parameters:
settings
- (undocumented)underlyingReplicator
- (undocumented)- Returns:
- (undocumented)
-
ReadLocal
public static Replicator.ReadLocal$ ReadLocal()
-
WriteLocal
public static Replicator.WriteLocal$ WriteLocal()
-
-