vertx / io.vertx.kotlin.servicediscovery / io.vertx.servicediscovery.ServiceDiscovery

Extensions for io.vertx.servicediscovery.ServiceDiscovery

getRecordAwait

suspend fun ServiceDiscovery.getRecordAwait(filter: JsonObject): Record?
suspend fun ServiceDiscovery.getRecordAwait(filter: Function<Record, Boolean>): Record?
suspend fun ServiceDiscovery.getRecordAwait(filter: Function<Record, Boolean>, includeOutOfService: Boolean): Record?

Lookups for a single record.

getRecordsAwait

suspend fun ServiceDiscovery.getRecordsAwait(filter: JsonObject): List<Record>
suspend fun ServiceDiscovery.getRecordsAwait(filter: Function<Record, Boolean>): List<Record>
suspend fun ServiceDiscovery.getRecordsAwait(filter: Function<Record, Boolean>, includeOutOfService: Boolean): List<Record>

Lookups for a set of records. Unlike io.vertx.servicediscovery.ServiceDiscovery, this method returns all matching records.

publishAwait

suspend fun ServiceDiscovery.publishAwait(record: Record): Record

Publishes a record.

unpublishAwait

suspend fun ServiceDiscovery.unpublishAwait(id: String): Unit

Un-publishes a record.

updateAwait

suspend fun ServiceDiscovery.updateAwait(record: Record): Record

Updates the given record. The record must has been published, and has it's registration id set.