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<Address> allNodes()
      • cleanupDeltaEntries

        void cleanupDeltaEntries()
      • cleanupRemovedNode

        void cleanupRemovedNode​(Address address)
      • collectPropagations

        scala.collection.immutable.Map<Address,​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<Address,​java.lang.Object>> x$1)
      • findSmallestVersionPropagatedToAllNodes

        long findSmallestVersionPropagatedToAllNodes​(java.lang.String key,
                                                     scala.collection.immutable.Vector<Address> 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)