Class Replicator.Internal$.DeltaPropagation$

  • All Implemented Interfaces:
    java.io.Serializable
    Enclosing class:
    Replicator.Internal$

    public class Replicator.Internal$.DeltaPropagation$
    extends java.lang.Object
    implements java.io.Serializable
    See Also:
    Serialized Form
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      akka.cluster.ddata.Replicator.Internal.DeltaPropagation apply​(UniqueAddress _fromNode, boolean reply, scala.collection.immutable.Map<java.lang.String,​akka.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,​java.lang.Object,​scala.collection.immutable.Map<java.lang.String,​akka.cluster.ddata.Replicator.Internal.Delta>>> unapply​(akka.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
    • Constructor Detail

      • DeltaPropagation$

        public DeltaPropagation$()
    • Method Detail

      • 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 akka.cluster.ddata.Replicator.Internal.DeltaPropagation apply​(UniqueAddress _fromNode,
                                                                             boolean reply,
                                                                             scala.collection.immutable.Map<java.lang.String,​akka.cluster.ddata.Replicator.Internal.Delta> deltas)
      • unapply

        public scala.Option<scala.Tuple3<UniqueAddress,​java.lang.Object,​scala.collection.immutable.Map<java.lang.String,​akka.cluster.ddata.Replicator.Internal.Delta>>> unapply​(akka.cluster.ddata.Replicator.Internal.DeltaPropagation x$0)