Package org.apache.pekko.cluster.ddata

Interface DeltaPropagationSelector

public interface DeltaPropagationSelector
INTERNAL API: Used by the Replicator actor. Extracted to separate trait to make it easy to test.

  • Method Details

    • _propagationCount_$eq

      void _propagationCount_$eq(long x$1)

    • allNodes

      scala.collection.immutable.Vector<UniqueAddress> allNodes()

    • cleanupDeltaEntries

      void cleanupDeltaEntries()

    • cleanupRemovedNode

      void cleanupRemovedNode(UniqueAddress address)

    • collectPropagations

      scala.collection.immutable.Map<UniqueAddress,org.apache.pekko.cluster.ddata.Replicator.Internal.DeltaPropagation> collectPropagations()

    • createDeltaPropagation

      org.apache.pekko.cluster.ddata.Replicator.Internal.DeltaPropagation createDeltaPropagation(scala.collection.immutable.Map<String,scala.Tuple3<ReplicatedData,Object,Object>> deltas)

    • currentVersion

      long currentVersion(String key)

    • delete

      void delete(String key)

    • deltaCounter_$eq

      void deltaCounter_$eq(scala.collection.immutable.Map<String,Object> x$1)

    • deltaEntriesAfter

      scala.collection.immutable.TreeMap<Object,ReplicatedData> deltaEntriesAfter(scala.collection.immutable.TreeMap<Object,ReplicatedData> entries, long version)

    • deltaEntries_$eq

      void deltaEntries_$eq(scala.collection.immutable.Map<String,scala.collection.immutable.TreeMap<Object,ReplicatedData>> x$1)

    • deltaNodeRoundRobinCounter_$eq

      void deltaNodeRoundRobinCounter_$eq(long x$1)

    • deltaSentToNode_$eq

      void deltaSentToNode_$eq(scala.collection.immutable.Map<String,scala.collection.immutable.Map<UniqueAddress,Object>> x$1)

    • findSmallestVersionPropagatedToAllNodes

      long findSmallestVersionPropagatedToAllNodes(String key, scala.collection.immutable.Vector<UniqueAddress> all)

    • gossipIntervalDivisor

      int gossipIntervalDivisor()

    • hasDeltaEntries

      boolean hasDeltaEntries(String key)

    • maxDeltaSize

      int maxDeltaSize()

    • nodesSliceSize

      int nodesSliceSize(int allNodesSize)

    • propagationCount

      long propagationCount()

    • update

      void update(String key, ReplicatedData delta)