Class Replicator
java.lang.Object
org.apache.pekko.cluster.ddata.typed.javadsl.Replicator
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic final classReplicator.Changed<A extends ReplicatedData>The data value is retrieved withReplicator.Changed.get(org.apache.pekko.cluster.ddata.Key<T>)using the typed key.static classstatic interfacestatic final classReplicator.DataDeleted<A extends ReplicatedData>static classstatic final classReplicator.Delete<A extends ReplicatedData>Send this message to the localReplicatorto delete a data value for the givenkey.static classstatic final classReplicator.Deleted<A extends ReplicatedData>static classstatic final classReplicator.DeleteFailure<A extends ReplicatedData>static classstatic interfaceReplicator.DeleteResponse<A extends ReplicatedData>static final classReplicator.DeleteSuccess<A extends ReplicatedData>static classstatic classINTERNAL API Obtain the instance of this class with theflushChanges()method.static final classReplicator.Get<A extends ReplicatedData>Send this message to the localReplicatorto retrieve a data value for the givenkey.static classstatic final classReplicator.GetDataDeleted<A extends ReplicatedData>TheReplicator.Getrequest couldn't be performed because the entry has been deleted.static classstatic final classReplicator.GetFailure<A extends ReplicatedData>TheReplicator.Getrequest could not be fulfill according to the givenconsistency levelandtimeout.static classstatic final classGet current number of replicas, including the local replica.static classstatic classReplicator.GetResponse<A extends ReplicatedData>static final classReplicator.GetSuccess<A extends ReplicatedData>Reply fromGet.static classstatic final classReplicator.ModifyFailure<A extends ReplicatedData>If themodifyfunction of theReplicator.Updatethrows an exception the reply message will be thisModifyFailuremessage.static classstatic final classReplicator.NotFound<A extends ReplicatedData>static classstatic final classstatic classstatic interfacestatic final classstatic classstatic classstatic final classstatic classstatic final classCurrent number of replicas.static classstatic final classReplicator.StoreFailure<A extends ReplicatedData>The local store or direct replication of theReplicator.Updatecould not be fulfill according to the givenconsistency leveldue to durable store errors.static classstatic final classReplicator.Subscribe<A extends ReplicatedData>Register a subscriber that will be notified with aReplicator.Changedmessage when the value of the givenkeyis changed.static classstatic interfaceReplicator.SubscribeResponse<A extends ReplicatedData>static final classReplicator.Unsubscribe<A extends ReplicatedData>Unregister a subscriber.static classstatic final classReplicator.Update<A extends ReplicatedData>static classstatic final classReplicator.UpdateDataDeleted<A extends ReplicatedData>TheReplicator.Updatecouldn't be performed because the entry has been deleted.static classstatic classReplicator.UpdateFailure<A extends ReplicatedData>static classReplicator.UpdateResponse<A extends ReplicatedData>static final classReplicator.UpdateSuccess<A extends ReplicatedData>static classstatic final classReplicator.UpdateTimeout<A extends ReplicatedData>The direct replication of theReplicator.Updatecould not be fulfill according to the givenconsistency levelandtimeout.static classstatic final classstatic classstatic interfacestatic classstatic final classstatic classstatic final 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.CommandTheFlushChangesinstance.static Replicator.ReadConsistencyTheReadLocalinstancestatic Replicator.WriteConsistencyTheWriteLocalinstance
-
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
TheReadLocalinstance -
writeLocal
TheWriteLocalinstance -
flushChanges
TheFlushChangesinstance. Notify subscribers of changes now, otherwise they will be notified periodically with the configurednotify-subscribers-interval.
-