Class CounterService


  • public class CounterService
    extends java.lang.Object
    Provides a distributed counter (similar to AtomicLong) which can be atomically updated across a cluster.
    Since:
    3.0.0
    Author:
    Bela Ban
    • Constructor Detail

      • CounterService

        public CounterService​(JChannel ch)
    • Method Detail

      • setChannel

        public void setChannel​(JChannel ch)
      • getOrCreateCounter

        public Counter getOrCreateCounter​(java.lang.String name,
                                          long initial_value)
        Returns an existing counter, or creates a new one if none exists
        Parameters:
        name - Name of the counter, different counters have to have different names
        initial_value - The initial value of a new counter if there is no existing counter. Ignored if the counter already exists
        Returns:
        The counter implementation
      • deleteCounter

        public void deleteCounter​(java.lang.String name)
        Deletes a counter instance (on the coordinator)
        Parameters:
        name - The name of the counter. No-op if the counter doesn't exist
      • printCounters

        public java.lang.String printCounters()
      • dumpPendingRequests

        public java.lang.String dumpPendingRequests()