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

Class Replicator

java.lang.Object

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

public class Replicator
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Replicator.Changed$	The data value is retrieved with pekko.cluster.ddata.Replicator.Changed.get using the typed key.
static interface	Replicator.Command
static class	Replicator.DataDeleted$
static final 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 configured notify-subscribers-interval.
static final class	Replicator.Get<A extends ReplicatedData>
static class	Replicator.Get$
static class	Replicator.GetDataDeleted$
static class	Replicator.GetFailure$
static final 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 final class	Replicator.Subscribe<A extends ReplicatedData>	Register a subscriber that will be notified with a Changed message when the value of the given key is changed.
static class	Replicator.Subscribe$
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 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

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.ReadLocal$	ReadLocal()
static Replicator.WriteLocal$	WriteLocal()

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.ReadLocal$ ReadLocal()

WriteLocal

public static Replicator.WriteLocal$ WriteLocal()