Package akka.cluster.ddata.typed.scaladsl

Class Replicator

java.lang.Object

akka.cluster.ddata.typed.scaladsl.Replicator

public class Replicator
extends java.lang.Object

The Behavior for the Replicator 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 for ask.
static class	Replicator.FlushChanges$	Notify subscribers of changes now, otherwise they will be notified periodically with the configured notify-subscribers-interval.
static class	Replicator.Get<A extends ReplicatedData>
static class	Replicator.Get$
static class	Replicator.GetReplicaCount
static class	Replicator.GetReplicaCount$	Convenience for ask.
static class	Replicator.GetSuccess$
static 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 class	Replicator.Unsubscribe<A extends ReplicatedData>
static class	Replicator.Unsubscribe$
static class	Replicator.Update<A extends ReplicatedData>
static class	Replicator.Update$	Modify value of local Replicator and replicate with given writeConsistency.

Constructor Summary

Constructors

Constructor	Description
Replicator()

Method Summary

Modifier and Type	Method	Description
static Behavior<Replicator.Command>	behavior(ReplicatorSettings settings)
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 Detail

Replicator

public Replicator()

Method Detail

behavior

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

behavior

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

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

Parameters:

settings - (undocumented)

underlyingReplicator - (undocumented)

Returns:

(undocumented)

ReadLocal

public static Replicator.ReadLocal$ ReadLocal()

WriteLocal

public static Replicator.WriteLocal$ WriteLocal()