vertx / io.vertx.kotlin.ext.consul / io.vertx.ext.consul.ConsulService

Extensions for io.vertx.ext.consul.ConsulService

agentInfoAwait

suspend fun ConsulService.agentInfoAwait(): JsonObject

catalogDatacentersAwait

suspend fun ConsulService.catalogDatacentersAwait(): List<String>

catalogNodeServicesAwait

suspend fun ConsulService.catalogNodeServicesAwait(node: String): ServiceList

catalogNodeServicesWithOptionsAwait

suspend fun ConsulService.catalogNodeServicesWithOptionsAwait(node: String, options: BlockingQueryOptions): ServiceList

catalogNodesAwait

suspend fun ConsulService.catalogNodesAwait(): NodeList

catalogNodesWithOptionsAwait

suspend fun ConsulService.catalogNodesWithOptionsAwait(options: NodeQueryOptions): NodeList

catalogServiceNodesAwait

suspend fun ConsulService.catalogServiceNodesAwait(service: String): ServiceList

catalogServiceNodesWithOptionsAwait

suspend fun ConsulService.catalogServiceNodesWithOptionsAwait(service: String, options: ServiceQueryOptions): ServiceList

catalogServicesAwait

suspend fun ConsulService.catalogServicesAwait(): ServiceList

catalogServicesWithOptionsAwait

suspend fun ConsulService.catalogServicesWithOptionsAwait(options: BlockingQueryOptions): ServiceList

cloneAclTokenAwait

suspend fun ConsulService.cloneAclTokenAwait(id: String): String

coordinateDatacentersAwait

suspend fun ConsulService.coordinateDatacentersAwait(): List<DcCoordinates>

coordinateNodesAwait

suspend fun ConsulService.coordinateNodesAwait(): CoordinateList

coordinateNodesWithOptionsAwait

suspend fun ConsulService.coordinateNodesWithOptionsAwait(options: BlockingQueryOptions): CoordinateList

createAclTokenAwait

suspend fun ConsulService.createAclTokenAwait(token: AclToken): String

createPreparedQueryAwait

suspend fun ConsulService.createPreparedQueryAwait(definition: PreparedQueryDefinition): String

createSessionAwait

suspend fun ConsulService.createSessionAwait(): String

createSessionWithOptionsAwait

suspend fun ConsulService.createSessionWithOptionsAwait(options: SessionOptions): String

deletePreparedQueryAwait

suspend fun ConsulService.deletePreparedQueryAwait(id: String): Unit

deleteValueAwait

suspend fun ConsulService.deleteValueAwait(key: String): Unit

deleteValuesAwait

suspend fun ConsulService.deleteValuesAwait(keyPrefix: String): Unit

deregisterCheckAwait

suspend fun ConsulService.deregisterCheckAwait(checkId: String): Unit

deregisterServiceAwait

suspend fun ConsulService.deregisterServiceAwait(id: String): Unit

destroyAclTokenAwait

suspend fun ConsulService.destroyAclTokenAwait(id: String): Unit

destroySessionAwait

suspend fun ConsulService.destroySessionAwait(id: String): Unit

executePreparedQueryAwait

suspend fun ConsulService.executePreparedQueryAwait(query: String): PreparedQueryExecuteResponse

executePreparedQueryWithOptionsAwait

suspend fun ConsulService.executePreparedQueryWithOptionsAwait(query: String, options: PreparedQueryExecuteOptions): PreparedQueryExecuteResponse

failCheckAwait

suspend fun ConsulService.failCheckAwait(checkId: String): Unit

failCheckWithNoteAwait

suspend fun ConsulService.failCheckWithNoteAwait(checkId: String, note: String): Unit

fireEventAwait

suspend fun ConsulService.fireEventAwait(name: String): Event

fireEventWithOptionsAwait

suspend fun ConsulService.fireEventWithOptionsAwait(name: String, options: EventOptions): Event

getAllPreparedQueriesAwait

suspend fun ConsulService.getAllPreparedQueriesAwait(): List<PreparedQueryDefinition>

getKeysAwait

suspend fun ConsulService.getKeysAwait(keyPrefix: String): List<String>

getKeysWithOptionsAwait

suspend fun ConsulService.getKeysWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): List<String>

getPreparedQueryAwait

suspend fun ConsulService.getPreparedQueryAwait(id: String): PreparedQueryDefinition

getValueAwait

suspend fun ConsulService.getValueAwait(key: String): KeyValue

getValueWithOptionsAwait

