Class PNCounter

    • Method Detail

      • create

        public static PNCounter create()
        Java API
      • value

        public scala.math.BigInt value()
        Scala API: Current total value of the counter.
      • getValue

        public java.math.BigInteger getValue()
        Java API: Current total value of the counter.
      • $colon$plus

        public PNCounter $colon$plus​(long n,
                                     SelfUniqueAddress node)
        Increment the counter with the delta n specified. If the delta is negative then it will decrement instead of increment.
      • $colon$plus

        public PNCounter $colon$plus​(scala.math.BigInt n,
                                     SelfUniqueAddress node)
        Increment the counter with the delta n specified. If the delta is negative then it will decrement instead of increment.
      • increment

        public PNCounter increment​(long n,
                                   SelfUniqueAddress node)
        Scala API: Increment the counter with the delta n specified. If the delta is negative then it will decrement instead of increment.
      • increment

        public PNCounter increment​(scala.math.BigInt n,
                                   SelfUniqueAddress node)
        Increment the counter with the delta n specified. If the delta is negative then it will decrement instead of increment.
      • increment

        public PNCounter increment​(SelfUniqueAddress node,
                                   java.math.BigInteger n)
        Java API: Increment the counter with the delta n specified. If the delta is negative then it will decrement instead of increment.
      • increment

        public PNCounter increment​(SelfUniqueAddress node,
                                   long n)
        Java API: Increment the counter with the delta n specified. If the delta is negative then it will decrement instead of increment.
      • decrement

        public PNCounter decrement​(long n,
                                   SelfUniqueAddress node)
        Decrement the counter with the delta n specified. If the delta is negative then it will increment instead of decrement.
      • decrement

        public PNCounter decrement​(scala.math.BigInt n,
                                   SelfUniqueAddress node)
        Decrement the counter with the delta n specified. If the delta is negative then it will increment instead of decrement.
      • decrement

        public PNCounter decrement​(SelfUniqueAddress node,
                                   long n)
        Decrement the counter with the delta n specified. If the delta n is negative then it will increment instead of decrement.
      • decrement

        public PNCounter decrement​(SelfUniqueAddress node,
                                   scala.math.BigInt n)
        Scala API: Decrement the counter with the delta n specified. If the delta n is negative then it will increment instead of decrement.
      • decrement

        public PNCounter decrement​(SelfUniqueAddress node,
                                   java.math.BigInteger n)
        Java API: Decrement the counter with the delta n specified. If the delta n is negative then it will increment instead of decrement.
      • delta

        public scala.Option<PNCounter> delta()
        Description copied from interface: DeltaReplicatedData
        The accumulated delta of mutator operations since previous DeltaReplicatedData.resetDelta(). When the Replicator invokes the modify function of the Update message and the user code is invoking one or more mutator operations the data is collecting the delta of the operations and makes it available for the Replicator with the DeltaReplicatedData.delta() accessor. The modify function shall still return the full state in the same way as ReplicatedData without support for deltas.
        Specified by:
        delta in interface DeltaReplicatedData
      • zero

        public PNCounter zero()
        Description copied from interface: ReplicatedDelta
        The empty full state. This is used when a delta is received and no existing full state exists on the receiving side. Then the delta is merged into the zero to create the initial full state.
        Specified by:
        zero in interface ReplicatedDelta
      • resetDelta

        public PNCounter resetDelta()
        Description copied from interface: DeltaReplicatedData
        Reset collection of deltas from mutator operations. When the Replicator invokes the modify function of the Update message the delta is always "reset" and when the user code is invoking one or more mutator operations the data is collecting the delta of the operations and makes it available for the Replicator with the DeltaReplicatedData.delta() accessor. When the Replicator has grabbed the delta it will invoke this method to get a clean data instance without the delta.
        Specified by:
        resetDelta in interface DeltaReplicatedData
      • modifiedByNodes

        public scala.collection.immutable.Set<UniqueAddress> modifiedByNodes()
        Description copied from interface: RemovedNodePruning
        The nodes that have changed the state for this data and would need pruning when such node is no longer part of the cluster.
        Specified by:
        modifiedByNodes in interface RemovedNodePruning
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object