Packages

class SharedData extends AnyRef

Shared data allows you to share data safely between different parts of your application in a safe way.

Shared data provides:

  • Cluster wide maps which can be accessed from any node of the cluster
  • Cluster wide locks which can be used to give exclusive access to resources across the cluster
  • Cluster wide counters used to maintain counts consistently across the cluster
  • Local maps for sharing data safely in the same Vert.x instance

Please see the documentation for more information.

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

Instance Constructors

  1. new SharedData(_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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def asJava: AnyRef
  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  11. def getClusterWideMap[K, V](name: String, resultHandler: Handler[AsyncResult[AsyncMap[K, V]]])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): Unit

    Get the cluster wide map with the specified name.

    Get the cluster wide map with the specified name. The map is accessible to all nodes in the cluster and data put into the map from any node is visible to to any other node.

    name

    the name of the map

    resultHandler

    the map will be returned asynchronously in this handler

  12. def getClusterWideMapFuture[K, V](name: String)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): scala.concurrent.Future[AsyncMap[K, V]]

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

  13. def getCounter(name: String, resultHandler: Handler[AsyncResult[Counter]]): Unit

    Get a cluster wide counter.

    Get a cluster wide counter. The counter will be passed to the handler.

    name

    the name of the counter.

    resultHandler

    the handler

  14. def getCounterFuture(name: String): scala.concurrent.Future[Counter]

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

  15. def getLocalMap[K, V](name: String)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[K], arg1: scala.reflect.api.JavaUniverse.TypeTag[V]): LocalMap[K, V]

    Return a LocalMap with the specific name.

    Return a LocalMap with the specific name.

    name

    the name of the map

    returns

    the msp

  16. def getLock(name: String, resultHandler: Handler[AsyncResult[Lock]]): Unit

    Get a cluster wide lock with the specified name.

    Get a cluster wide lock with the specified name. The lock will be passed to the handler when it is available.

    name

    the name of the lock

    resultHandler

    the handler

  17. def getLockFuture(name: String): scala.concurrent.Future[Lock]

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

  18. def getLockWithTimeout(name: String, timeout: Long, resultHandler: Handler[AsyncResult[Lock]]): Unit

    Like io.vertx.scala.core.shareddata.SharedData#getLockFuture but specifying a timeout.

    Like io.vertx.scala.core.shareddata.SharedData#getLockFuture but specifying a timeout. If the lock is not obtained within the timeout a failure will be sent to the handler

    name

    the name of the lock

    timeout

    the timeout in ms

    resultHandler

    the handler

  19. def getLockWithTimeoutFuture(name: String, timeout: Long): scala.concurrent.Future[Lock]

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

  20. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  21. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  22. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  23. final def notify(): Unit
    Definition Classes
    AnyRef
  24. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  25. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  26. def toString(): String
    Definition Classes
    AnyRef → Any
  27. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  28. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped