Package akka.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 Detail

      • _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,​akka.cluster.ddata.Replicator.Internal.DeltaPropagation> collectPropagations()

      • createDeltaPropagation

        akka.cluster.ddata.Replicator.Internal.DeltaPropagation createDeltaPropagation​(scala.collection.immutable.Map<java.lang.String,​scala.Tuple3<ReplicatedData,​java.lang.Object,​java.lang.Object>> deltas)

      • currentVersion

        long currentVersion​(java.lang.String key)

      • delete

        void delete​(java.lang.String key)

      • deltaCounter_$eq

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

      • deltaEntriesAfter

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

      • deltaEntries_$eq

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

      • deltaNodeRoundRobinCounter_$eq

        void deltaNodeRoundRobinCounter_$eq​(long x$1)

      • deltaSentToNode_$eq

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

      • findSmallestVersionPropagatedToAllNodes

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

      • gossipIntervalDivisor

        int gossipIntervalDivisor()

      • hasDeltaEntries

        boolean hasDeltaEntries​(java.lang.String key)

      • maxDeltaSize

        int maxDeltaSize()

      • nodesSliceSize

        int nodesSliceSize​(int allNodesSize)

      • propagationCount

        long propagationCount()

      • update

        void update​(java.lang.String key,
            ReplicatedData delta)