public class SharedData extends Object
Shared data provides:
Please see the documentation for more information.
NOTE: This class has been automatically generated from theoriginal
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static TypeArg<SharedData> |
__TYPE_ARG |
Constructor and Description |
---|
SharedData(SharedData delegate) |
Modifier and Type | Method and Description |
---|---|
<K,V> void |
getClusterWideMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Get the cluster wide map with the specified name.
|
<K,V> rx.Observable<AsyncMap<K,V>> |
getClusterWideMapObservable(String name)
Deprecated.
use
rxGetClusterWideMap(java.lang.String) instead |
void |
getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler)
Get a cluster wide counter.
|
rx.Observable<Counter> |
getCounterObservable(String name)
Deprecated.
use
rxGetCounter(java.lang.String) instead |
SharedData |
getDelegate() |
<K,V> LocalMap<K,V> |
getLocalMap(String name)
Return a
LocalMap with the specific name . |
void |
getLock(String name,
Handler<AsyncResult<Lock>> resultHandler)
Get a cluster wide lock with the specified name.
|
rx.Observable<Lock> |
getLockObservable(String name)
Deprecated.
use
rxGetLock(java.lang.String) instead |
void |
getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler)
Like
getLock(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.shareddata.Lock>>) but specifying a timeout. |
rx.Observable<Lock> |
getLockWithTimeoutObservable(String name,
long timeout)
Deprecated.
use
rxGetLockWithTimeout(java.lang.String, long) instead |
static SharedData |
newInstance(SharedData arg) |
<K,V> rx.Single<AsyncMap<K,V>> |
rxGetClusterWideMap(String name)
Get the cluster wide map with the specified name.
|
rx.Single<Counter> |
rxGetCounter(String name)
Get a cluster wide counter.
|
rx.Single<Lock> |
rxGetLock(String name)
Get a cluster wide lock with the specified name.
|
rx.Single<Lock> |
rxGetLockWithTimeout(String name,
long timeout)
Like
getLock(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.shareddata.Lock>>) but specifying a timeout. |
public static final TypeArg<SharedData> __TYPE_ARG
public SharedData(SharedData delegate)
public SharedData getDelegate()
public <K,V> void getClusterWideMap(String name, Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
name
- the name of the mapresultHandler
- the map will be returned asynchronously in this handler@Deprecated public <K,V> rx.Observable<AsyncMap<K,V>> getClusterWideMapObservable(String name)
rxGetClusterWideMap(java.lang.String)
insteadname
- the name of the mappublic <K,V> rx.Single<AsyncMap<K,V>> rxGetClusterWideMap(String name)
name
- the name of the mappublic void getLock(String name, Handler<AsyncResult<Lock>> resultHandler)
name
- the name of the lockresultHandler
- the handler@Deprecated public rx.Observable<Lock> getLockObservable(String name)
rxGetLock(java.lang.String)
insteadname
- the name of the lockpublic rx.Single<Lock> rxGetLock(String name)
name
- the name of the lockpublic void getLockWithTimeout(String name, long timeout, Handler<AsyncResult<Lock>> resultHandler)
getLock(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.shareddata.Lock>>)
but specifying a timeout. If the lock is not obtained within the timeout
a failure will be sent to the handlername
- the name of the locktimeout
- the timeout in msresultHandler
- the handler@Deprecated public rx.Observable<Lock> getLockWithTimeoutObservable(String name, long timeout)
rxGetLockWithTimeout(java.lang.String, long)
insteadgetLock(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.shareddata.Lock>>)
but specifying a timeout. If the lock is not obtained within the timeout
a failure will be sent to the handlername
- the name of the locktimeout
- the timeout in mspublic rx.Single<Lock> rxGetLockWithTimeout(String name, long timeout)
getLock(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.core.shareddata.Lock>>)
but specifying a timeout. If the lock is not obtained within the timeout
a failure will be sent to the handlername
- the name of the locktimeout
- the timeout in mspublic void getCounter(String name, Handler<AsyncResult<Counter>> resultHandler)
name
- the name of the counter.resultHandler
- the handler@Deprecated public rx.Observable<Counter> getCounterObservable(String name)
rxGetCounter(java.lang.String)
insteadname
- the name of the counter.public rx.Single<Counter> rxGetCounter(String name)
name
- the name of the counter.public <K,V> LocalMap<K,V> getLocalMap(String name)
LocalMap
with the specific name
.name
- the name of the mappublic static SharedData newInstance(SharedData arg)
Copyright © 2017. All rights reserved.