Modifier and Type | Method and Description |
---|---|
Record |
ServiceReference.record() |
Modifier and Type | Method and Description |
---|---|
Maybe<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter)
Lookups for a single record.
|
Maybe<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a single record.
|
Maybe<Record> |
ServiceDiscovery.rxGetRecord(JsonObject filter)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter)
Lookups for a set of records.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a set of records.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(JsonObject filter)
Lookups for a set of records.
|
Single<Record> |
ServiceDiscovery.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServiceDiscovery.rxUpdate(Record record)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
ServiceReference |
ServiceDiscovery.getReference(Record record)
Gets a service reference from the given record.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
void |
ServiceDiscovery.publish(Record record)
Publishes a record.
|
void |
ServiceDiscovery.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
Single<Record> |
ServiceDiscovery.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServiceDiscovery.rxUpdate(Record record)
Updates the given record.
|
void |
ServiceDiscovery.update(Record record)
Updates the given record.
|
void |
ServiceDiscovery.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
Maybe<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter)
Lookups for a single record.
|
Maybe<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter)
Lookups for a set of records.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a set of records.
|
void |
ServiceDiscovery.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
Single<Record> |
ServicePublisher.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServicePublisher.rxUpdate(Record record)
Updates an existing record.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceExporter.onPublish(Record record)
Notify a new record has been published, the record's registration can be used to uniquely
identify the record
|
void |
ServiceExporter.onUpdate(Record record)
Notify an existing record has been updated, the record's registration can be used to uniquely
identify the record
|
void |
ServicePublisher.publish(Record record)
Publishes a record.
|
void |
ServicePublisher.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
Single<Record> |
ServicePublisher.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServicePublisher.rxUpdate(Record record)
Updates an existing record.
|
void |
ServicePublisher.update(Record record)
Updates an existing record.
|
void |
ServicePublisher.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates an existing record.
|
Modifier and Type | Method and Description |
---|---|
void |
ServicePublisher.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
void |
ServicePublisher.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates an existing record.
|
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but let you configure whether or not the
service is using https . |
static Record |
MongoDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Mongo data source.
|
static Record |
RedisDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Redis data source.
|
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
HttpEndpoint.createRecord(String name,
String host)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but without metadata, using the port 80
and using "/" as root. |
static Record |
MessageSource.createRecord(String name,
String address)
Same as
MessageSource.createRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject) without additional metadata, and no type for
the payload. |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but without metadata. |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String classname)
Creates a record based on the parameters.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type)
Same as
MessageSource.createRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject) without additional metadata. |
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
Modifier and Type | Method and Description |
---|---|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured .
|
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
Handler<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,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
Modifier and Type | Method and Description |
---|---|
Record |
ServiceReference.record() |
Modifier and Type | Method and Description |
---|---|
Single<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter)
Lookups for a single record.
|
Single<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a single record.
|
Single<Record> |
ServiceDiscovery.rxGetRecord(JsonObject filter)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter)
Lookups for a set of records.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a set of records.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(JsonObject filter)
Lookups for a set of records.
|
Single<Record> |
ServiceDiscovery.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServiceDiscovery.rxUpdate(Record record)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
ServiceReference |
ServiceDiscovery.getReference(Record record)
Gets a service reference from the given record.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
void |
ServiceDiscovery.publish(Record record)
Publishes a record.
|
void |
ServiceDiscovery.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
Single<Record> |
ServiceDiscovery.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServiceDiscovery.rxUpdate(Record record)
Updates the given record.
|
void |
ServiceDiscovery.update(Record record)
Updates the given record.
|
void |
ServiceDiscovery.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
Single<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter)
Lookups for a single record.
|
Single<Record> |
ServiceDiscovery.rxGetRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter)
Lookups for a set of records.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Lookups for a set of records.
|
void |
ServiceDiscovery.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
Single<Record> |
ServicePublisher.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServicePublisher.rxUpdate(Record record)
Updates an existing record.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceExporter.onPublish(Record record)
Notify a new record has been published, the record's registration can be used to uniquely
identify the record
|
void |
ServiceExporter.onUpdate(Record record)
Notify an existing record has been updated, the record's registration can be used to uniquely
identify the record
|
void |
ServicePublisher.publish(Record record)
Publishes a record.
|
void |
ServicePublisher.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
Single<Record> |
ServicePublisher.rxPublish(Record record)
Publishes a record.
|
Single<Record> |
ServicePublisher.rxUpdate(Record record)
Updates an existing record.
|
void |
ServicePublisher.update(Record record)
Updates an existing record.
|
void |
ServicePublisher.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates an existing record.
|
Modifier and Type | Method and Description |
---|---|
void |
ServicePublisher.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
void |
ServicePublisher.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates an existing record.
|
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but let you configure whether or not the
service is using https . |
static Record |
MongoDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Mongo data source.
|
static Record |
RedisDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Redis data source.
|
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
HttpEndpoint.createRecord(String name,
String host)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but without metadata, using the port 80
and using "/" as root. |
static Record |
MessageSource.createRecord(String name,
String address)
Same as
MessageSource.createRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject) without additional metadata, and no type for
the payload. |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but without metadata. |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String classname)
Creates a record based on the parameters.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type)
Same as
MessageSource.createRecord(java.lang.String, java.lang.String, java.lang.String, io.vertx.core.json.JsonObject) without additional metadata. |
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
Modifier and Type | Method and Description |
---|---|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured .
|
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
Handler<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,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a message source and provides the configured .
|
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
Modifier and Type | Method and Description |
---|---|
Record |
ServiceReference.record() |
Record |
Record.setLocation(JsonObject location)
Sets the json object describing the location of the service.
|
Record |
Record.setMetadata(JsonObject metadata) |
Record |
Record.setName(String name)
Sets the name of the service.
|
Record |
Record.setRegistration(String reg)
Sets the registration id.
|
Record |
Record.setStatus(Status status)
Sets the status of the service.
|
Record |
Record.setType(String type)
Sets the type of service.
|
Modifier and Type | Method and Description |
---|---|
Future<Record> |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter)
Like
ServiceDiscovery.getRecord(Function, Handler) but returns a Future of the asynchronous result |
Future<Record> |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Like
ServiceDiscovery.getRecords(Function, boolean, Handler) but returns a Future of the asynchronous result |
Future<Record> |
ServiceDiscovery.getRecord(JsonObject filter)
Like
ServiceDiscovery.getRecord(JsonObject, Handler) but returns a Future of the asynchronous result |
Future<List<Record>> |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter)
Like
ServiceDiscovery.getRecords(Function, Handler) but returns a Future of the asynchronous result |
Future<List<Record>> |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Like
ServiceDiscovery.getRecords(Function, boolean, Handler) but returns a Future of the asynchronous result |
Future<List<Record>> |
ServiceDiscovery.getRecords(JsonObject filter)
Like
ServiceDiscovery.getRecords(JsonObject, Handler) but returns a Future of the asynchronous result |
Future<Record> |
ServiceDiscovery.publish(Record record)
Like
ServiceDiscovery.publish(Record, Handler) but returns a Future of the asynchronous result |
Future<Record> |
ServiceDiscovery.update(Record record)
Like
ServiceDiscovery.update(Record, Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
static void |
RecordConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
Record obj) |
ServiceReference |
ServiceDiscovery.getReference(Record record)
Gets a service reference from the given record.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
Future<Record> |
ServiceDiscovery.publish(Record record)
Like
ServiceDiscovery.publish(Record, Handler) but returns a Future of the asynchronous result |
void |
ServiceDiscovery.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
static void |
RecordConverter.toJson(Record obj,
JsonObject json) |
static void |
RecordConverter.toJson(Record obj,
Map<String,Object> json) |
Future<Record> |
ServiceDiscovery.update(Record record)
Like
ServiceDiscovery.update(Record, Handler) but returns a Future of the asynchronous result |
void |
ServiceDiscovery.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
Future<Record> |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter)
Like
ServiceDiscovery.getRecord(Function, Handler) but returns a Future of the asynchronous result |
Future<Record> |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Like
ServiceDiscovery.getRecords(Function, boolean, Handler) but returns a Future of the asynchronous result |
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
Future<List<Record>> |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter)
Like
ServiceDiscovery.getRecords(Function, Handler) but returns a Future of the asynchronous result |
Future<List<Record>> |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService)
Like
ServiceDiscovery.getRecords(Function, boolean, Handler) but returns a Future of the asynchronous result |
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
boolean includeOutOfService,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
void |
ServiceDiscovery.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
void |
ServiceDiscovery.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Constructor and Description |
---|
Record(Record other)
|
Modifier and Type | Method and Description |
---|---|
void |
RedisBackendService.remove(Record record,
Handler<AsyncResult<Record>> resultHandler) |
void |
RedisBackendService.store(Record record,
Handler<AsyncResult<Record>> resultHandler) |
void |
RedisBackendService.update(Record record,
Handler<AsyncResult<Void>> resultHandler) |
Modifier and Type | Method and Description |
---|---|
void |
RedisBackendService.getRecord(String uuid,
Handler<AsyncResult<Record>> resultHandler) |
void |
RedisBackendService.getRecords(Handler<AsyncResult<List<Record>>> resultHandler) |
void |
RedisBackendService.remove(Record record,
Handler<AsyncResult<Record>> resultHandler) |
void |
RedisBackendService.remove(String uuid,
Handler<AsyncResult<Record>> resultHandler) |
void |
RedisBackendService.store(Record record,
Handler<AsyncResult<Record>> resultHandler) |
Constructor and Description |
---|
ImportedConsulService(String name,
String id,
Record record)
Creates a new instance of
ImportedConsulService . |
Modifier and Type | Method and Description |
---|---|
Future<Record> |
ServicePublisher.publish(Record record)
Like
ServicePublisher.publish(Record, Handler) but returns a future of the result |
Future<Record> |
ServicePublisher.update(Record record)
Like
ServicePublisher.update(Record, Handler) but returns a future of the result |
Modifier and Type | Method and Description |
---|---|
ServiceReference |
ServiceType.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration)
Gets the `service` for the given record.
|
void |
ServiceExporter.onPublish(Record record)
Notify a new record has been published, the record's registration can be used to uniquely
identify the record
|
void |
ServiceExporter.onUpdate(Record record)
Notify an existing record has been updated, the record's registration can be used to uniquely
identify the record
|
Future<Record> |
ServicePublisher.publish(Record record)
Like
ServicePublisher.publish(Record, Handler) but returns a future of the result |
void |
ServicePublisher.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
void |
ServiceDiscoveryBackend.remove(Record record,
Handler<AsyncResult<Record>> resultHandler)
Removes a record.
|
void |
ServiceDiscoveryBackend.store(Record record,
Handler<AsyncResult<Record>> resultHandler)
Stores a record.
|
Future<Record> |
ServicePublisher.update(Record record)
Like
ServicePublisher.update(Record, Handler) but returns a future of the result |
void |
ServicePublisher.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates an existing record.
|
void |
ServiceDiscoveryBackend.update(Record record,
Handler<AsyncResult<Void>> resultHandler)
Updates a record
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceDiscoveryBackend.getRecord(String uuid,
Handler<AsyncResult<Record>> resultHandler)
Get the record with the given uuid.
|
void |
ServiceDiscoveryBackend.getRecords(Handler<AsyncResult<List<Record>>> resultHandler)
Gets all the records
|
void |
ServicePublisher.publish(Record record,
Handler<AsyncResult<Record>> resultHandler)
Publishes a record.
|
void |
ServiceDiscoveryBackend.remove(Record record,
Handler<AsyncResult<Record>> resultHandler)
Removes a record.
|
void |
ServiceDiscoveryBackend.remove(String uuid,
Handler<AsyncResult<Record>> resultHandler)
Removes a records based on its UUID.
|
void |
ServiceDiscoveryBackend.store(Record record,
Handler<AsyncResult<Record>> resultHandler)
Stores a record.
|
void |
ServicePublisher.update(Record record,
Handler<AsyncResult<Record>> resultHandler)
Updates an existing record.
|
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(String, String, int, String, JsonObject) but let you configure whether or not the
service is using https . |
static Record |
MongoDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Mongo data source.
|
static Record |
RedisDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Redis data source.
|
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
HttpEndpoint.createRecord(String name,
String host)
Same as
HttpEndpoint.createRecord(String, String, int, String, JsonObject) but without metadata, using the port 80
and using "/" as root. |
static Record |
MessageSource.createRecord(String name,
String address)
Same as
MessageSource.createRecord(String, String, Class, JsonObject) without additional metadata, and no type for
the payload. |
static Record |
EventBusService.createRecord(String name,
String address,
Class itf)
Same as
EventBusService.createRecord(String, String, Class, JsonObject) but without metadata. |
static Record |
MessageSource.createRecord(String name,
String address,
Class type)
Same as
MessageSource.createRecord(String, String, Class, JsonObject) without additional metadata. |
static Record |
EventBusService.createRecord(String name,
String address,
Class itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
Class type,
JsonObject metadata)
Create a record representing a data producer.
|
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root)
Same as
HttpEndpoint.createRecord(String, String, int, String, JsonObject) but without metadata. |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String classname)
Creates a record based on the parameters.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type)
Same as
MessageSource.createRecord(String, String, String, JsonObject) without additional metadata. |
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
Record |
AbstractServiceReference.record() |
Modifier and Type | Method and Description |
---|---|
static Future<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Like
HttpEndpoint.getClient(ServiceDiscovery, Function, Handler) but returns a future of the result |
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
HttpClient . |
static Future<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Like
HttpEndpoint.getClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
HttpClient . |
static <T> Future<MessageConsumer<T>> |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Like
MessageSource.getConsumer(ServiceDiscovery, Function, Handler) but returns a future of the result |
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured
MessageConsumer . |
static Future<JDBCClient> |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Like
JDBCDataSource.getJDBCClient(ServiceDiscovery, Function, Handler) but returns a future of the result |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Future<JDBCClient> |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Like
JDBCDataSource.getJDBCClient(ServiceDiscovery, Function, JsonObject, Handler) but returns a future of the result |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Future<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Like
MongoDataSource.getMongoClient(ServiceDiscovery, Function, Handler) but returns a future of the result |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Future<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Like
RedisDataSource.getRedisClient(ServiceDiscovery, Function, Handler) but returns a future of the result |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Future<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Like
RedisDataSource.getRedisClient(ServiceDiscovery, Function, JsonObject, Handler) but returns a future of the result |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
Handler<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,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static Future<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Like
HttpEndpoint.getWebClient(ServiceDiscovery, Function, Handler) but returns a future of the result |
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
WebClient . |
static Future<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Like
HttpEndpoint.getWebClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
WebClient . |
Constructor and Description |
---|
AbstractServiceReference(Vertx vertx,
ServiceDiscovery discovery,
Record record)
Creates a new instance of
AbstractServiceReference . |
Copyright © 2021 Eclipse. All rights reserved.