Packages

class Counter extends AnyRef

An asynchronous counter that can be used to across the cluster to maintain a consistent count.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Counter
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Counter(_asJava: AnyRef)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def addAndGet(value: Long, resultHandler: Handler[AsyncResult[Long]]): Unit

    Add the value to the counter atomically and return the new count * @param value the value to add

    Add the value to the counter atomically and return the new count * @param value the value to add

    resultHandler

    handler which will be passed the value

  5. def addAndGetFuture(value: Long): scala.concurrent.Future[Long]

    Like addAndGet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  6. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  7. def asJava: AnyRef
  8. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  9. def compareAndSet(expected: Long, value: Long, resultHandler: Handler[AsyncResult[Boolean]]): Unit

    Set the counter to the specified value only if the current value is the expectec value.

    Set the counter to the specified value only if the current value is the expectec value. This happens atomically. * @param expected the expected value

    value

    the new value

    resultHandler

    the handler will be passed true on success

  10. def compareAndSetFuture(expected: Long, value: Long): scala.concurrent.Future[Boolean]

    Like compareAndSet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  11. def decrementAndGet(resultHandler: Handler[AsyncResult[Long]]): Unit

    Decrement the counter atomically and return the new count * @param resultHandler handler which will be passed the value

  12. def decrementAndGetFuture(): scala.concurrent.Future[Long]

    Like decrementAndGet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  13. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  15. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  16. def get(resultHandler: Handler[AsyncResult[Long]]): Unit

    Get the current value of the counter * @param resultHandler handler which will be passed the value

  17. def getAndAdd(value: Long, resultHandler: Handler[AsyncResult[Long]]): Unit

    Add the value to the counter atomically and return the value before the add * @param value the value to add

    Add the value to the counter atomically and return the value before the add * @param value the value to add

    resultHandler

    handler which will be passed the value

  18. def getAndAddFuture(value: Long): scala.concurrent.Future[Long]

    Like getAndAdd but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  19. def getAndIncrement(resultHandler: Handler[AsyncResult[Long]]): Unit

    Increment the counter atomically and return the value before the increment.

    Increment the counter atomically and return the value before the increment. * @param resultHandler handler which will be passed the value

  20. def getAndIncrementFuture(): scala.concurrent.Future[Long]

    Like getAndIncrement but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  21. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  22. def getFuture(): scala.concurrent.Future[Long]

    Like get but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  23. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  24. def incrementAndGet(resultHandler: Handler[AsyncResult[Long]]): Unit

    Increment the counter atomically and return the new count * @param resultHandler handler which will be passed the value

  25. def incrementAndGetFuture(): scala.concurrent.Future[Long]

    Like incrementAndGet but returns a scala.concurrent.Future instead of taking an AsyncResultHandler.

  26. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  27. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  28. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  29. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  30. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  31. def toString(): String
    Definition Classes
    AnyRef → Any
  32. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  33. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  34. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped