Package org.apache.pekko.cluster.ddata

Class Replicator.Internal$.DeltaPropagation$

java.lang.Object
org.apache.pekko.cluster.ddata.Replicator.Internal$.DeltaPropagation$
All Implemented Interfaces:
Serializable
Enclosing class:
Replicator.Internal$
public class Replicator.Internal$.DeltaPropagation$ extends Object implements Serializable
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final Replicator.Internal$.DeltaPropagation$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    DeltaPropagation$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pekko.cluster.ddata.Replicator.Internal.DeltaPropagation
    apply(UniqueAddress _fromNode, boolean reply, scala.collection.immutable.Map<String,org.apache.pekko.cluster.ddata.Replicator.Internal.Delta> deltas)
     
    ReplicatedDelta
    NoDeltaPlaceholder()
    When a DeltaReplicatedData returns None from delta it must still be treated as a delta that increase the version counter in DeltaPropagationSelector.
    scala.Option<scala.Tuple3<UniqueAddress,Object,scala.collection.immutable.Map<String,org.apache.pekko.cluster.ddata.Replicator.Internal.Delta>>>
    unapply(org.apache.pekko.cluster.ddata.Replicator.Internal.DeltaPropagation x$0)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

  • Constructor Details

    • DeltaPropagation$

      public DeltaPropagation$()

  • Method Details

    • NoDeltaPlaceholder

      public ReplicatedDelta NoDeltaPlaceholder()
      When a DeltaReplicatedData returns None from delta it must still be treated as a delta that increase the version counter in DeltaPropagationSelector. Otherwise a later delta might be applied before the full state gossip is received and thereby violating RequiresCausalDeliveryOfDeltas.

      This is used as a placeholder for such None delta. It's filtered out in createDeltaPropagation, i.e. never sent to the other replicas.

    • apply

      public org.apache.pekko.cluster.ddata.Replicator.Internal.DeltaPropagation apply(UniqueAddress _fromNode, boolean reply, scala.collection.immutable.Map<String,org.apache.pekko.cluster.ddata.Replicator.Internal.Delta> deltas)

    • unapply

      public scala.Option<scala.Tuple3<UniqueAddress,Object,scala.collection.immutable.Map<String,org.apache.pekko.cluster.ddata.Replicator.Internal.Delta>>> unapply(org.apache.pekko.cluster.ddata.Replicator.Internal.DeltaPropagation x$0)