Package akka.cluster.ddata.typed.javadsl

Class Replicator

java.lang.Object

akka.cluster.ddata.typed.javadsl.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<A extends ReplicatedData>
static class	Replicator.Changed$
static interface	Replicator.Command
static class	Replicator.DataDeleted<A extends ReplicatedData>
static class	Replicator.DataDeleted$
static class	Replicator.Delete<A extends ReplicatedData>
static class	Replicator.Delete$
static interface	Replicator.DeleteResponse<A extends ReplicatedData>
static class	Replicator.DeleteSuccess<A extends ReplicatedData>
static class	Replicator.DeleteSuccess$
static class	Replicator.FlushChanges$
static 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 class	Replicator.GetFailure<A extends ReplicatedData>
static class	Replicator.GetFailure$
static class	Replicator.GetReplicaCount
static class	Replicator.GetReplicaCount$
static class	Replicator.GetResponse<A extends ReplicatedData>
static class	Replicator.GetSuccess<A extends ReplicatedData>
static class	Replicator.GetSuccess$
static class	Replicator.ModifyFailure<A extends ReplicatedData>
static class	Replicator.ModifyFailure$
static class	Replicator.NotFound<A extends ReplicatedData>
static class	Replicator.NotFound$
static class	Replicator.ReadAll
static class	Replicator.ReadAll$
static interface	Replicator.ReadConsistency
static class	Replicator.ReadFrom
static class	Replicator.ReadFrom$
static class	Replicator.ReadLocal$
static class	Replicator.ReadMajority
static class	Replicator.ReadMajority$
static class	Replicator.ReplicaCount
static class	Replicator.ReplicaCount$
static class	Replicator.ReplicationDeleteFailure<A extends ReplicatedData>
static class	Replicator.ReplicationDeleteFailure$
static class	Replicator.StoreFailure<A extends ReplicatedData>
static class	Replicator.StoreFailure$
static class	Replicator.Subscribe<A extends ReplicatedData>
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$
static class	Replicator.UpdateFailure<A extends ReplicatedData>
static class	Replicator.UpdateResponse<A extends ReplicatedData>
static class	Replicator.UpdateSuccess<A extends ReplicatedData>
static class	Replicator.UpdateSuccess$
static class	Replicator.UpdateTimeout<A extends ReplicatedData>
static class	Replicator.UpdateTimeout$
static class	Replicator.WriteAll
static class	Replicator.WriteAll$
static interface	Replicator.WriteConsistency
static class	Replicator.WriteLocal$
static class	Replicator.WriteMajority
static class	Replicator.WriteMajority$
static 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)
static Behavior<Replicator.Command>	behavior(ReplicatorSettings settings, ActorRef underlyingReplicator)	The Behavior for the Replicator actor.
static Replicator.Command	flushChanges()
static Replicator.ReadConsistency	readLocal()
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 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.ReadConsistency readLocal()

writeLocal

public static Replicator.WriteConsistency writeLocal()

The WriteLocal instance

Returns:

(undocumented)

flushChanges

public static Replicator.Command flushChanges()