Package | Description |
---|---|
io.vertx.rxjava3.servicediscovery | |
io.vertx.rxjava3.servicediscovery.types |
Modifier and Type | Field and Description |
---|---|
static TypeArg<ServiceDiscovery> |
ServiceDiscovery.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx)
Creates a new instance of
ServiceDiscovery using the default configuration. |
static ServiceDiscovery |
ServiceDiscovery.create(Vertx vertx,
io.vertx.servicediscovery.ServiceDiscoveryOptions options)
Creates an instance of
ServiceDiscovery . |
static ServiceDiscovery |
ServiceDiscovery.newInstance(io.vertx.servicediscovery.ServiceDiscovery arg) |
Modifier and Type | Method and Description |
---|---|
static void |
ServiceDiscovery.releaseServiceObject(ServiceDiscovery discovery,
Object svcObject)
Release the service object retrieved using
get methods from the service type interface. |
Modifier and Type | Method and Description |
---|---|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> io.reactivex.rxjava3.core.Single<MessageConsumer<T>> |
MessageSource.getConsumer(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> io.reactivex.rxjava3.core.Single<MessageConsumer<T>> |
MessageSource.getConsumer(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static io.reactivex.rxjava3.core.Single<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static io.reactivex.rxjava3.core.Single<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static io.reactivex.rxjava3.core.Single<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
io.vertx.core.json.JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
Class<T> clientClass,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
Class<T> clientClass,
io.vertx.core.json.JsonObject conf,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
Class<T> clientClass,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
Class<T> clientClass,
io.vertx.core.json.JsonObject conf,
io.vertx.core.Handler<io.vertx.core.AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> io.reactivex.rxjava3.core.Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> io.reactivex.rxjava3.core.Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static io.reactivex.rxjava3.core.Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static io.reactivex.rxjava3.core.Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static io.reactivex.rxjava3.core.Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
io.vertx.core.json.JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static io.reactivex.rxjava3.core.Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
Function<io.vertx.servicediscovery.Record,Boolean> filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static io.reactivex.rxjava3.core.Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
io.vertx.core.json.JsonObject filter,
io.vertx.core.json.JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
Copyright © 2022 Eclipse. All rights reserved.