Package org.apache.pekko.cluster.ddata.typed.javadsl

Class Replicator

java.lang.Object

org.apache.pekko.cluster.ddata.typed.javadsl.Replicator

public class Replicator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	Replicator.Changed<A extends ReplicatedData>	The data value is retrieved with Replicator.Changed.get(org.apache.pekko.cluster.ddata.Key<T>) using the typed key.
static class	Replicator.Changed$
static interface	Replicator.Command
static final class	Replicator.DataDeleted<A extends ReplicatedData>
static class	Replicator.DataDeleted$
static final class	Replicator.Delete<A extends ReplicatedData>	Send this message to the local Replicator to delete a data value for the given key.
static class	Replicator.Delete$
static final class	Replicator.Deleted<A extends ReplicatedData>
static class	Replicator.Deleted$
static final class	Replicator.DeleteFailure<A extends ReplicatedData>
static class	Replicator.DeleteFailure$
static interface	Replicator.DeleteResponse<A extends ReplicatedData>
static final class	Replicator.DeleteSuccess<A extends ReplicatedData>
static class	Replicator.DeleteSuccess$
static class	Replicator.FlushChanges$	INTERNAL API Obtain the instance of this class with the flushChanges() method.
static final class	Replicator.Get<A extends ReplicatedData>	Send this message to the local Replicator to retrieve a data value for the given key.
static class	Replicator.Get$
static final class	Replicator.GetDataDeleted<A extends ReplicatedData>	The Replicator.Get request couldn't be performed because the entry has been deleted.
static class	Replicator.GetDataDeleted$
static final class	Replicator.GetFailure<A extends ReplicatedData>	The Replicator.Get request could not be fulfill according to the given consistency level and timeout.
static class	Replicator.GetFailure$
static final class	Replicator.GetReplicaCount	Get current number of replicas, including the local replica.
static class	Replicator.GetReplicaCount$
static class	Replicator.GetResponse<A extends ReplicatedData>
static final class	Replicator.GetSuccess<A extends ReplicatedData>	Reply from Get.
static class	Replicator.GetSuccess$
static final class	Replicator.ModifyFailure<A extends ReplicatedData>	If the modify function of the Replicator.Update throws an exception the reply message will be this ModifyFailure message.
static class	Replicator.ModifyFailure$
static final class	Replicator.NotFound<A extends ReplicatedData>
static class	Replicator.NotFound$
static final class	Replicator.ReadAll
static class	Replicator.ReadAll$
static interface	Replicator.ReadConsistency
static final class	Replicator.ReadFrom
static class	Replicator.ReadFrom$
static class	Replicator.ReadLocal$
static final class	Replicator.ReadMajority
static class	Replicator.ReadMajority$
static final class	Replicator.ReplicaCount	Current number of replicas.
static class	Replicator.ReplicaCount$
static final class	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.
static class	Replicator.StoreFailure$
static final class	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.
static class	Replicator.Subscribe$
static interface	Replicator.SubscribeResponse<A extends ReplicatedData>
static final class	Replicator.Unsubscribe<A extends ReplicatedData>	Unregister a subscriber.
static class	Replicator.Unsubscribe$
static final class	Replicator.Update<A extends ReplicatedData>
static class	Replicator.Update$
static final class	Replicator.UpdateDataDeleted<A extends ReplicatedData>	The Replicator.Update couldn't be performed because the entry has been deleted.
static class	Replicator.UpdateDataDeleted$
static class	Replicator.UpdateFailure<A extends ReplicatedData>
static class	Replicator.UpdateResponse<A extends ReplicatedData>
static final class	Replicator.UpdateSuccess<A extends ReplicatedData>
static class	Replicator.UpdateSuccess$
static final class	Replicator.UpdateTimeout<A extends ReplicatedData>	The direct replication of the Replicator.Update could not be fulfill according to the given consistency level and timeout.
static class	Replicator.UpdateTimeout$
static final class	Replicator.WriteAll
static class	Replicator.WriteAll$
static interface	Replicator.WriteConsistency
static class	Replicator.WriteLocal$
static final class	Replicator.WriteMajority
static class	Replicator.WriteMajority$
static final class	Replicator.WriteTo
static class	Replicator.WriteTo$

Constructor Summary

Constructors

Constructor	Description
Replicator()

Method Summary

Modifier and Type	Method	Description
static Behavior<Replicator.Command>	behavior(ReplicatorSettings settings)	The Behavior for the Replicator actor.
static Behavior<Replicator.Command>	behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)	The Behavior for the Replicator actor.
static Replicator.Command	flushChanges()	The FlushChanges instance.
static Replicator.ReadConsistency	readLocal()	The ReadLocal instance
static Replicator.WriteConsistency	writeLocal()	The WriteLocal instance

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Replicator

public Replicator()

Method Details

behavior

public static Behavior<Replicator.Command> behavior(ReplicatorSettings settings)

The Behavior for the Replicator actor.

behavior

public static Behavior<Replicator.Command> behavior(ReplicatorSettings settings,
 ActorRef underlyingReplicator)

The Behavior for the Replicator actor. It will use the given underlying pekko.cluster.ddata.Replicator

readLocal

public static Replicator.ReadConsistency readLocal()

The ReadLocal instance

writeLocal

public static Replicator.WriteConsistency writeLocal()

The WriteLocal instance

flushChanges

public static Replicator.Command flushChanges()

The FlushChanges instance. Notify subscribers of changes now, otherwise they will be notified periodically with the configured notify-subscribers-interval.