Class Replicator
java.lang.Object
org.apache.pekko.cluster.ddata.typed.scaladsl.Replicator
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic classThe data value is retrieved withpekko.cluster.ddata.Replicator.Changed.getusing the typed key.static interfacestatic classstatic final classReplicator.Delete<A extends ReplicatedData>static classstatic classstatic classstatic classstatic classNotify subscribers of changes now, otherwise they will be notified periodically with the configurednotify-subscribers-interval.static final classReplicator.Get<A extends ReplicatedData>static classstatic classstatic classstatic final classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic classstatic final classReplicator.Subscribe<A extends ReplicatedData>Register a subscriber that will be notified with aChangedmessage when the value of the givenkeyis changed.static classstatic final classReplicator.Unsubscribe<A extends ReplicatedData>Unregister a subscriber.static classstatic final classReplicator.Update<A extends ReplicatedData>static classstatic classstatic classstatic classstatic classstatic classstatic classstatic class -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic Behavior<Replicator.Command>behavior(ReplicatorSettings settings) TheBehaviorfor theReplicatoractor.static Behavior<Replicator.Command>behavior(ReplicatorSettings settings, ActorRef underlyingReplicator) TheBehaviorfor theReplicatoractor.static Replicator.ReadLocal$static Replicator.WriteLocal$
-
Constructor Details
-
Replicator
public Replicator()
-
-
Method Details
-
behavior
TheBehaviorfor theReplicatoractor. -
behavior
public static Behavior<Replicator.Command> behavior(ReplicatorSettings settings, ActorRef underlyingReplicator) TheBehaviorfor theReplicatoractor. It will use the given underlyingpekko.cluster.ddata.Replicator -
ReadLocal
-
WriteLocal
-