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,
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,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
Handler<AsyncResult<RedisClient>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<RedisClient>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
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,
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,
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<RedisClient> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
static Single<RedisClient> |
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
RedisClient . |
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,
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,
Handler<AsyncResult<Record>> resultHandler)
Updates the given record.
|
Modifier and Type | Method and Description |
---|---|
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,
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,
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,
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,
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,
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,
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,
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,
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,
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,
Handler<AsyncResult<RedisClient>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<RedisClient>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
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,
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,
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<RedisClient> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
static Single<RedisClient> |
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
RedisClient . |
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 |
---|---|
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.
|
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) |
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,
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,
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 |
---|---|
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
|
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.
|
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 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 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> 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 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,
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,
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,
Handler<AsyncResult<RedisClient>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<RedisClient>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
RedisClient . |
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,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
WebClient . |
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 © 2023 Eclipse. All rights reserved.