suspend fun ConsulService.getValueWithOptionsAwait(key: String, options: BlockingQueryOptions): KeyValue

getValuesAwait

suspend fun ConsulService.getValuesAwait(keyPrefix: String): KeyValueList

getValuesWithOptionsAwait

suspend fun ConsulService.getValuesWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): KeyValueList

healthChecksAwait

suspend fun ConsulService.healthChecksAwait(service: String): CheckList

healthChecksWithOptionsAwait

suspend fun ConsulService.healthChecksWithOptionsAwait(service: String, options: CheckQueryOptions): CheckList

healthServiceNodesAwait

suspend fun ConsulService.healthServiceNodesAwait(service: String, passing: Boolean): ServiceEntryList

healthServiceNodesWithOptionsAwait

suspend fun ConsulService.healthServiceNodesWithOptionsAwait(service: String, passing: Boolean, options: ServiceQueryOptions): ServiceEntryList

healthStateAwait

suspend fun ConsulService.healthStateAwait(healthState: HealthState): CheckList

healthStateWithOptionsAwait

suspend fun ConsulService.healthStateWithOptionsAwait(healthState: HealthState, checkQueryOptions: CheckQueryOptions): CheckList

infoAclTokenAwait

suspend fun ConsulService.infoAclTokenAwait(id: String): AclToken

infoSessionAwait

suspend fun ConsulService.infoSessionAwait(id: String): Session

infoSessionWithOptionsAwait

suspend fun ConsulService.infoSessionWithOptionsAwait(id: String, options: BlockingQueryOptions): Session

leaderStatusAwait

suspend fun ConsulService.leaderStatusAwait(): String

listAclTokensAwait

suspend fun ConsulService.listAclTokensAwait(): List<AclToken>

listEventsAwait

suspend fun ConsulService.listEventsAwait(): EventList

listEventsWithOptionsAwait

suspend fun ConsulService.listEventsWithOptionsAwait(options: EventListOptions): EventList

listNodeSessionsAwait

suspend fun ConsulService.listNodeSessionsAwait(nodeId: String): SessionList

listNodeSessionsWithOptionsAwait

suspend fun ConsulService.listNodeSessionsWithOptionsAwait(nodeId: String, options: BlockingQueryOptions): SessionList

listSessionsAwait

suspend fun ConsulService.listSessionsAwait(): SessionList

listSessionsWithOptionsAwait

suspend fun ConsulService.listSessionsWithOptionsAwait(options: BlockingQueryOptions): SessionList

localChecksAwait

suspend fun ConsulService.localChecksAwait(): List<Check>

localServicesAwait

suspend fun ConsulService.localServicesAwait(): List<Service>

maintenanceServiceAwait

suspend fun ConsulService.maintenanceServiceAwait(maintenanceOptions: MaintenanceOptions): Unit

passCheckAwait

suspend fun ConsulService.passCheckAwait(checkId: String): Unit

passCheckWithNoteAwait

suspend fun ConsulService.passCheckWithNoteAwait(checkId: String, note: String): Unit

peersStatusAwait

suspend fun ConsulService.peersStatusAwait(): List<String>

putValueAwait

suspend fun ConsulService.putValueAwait(key: String, value: String): Boolean

putValueWithOptionsAwait

suspend fun ConsulService.putValueWithOptionsAwait(key: String, value: String, options: KeyValueOptions): Boolean

registerCheckAwait

suspend fun ConsulService.registerCheckAwait(checkOptions: CheckOptions): Unit

registerServiceAwait

suspend fun ConsulService.registerServiceAwait(serviceOptions: ServiceOptions): Unit

renewSessionAwait

suspend fun ConsulService.renewSessionAwait(id: String): Session

transactionAwait

suspend fun ConsulService.transactionAwait(request: TxnRequest): TxnResponse

updateAclTokenAwait

suspend fun ConsulService.updateAclTokenAwait(token: AclToken): String

updateCheckAwait

suspend fun ConsulService.updateCheckAwait(checkId: String, status: CheckStatus): Unit

updateCheckWithNoteAwait

suspend fun ConsulService.updateCheckWithNoteAwait(checkId: String, status: CheckStatus, note: String): Unit

updatePreparedQueryAwait

suspend fun ConsulService.updatePreparedQueryAwait(definition: PreparedQueryDefinition): Unit

warnCheckAwait

suspend fun ConsulService.warnCheckAwait(checkId: String): Unit

warnCheckWithNoteAwait

suspend fun ConsulService.warnCheckWithNoteAwait(checkId: String, note: String): Unit