Packages

object Replicator

Source
Replicator.scala
See also

akka.cluster.ddata.Replicator.

Linear Supertypes
Content Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Replicator
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. type Changed[A <: ReplicatedData] = Replicator.Changed[A]

    The data value is retrieved with dd.Replicator.Changed.get using the typed key.

    The data value is retrieved with dd.Replicator.Changed.get using the typed key.

    See also

    Subscribe

  2. trait Command extends AnyRef
  3. type DataDeleted[A <: ReplicatedData] = Replicator.DataDeleted[A]
  4. final case class Delete[A <: ReplicatedData](key: Key[A], consistency: WriteConsistency, replyTo: ActorRef[DeleteResponse[A]]) extends Command with Product with Serializable

    Send this message to the local Replicator to delete a data value for the given key.

    Send this message to the local Replicator to delete a data value for the given key. The Replicator will reply with one of the DeleteResponse messages.

  5. type DeleteFailure[A <: ReplicatedData] = ReplicationDeleteFailure[A]
  6. type DeleteResponse[A <: ReplicatedData] = Replicator.DeleteResponse[A]
  7. type DeleteSuccess[A <: ReplicatedData] = Replicator.DeleteSuccess[A]
  8. type Deleted[A <: ReplicatedData] = Replicator.Deleted[A]

    See also

    Delete

  9. type Expired[A <: ReplicatedData] = Replicator.Expired[A]

    See also

    Expired

  10. final case class Get[A <: ReplicatedData](key: Key[A], consistency: ReadConsistency, replyTo: ActorRef[GetResponse[A]]) extends Command with Product with Serializable

    Send this message to the local Replicator to retrieve a data value for the given key.

    Send this message to the local Replicator to retrieve a data value for the given key. The Replicator will reply with one of the GetResponse messages.

  11. type GetDataDeleted[A <: ReplicatedData] = Replicator.GetDataDeleted[A]

    The Get request couldn't be performed because the entry has been deleted.

  12. type GetFailure[A <: ReplicatedData] = Replicator.GetFailure[A]

    The Get request could not be fulfill according to the given consistency level and timeout.

  13. final case class GetReplicaCount(replyTo: ActorRef[ReplicaCount]) extends Command with Product with Serializable

    Get current number of replicas, including the local replica.

    Get current number of replicas, including the local replica. Will reply to sender with ReplicaCount.

  14. type GetResponse[A <: ReplicatedData] = Replicator.GetResponse[A]

    Reply from Get.

    Reply from Get. The data value is retrieved with dd.Replicator.GetSuccess.get using the typed key.

  15. type GetSuccess[A <: ReplicatedData] = Replicator.GetSuccess[A]
  16. type ModifyFailure[A <: ReplicatedData] = Replicator.ModifyFailure[A]

    If the modify function of the Update throws an exception the reply message will be this ModifyFailure message.

    If the modify function of the Update throws an exception the reply message will be this ModifyFailure message. The original exception is included as cause.

  17. type NotFound[A <: ReplicatedData] = Replicator.NotFound[A]
  18. type ReadAll = Replicator.ReadAll
  19. type ReadConsistency = Replicator.ReadConsistency
  20. type ReadFrom = Replicator.ReadFrom
  21. type ReadMajority = Replicator.ReadMajority
  22. type ReplicaCount = Replicator.ReplicaCount

    Current number of replicas.

    Current number of replicas. Reply to GetReplicaCount.

  23. type StoreFailure[A <: ReplicatedData] = Replicator.StoreFailure[A]

    The local store or direct replication of the Update could not be fulfill according to the given consistency level due to durable store errors.

    The local store or direct replication of the Update could not be fulfill according to the given consistency level due to durable store errors. This is only used for entries that have been configured to be durable.

    The Update was still performed in memory locally and possibly replicated to some nodes, but it might not have been written to durable storage. It will eventually be disseminated to other replicas, unless the local replica crashes before it has been able to communicate with other replicas.

  24. final case class Subscribe[A <: ReplicatedData](key: Key[A], subscriber: ActorRef[SubscribeResponse[A]]) extends Command with Product with Serializable

    Register a subscriber that will be notified with a Changed message when the value of the given key is changed.

    Register a subscriber that will be notified with a Changed message when the value of the given key is changed. Current value is also sent as a Changed message to a new subscriber.

    Subscribers will be notified periodically with the configured notify-subscribers-interval, and it is also possible to send an explicit FlushChanges message to the Replicator to notify the subscribers immediately.

    The subscriber will automatically be unregistered if it is terminated.

    If the key is deleted the subscriber is notified with a Deleted message.

  25. type SubscribeResponse[A <: ReplicatedData] = Replicator.SubscribeResponse[A]

    See also

    Subscribe

  26. final case class Unsubscribe[A <: ReplicatedData](key: Key[A], subscriber: ActorRef[SubscribeResponse[A]]) extends Command with Product with Serializable

    Unregister a subscriber.

    Unregister a subscriber.

    See also

    Subscribe

  27. final case class Update[A <: ReplicatedData](key: Key[A], writeConsistency: WriteConsistency, replyTo: ActorRef[UpdateResponse[A]])(modify: (Option[A]) => A) extends Command with Product with Serializable

    Send this message to the local Replicator to update a data value for the given key.

    Send this message to the local Replicator to update a data value for the given key. The Replicator will reply with one of the UpdateResponse messages.

    Note that the companion object provides apply functions for convenient construction of this message.

    The current data value for the key is passed as parameter to the modify function. It is None if there is no value for the key, and otherwise Some(data). The function is supposed to return the new value of the data, which will then be replicated according to the given writeConsistency.

    The modify function is called by the Replicator actor and must therefore be a pure function that only uses the data parameter and stable fields from enclosing scope. It must for example not access sender() reference of an enclosing actor.

  28. type UpdateDataDeleted[A <: ReplicatedData] = Replicator.UpdateDataDeleted[A]

    The Update couldn't be performed because the entry has been deleted.

  29. type UpdateFailure[A <: ReplicatedData] = Replicator.UpdateFailure[A]
  30. type UpdateResponse[A <: ReplicatedData] = Replicator.UpdateResponse[A]
  31. type UpdateSuccess[A <: ReplicatedData] = Replicator.UpdateSuccess[A]
  32. type UpdateTimeout[A <: ReplicatedData] = Replicator.UpdateTimeout[A]

    The direct replication of the Update could not be fulfill according to the given consistency level and timeout.

    The direct replication of the Update could not be fulfill according to the given consistency level and timeout.

    The Update was still performed locally and possibly replicated to some nodes. It will eventually be disseminated to other replicas, unless the local replica crashes before it has been able to communicate with other replicas.

  33. type WriteAll = Replicator.WriteAll
  34. type WriteConsistency = Replicator.WriteConsistency
  35. type WriteMajority = Replicator.WriteMajority
  36. type WriteTo = Replicator.WriteTo

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val ReadLocal: Replicator.ReadLocal.type
  5. val WriteLocal: Replicator.WriteLocal.type
  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def behavior(settings: ReplicatorSettings, underlyingReplicator: ActorRef): Behavior[Command]

    The Behavior for the Replicator actor.

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

  8. def behavior(settings: ReplicatorSettings): Behavior[Command]

    The Behavior for the Replicator actor.

  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  10. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  11. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  13. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  18. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  19. def toString(): String
    Definition Classes
    AnyRef → Any
  20. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  21. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  22. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  23. object Changed

    The data value is retrieved with dd.Replicator.Changed.get using the typed key.

    The data value is retrieved with dd.Replicator.Changed.get using the typed key.

    See also

    Subscribe

  24. object DataDeleted
  25. object Delete extends Serializable
  26. object DeleteFailure
  27. object DeleteSuccess
  28. object Deleted
  29. object Expired
  30. object FlushChanges extends Command

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

  31. object Get extends Serializable
  32. object GetDataDeleted
  33. object GetFailure
  34. object GetReplicaCount extends Serializable
  35. object GetSuccess
  36. object ModifyFailure
  37. object NotFound
  38. object ReadAll
  39. object ReadFrom
  40. object ReadMajority
  41. object ReplicaCount
  42. object StoreFailure
  43. object Update extends Serializable
  44. object UpdateDataDeleted
  45. object UpdateFailure
  46. object UpdateSuccess
  47. object UpdateTimeout
  48. object WriteAll
  49. object WriteMajority
  50. object WriteTo

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped