vertx

alltypes

object AzureADAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object GoogleAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object HttpEndpoint

suspend fun getClientAwait(discovery: ServiceDiscovery, filter: JsonObject): HttpClient
suspend fun getClientAwait(discovery: ServiceDiscovery, filter: JsonObject, conf: JsonObject): HttpClient
suspend fun getClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): HttpClient
suspend fun getClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, conf: JsonObject): HttpClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: JsonObject): WebClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: JsonObject, conf: JsonObject): WebClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): WebClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, conf: JsonObject): WebClient

object JDBCDataSource

suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: JsonObject): JDBCClient
suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): JDBCClient
suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): JDBCClient
suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, consumerConfiguration: JsonObject): JDBCClient

object Json
object KeycloakAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object MessageSource

suspend fun <T> getConsumerAwait(discovery: ServiceDiscovery, filter: JsonObject): MessageConsumer<T>
suspend fun <T> getConsumerAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): MessageConsumer<T>

object MongoDataSource

suspend fun getMongoClientAwait(discovery: ServiceDiscovery, filter: JsonObject): MongoClient
suspend fun getMongoClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): MongoClient
suspend fun getMongoClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): MongoClient

object MySQLConnection

suspend fun connectAwait(vertx: Vertx, connectOptions: MySQLConnectOptions): MySQLConnection
suspend fun connectAwait(vertx: Vertx, connectionUri: String): MySQLConnection

object OpenAPI3RouterFactory

suspend fun createAwait(vertx: Vertx, url: String): OpenAPI3RouterFactory
suspend fun createAwait(vertx: Vertx, url: String, auth: List<JsonObject>): OpenAPI3RouterFactory

object OpenIDConnectAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object PgConnection

suspend fun connectAwait(vertx: Vertx, options: PgConnectOptions): PgConnection
suspend fun connectAwait(vertx: Vertx): PgConnection
suspend fun connectAwait(vertx: Vertx, connectionUri: String): PgConnection

object RedisDataSource

suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: JsonObject): Redis
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): Redis
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): Redis
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, consumerConfiguration: JsonObject): Redis

object SalesforceAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object Vertx

suspend fun clusteredVertxAwait(options: VertxOptions): Vertx

io.vertx.amqp.AmqpClient

suspend fun AmqpClient.closeAwait(): Unit
suspend fun AmqpClient.connectAwait(): AmqpConnection
suspend fun AmqpClient.createReceiverAwait(address: String): AmqpReceiver
suspend fun AmqpClient.createReceiverAwait(address: String, receiverOptions: AmqpReceiverOptions): AmqpReceiver
suspend fun AmqpClient.createSenderAwait(address: String): AmqpSender
suspend fun AmqpClient.createSenderAwait(address: String, options: AmqpSenderOptions): AmqpSender

io.vertx.amqp.AmqpConnection

suspend fun AmqpConnection.closeAwait(): Unit
suspend fun AmqpConnection.createAnonymousSenderAwait(): AmqpSender
suspend fun AmqpConnection.createDynamicReceiverAwait(): AmqpReceiver
suspend fun AmqpConnection.createReceiverAwait(address: String): AmqpReceiver
suspend fun AmqpConnection.createReceiverAwait(address: String, receiverOptions: AmqpReceiverOptions): AmqpReceiver
suspend fun AmqpConnection.createSenderAwait(address: String): AmqpSender
suspend fun AmqpConnection.createSenderAwait(address: String, options: AmqpSenderOptions): AmqpSender

io.vertx.amqp.AmqpReceiver

suspend fun AmqpReceiver.closeAwait(): Unit
suspend fun AmqpReceiver.pipeToAwait(dst: WriteStream<AmqpMessage>): Unit

io.vertx.amqp.AmqpSender

suspend fun AmqpSender.closeAwait(): Unit
suspend fun AmqpSender.endAwait(): Unit
suspend fun AmqpSender.endAwait(data: AmqpMessage): Unit
suspend fun AmqpSender.sendWithAckAwait(message: AmqpMessage): Unit
suspend fun AmqpSender.writeAwait(data: AmqpMessage): Unit

io.vertx.cassandra.CassandraClient

suspend fun CassandraClient.closeAwait(): Unit
suspend fun CassandraClient.executeAwait(query: String): ResultSet
suspend fun CassandraClient.executeAwait(statement: Statement): ResultSet
suspend fun CassandraClient.executeWithFullFetchAwait(query: String): List<Row>
suspend fun CassandraClient.executeWithFullFetchAwait(statement: Statement): List<Row>
suspend fun CassandraClient.prepareAwait(query: String): PreparedStatement
suspend fun CassandraClient.queryStreamAwait(sql: String): CassandraRowStream
suspend fun CassandraClient.queryStreamAwait(statement: Statement): CassandraRowStream

io.vertx.cassandra.CassandraRowStream

suspend fun CassandraRowStream.pipeToAwait(dst: WriteStream<Row>): Unit

io.vertx.cassandra.Mapper

suspend fun <T> Mapper<T>.deleteAwait(primaryKey: List<Any>): Unit
suspend fun <T> Mapper<T>.getAwait(primaryKey: List<Any>): T
suspend fun <T> Mapper<T>.saveAwait(entity: T): Unit

io.vertx.cassandra.ResultSet

suspend fun ResultSet.allAwait(): List<Row>
suspend fun ResultSet.fetchMoreResultsAwait(): Unit
suspend fun ResultSet.oneAwait(): Row?
suspend fun ResultSet.severalAwait(amount: Int): List<Row>

io.vertx.circuitbreaker.CircuitBreaker

suspend fun <T> CircuitBreaker.executeAwait(command: (Promise<T>) -> Unit): T
suspend fun <T> CircuitBreaker.executeWithFallbackAwait(command: (Promise<T>) -> Unit, fallback: (Throwable) -> T): T

io.vertx.config.ConfigRetriever

suspend fun ConfigRetriever.getConfigAwait(): JsonObject

io.vertx.core.CompositeFuture

suspend fun CompositeFuture.setHandlerAwait(): CompositeFuture

io.vertx.core.Context

suspend fun <T> Context.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit, ordered: Boolean): T?
suspend fun <T> Context.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit): T?

io.vertx.core.Future

suspend fun <T> Future<T>.setHandlerAwait(): T

io.vertx.core.TimeoutStream

suspend fun TimeoutStream.pipeToAwait(dst: WriteStream<Long>): Unit

io.vertx.core.Vertx

suspend fun Vertx.closeAwait(): Unit
suspend fun Vertx.deployVerticleAwait(name: String): String
suspend fun Vertx.deployVerticleAwait(name: String, options: DeploymentOptions): String
suspend fun Vertx.deployVerticleAwait(verticle: Verticle): String
suspend fun Vertx.deployVerticleAwait(verticle: Verticle, options: DeploymentOptions): String
suspend fun Vertx.deployVerticleAwait(verticleSupplier: Supplier<Verticle>, options: DeploymentOptions): String
suspend fun <T> Vertx.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit, ordered: Boolean): T?
suspend fun <T> Vertx.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit): T?
suspend fun Vertx.undeployAwait(deploymentID: String): Unit

io.vertx.core.WorkerExecutor

suspend fun <T> WorkerExecutor.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit, ordered: Boolean): T?
suspend fun <T> WorkerExecutor.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit): T?

io.vertx.core.buffer.Buffer

inline fun Buffer.appendJson(pretty: Boolean = false, block: Json.() -> Any): Buffer

io.vertx.core.datagram.DatagramSocket

suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, networkInterface: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.closeAwait(): Unit
suspend fun DatagramSocket.listenAwait(port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String): Unit
suspend fun DatagramSocket.pipeToAwait(dst: WriteStream<DatagramPacket>): Unit
suspend fun DatagramSocket.sendAwait(packet: Buffer, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, enc: String, port: Int, host: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String): Unit

io.vertx.core.dns.DnsClient

suspend fun DnsClient.lookup4Await(name: String): String?
suspend fun DnsClient.lookup6Await(name: String): String?
suspend fun DnsClient.lookupAwait(name: String): String?
suspend fun DnsClient.resolveAAAAAwait(name: String): List<String>
suspend fun DnsClient.resolveAAwait(name: String): List<String>
suspend fun DnsClient.resolveCNAMEAwait(name: String): List<String>
suspend fun DnsClient.resolveMXAwait(name: String): List<MxRecord>
suspend fun DnsClient.resolveNSAwait(name: String): List<String>
suspend fun DnsClient.resolvePTRAwait(name: String): String?
suspend fun DnsClient.resolveSRVAwait(name: String): List<SrvRecord>
suspend fun DnsClient.resolveTXTAwait(name: String): List<String>
suspend fun DnsClient.reverseLookupAwait(ipaddress: String): String?

io.vertx.core.eventbus.EventBus

suspend fun <T> EventBus.requestAwait(address: String, message: Any): Message<T>
suspend fun <T> EventBus.requestAwait(address: String, message: Any, options: DeliveryOptions): Message<T>

io.vertx.core.eventbus.Message

suspend fun <R, T> Message<T>.replyAndRequestAwait(message: Any): Message<R>
suspend fun <R, T> Message<T>.replyAndRequestAwait(message: Any, options: DeliveryOptions): Message<R>

io.vertx.core.eventbus.MessageConsumer

suspend fun <T> MessageConsumer<T>.completionHandlerAwait(): Unit
suspend fun <T> MessageConsumer<T>.pipeToAwait(dst: WriteStream<Message<T>>): Unit
suspend fun <T> MessageConsumer<T>.unregisterAwait(): Unit

io.vertx.core.eventbus.MessageProducer

suspend fun <T> MessageProducer<T>.closeAwait(): Unit
suspend fun <T> MessageProducer<T>.endAwait(data: T): Unit
suspend fun <T> MessageProducer<T>.endAwait(): Unit
suspend fun <T> MessageProducer<T>.writeAwait(data: T): Unit

io.vertx.core.file.AsyncFile

suspend fun AsyncFile.closeAwait(): Unit
suspend fun AsyncFile.endAwait(): Unit
suspend fun AsyncFile.endAwait(data: Buffer): Unit
suspend fun AsyncFile.flushAwait(): Unit
suspend fun AsyncFile.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun AsyncFile.readAwait(buffer: Buffer, offset: Int, position: Long, length: Int): Buffer
suspend fun AsyncFile.writeAwait(data: Buffer): Unit
suspend fun AsyncFile.writeAwait(buffer: Buffer, position: Long): Unit

io.vertx.core.file.FileSystem

suspend fun FileSystem.chmodAwait(path: String, perms: String): Unit
suspend fun FileSystem.chmodRecursiveAwait(path: String, perms: String, dirPerms: String): Unit
suspend fun FileSystem.chownAwait(path: String, user: String, group: String): Unit
suspend fun FileSystem.copyAwait(from: String, to: String): Unit
suspend fun FileSystem.copyAwait(from: String, to: String, options: CopyOptions): Unit
suspend fun FileSystem.copyRecursiveAwait(from: String, to: String, recursive: Boolean): Unit
suspend fun FileSystem.createFileAwait(path: String): Unit
suspend fun FileSystem.createFileAwait(path: String, perms: String): Unit
suspend fun FileSystem.createTempDirectoryAwait(prefix: String): String
suspend fun FileSystem.createTempDirectoryAwait(prefix: String, perms: String): String
suspend fun FileSystem.createTempDirectoryAwait(dir: String, prefix: String, perms: String): String
suspend fun FileSystem.createTempFileAwait(prefix: String, suffix: String): String
suspend fun FileSystem.createTempFileAwait(prefix: String, suffix: String, perms: String): String
suspend fun FileSystem.createTempFileAwait(dir: String, prefix: String, suffix: String, perms: String): String
suspend fun FileSystem.deleteAwait(path: String): Unit
suspend fun FileSystem.deleteRecursiveAwait(path: String, recursive: Boolean): Unit
suspend fun FileSystem.existsAwait(path: String): Boolean
suspend fun FileSystem.fsPropsAwait(path: String): FileSystemProps
suspend fun FileSystem.linkAwait(link: String, existing: String): Unit
suspend fun FileSystem.lpropsAwait(path: String): FileProps
suspend fun FileSystem.mkdirAwait(path: String): Unit
suspend fun FileSystem.mkdirAwait(path: String, perms: String): Unit
suspend fun FileSystem.mkdirsAwait(path: String): Unit
suspend fun FileSystem.mkdirsAwait(path: String, perms: String): Unit
suspend fun FileSystem.moveAwait(from: String, to: String): Unit
suspend fun FileSystem.moveAwait(from: String, to: String, options: CopyOptions): Unit
suspend fun FileSystem.openAwait(path: String, options: OpenOptions): AsyncFile
suspend fun FileSystem.propsAwait(path: String): FileProps
suspend fun FileSystem.readDirAwait(path: String): List<String>
suspend fun FileSystem.readDirAwait(path: String, filter: String): List<String>
suspend fun FileSystem.readFileAwait(path: String): Buffer
suspend fun FileSystem.readSymlinkAwait(link: String): String
suspend fun FileSystem.symlinkAwait(link: String, existing: String): Unit
suspend fun FileSystem.truncateAwait(path: String, len: Long): Unit
suspend fun FileSystem.unlinkAwait(link: String): Unit
suspend fun FileSystem.writeFileAwait(path: String, data: Buffer): Unit

io.vertx.core.http.HttpClient

suspend fun HttpClient.getNowAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.getNowAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getNowAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getNowAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.headNowAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.headNowAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headNowAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headNowAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.webSocketAbsAwait(url: String, headers: MultiMap, version: WebsocketVersion, subProtocols: List<String>): WebSocket
suspend fun HttpClient.webSocketAwait(port: Int, host: String, requestURI: String): WebSocket
suspend fun HttpClient.webSocketAwait(host: String, requestURI: String): WebSocket
suspend fun HttpClient.webSocketAwait(requestURI: String): WebSocket
suspend fun HttpClient.webSocketAwait(options: WebSocketConnectOptions): WebSocket

io.vertx.core.http.HttpClientRequest

suspend fun HttpClientRequest.endAwait(chunk: String): Unit
suspend fun HttpClientRequest.endAwait(chunk: String, enc: String): Unit
suspend fun HttpClientRequest.endAwait(chunk: Buffer): Unit
suspend fun HttpClientRequest.endAwait(): Unit
suspend fun HttpClientRequest.setHandlerAwait(): HttpClientResponse
suspend fun HttpClientRequest.writeAwait(data: Buffer): Unit
suspend fun HttpClientRequest.writeAwait(chunk: String): Unit
suspend fun HttpClientRequest.writeAwait(chunk: String, enc: String): Unit

io.vertx.core.http.HttpClientResponse

suspend fun HttpClientResponse.bodyAwait(): Buffer
suspend fun HttpClientResponse.pipeToAwait(dst: WriteStream<Buffer>): Unit

io.vertx.core.http.HttpConnection

suspend fun HttpConnection.pingAwait(data: Buffer): Buffer
suspend fun HttpConnection.updateSettingsAwait(settings: Http2Settings): Unit

io.vertx.core.http.HttpServer

suspend fun HttpServer.closeAwait(): Unit
suspend fun HttpServer.listenAwait(port: Int, host: String): HttpServer
suspend fun HttpServer.listenAwait(address: SocketAddress): HttpServer
suspend fun HttpServer.listenAwait(port: Int): HttpServer
suspend fun HttpServer.listenAwait(): HttpServer

io.vertx.core.http.HttpServerFileUpload

suspend fun HttpServerFileUpload.pipeToAwait(dst: WriteStream<Buffer>): Unit

io.vertx.core.http.HttpServerRequest

suspend fun HttpServerRequest.pipeToAwait(dst: WriteStream<Buffer>): Unit

io.vertx.core.http.HttpServerResponse

suspend fun HttpServerResponse.endAwait(): Unit
suspend fun HttpServerResponse.endAwait(chunk: String): Unit
suspend fun HttpServerResponse.endAwait(chunk: String, enc: String): Unit
suspend fun HttpServerResponse.endAwait(chunk: Buffer): Unit
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, host: String, path: String): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, path: String, headers: MultiMap): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, path: String): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, host: String, path: String, headers: MultiMap): HttpServerResponse
suspend fun HttpServerResponse.sendFileAwait(filename: String): Unit
suspend fun HttpServerResponse.sendFileAwait(filename: String, offset: Long): Unit
suspend fun HttpServerResponse.sendFileAwait(filename: String, offset: Long, length: Long): Unit
suspend fun HttpServerResponse.writeAwait(data: Buffer): Unit
suspend fun HttpServerResponse.writeAwait(chunk: String, enc: String): Unit
suspend fun HttpServerResponse.writeAwait(chunk: String): Unit

io.vertx.core.http.ServerWebSocket

suspend fun ServerWebSocket.closeAwait(): Unit
suspend fun ServerWebSocket.closeAwait(statusCode: Short): Unit
suspend fun ServerWebSocket.closeAwait(statusCode: Short, reason: String): Unit
suspend fun ServerWebSocket.endAwait(data: Buffer): Unit
suspend fun ServerWebSocket.endAwait(): Unit
suspend fun ServerWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun ServerWebSocket.writeAwait(data: Buffer): Unit
suspend fun ServerWebSocket.writeBinaryMessageAwait(data: Buffer): Unit
suspend fun ServerWebSocket.writeFinalBinaryFrameAwait(data: Buffer): Unit
suspend fun ServerWebSocket.writeFinalTextFrameAwait(text: String): Unit
suspend fun ServerWebSocket.writeFrameAwait(frame: WebSocketFrame): Unit
suspend fun ServerWebSocket.writeTextMessageAwait(text: String): Unit

io.vertx.core.http.WebSocket

suspend fun WebSocket.closeAwait(): Unit
suspend fun WebSocket.closeAwait(statusCode: Short): Unit
suspend fun WebSocket.closeAwait(statusCode: Short, reason: String): Unit
suspend fun WebSocket.endAwait(data: Buffer): Unit
suspend fun WebSocket.endAwait(): Unit
suspend fun WebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun WebSocket.writeAwait(data: Buffer): Unit
suspend fun WebSocket.writeBinaryMessageAwait(data: Buffer): Unit
suspend fun WebSocket.writeFinalBinaryFrameAwait(data: Buffer): Unit
suspend fun WebSocket.writeFinalTextFrameAwait(text: String): Unit
suspend fun WebSocket.writeFrameAwait(frame: WebSocketFrame): Unit
suspend fun WebSocket.writeTextMessageAwait(text: String): Unit

io.vertx.core.http.WebSocketBase

suspend fun WebSocketBase.closeAwait(): Unit
suspend fun WebSocketBase.closeAwait(statusCode: Short): Unit
suspend fun WebSocketBase.closeAwait(statusCode: Short, reason: String): Unit
suspend fun WebSocketBase.endAwait(data: Buffer): Unit
suspend fun WebSocketBase.endAwait(): Unit
suspend fun WebSocketBase.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun WebSocketBase.writeAwait(data: Buffer): Unit
suspend fun WebSocketBase.writeBinaryMessageAwait(data: Buffer): Unit
suspend fun WebSocketBase.writeFinalBinaryFrameAwait(data: Buffer): Unit
suspend fun WebSocketBase.writeFinalTextFrameAwait(text: String): Unit
suspend fun WebSocketBase.writeFrameAwait(frame: WebSocketFrame): Unit
suspend fun WebSocketBase.writeTextMessageAwait(text: String): Unit

io.vertx.core.json.JsonArray

operator fun <T> JsonArray.get(index: Int): T

io.vertx.core.json.JsonObject

operator fun <T> JsonObject.get(key: String): T

io.vertx.core.net.NetClient

suspend fun NetClient.connectAwait(port: Int, host: String): NetSocket
suspend fun NetClient.connectAwait(port: Int, host: String, serverName: String): NetSocket
suspend fun NetClient.connectAwait(remoteAddress: SocketAddress): NetSocket
suspend fun NetClient.connectAwait(remoteAddress: SocketAddress, serverName: String): NetSocket

io.vertx.core.net.NetServer

suspend fun NetServer.closeAwait(): Unit
suspend fun NetServer.listenAwait(): NetServer
suspend fun NetServer.listenAwait(port: Int, host: String): NetServer
suspend fun NetServer.listenAwait(port: Int): NetServer
suspend fun NetServer.listenAwait(localAddress: SocketAddress): NetServer

io.vertx.core.net.NetSocket

suspend fun NetSocket.closeAwait(): Unit
suspend fun NetSocket.endAwait(data: Buffer): Unit
suspend fun NetSocket.endAwait(): Unit
suspend fun NetSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun NetSocket.sendFileAwait(filename: String): Unit
suspend fun NetSocket.sendFileAwait(filename: String, offset: Long): Unit
suspend fun NetSocket.sendFileAwait(filename: String, offset: Long, length: Long): Unit
suspend fun NetSocket.upgradeToSslAwait(): Unit
suspend fun NetSocket.upgradeToSslAwait(serverName: String): Unit
suspend fun NetSocket.writeAwait(str: String): Unit
suspend fun NetSocket.writeAwait(str: String, enc: String): Unit
suspend fun NetSocket.writeAwait(message: Buffer): Unit

io.vertx.core.parsetools.JsonParser

suspend fun JsonParser.pipeToAwait(dst: WriteStream<JsonEvent>): Unit

io.vertx.core.parsetools.RecordParser

suspend fun RecordParser.pipeToAwait(dst: WriteStream<Buffer>): Unit

io.vertx.core.shareddata.AsyncMap

suspend fun <K, V> AsyncMap<K, V>.clearAwait(): Unit
suspend fun <K, V> AsyncMap<K, V>.getAwait(k: K): V?
suspend fun <K, V> AsyncMap<K, V>.putAwait(k: K, v: V): Unit
suspend fun <K, V> AsyncMap<K, V>.putAwait(k: K, v: V, ttl: Long): Unit
suspend fun <K, V> AsyncMap<K, V>.putIfAbsentAwait(k: K, v: V): V?
suspend fun <K, V> AsyncMap<K, V>.putIfAbsentAwait(k: K, v: V, ttl: Long): V?
suspend fun <K, V> AsyncMap<K, V>.removeAwait(k: K): V?
suspend fun <K, V> AsyncMap<K, V>.removeIfPresentAwait(k: K, v: V): Boolean
suspend fun <K, V> AsyncMap<K, V>.replaceAwait(k: K, v: V): V?
suspend fun <K, V> AsyncMap<K, V>.replaceIfPresentAwait(k: K, oldValue: V, newValue: V): Boolean
suspend fun <K, V> AsyncMap<K, V>.sizeAwait(): Int

io.vertx.core.shareddata.Counter

suspend fun Counter.addAndGetAwait(value: Long): Long
suspend fun Counter.compareAndSetAwait(expected: Long, value: Long): Boolean
suspend fun Counter.decrementAndGetAwait(): Long
suspend fun Counter.getAndAddAwait(value: Long): Long
suspend fun Counter.getAndIncrementAwait(): Long
suspend fun Counter.getAwait(): Long
suspend fun Counter.incrementAndGetAwait(): Long

io.vertx.core.shareddata.SharedData

suspend fun <K, V> SharedData.getAsyncMapAwait(name: String): AsyncMap<K, V>
suspend fun <K, V> SharedData.getClusterWideMapAwait(name: String): AsyncMap<K, V>
suspend fun SharedData.getCounterAwait(name: String): Counter
suspend fun <K, V> SharedData.getLocalAsyncMapAwait(name: String): AsyncMap<K, V>
suspend fun SharedData.getLocalCounterAwait(name: String): Counter
suspend fun SharedData.getLocalLockAwait(name: String): Lock
suspend fun SharedData.getLocalLockWithTimeoutAwait(name: String, timeout: Long): Lock
suspend fun SharedData.getLockAwait(name: String): Lock
suspend fun SharedData.getLockWithTimeoutAwait(name: String, timeout: Long): Lock

io.vertx.core.streams.Pipe

suspend fun <T> Pipe<T>.toAwait(dst: WriteStream<T>): Unit

io.vertx.core.streams.ReadStream

suspend fun <T> ReadStream<T>.pipeToAwait(dst: WriteStream<T>): Unit

io.vertx.core.streams.WriteStream

suspend fun <T> WriteStream<T>.endAwait(): Unit
suspend fun <T> WriteStream<T>.endAwait(data: T): Unit
suspend fun <T> WriteStream<T>.writeAwait(data: T): Unit

io.vertx.ext.auth.AuthProvider

suspend fun AuthProvider.authenticateAwait(authInfo: JsonObject): User

io.vertx.ext.auth.User

suspend fun User.isAuthorizedAwait(authority: String): Boolean

io.vertx.ext.auth.mongo.MongoAuth

suspend fun MongoAuth.insertUserAwait(username: String, password: String, roles: List<String>, permissions: List<String>): String

io.vertx.ext.auth.oauth2.AccessToken

suspend fun AccessToken.fetchAwait(resource: String): OAuth2Response
suspend fun AccessToken.fetchAwait(method: HttpMethod, resource: String, headers: JsonObject, payload: Buffer): OAuth2Response
suspend fun AccessToken.introspectAwait(): Unit
suspend fun AccessToken.introspectAwait(tokenType: String): Unit
suspend fun AccessToken.logoutAwait(): Unit
suspend fun AccessToken.refreshAwait(): Unit
suspend fun AccessToken.revokeAwait(token_type: String): Unit
suspend fun AccessToken.userInfoAwait(): JsonObject

io.vertx.ext.auth.oauth2.OAuth2Auth

suspend fun OAuth2Auth.decodeTokenAwait(token: String): AccessToken
suspend fun OAuth2Auth.introspectTokenAwait(token: String): AccessToken
suspend fun OAuth2Auth.introspectTokenAwait(token: String, tokenType: String): AccessToken
suspend fun OAuth2Auth.loadJWKAwait(): Unit

io.vertx.ext.auth.oauth2.OAuth2RBAC

suspend fun OAuth2RBAC.isAuthorizedAwait(user: AccessToken, authority: String): Boolean

io.vertx.ext.consul.ConsulClient

suspend fun ConsulClient.agentInfoAwait(): JsonObject
suspend fun ConsulClient.catalogDatacentersAwait(): List<String>
suspend fun ConsulClient.catalogNodeServicesAwait(node: String): ServiceList
suspend fun ConsulClient.catalogNodeServicesWithOptionsAwait(node: String, options: BlockingQueryOptions): ServiceList
suspend fun ConsulClient.catalogNodesAwait(): NodeList
suspend fun ConsulClient.catalogNodesWithOptionsAwait(options: NodeQueryOptions): NodeList
suspend fun ConsulClient.catalogServiceNodesAwait(service: String): ServiceList
suspend fun ConsulClient.catalogServiceNodesWithOptionsAwait(service: String, options: ServiceQueryOptions): ServiceList
suspend fun ConsulClient.catalogServicesAwait(): ServiceList
suspend fun ConsulClient.catalogServicesWithOptionsAwait(options: BlockingQueryOptions): ServiceList
suspend fun ConsulClient.cloneAclTokenAwait(id: String): String
suspend fun ConsulClient.coordinateDatacentersAwait(): List<DcCoordinates>
suspend fun ConsulClient.coordinateNodesAwait(): CoordinateList
suspend fun ConsulClient.coordinateNodesWithOptionsAwait(options: BlockingQueryOptions): CoordinateList
suspend fun ConsulClient.createAclTokenAwait(token: AclToken): String
suspend fun ConsulClient.createPreparedQueryAwait(definition: PreparedQueryDefinition): String
suspend fun ConsulClient.createSessionAwait(): String
suspend fun ConsulClient.createSessionWithOptionsAwait(options: SessionOptions): String
suspend fun ConsulClient.deletePreparedQueryAwait(id: String): Unit
suspend fun ConsulClient.deleteValueAwait(key: String): Unit
suspend fun ConsulClient.deleteValuesAwait(keyPrefix: String): Unit
suspend fun ConsulClient.deregisterCheckAwait(checkId: String): Unit
suspend fun ConsulClient.deregisterServiceAwait(id: String): Unit
suspend fun ConsulClient.destroyAclTokenAwait(id: String): Unit
suspend fun ConsulClient.destroySessionAwait(id: String): Unit
suspend fun ConsulClient.executePreparedQueryAwait(query: String): PreparedQueryExecuteResponse
suspend fun ConsulClient.executePreparedQueryWithOptionsAwait(query: String, options: PreparedQueryExecuteOptions): PreparedQueryExecuteResponse
suspend fun ConsulClient.failCheckAwait(checkId: String): Unit
suspend fun ConsulClient.failCheckWithNoteAwait(checkId: String, note: String): Unit
suspend fun ConsulClient.fireEventAwait(name: String): Event
suspend fun ConsulClient.fireEventWithOptionsAwait(name: String, options: EventOptions): Event
suspend fun ConsulClient.getAllPreparedQueriesAwait(): List<PreparedQueryDefinition>
suspend fun ConsulClient.getKeysAwait(keyPrefix: String): List<String>
suspend fun ConsulClient.getKeysWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): List<String>
suspend fun ConsulClient.getPreparedQueryAwait(id: String): PreparedQueryDefinition
suspend fun ConsulClient.getValueAwait(key: String): KeyValue
suspend fun ConsulClient.getValueWithOptionsAwait(key: String, options: BlockingQueryOptions): KeyValue
suspend fun ConsulClient.getValuesAwait(keyPrefix: String): KeyValueList
suspend fun ConsulClient.getValuesWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): KeyValueList
suspend fun ConsulClient.healthChecksAwait(service: String): CheckList
suspend fun ConsulClient.healthChecksWithOptionsAwait(service: String, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.healthServiceNodesAwait(service: String, passing: Boolean): ServiceEntryList
suspend fun ConsulClient.healthServiceNodesWithOptionsAwait(service: String, passing: Boolean, options: ServiceQueryOptions): ServiceEntryList
suspend fun ConsulClient.healthStateAwait(healthState: HealthState): CheckList
suspend fun ConsulClient.healthStateWithOptionsAwait(healthState: HealthState, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.infoAclTokenAwait(id: String): AclToken
suspend fun ConsulClient.infoSessionAwait(id: String): Session
suspend fun ConsulClient.infoSessionWithOptionsAwait(id: String, options: BlockingQueryOptions): Session
suspend fun ConsulClient.leaderStatusAwait(): String
suspend fun ConsulClient.listAclTokensAwait(): List<AclToken>
suspend fun ConsulClient.listEventsAwait(): EventList
suspend fun ConsulClient.listEventsWithOptionsAwait(options: EventListOptions): EventList
suspend fun ConsulClient.listNodeSessionsAwait(nodeId: String): SessionList
suspend fun ConsulClient.listNodeSessionsWithOptionsAwait(nodeId: String, options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.listSessionsAwait(): SessionList
suspend fun ConsulClient.listSessionsWithOptionsAwait(options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.localChecksAwait(): List<Check>
suspend fun ConsulClient.localServicesAwait(): List<Service>
suspend fun ConsulClient.maintenanceServiceAwait(maintenanceOptions: MaintenanceOptions): Unit
suspend fun ConsulClient.passCheckAwait(checkId: String): Unit
suspend fun ConsulClient.passCheckWithNoteAwait(checkId: String, note: String): Unit
suspend fun ConsulClient.peersStatusAwait(): List<String>
suspend fun ConsulClient.putValueAwait(key: String, value: String): Boolean
suspend fun ConsulClient.putValueWithOptionsAwait(key: String, value: String, options: KeyValueOptions): Boolean
suspend fun ConsulClient.registerCheckAwait(checkOptions: CheckOptions): Unit
suspend fun ConsulClient.registerServiceAwait(serviceOptions: ServiceOptions): Unit
suspend fun ConsulClient.renewSessionAwait(id: String): Session
suspend fun ConsulClient.transactionAwait(request: TxnRequest): TxnResponse
suspend fun ConsulClient.updateAclTokenAwait(token: AclToken): String
suspend fun ConsulClient.updateCheckAwait(checkId: String, status: CheckStatus): Unit
suspend fun ConsulClient.updateCheckWithNoteAwait(checkId: String, status: CheckStatus, note: String): Unit
suspend fun ConsulClient.updatePreparedQueryAwait(definition: PreparedQueryDefinition): Unit
suspend fun ConsulClient.warnCheckAwait(checkId: String): Unit
suspend fun ConsulClient.warnCheckWithNoteAwait(checkId: String, note: String): Unit

io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge

suspend fun TcpEventBusBridge.closeAwait(): Unit
suspend fun TcpEventBusBridge.listenAwait(): TcpEventBusBridge
suspend fun TcpEventBusBridge.listenAwait(port: Int, address: String): TcpEventBusBridge
suspend fun TcpEventBusBridge.listenAwait(port: Int): TcpEventBusBridge

io.vertx.ext.healthchecks.HealthChecks

suspend fun HealthChecks.invokeAwait(name: String): JsonObject

io.vertx.ext.jdbc.JDBCClient

suspend fun JDBCClient.querySingleAwait(sql: String): JsonArray?
suspend fun JDBCClient.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?

io.vertx.ext.mail.MailClient

suspend fun MailClient.sendMailAwait(email: MailMessage): MailResult

io.vertx.ext.mongo.MongoClient

suspend fun MongoClient.bulkWriteAwait(collection: String, operations: List<BulkOperation>): MongoClientBulkWriteResult?
suspend fun MongoClient.bulkWriteWithOptionsAwait(collection: String, operations: List<BulkOperation>, bulkWriteOptions: BulkWriteOptions): MongoClientBulkWriteResult?
suspend fun MongoClient.countAwait(collection: String, query: JsonObject): Long
suspend fun MongoClient.createCollectionAwait(collectionName: String): Unit
suspend fun MongoClient.createDefaultGridFsBucketServiceAwait(): MongoGridFsClient
suspend fun MongoClient.createGridFsBucketServiceAwait(bucketName: String): MongoGridFsClient
suspend fun MongoClient.createIndexAwait(collection: String, key: JsonObject): Unit
suspend fun MongoClient.createIndexWithOptionsAwait(collection: String, key: JsonObject, options: IndexOptions): Unit
suspend fun MongoClient.createIndexesAwait(collection: String, indexes: List<IndexModel>): Unit
suspend fun MongoClient.distinctAwait(collection: String, fieldName: String, resultClassname: String): JsonArray
suspend fun MongoClient.distinctWithQueryAwait(collection: String, fieldName: String, resultClassname: String, query: JsonObject): JsonArray
suspend fun MongoClient.dropCollectionAwait(collection: String): Unit
suspend fun MongoClient.dropIndexAwait(collection: String, indexName: String): Unit
suspend fun MongoClient.findAwait(collection: String, query: JsonObject): List<JsonObject>
suspend fun MongoClient.findOneAndDeleteAwait(collection: String, query: JsonObject): JsonObject?
suspend fun MongoClient.findOneAndDeleteWithOptionsAwait(collection: String, query: JsonObject, findOptions: FindOptions): JsonObject?
suspend fun MongoClient.findOneAndReplaceAwait(collection: String, query: JsonObject, replace: JsonObject): JsonObject?
suspend fun MongoClient.findOneAndReplaceWithOptionsAwait(collection: String, query: JsonObject, replace: JsonObject, findOptions: FindOptions, updateOptions: UpdateOptions): JsonObject?
suspend fun MongoClient.findOneAndUpdateAwait(collection: String, query: JsonObject, update: JsonObject): JsonObject?
suspend fun MongoClient.findOneAndUpdateWithOptionsAwait(collection: String, query: JsonObject, update: JsonObject, findOptions: FindOptions, updateOptions: UpdateOptions): JsonObject?
suspend fun MongoClient.findOneAwait(collection: String, query: JsonObject, fields: JsonObject): JsonObject?
suspend fun MongoClient.findWithOptionsAwait(collection: String, query: JsonObject, options: FindOptions): List<JsonObject>
suspend fun MongoClient.getCollectionsAwait(): List<String>
suspend fun MongoClient.insertAwait(collection: String, document: JsonObject): String?
suspend fun MongoClient.insertWithOptionsAwait(collection: String, document: JsonObject, writeOption: WriteOption): String?
suspend fun MongoClient.listIndexesAwait(collection: String): JsonArray
suspend fun MongoClient.removeDocumentAwait(collection: String, query: JsonObject): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentsAwait(collection: String, query: JsonObject): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentsWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption): MongoClientDeleteResult?
suspend fun MongoClient.replaceDocumentsAwait(collection: String, query: JsonObject, replace: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.replaceDocumentsWithOptionsAwait(collection: String, query: JsonObject, replace: JsonObject, options: UpdateOptions): MongoClientUpdateResult?
suspend fun MongoClient.runCommandAwait(commandName: String, command: JsonObject): JsonObject?
suspend fun MongoClient.saveAwait(collection: String, document: JsonObject): String?
suspend fun MongoClient.saveWithOptionsAwait(collection: String, document: JsonObject, writeOption: WriteOption): String?
suspend fun MongoClient.updateCollectionAwait(collection: String, query: JsonObject, update: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.updateCollectionWithOptionsAwait(collection: String, query: JsonObject, update: JsonObject, options: UpdateOptions): MongoClientUpdateResult?

io.vertx.ext.mongo.MongoGridFsClient

suspend fun MongoGridFsClient.deleteAwait(id: String): Unit
suspend fun MongoGridFsClient.downloadByFileNameAwait(stream: WriteStream<Buffer>, fileName: String): Long
suspend fun MongoGridFsClient.downloadByFileNameWithOptionsAwait(stream: WriteStream<Buffer>, fileName: String, options: GridFsDownloadOptions): Long
suspend fun MongoGridFsClient.downloadByIdAwait(stream: WriteStream<Buffer>, id: String): Long
suspend fun MongoGridFsClient.downloadFileAsAwait(fileName: String, newFileName: String): Long
suspend fun MongoGridFsClient.downloadFileAwait(fileName: String): Long
suspend fun MongoGridFsClient.downloadFileByIDAwait(id: String, fileName: String): Long
suspend fun MongoGridFsClient.dropAwait(): Unit
suspend fun MongoGridFsClient.findAllIdsAwait(): List<String>
suspend fun MongoGridFsClient.findIdsAwait(query: JsonObject): List<String>
suspend fun MongoGridFsClient.uploadByFileNameAwait(stream: ReadStream<Buffer>, fileName: String): String
suspend fun MongoGridFsClient.uploadByFileNameWithOptionsAwait(stream: ReadStream<Buffer>, fileName: String, options: GridFsUploadOptions): String
suspend fun MongoGridFsClient.uploadFileAwait(fileName: String): String
suspend fun MongoGridFsClient.uploadFileWithOptionsAwait(fileName: String, options: GridFsUploadOptions): String

io.vertx.ext.shell.ShellServer

suspend fun ShellServer.closeAwait(): Unit
suspend fun ShellServer.listenAwait(): Unit

io.vertx.ext.shell.ShellService

suspend fun ShellService.startAwait(): Unit
suspend fun ShellService.stopAwait(): Unit

io.vertx.ext.shell.command.CommandRegistry

suspend fun CommandRegistry.registerCommandAwait(command: Command): Command
suspend fun CommandRegistry.registerCommandsAwait(commands: List<Command>): List<Command>
suspend fun CommandRegistry.unregisterCommandAwait(commandName: String): Unit

io.vertx.ext.shell.term.TermServer

suspend fun TermServer.closeAwait(): Unit
suspend fun TermServer.listenAwait(): TermServer

io.vertx.ext.sql.SQLClient

suspend fun SQLClient.callAwait(sql: String): ResultSet
suspend fun SQLClient.callWithParamsAwait(sql: String, params: JsonArray, outputs: JsonArray): ResultSet
suspend fun SQLClient.closeAwait(): Unit
suspend fun SQLClient.getConnectionAwait(): SQLConnection
suspend fun SQLClient.queryAwait(sql: String): ResultSet
suspend fun SQLClient.querySingleAwait(sql: String): JsonArray?
suspend fun SQLClient.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?
suspend fun SQLClient.queryStreamAwait(sql: String): SQLRowStream
suspend fun SQLClient.queryStreamWithParamsAwait(sql: String, params: JsonArray): SQLRowStream
suspend fun SQLClient.queryWithParamsAwait(sql: String, arguments: JsonArray): ResultSet
suspend fun SQLClient.updateAwait(sql: String): UpdateResult
suspend fun SQLClient.updateWithParamsAwait(sql: String, params: JsonArray): UpdateResult

io.vertx.ext.sql.SQLConnection

suspend fun SQLConnection.batchAwait(sqlStatements: List<String>): List<Int>
suspend fun SQLConnection.batchCallableWithParamsAwait(sqlStatement: String, inArgs: List<JsonArray>, outArgs: List<JsonArray>): List<Int>
suspend fun SQLConnection.batchWithParamsAwait(sqlStatement: String, args: List<JsonArray>): List<Int>
suspend fun SQLConnection.callAwait(sql: String): ResultSet
suspend fun SQLConnection.callWithParamsAwait(sql: String, params: JsonArray, outputs: JsonArray): ResultSet
suspend fun SQLConnection.closeAwait(): Unit
suspend fun SQLConnection.commitAwait(): Unit
suspend fun SQLConnection.executeAwait(sql: String): Unit
suspend fun SQLConnection.getTransactionIsolationAwait(): TransactionIsolation
suspend fun SQLConnection.queryAwait(sql: String): ResultSet
suspend fun SQLConnection.querySingleAwait(sql: String): JsonArray?
suspend fun SQLConnection.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?
suspend fun SQLConnection.queryStreamAwait(sql: String): SQLRowStream
suspend fun SQLConnection.queryStreamWithParamsAwait(sql: String, params: JsonArray): SQLRowStream
suspend fun SQLConnection.queryWithParamsAwait(sql: String, params: JsonArray): ResultSet
suspend fun SQLConnection.rollbackAwait(): Unit
suspend fun SQLConnection.setAutoCommitAwait(autoCommit: Boolean): Unit
suspend fun SQLConnection.setTransactionIsolationAwait(isolation: TransactionIsolation): Unit
suspend fun SQLConnection.updateAwait(sql: String): UpdateResult
suspend fun SQLConnection.updateWithParamsAwait(sql: String, params: JsonArray): UpdateResult

io.vertx.ext.sql.SQLOperations

suspend fun SQLOperations.callAwait(sql: String): ResultSet
suspend fun SQLOperations.callWithParamsAwait(sql: String, params: JsonArray, outputs: JsonArray): ResultSet
suspend fun SQLOperations.queryAwait(sql: String): ResultSet
suspend fun SQLOperations.querySingleAwait(sql: String): JsonArray?
suspend fun SQLOperations.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?
suspend fun SQLOperations.queryStreamAwait(sql: String): SQLRowStream
suspend fun SQLOperations.queryStreamWithParamsAwait(sql: String, params: JsonArray): SQLRowStream
suspend fun SQLOperations.queryWithParamsAwait(sql: String, params: JsonArray): ResultSet
suspend fun SQLOperations.updateAwait(sql: String): UpdateResult
suspend fun SQLOperations.updateWithParamsAwait(sql: String, params: JsonArray): UpdateResult

io.vertx.ext.sql.SQLRowStream

suspend fun SQLRowStream.closeAwait(): Unit
suspend fun SQLRowStream.pipeToAwait(dst: WriteStream<JsonArray>): Unit

io.vertx.ext.stomp.StompClient

suspend fun StompClient.connectAwait(port: Int, host: String): StompClientConnection
suspend fun StompClient.connectAwait(net: NetClient): StompClientConnection
suspend fun StompClient.connectAwait(port: Int, host: String, net: NetClient): StompClientConnection
suspend fun StompClient.connectAwait(): StompClientConnection

io.vertx.ext.stomp.StompServer

suspend fun StompServer.closeAwait(): Unit
suspend fun StompServer.listenAwait(): StompServer
suspend fun StompServer.listenAwait(port: Int): StompServer
suspend fun StompServer.listenAwait(port: Int, host: String): StompServer

io.vertx.ext.stomp.StompServerHandler

suspend fun StompServerHandler.onAuthenticationRequestAwait(connection: StompServerConnection, login: String, passcode: String): Boolean

io.vertx.ext.unit.Async

suspend fun Async.handlerAwait(): Unit?

io.vertx.ext.unit.Completion

suspend fun <T> Completion<T>.handlerAwait(): T?

io.vertx.ext.unit.TestCompletion

suspend fun TestCompletion.handlerAwait(): Unit?

io.vertx.ext.unit.report.TestSuiteReport

suspend fun TestSuiteReport.pipeToAwait(dst: WriteStream<TestCaseReport>): Unit

io.vertx.ext.web.client.HttpRequest

suspend fun <T> HttpRequest<T>.sendAwait(): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendBufferAwait(body: Buffer): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendFormAwait(body: MultiMap): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendJsonAwait(body: Any): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendJsonObjectAwait(body: JsonObject): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendMultipartFormAwait(body: MultipartForm): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendStreamAwait(body: ReadStream<Buffer>): HttpResponse<T>

io.vertx.ext.web.common.template.TemplateEngine

suspend fun TemplateEngine.renderAwait(context: JsonObject, templateFileName: String): Buffer
suspend fun TemplateEngine.renderAwait(context: Map<String, Any>, templateFileName: String): Buffer

io.vertx.ext.web.handler.AuthHandler

suspend fun AuthHandler.authorizeAwait(user: User): Unit
suspend fun AuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.BasicAuthHandler

suspend fun BasicAuthHandler.authorizeAwait(user: User): Unit
suspend fun BasicAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.ChainAuthHandler

suspend fun ChainAuthHandler.authorizeAwait(user: User): Unit
suspend fun ChainAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.DigestAuthHandler

suspend fun DigestAuthHandler.authorizeAwait(user: User): Unit
suspend fun DigestAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.JWTAuthHandler

suspend fun JWTAuthHandler.authorizeAwait(user: User): Unit
suspend fun JWTAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.OAuth2AuthHandler

suspend fun OAuth2AuthHandler.authorizeAwait(user: User): Unit
suspend fun OAuth2AuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.RedirectAuthHandler

suspend fun RedirectAuthHandler.authorizeAwait(user: User): Unit
suspend fun RedirectAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.sockjs.SockJSSocket

suspend fun SockJSSocket.endAwait(): Unit
suspend fun SockJSSocket.endAwait(data: Buffer): Unit
suspend fun SockJSSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun SockJSSocket.writeAwait(data: String): Unit
suspend fun SockJSSocket.writeAwait(data: Buffer): Unit

io.vertx.ext.web.sstore.SessionStore

suspend fun SessionStore.clearAwait(): Unit
suspend fun SessionStore.deleteAwait(id: String): Unit
suspend fun SessionStore.getAwait(cookieValue: String): Session?
suspend fun SessionStore.putAwait(session: Session): Unit
suspend fun SessionStore.sizeAwait(): Int

io.vertx.kafka.admin.KafkaAdminClient

suspend fun KafkaAdminClient.createTopicsAwait(topics: List<NewTopic>): Unit
suspend fun KafkaAdminClient.deleteTopicsAwait(topicNames: List<String>): Unit
suspend fun KafkaAdminClient.describeConsumerGroupsAwait(groupIds: List<String>): Map<String, ConsumerGroupDescription>
suspend fun KafkaAdminClient.describeTopicsAwait(topicNames: List<String>): Map<String, TopicDescription>
suspend fun KafkaAdminClient.listConsumerGroupsAwait(): List<ConsumerGroupListing>
suspend fun KafkaAdminClient.listTopicsAwait(): Set<String>

io.vertx.kafka.client.consumer.KafkaConsumer

suspend fun <K, V> KafkaConsumer<K, V>.assignAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.assignAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.assignmentAwait(): Set<TopicPartition>
suspend fun <K, V> KafkaConsumer<K, V>.beginningOffsetsAwait(topicPartition: TopicPartition): Long
suspend fun <K, V> KafkaConsumer<K, V>.closeAwait(): Unit
suspend fun <K, V> KafkaConsumer<K, V>.commitAwait(): Unit
suspend fun <K, V> KafkaConsumer<K, V>.committedAwait(topicPartition: TopicPartition): OffsetAndMetadata
suspend fun <K, V> KafkaConsumer<K, V>.endOffsetsAwait(topicPartition: TopicPartition): Long
suspend fun <K, V> KafkaConsumer<K, V>.offsetsForTimesAwait(topicPartition: TopicPartition, timestamp: Long): OffsetAndTimestamp
suspend fun <K, V> KafkaConsumer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>
suspend fun <K, V> KafkaConsumer<K, V>.pauseAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.pauseAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.pausedAwait(): Set<TopicPartition>
suspend fun <K, V> KafkaConsumer<K, V>.pipeToAwait(dst: WriteStream<KafkaConsumerRecord<K, V>>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.pollAwait(timeout: Long): KafkaConsumerRecords<K, V>
suspend fun <K, V> KafkaConsumer<K, V>.positionAwait(partition: TopicPartition): Long
suspend fun <K, V> KafkaConsumer<K, V>.resumeAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.resumeAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekAwait(topicPartition: TopicPartition, offset: Long): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToBeginningAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToBeginningAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.subscribeAwait(topic: String): Unit
suspend fun <K, V> KafkaConsumer<K, V>.subscribeAwait(topics: Set<String>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.subscriptionAwait(): Set<String>
suspend fun <K, V> KafkaConsumer<K, V>.unsubscribeAwait(): Unit

io.vertx.kafka.client.producer.KafkaProducer

suspend fun <K, V> KafkaProducer<K, V>.closeAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.closeAwait(timeout: Long): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(data: KafkaProducerRecord<K, V>): Unit
suspend fun <K, V> KafkaProducer<K, V>.flushAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>
suspend fun <K, V> KafkaProducer<K, V>.sendAwait(record: KafkaProducerRecord<K, V>): RecordMetadata
suspend fun <K, V> KafkaProducer<K, V>.writeAwait(data: KafkaProducerRecord<K, V>): Unit

io.vertx.mqtt.MqttClient

suspend fun MqttClient.connectAwait(port: Int, host: String): MqttConnAckMessage
suspend fun MqttClient.connectAwait(port: Int, host: String, serverName: String): MqttConnAckMessage
suspend fun MqttClient.disconnectAwait(): Unit
suspend fun MqttClient.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): Int
suspend fun MqttClient.subscribeAwait(topic: String, qos: Int): Int
suspend fun MqttClient.subscribeAwait(topics: Map<String, Int>): Int
suspend fun MqttClient.unsubscribeAwait(topic: String): Int

io.vertx.mqtt.MqttEndpoint

suspend fun MqttEndpoint.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): Int
suspend fun MqttEndpoint.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean, messageId: Int): Int

io.vertx.mqtt.MqttServer

suspend fun MqttServer.closeAwait(): Unit
suspend fun MqttServer.listenAwait(port: Int, host: String): MqttServer
suspend fun MqttServer.listenAwait(port: Int): MqttServer
suspend fun MqttServer.listenAwait(): MqttServer

io.vertx.mysqlclient.MySQLConnection

suspend fun MySQLConnection.changeUserAwait(options: MySQLAuthOptions): Unit
suspend fun MySQLConnection.debugAwait(): Unit
suspend fun MySQLConnection.getInternalStatisticsAwait(): String
suspend fun MySQLConnection.pingAwait(): Unit
suspend fun MySQLConnection.prepareAwait(sql: String): PreparedQuery
suspend fun MySQLConnection.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun MySQLConnection.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun MySQLConnection.queryAwait(sql: String): RowSet<Row>
suspend fun MySQLConnection.resetConnectionAwait(): Unit
suspend fun MySQLConnection.setOptionAwait(option: MySQLSetOption): Unit
suspend fun MySQLConnection.specifySchemaAwait(schemaName: String): Unit

io.vertx.mysqlclient.MySQLPool

suspend fun MySQLPool.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun MySQLPool.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun MySQLPool.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun MySQLPool.queryAwait(sql: String): RowSet<Row>

io.vertx.pgclient.PgConnection

suspend fun PgConnection.prepareAwait(sql: String): PreparedQuery
suspend fun PgConnection.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun PgConnection.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun PgConnection.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun PgConnection.queryAwait(sql: String): RowSet<Row>

io.vertx.pgclient.PgPool

suspend fun PgPool.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun PgPool.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun PgPool.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun PgPool.queryAwait(sql: String): RowSet<Row>

io.vertx.pgclient.pubsub.PgChannel

suspend fun PgChannel.pipeToAwait(dst: WriteStream<String>): Unit

io.vertx.pgclient.pubsub.PgSubscriber

suspend fun PgSubscriber.connectAwait(): Unit

io.vertx.rabbitmq.RabbitMQClient

suspend fun RabbitMQClient.basicAckAwait(deliveryTag: Long, multiple: Boolean): JsonObject
suspend fun RabbitMQClient.basicConsumerAwait(queue: String): RabbitMQConsumer
suspend fun RabbitMQClient.basicConsumerAwait(queue: String, options: QueueOptions): RabbitMQConsumer
suspend fun RabbitMQClient.basicGetAwait(queue: String, autoAck: Boolean): JsonObject
suspend fun RabbitMQClient.basicNackAwait(deliveryTag: Long, multiple: Boolean, requeue: Boolean): JsonObject
suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, message: JsonObject): Unit
suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int): Unit
suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int, global: Boolean): Unit
suspend fun RabbitMQClient.basicQosAwait(prefetchSize: Int, prefetchCount: Int, global: Boolean): Unit
suspend fun RabbitMQClient.confirmSelectAwait(): Unit
suspend fun RabbitMQClient.exchangeBindAwait(destination: String, source: String, routingKey: String): Unit
suspend fun RabbitMQClient.exchangeDeclareAwait(exchange: String, type: String, durable: Boolean, autoDelete: Boolean): Unit
suspend fun RabbitMQClient.exchangeDeclareAwait(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, config: JsonObject): Unit
suspend fun RabbitMQClient.exchangeDeleteAwait(exchange: String): Unit
suspend fun RabbitMQClient.exchangeUnbindAwait(destination: String, source: String, routingKey: String): Unit
suspend fun RabbitMQClient.messageCountAwait(queue: String): Long
suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String): Unit
suspend fun RabbitMQClient.queueDeclareAutoAwait(): JsonObject
suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean): JsonObject
suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: JsonObject): JsonObject
suspend fun RabbitMQClient.queueDeleteAwait(queue: String): JsonObject
suspend fun RabbitMQClient.queueDeleteIfAwait(queue: String, ifUnused: Boolean, ifEmpty: Boolean): JsonObject
suspend fun RabbitMQClient.startAwait(): Unit
suspend fun RabbitMQClient.stopAwait(): Unit
suspend fun RabbitMQClient.waitForConfirmsAwait(): Unit
suspend fun RabbitMQClient.waitForConfirmsAwait(timeout: Long): Unit

io.vertx.rabbitmq.RabbitMQConsumer

suspend fun RabbitMQConsumer.cancelAwait(): Unit
suspend fun RabbitMQConsumer.pipeToAwait(dst: WriteStream<RabbitMQMessage>): Unit

io.vertx.redis.client.Redis

suspend fun Redis.connectAwait(): RedisConnection

io.vertx.redis.client.RedisAPI

suspend fun RedisAPI.appendAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.askingAwait(): Response?
suspend fun RedisAPI.authAwait(arg0: String): Response?
suspend fun RedisAPI.bgrewriteaofAwait(): Response?
suspend fun RedisAPI.bgsaveAwait(args: List<String>): Response?
suspend fun RedisAPI.bitcountAwait(args: List<String>): Response?
suspend fun RedisAPI.bitfieldAwait(args: List<String>): Response?
suspend fun RedisAPI.bitopAwait(args: List<String>): Response?
suspend fun RedisAPI.bitposAwait(args: List<String>): Response?
suspend fun RedisAPI.blpopAwait(args: List<String>): Response?
suspend fun RedisAPI.brpopAwait(args: List<String>): Response?
suspend fun RedisAPI.brpoplpushAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.bzpopmaxAwait(args: List<String>): Response?
suspend fun RedisAPI.bzpopminAwait(args: List<String>): Response?
suspend fun RedisAPI.clientAwait(args: List<String>): Response?
suspend fun RedisAPI.clusterAwait(args: List<String>): Response?
suspend fun RedisAPI.commandAwait(): Response?
suspend fun RedisAPI.configAwait(args: List<String>): Response?
suspend fun RedisAPI.dbsizeAwait(): Response?
suspend fun RedisAPI.debugAwait(args: List<String>): Response?
suspend fun RedisAPI.decrAwait(arg0: String): Response?
suspend fun RedisAPI.decrbyAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.delAwait(args: List<String>): Response?
suspend fun RedisAPI.discardAwait(): Response?
suspend fun RedisAPI.dumpAwait(arg0: String): Response?
suspend fun RedisAPI.echoAwait(arg0: String): Response?
suspend fun RedisAPI.evalAwait(args: List<String>): Response?
suspend fun RedisAPI.evalshaAwait(args: List<String>): Response?
suspend fun RedisAPI.execAwait(): Response?
suspend fun RedisAPI.existsAwait(args: List<String>): Response?
suspend fun RedisAPI.expireAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.expireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.flushallAwait(args: List<String>): Response?
suspend fun RedisAPI.flushdbAwait(args: List<String>): Response?
suspend fun RedisAPI.geoaddAwait(args: List<String>): Response?
suspend fun RedisAPI.geodistAwait(args: List<String>): Response?
suspend fun RedisAPI.geohashAwait(args: List<String>): Response?
suspend fun RedisAPI.geoposAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusRoAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusbymemberAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusbymemberRoAwait(args: List<String>): Response?
suspend fun RedisAPI.getAwait(arg0: String): Response?
suspend fun RedisAPI.getbitAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.getrangeAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.getsetAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hdelAwait(args: List<String>): Response?
suspend fun RedisAPI.hexistsAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hgetAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hgetallAwait(arg0: String): Response?
suspend fun RedisAPI.hincrbyAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.hincrbyfloatAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.hkeysAwait(arg0: String): Response?
suspend fun RedisAPI.hlenAwait(arg0: String): Response?
suspend fun RedisAPI.hmgetAwait(args: List<String>): Response?
suspend fun RedisAPI.hmsetAwait(args: List<String>): Response?
suspend fun RedisAPI.hostAwait(args: List<String>): Response?
suspend fun RedisAPI.hscanAwait(args: List<String>): Response?
suspend fun RedisAPI.hsetAwait(args: List<String>): Response?
suspend fun RedisAPI.hsetnxAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.hstrlenAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hvalsAwait(arg0: String): Response?
suspend fun RedisAPI.incrAwait(arg0: String): Response?
suspend fun RedisAPI.incrbyAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.incrbyfloatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.infoAwait(args: List<String>): Response?
suspend fun RedisAPI.keysAwait(arg0: String): Response?
suspend fun RedisAPI.lastsaveAwait(): Response?
suspend fun RedisAPI.latencyAwait(args: List<String>): Response?
suspend fun RedisAPI.lindexAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.linsertAwait(arg0: String, arg1: String, arg2: String, arg3: String): Response?
suspend fun RedisAPI.llenAwait(arg0: String): Response?
suspend fun RedisAPI.lolwutAwait(args: List<String>): Response?
suspend fun RedisAPI.lpopAwait(arg0: String): Response?
suspend fun RedisAPI.lpushAwait(args: List<String>): Response?
suspend fun RedisAPI.lpushxAwait(args: List<String>): Response?
suspend fun RedisAPI.lrangeAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.lremAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.lsetAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.ltrimAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.memoryAwait(args: List<String>): Response?
suspend fun RedisAPI.mgetAwait(args: List<String>): Response?
suspend fun RedisAPI.migrateAwait(args: List<String>): Response?
suspend fun RedisAPI.moduleAwait(args: List<String>): Response?
suspend fun RedisAPI.monitorAwait(): Response?
suspend fun RedisAPI.moveAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.msetAwait(args: List<String>): Response?
suspend fun RedisAPI.msetnxAwait(args: List<String>): Response?
suspend fun RedisAPI.multiAwait(): Response?
suspend fun RedisAPI.objectAwait(args: List<String>): Response?
suspend fun RedisAPI.persistAwait(arg0: String): Response?
suspend fun RedisAPI.pexpireAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pexpireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pfaddAwait(args: List<String>): Response?
suspend fun RedisAPI.pfcountAwait(args: List<String>): Response?
suspend fun RedisAPI.pfdebugAwait(args: List<String>): Response?
suspend fun RedisAPI.pfmergeAwait(args: List<String>): Response?
suspend fun RedisAPI.pfselftestAwait(): Response?
suspend fun RedisAPI.pingAwait(args: List<String>): Response?
suspend fun RedisAPI.postAwait(args: List<String>): Response?
suspend fun RedisAPI.psetexAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.psubscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.psyncAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pttlAwait(arg0: String): Response?
suspend fun RedisAPI.publishAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pubsubAwait(args: List<String>): Response?
suspend fun RedisAPI.punsubscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.randomkeyAwait(): Response?
suspend fun RedisAPI.readonlyAwait(): Response?
suspend fun RedisAPI.readwriteAwait(): Response?
suspend fun RedisAPI.renameAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.renamenxAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.replconfAwait(args: List<String>): Response?
suspend fun RedisAPI.replicaofAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.restoreAskingAwait(args: List<String>): Response?
suspend fun RedisAPI.restoreAwait(args: List<String>): Response?
suspend fun RedisAPI.roleAwait(): Response?
suspend fun RedisAPI.rpopAwait(arg0: String): Response?
suspend fun RedisAPI.rpoplpushAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.rpushAwait(args: List<String>): Response?
suspend fun RedisAPI.rpushxAwait(args: List<String>): Response?
suspend fun RedisAPI.saddAwait(args: List<String>): Response?
suspend fun RedisAPI.saveAwait(): Response?
suspend fun RedisAPI.scanAwait(args: List<String>): Response?
suspend fun RedisAPI.scardAwait(arg0: String): Response?
suspend fun RedisAPI.scriptAwait(args: List<String>): Response?
suspend fun RedisAPI.sdiffAwait(args: List<String>): Response?
suspend fun RedisAPI.sdiffstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.selectAwait(arg0: String): Response?
suspend fun RedisAPI.setAwait(args: List<String>): Response?
suspend fun RedisAPI.setbitAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.setexAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.setnxAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.setrangeAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.shutdownAwait(args: List<String>): Response?
suspend fun RedisAPI.sinterAwait(args: List<String>): Response?
suspend fun RedisAPI.sinterstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.sismemberAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.slaveofAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.slowlogAwait(args: List<String>): Response?
suspend fun RedisAPI.smembersAwait(arg0: String): Response?
suspend fun RedisAPI.smoveAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.sortAwait(args: List<String>): Response?
suspend fun RedisAPI.spopAwait(args: List<String>): Response?
suspend fun RedisAPI.srandmemberAwait(args: List<String>): Response?
suspend fun RedisAPI.sremAwait(args: List<String>): Response?
suspend fun RedisAPI.sscanAwait(args: List<String>): Response?
suspend fun RedisAPI.strlenAwait(arg0: String): Response?
suspend fun RedisAPI.subscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.substrAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.sunionAwait(args: List<String>): Response?
suspend fun RedisAPI.sunionstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.swapdbAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.syncAwait(): Response?
suspend fun RedisAPI.timeAwait(): Response?
suspend fun RedisAPI.touchAwait(args: List<String>): Response?
suspend fun RedisAPI.ttlAwait(arg0: String): Response?
suspend fun RedisAPI.typeAwait(arg0: String): Response?
suspend fun RedisAPI.unlinkAwait(args: List<String>): Response?
suspend fun RedisAPI.unsubscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.unwatchAwait(): Response?
suspend fun RedisAPI.waitAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.watchAwait(args: List<String>): Response?
suspend fun RedisAPI.xackAwait(args: List<String>): Response?
suspend fun RedisAPI.xaddAwait(args: List<String>): Response?
suspend fun RedisAPI.xclaimAwait(args: List<String>): Response?
suspend fun RedisAPI.xdelAwait(args: List<String>): Response?
suspend fun RedisAPI.xgroupAwait(args: List<String>): Response?
suspend fun RedisAPI.xinfoAwait(args: List<String>): Response?
suspend fun RedisAPI.xlenAwait(arg0: String): Response?
suspend fun RedisAPI.xpendingAwait(args: List<String>): Response?
suspend fun RedisAPI.xrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.xreadAwait(args: List<String>): Response?
suspend fun RedisAPI.xreadgroupAwait(args: List<String>): Response?
suspend fun RedisAPI.xrevrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.xsetidAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.xtrimAwait(args: List<String>): Response?
suspend fun RedisAPI.zaddAwait(args: List<String>): Response?
suspend fun RedisAPI.zcardAwait(arg0: String): Response?
suspend fun RedisAPI.zcountAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zincrbyAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zinterstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.zlexcountAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zpopmaxAwait(args: List<String>): Response?
suspend fun RedisAPI.zpopminAwait(args: List<String>): Response?
suspend fun RedisAPI.zrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.zrangebylexAwait(args: List<String>): Response?
suspend fun RedisAPI.zrangebyscoreAwait(args: List<String>): Response?
suspend fun RedisAPI.zrankAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.zremAwait(args: List<String>): Response?
suspend fun RedisAPI.zremrangebylexAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zremrangebyrankAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zremrangebyscoreAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zrevrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.zrevrangebylexAwait(args: List<String>): Response?
suspend fun RedisAPI.zrevrangebyscoreAwait(args: List<String>): Response?
suspend fun RedisAPI.zrevrankAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.zscanAwait(args: List<String>): Response?
suspend fun RedisAPI.zscoreAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.zunionstoreAwait(args: List<String>): Response?

io.vertx.redis.client.RedisConnection

suspend fun RedisConnection.batchAwait(commands: List<Request>): List<Response>
suspend fun RedisConnection.pipeToAwait(dst: WriteStream<Response>): Unit
suspend fun RedisConnection.sendAwait(command: Request): Response?

io.vertx.servicediscovery.ServiceDiscovery

suspend fun ServiceDiscovery.getRecordAwait(filter: JsonObject): Record?
suspend fun ServiceDiscovery.getRecordAwait(filter: (Record) -> Boolean): Record?
suspend fun ServiceDiscovery.getRecordAwait(filter: (Record) -> Boolean, includeOutOfService: Boolean): Record?
suspend fun ServiceDiscovery.getRecordsAwait(filter: JsonObject): List<Record>
suspend fun ServiceDiscovery.getRecordsAwait(filter: (Record) -> Boolean): List<Record>
suspend fun ServiceDiscovery.getRecordsAwait(filter: (Record) -> Boolean, includeOutOfService: Boolean): List<Record>
suspend fun ServiceDiscovery.publishAwait(record: Record): Record
suspend fun ServiceDiscovery.registerServiceExporterAwait(exporter: ServiceExporter, configuration: JsonObject): Unit
suspend fun ServiceDiscovery.registerServiceImporterAwait(importer: ServiceImporter, configuration: JsonObject): Unit
suspend fun ServiceDiscovery.unpublishAwait(id: String): Unit
suspend fun ServiceDiscovery.updateAwait(record: Record): Record

io.vertx.servicediscovery.spi.ServicePublisher

suspend fun ServicePublisher.publishAwait(record: Record): Record
suspend fun ServicePublisher.unpublishAwait(id: String): Unit
suspend fun ServicePublisher.updateAwait(record: Record): Record

io.vertx.sqlclient.Cursor

suspend fun Cursor.closeAwait(): Unit
suspend fun Cursor.readAwait(count: Int): RowSet<Row>

io.vertx.sqlclient.Pool

suspend fun Pool.beginAwait(): Transaction
suspend fun Pool.getConnectionAwait(): SqlConnection
suspend fun Pool.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun Pool.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun Pool.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun Pool.queryAwait(sql: String): RowSet<Row>

io.vertx.sqlclient.PreparedQuery

suspend fun PreparedQuery.batchAwait(argsList: List<Tuple>): RowSet<Row>
suspend fun PreparedQuery.closeAwait(): Unit
suspend fun PreparedQuery.executeAwait(): RowSet<Row>
suspend fun PreparedQuery.executeAwait(args: Tuple): RowSet<Row>

io.vertx.sqlclient.RowStream

suspend fun <T> RowStream<T>.closeAwait(): Unit
suspend fun <T> RowStream<T>.pipeToAwait(dst: WriteStream<T>): Unit

io.vertx.sqlclient.SqlClient

suspend fun SqlClient.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun SqlClient.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun SqlClient.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun SqlClient.queryAwait(sql: String): RowSet<Row>

io.vertx.sqlclient.SqlConnection

suspend fun SqlConnection.prepareAwait(sql: String): PreparedQuery
suspend fun SqlConnection.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun SqlConnection.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun SqlConnection.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun SqlConnection.queryAwait(sql: String): RowSet<Row>

io.vertx.sqlclient.Transaction

suspend fun Transaction.commitAwait(): Unit
suspend fun Transaction.prepareAwait(sql: String): PreparedQuery
suspend fun Transaction.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun Transaction.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun Transaction.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun Transaction.queryAwait(sql: String): RowSet<Row>
suspend fun Transaction.rollbackAwait(): Unit

package io.vertx.kotlin.amqp

fun amqpClientOptionsOf(connectTimeout: Int? = null, containerId: String? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSaslMechanisms: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, heartbeat: Int? = null, host: String? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxFrameSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, password: String? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sniServerName: String? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, username: String? = null, virtualHost: String? = null): AmqpClientOptions
fun amqpReceiverOptionsOf(autoAcknowledgement: Boolean? = null, capabilities: Iterable<String>? = null, capabilitys: Iterable<String>? = null, durable: Boolean? = null, dynamic: Boolean? = null, linkName: String? = null, maxBufferedMessages: Int? = null, qos: String? = null): AmqpReceiverOptions
fun amqpSenderOptionsOf(autoDrained: Boolean? = null, dynamic: Boolean? = null, linkName: String? = null): AmqpSenderOptions
io.vertx.amqp.AmqpClient

suspend fun AmqpClient.closeAwait(): Unit
suspend fun AmqpClient.connectAwait(): AmqpConnection
suspend fun AmqpClient.createReceiverAwait(address: String): AmqpReceiver
suspend fun AmqpClient.createReceiverAwait(address: String, receiverOptions: AmqpReceiverOptions): AmqpReceiver
suspend fun AmqpClient.createSenderAwait(address: String): AmqpSender
suspend fun AmqpClient.createSenderAwait(address: String, options: AmqpSenderOptions): AmqpSender

io.vertx.amqp.AmqpConnection

suspend fun AmqpConnection.closeAwait(): Unit
suspend fun AmqpConnection.createAnonymousSenderAwait(): AmqpSender
suspend fun AmqpConnection.createDynamicReceiverAwait(): AmqpReceiver
suspend fun AmqpConnection.createReceiverAwait(address: String): AmqpReceiver
suspend fun AmqpConnection.createReceiverAwait(address: String, receiverOptions: AmqpReceiverOptions): AmqpReceiver
suspend fun AmqpConnection.createSenderAwait(address: String): AmqpSender
suspend fun AmqpConnection.createSenderAwait(address: String, options: AmqpSenderOptions): AmqpSender

io.vertx.amqp.AmqpReceiver

suspend fun AmqpReceiver.closeAwait(): Unit
suspend fun AmqpReceiver.pipeToAwait(dst: WriteStream<AmqpMessage>): Unit

io.vertx.amqp.AmqpSender

suspend fun AmqpSender.closeAwait(): Unit
suspend fun AmqpSender.endAwait(): Unit
suspend fun AmqpSender.endAwait(data: AmqpMessage): Unit
suspend fun AmqpSender.sendWithAckAwait(message: AmqpMessage): Unit
suspend fun AmqpSender.writeAwait(data: AmqpMessage): Unit

package io.vertx.kotlin.cassandra

fun cassandraClientOptionsOf(contactPoints: Iterable<String>? = null, keyspace: String? = null, port: Int? = null): CassandraClientOptions
io.vertx.cassandra.CassandraClient

suspend fun CassandraClient.closeAwait(): Unit
suspend fun CassandraClient.executeAwait(query: String): ResultSet
suspend fun CassandraClient.executeAwait(statement: Statement): ResultSet
suspend fun CassandraClient.executeWithFullFetchAwait(query: String): List<Row>
suspend fun CassandraClient.executeWithFullFetchAwait(statement: Statement): List<Row>
suspend fun CassandraClient.prepareAwait(query: String): PreparedStatement
suspend fun CassandraClient.queryStreamAwait(sql: String): CassandraRowStream
suspend fun CassandraClient.queryStreamAwait(statement: Statement): CassandraRowStream

io.vertx.cassandra.CassandraRowStream

suspend fun CassandraRowStream.pipeToAwait(dst: WriteStream<Row>): Unit

io.vertx.cassandra.Mapper

suspend fun <T> Mapper<T>.deleteAwait(primaryKey: List<Any>): Unit
suspend fun <T> Mapper<T>.getAwait(primaryKey: List<Any>): T
suspend fun <T> Mapper<T>.saveAwait(entity: T): Unit

io.vertx.cassandra.ResultSet

suspend fun ResultSet.allAwait(): List<Row>
suspend fun ResultSet.fetchMoreResultsAwait(): Unit
suspend fun ResultSet.oneAwait(): Row?
suspend fun ResultSet.severalAwait(amount: Int): List<Row>

package io.vertx.kotlin.circuitbreaker

fun circuitBreakerOptionsOf(failuresRollingWindow: Long? = null, fallbackOnFailure: Boolean? = null, maxFailures: Int? = null, maxRetries: Int? = null, metricsRollingBuckets: Int? = null, metricsRollingWindow: Long? = null, notificationAddress: String? = null, notificationPeriod: Long? = null, resetTimeout: Long? = null, timeout: Long? = null): CircuitBreakerOptions
io.vertx.circuitbreaker.CircuitBreaker

suspend fun <T> CircuitBreaker.executeAwait(command: (Promise<T>) -> Unit): T
suspend fun <T> CircuitBreaker.executeWithFallbackAwait(command: (Promise<T>) -> Unit, fallback: (Throwable) -> T): T

package io.vertx.kotlin.config

fun configChangeOf(newConfiguration: JsonObject? = null, previousConfiguration: JsonObject? = null): ConfigChange
fun configRetrieverOptionsOf(includeDefaultStores: Boolean? = null, scanPeriod: Long? = null, stores: Iterable<ConfigStoreOptions>? = null): ConfigRetrieverOptions
fun configStoreOptionsOf(config: JsonObject? = null, format: String? = null, optional: Boolean? = null, type: String? = null): ConfigStoreOptions
io.vertx.config.ConfigRetriever

suspend fun ConfigRetriever.getConfigAwait(): JsonObject

package io.vertx.kotlin.core

object Vertx

suspend fun clusteredVertxAwait(options: VertxOptions): Vertx

fun deploymentOptionsOf(config: JsonObject? = null, extraClasspath: Iterable<String>? = null, ha: Boolean? = null, instances: Int? = null, isolatedClasses: Iterable<String>? = null, isolationGroup: String? = null, maxWorkerExecuteTime: Long? = null, maxWorkerExecuteTimeUnit: TimeUnit? = null, worker: Boolean? = null, workerPoolName: String? = null, workerPoolSize: Int? = null): DeploymentOptions
io.vertx.core.CompositeFuture

suspend fun CompositeFuture.setHandlerAwait(): CompositeFuture

io.vertx.core.Context

suspend fun <T> Context.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit, ordered: Boolean): T?
suspend fun <T> Context.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit): T?

io.vertx.core.Future

suspend fun <T> Future<T>.setHandlerAwait(): T

io.vertx.core.TimeoutStream

suspend fun TimeoutStream.pipeToAwait(dst: WriteStream<Long>): Unit

io.vertx.core.Vertx

suspend fun Vertx.closeAwait(): Unit
suspend fun Vertx.deployVerticleAwait(name: String): String
suspend fun Vertx.deployVerticleAwait(name: String, options: DeploymentOptions): String
suspend fun Vertx.deployVerticleAwait(verticle: Verticle): String
suspend fun Vertx.deployVerticleAwait(verticle: Verticle, options: DeploymentOptions): String
suspend fun Vertx.deployVerticleAwait(verticleSupplier: Supplier<Verticle>, options: DeploymentOptions): String
suspend fun <T> Vertx.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit, ordered: Boolean): T?
suspend fun <T> Vertx.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit): T?
suspend fun Vertx.undeployAwait(deploymentID: String): Unit

io.vertx.core.WorkerExecutor

suspend fun <T> WorkerExecutor.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit, ordered: Boolean): T?
suspend fun <T> WorkerExecutor.executeBlockingAwait(blockingCodeHandler: (Promise<T>) -> Unit): T?

fun vertxOptionsOf(addressResolverOptions: AddressResolverOptions? = null, blockedThreadCheckInterval: Long? = null, blockedThreadCheckIntervalUnit: TimeUnit? = null, clusterHost: String? = null, clusterPingInterval: Long? = null, clusterPingReplyInterval: Long? = null, clusterPort: Int? = null, clusterPublicHost: String? = null, clusterPublicPort: Int? = null, clustered: Boolean? = null, eventBusOptions: EventBusOptions? = null, eventLoopPoolSize: Int? = null, fileSystemOptions: FileSystemOptions? = null, haEnabled: Boolean? = null, haGroup: String? = null, internalBlockingPoolSize: Int? = null, maxEventLoopExecuteTime: Long? = null, maxEventLoopExecuteTimeUnit: TimeUnit? = null, maxWorkerExecuteTime: Long? = null, maxWorkerExecuteTimeUnit: TimeUnit? = null, metricsOptions: MetricsOptions? = null, preferNativeTransport: Boolean? = null, quorumSize: Int? = null, tracingOptions: TracingOptions? = null, warningExceptionTime: Long? = null, warningExceptionTimeUnit: TimeUnit? = null, workerPoolSize: Int? = null): VertxOptions

package io.vertx.kotlin.core.buffer

io.vertx.core.buffer.Buffer

inline fun Buffer.appendJson(pretty: Boolean = false, block: Json.() -> Any): Buffer

package io.vertx.kotlin.core.cli

fun argumentOf(argName: String? = null, defaultValue: String? = null, description: String? = null, hidden: Boolean? = null, index: Int? = null, multiValued: Boolean? = null, required: Boolean? = null): Argument
fun optionOf(argName: String? = null, choices: Iterable<String>? = null, defaultValue: String? = null, description: String? = null, flag: Boolean? = null, help: Boolean? = null, hidden: Boolean? = null, longName: String? = null, multiValued: Boolean? = null, required: Boolean? = null, shortName: String? = null, singleValued: Boolean? = null): Option

package io.vertx.kotlin.core.datagram

fun datagramSocketOptionsOf(broadcast: Boolean? = null, ipV6: Boolean? = null, logActivity: Boolean? = null, loopbackModeDisabled: Boolean? = null, multicastNetworkInterface: String? = null, multicastTimeToLive: Int? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, trafficClass: Int? = null): DatagramSocketOptions
io.vertx.core.datagram.DatagramSocket

suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, networkInterface: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.closeAwait(): Unit
suspend fun DatagramSocket.listenAwait(port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String): Unit
suspend fun DatagramSocket.pipeToAwait(dst: WriteStream<DatagramPacket>): Unit
suspend fun DatagramSocket.sendAwait(packet: Buffer, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, enc: String, port: Int, host: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String): Unit

package io.vertx.kotlin.core.dns

fun addressResolverOptionsOf(cacheMaxTimeToLive: Int? = null, cacheMinTimeToLive: Int? = null, cacheNegativeTimeToLive: Int? = null, hostsPath: String? = null, hostsValue: Buffer? = null, maxQueries: Int? = null, ndots: Int? = null, optResourceEnabled: Boolean? = null, queryTimeout: Long? = null, rdFlag: Boolean? = null, rotateServers: Boolean? = null, searchDomains: Iterable<String>? = null, servers: Iterable<String>? = null): AddressResolverOptions
fun dnsClientOptionsOf(host: String? = null, logActivity: Boolean? = null, port: Int? = null, queryTimeout: Long? = null, recursionDesired: Boolean? = null): DnsClientOptions
io.vertx.core.dns.DnsClient

suspend fun DnsClient.lookup4Await(name: String): String?
suspend fun DnsClient.lookup6Await(name: String): String?
suspend fun DnsClient.lookupAwait(name: String): String?
suspend fun DnsClient.resolveAAAAAwait(name: String): List<String>
suspend fun DnsClient.resolveAAwait(name: String): List<String>
suspend fun DnsClient.resolveCNAMEAwait(name: String): List<String>
suspend fun DnsClient.resolveMXAwait(name: String): List<MxRecord>
suspend fun DnsClient.resolveNSAwait(name: String): List<String>
suspend fun DnsClient.resolvePTRAwait(name: String): String?
suspend fun DnsClient.resolveSRVAwait(name: String): List<SrvRecord>
suspend fun DnsClient.resolveTXTAwait(name: String): List<String>
suspend fun DnsClient.reverseLookupAwait(ipaddress: String): String?

package io.vertx.kotlin.core.eventbus

fun deliveryOptionsOf(codecName: String? = null, headers: Map<String, String>? = null, localOnly: Boolean? = null, sendTimeout: Long? = null): DeliveryOptions
fun eventBusOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, clusterPingInterval: Long? = null, clusterPingReplyInterval: Long? = null, clusterPublicHost: String? = null, clusterPublicPort: Int? = null, clustered: Boolean? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null): EventBusOptions
io.vertx.core.eventbus.EventBus

suspend fun <T> EventBus.requestAwait(address: String, message: Any): Message<T>
suspend fun <T> EventBus.requestAwait(address: String, message: Any, options: DeliveryOptions): Message<T>

io.vertx.core.eventbus.Message

suspend fun <R, T> Message<T>.replyAndRequestAwait(message: Any): Message<R>
suspend fun <R, T> Message<T>.replyAndRequestAwait(message: Any, options: DeliveryOptions): Message<R>

io.vertx.core.eventbus.MessageConsumer

suspend fun <T> MessageConsumer<T>.completionHandlerAwait(): Unit
suspend fun <T> MessageConsumer<T>.pipeToAwait(dst: WriteStream<Message<T>>): Unit
suspend fun <T> MessageConsumer<T>.unregisterAwait(): Unit

io.vertx.core.eventbus.MessageProducer

suspend fun <T> MessageProducer<T>.closeAwait(): Unit
suspend fun <T> MessageProducer<T>.endAwait(data: T): Unit
suspend fun <T> MessageProducer<T>.endAwait(): Unit
suspend fun <T> MessageProducer<T>.writeAwait(data: T): Unit

package io.vertx.kotlin.core.file

fun copyOptionsOf(atomicMove: Boolean? = null, copyAttributes: Boolean? = null, nofollowLinks: Boolean? = null, replaceExisting: Boolean? = null): CopyOptions
fun fileSystemOptionsOf(classPathResolvingEnabled: Boolean? = null, fileCacheDir: String? = null, fileCachingEnabled: Boolean? = null): FileSystemOptions
io.vertx.core.file.AsyncFile

suspend fun AsyncFile.closeAwait(): Unit
suspend fun AsyncFile.endAwait(): Unit
suspend fun AsyncFile.endAwait(data: Buffer): Unit
suspend fun AsyncFile.flushAwait(): Unit
suspend fun AsyncFile.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun AsyncFile.readAwait(buffer: Buffer, offset: Int, position: Long, length: Int): Buffer
suspend fun AsyncFile.writeAwait(data: Buffer): Unit
suspend fun AsyncFile.writeAwait(buffer: Buffer, position: Long): Unit

io.vertx.core.file.FileSystem

suspend fun FileSystem.chmodAwait(path: String, perms: String): Unit
suspend fun FileSystem.chmodRecursiveAwait(path: String, perms: String, dirPerms: String): Unit
suspend fun FileSystem.chownAwait(path: String, user: String, group: String): Unit
suspend fun FileSystem.copyAwait(from: String, to: String): Unit
suspend fun FileSystem.copyAwait(from: String, to: String, options: CopyOptions): Unit
suspend fun FileSystem.copyRecursiveAwait(from: String, to: String, recursive: Boolean): Unit
suspend fun FileSystem.createFileAwait(path: String): Unit
suspend fun FileSystem.createFileAwait(path: String, perms: String): Unit
suspend fun FileSystem.createTempDirectoryAwait(prefix: String): String
suspend fun FileSystem.createTempDirectoryAwait(prefix: String, perms: String): String
suspend fun FileSystem.createTempDirectoryAwait(dir: String, prefix: String, perms: String): String
suspend fun FileSystem.createTempFileAwait(prefix: String, suffix: String): String
suspend fun FileSystem.createTempFileAwait(prefix: String, suffix: String, perms: String): String
suspend fun FileSystem.createTempFileAwait(dir: String, prefix: String, suffix: String, perms: String): String
suspend fun FileSystem.deleteAwait(path: String): Unit
suspend fun FileSystem.deleteRecursiveAwait(path: String, recursive: Boolean): Unit
suspend fun FileSystem.existsAwait(path: String): Boolean
suspend fun FileSystem.fsPropsAwait(path: String): FileSystemProps
suspend fun FileSystem.linkAwait(link: String, existing: String): Unit
suspend fun FileSystem.lpropsAwait(path: String): FileProps
suspend fun FileSystem.mkdirAwait(path: String): Unit
suspend fun FileSystem.mkdirAwait(path: String, perms: String): Unit
suspend fun FileSystem.mkdirsAwait(path: String): Unit
suspend fun FileSystem.mkdirsAwait(path: String, perms: String): Unit
suspend fun FileSystem.moveAwait(from: String, to: String): Unit
suspend fun FileSystem.moveAwait(from: String, to: String, options: CopyOptions): Unit
suspend fun FileSystem.openAwait(path: String, options: OpenOptions): AsyncFile
suspend fun FileSystem.propsAwait(path: String): FileProps
suspend fun FileSystem.readDirAwait(path: String): List<String>
suspend fun FileSystem.readDirAwait(path: String, filter: String): List<String>
suspend fun FileSystem.readFileAwait(path: String): Buffer
suspend fun FileSystem.readSymlinkAwait(link: String): String
suspend fun FileSystem.symlinkAwait(link: String, existing: String): Unit
suspend fun FileSystem.truncateAwait(path: String, len: Long): Unit
suspend fun FileSystem.unlinkAwait(link: String): Unit
suspend fun FileSystem.writeFileAwait(path: String, data: Buffer): Unit

fun openOptionsOf(append: Boolean? = null, create: Boolean? = null, createNew: Boolean? = null, deleteOnClose: Boolean? = null, dsync: Boolean? = null, perms: String? = null, read: Boolean? = null, sparse: Boolean? = null, sync: Boolean? = null, truncateExisting: Boolean? = null, write: Boolean? = null): OpenOptions

package io.vertx.kotlin.core.http

fun goAwayOf(debugData: Buffer? = null, errorCode: Long? = null, lastStreamId: Int? = null): GoAway
fun http2SettingsOf(headerTableSize: Long? = null, initialWindowSize: Int? = null, maxConcurrentStreams: Long? = null, maxFrameSize: Int? = null, maxHeaderListSize: Long? = null, pushEnabled: Boolean? = null): Http2Settings
fun httpClientOptionsOf(alpnVersions: Iterable<HttpVersion>? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, decoderInitialBufferSize: Int? = null, defaultHost: String? = null, defaultPort: Int? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, forceSni: Boolean? = null, http2ClearTextUpgrade: Boolean? = null, http2ConnectionWindowSize: Int? = null, http2KeepAliveTimeout: Int? = null, http2MaxPoolSize: Int? = null, http2MultiplexingLimit: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keepAlive: Boolean? = null, keepAliveTimeout: Int? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxPoolSize: Int? = null, maxRedirects: Int? = null, maxWaitQueueSize: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = null, pipeliningLimit: Int? = null, poolCleanerPeriod: Int? = null, protocolVersion: HttpVersion? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sendUnmaskedFrames: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, verifyHost: Boolean? = null, websocketCompressionAllowClientNoContext: Boolean? = null, websocketCompressionLevel: Int? = null, websocketCompressionRequestServerNoContext: Boolean? = null): HttpClientOptions
fun httpServerOptionsOf(acceptBacklog: Int? = null, acceptUnmaskedFrames: Boolean? = null, alpnVersions: Iterable<HttpVersion>? = null, clientAuth: ClientAuth? = null, compressionLevel: Int? = null, compressionSupported: Boolean? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, decoderInitialBufferSize: Int? = null, decompressionSupported: Boolean? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, handle100ContinueAutomatically: Boolean? = null, host: String? = null, http2ConnectionWindowSize: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, perFrameWebsocketCompressionSupported: Boolean? = null, perMessageWebsocketCompressionSupported: Boolean? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, websocketAllowServerNoContext: Boolean? = null, websocketCompressionLevel: Int? = null, websocketPreferredClientNoContext: Boolean? = null, websocketSubProtocols: String? = null): HttpServerOptions
io.vertx.core.http.HttpClient

suspend fun HttpClient.getNowAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.getNowAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getNowAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getNowAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.headNowAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.headNowAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headNowAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headNowAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsNowAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.webSocketAbsAwait(url: String, headers: MultiMap, version: WebsocketVersion, subProtocols: List<String>): WebSocket
suspend fun HttpClient.webSocketAwait(port: Int, host: String, requestURI: String): WebSocket
suspend fun HttpClient.webSocketAwait(host: String, requestURI: String): WebSocket
suspend fun HttpClient.webSocketAwait(requestURI: String): WebSocket
suspend fun HttpClient.webSocketAwait(options: WebSocketConnectOptions): WebSocket

io.vertx.core.http.HttpClientRequest

suspend fun HttpClientRequest.endAwait(chunk: String): Unit
suspend fun HttpClientRequest.endAwait(chunk: String, enc: String): Unit
suspend fun HttpClientRequest.endAwait(chunk: Buffer): Unit
suspend fun HttpClientRequest.endAwait(): Unit
suspend fun HttpClientRequest.setHandlerAwait(): HttpClientResponse
suspend fun HttpClientRequest.writeAwait(data: Buffer): Unit
suspend fun HttpClientRequest.writeAwait(chunk: String): Unit
suspend fun HttpClientRequest.writeAwait(chunk: String, enc: String): Unit

io.vertx.core.http.HttpClientResponse

suspend fun HttpClientResponse.bodyAwait(): Buffer
suspend fun HttpClientResponse.pipeToAwait(dst: WriteStream<Buffer>): Unit

io.vertx.core.http.HttpConnection

suspend fun HttpConnection.pingAwait(data: Buffer): Buffer
suspend fun HttpConnection.updateSettingsAwait(settings: Http2Settings): Unit

io.vertx.core.http.HttpServer

suspend fun HttpServer.closeAwait(): Unit
suspend fun HttpServer.listenAwait(port: Int, host: String): HttpServer
suspend fun HttpServer.listenAwait(address: SocketAddress): HttpServer
suspend fun HttpServer.listenAwait(port: Int): HttpServer
suspend fun HttpServer.listenAwait(): HttpServer

io.vertx.core.http.HttpServerFileUpload

suspend fun HttpServerFileUpload.pipeToAwait(dst: WriteStream<Buffer>): Unit

io.vertx.core.http.HttpServerRequest

suspend fun HttpServerRequest.pipeToAwait(dst: WriteStream<Buffer>): Unit

io.vertx.core.http.HttpServerResponse

suspend fun HttpServerResponse.endAwait(): Unit
suspend fun HttpServerResponse.endAwait(chunk: String): Unit
suspend fun HttpServerResponse.endAwait(chunk: String, enc: String): Unit
suspend fun HttpServerResponse.endAwait(chunk: Buffer): Unit
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, host: String, path: String): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, path: String, headers: MultiMap): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, path: String): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, host: String, path: String, headers: MultiMap): HttpServerResponse
suspend fun HttpServerResponse.sendFileAwait(filename: String): Unit
suspend fun HttpServerResponse.sendFileAwait(filename: String, offset: Long): Unit
suspend fun HttpServerResponse.sendFileAwait(filename: String, offset: Long, length: Long): Unit
suspend fun HttpServerResponse.writeAwait(data: Buffer): Unit
suspend fun HttpServerResponse.writeAwait(chunk: String, enc: String): Unit
suspend fun HttpServerResponse.writeAwait(chunk: String): Unit

io.vertx.core.http.ServerWebSocket

suspend fun ServerWebSocket.closeAwait(): Unit
suspend fun ServerWebSocket.closeAwait(statusCode: Short): Unit
suspend fun ServerWebSocket.closeAwait(statusCode: Short, reason: String): Unit
suspend fun ServerWebSocket.endAwait(data: Buffer): Unit
suspend fun ServerWebSocket.endAwait(): Unit
suspend fun ServerWebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun ServerWebSocket.writeAwait(data: Buffer): Unit
suspend fun ServerWebSocket.writeBinaryMessageAwait(data: Buffer): Unit
suspend fun ServerWebSocket.writeFinalBinaryFrameAwait(data: Buffer): Unit
suspend fun ServerWebSocket.writeFinalTextFrameAwait(text: String): Unit
suspend fun ServerWebSocket.writeFrameAwait(frame: WebSocketFrame): Unit
suspend fun ServerWebSocket.writeTextMessageAwait(text: String): Unit

io.vertx.core.http.WebSocket

suspend fun WebSocket.closeAwait(): Unit
suspend fun WebSocket.closeAwait(statusCode: Short): Unit
suspend fun WebSocket.closeAwait(statusCode: Short, reason: String): Unit
suspend fun WebSocket.endAwait(data: Buffer): Unit
suspend fun WebSocket.endAwait(): Unit
suspend fun WebSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun WebSocket.writeAwait(data: Buffer): Unit
suspend fun WebSocket.writeBinaryMessageAwait(data: Buffer): Unit
suspend fun WebSocket.writeFinalBinaryFrameAwait(data: Buffer): Unit
suspend fun WebSocket.writeFinalTextFrameAwait(text: String): Unit
suspend fun WebSocket.writeFrameAwait(frame: WebSocketFrame): Unit
suspend fun WebSocket.writeTextMessageAwait(text: String): Unit

io.vertx.core.http.WebSocketBase

suspend fun WebSocketBase.closeAwait(): Unit
suspend fun WebSocketBase.closeAwait(statusCode: Short): Unit
suspend fun WebSocketBase.closeAwait(statusCode: Short, reason: String): Unit
suspend fun WebSocketBase.endAwait(data: Buffer): Unit
suspend fun WebSocketBase.endAwait(): Unit
suspend fun WebSocketBase.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun WebSocketBase.writeAwait(data: Buffer): Unit
suspend fun WebSocketBase.writeBinaryMessageAwait(data: Buffer): Unit
suspend fun WebSocketBase.writeFinalBinaryFrameAwait(data: Buffer): Unit
suspend fun WebSocketBase.writeFinalTextFrameAwait(text: String): Unit
suspend fun WebSocketBase.writeFrameAwait(frame: WebSocketFrame): Unit
suspend fun WebSocketBase.writeTextMessageAwait(text: String): Unit

fun requestOptionsOf(headers: Map<String, String>? = null, host: String? = null, port: Int? = null, ssl: Boolean? = null, uri: String? = null): RequestOptions
fun streamPriorityOf(dependency: Int? = null, exclusive: Boolean? = null, weight: Short? = null): StreamPriority
fun webSocketConnectOptionsOf(headers: Map<String, String>? = null, host: String? = null, port: Int? = null, ssl: Boolean? = null, subProtocols: Iterable<String>? = null, uri: String? = null, version: WebsocketVersion? = null): WebSocketConnectOptions

package io.vertx.kotlin.core.json

object Json
fun Json.array(vararg values: Any?): JsonArray
fun Json.array(values: Iterable<Any?>): JsonArray
fun Json.array(block: JsonArray.() -> Unit): JsonArray
fun Json.array(value: JsonObject): JsonArray
fun Json.array(value: JsonArray): JsonArray
io.vertx.core.json.JsonArray

operator fun <T> JsonArray.get(index: Int): T

io.vertx.core.json.JsonObject

operator fun <T> JsonObject.get(key: String): T

inline fun <T> json(block: Json.() -> T): T
fun jsonArrayOf(vararg values: Any?): JsonArray
fun jsonObjectOf(vararg fields: Pair<String, Any?>): JsonObject
fun Json.obj(vararg fields: Pair<String, Any?>): JsonObject
fun Json.obj(fields: Iterable<Pair<String, Any?>>): JsonObject
fun Json.obj(fields: Map<String, Any?>): JsonObject
fun Json.obj(block: JsonObject.() -> Unit): JsonObject

package io.vertx.kotlin.core.metrics

fun metricsOptionsOf(enabled: Boolean? = null): MetricsOptions

package io.vertx.kotlin.core.net

io.vertx.core.net.NetClient

suspend fun NetClient.connectAwait(port: Int, host: String): NetSocket
suspend fun NetClient.connectAwait(port: Int, host: String, serverName: String): NetSocket
suspend fun NetClient.connectAwait(remoteAddress: SocketAddress): NetSocket
suspend fun NetClient.connectAwait(remoteAddress: SocketAddress, serverName: String): NetSocket

io.vertx.core.net.NetServer

suspend fun NetServer.closeAwait(): Unit
suspend fun NetServer.listenAwait(): NetServer
suspend fun NetServer.listenAwait(port: Int, host: String): NetServer
suspend fun NetServer.listenAwait(port: Int): NetServer
suspend fun NetServer.listenAwait(localAddress: SocketAddress): NetServer

io.vertx.core.net.NetSocket

suspend fun NetSocket.closeAwait(): Unit
suspend fun NetSocket.endAwait(data: Buffer): Unit
suspend fun NetSocket.endAwait(): Unit
suspend fun NetSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun NetSocket.sendFileAwait(filename: String): Unit
suspend fun NetSocket.sendFileAwait(filename: String, offset: Long): Unit
suspend fun NetSocket.sendFileAwait(filename: String, offset: Long, length: Long): Unit
suspend fun NetSocket.upgradeToSslAwait(): Unit
suspend fun NetSocket.upgradeToSslAwait(serverName: String): Unit
suspend fun NetSocket.writeAwait(str: String): Unit
suspend fun NetSocket.writeAwait(str: String, enc: String): Unit
suspend fun NetSocket.writeAwait(message: Buffer): Unit

fun jdkSSLEngineOptionsOf(): JdkSSLEngineOptions
fun jksOptionsOf(password: String? = null, path: String? = null, value: Buffer? = null): JksOptions
fun netClientOptionsOf(connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null): NetClientOptions
fun netServerOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null): NetServerOptions
fun openSSLEngineOptionsOf(sessionCacheEnabled: Boolean? = null): OpenSSLEngineOptions
fun pemKeyCertOptionsOf(certPath: String? = null, certPaths: Iterable<String>? = null, certValue: Buffer? = null, certValues: Iterable<Buffer>? = null, keyPath: String? = null, keyPaths: Iterable<String>? = null, keyValue: Buffer? = null, keyValues: Iterable<Buffer>? = null): PemKeyCertOptions
fun pemTrustOptionsOf(certPaths: Iterable<String>? = null, certValues: Iterable<Buffer>? = null): PemTrustOptions
fun pfxOptionsOf(password: String? = null, path: String? = null, value: Buffer? = null): PfxOptions
fun proxyOptionsOf(host: String? = null, password: String? = null, port: Int? = null, type: ProxyType? = null, username: String? = null): ProxyOptions

package io.vertx.kotlin.core.parsetools

io.vertx.core.parsetools.JsonParser

suspend fun JsonParser.pipeToAwait(dst: WriteStream<JsonEvent>): Unit

io.vertx.core.parsetools.RecordParser

suspend fun RecordParser.pipeToAwait(dst: WriteStream<Buffer>): Unit

package io.vertx.kotlin.core.shareddata

io.vertx.core.shareddata.AsyncMap

suspend fun <K, V> AsyncMap<K, V>.clearAwait(): Unit
suspend fun <K, V> AsyncMap<K, V>.getAwait(k: K): V?
suspend fun <K, V> AsyncMap<K, V>.putAwait(k: K, v: V): Unit
suspend fun <K, V> AsyncMap<K, V>.putAwait(k: K, v: V, ttl: Long): Unit
suspend fun <K, V> AsyncMap<K, V>.putIfAbsentAwait(k: K, v: V): V?
suspend fun <K, V> AsyncMap<K, V>.putIfAbsentAwait(k: K, v: V, ttl: Long): V?
suspend fun <K, V> AsyncMap<K, V>.removeAwait(k: K): V?
suspend fun <K, V> AsyncMap<K, V>.removeIfPresentAwait(k: K, v: V): Boolean
suspend fun <K, V> AsyncMap<K, V>.replaceAwait(k: K, v: V): V?
suspend fun <K, V> AsyncMap<K, V>.replaceIfPresentAwait(k: K, oldValue: V, newValue: V): Boolean
suspend fun <K, V> AsyncMap<K, V>.sizeAwait(): Int

io.vertx.core.shareddata.Counter

suspend fun Counter.addAndGetAwait(value: Long): Long
suspend fun Counter.compareAndSetAwait(expected: Long, value: Long): Boolean
suspend fun Counter.decrementAndGetAwait(): Long
suspend fun Counter.getAndAddAwait(value: Long): Long
suspend fun Counter.getAndIncrementAwait(): Long
suspend fun Counter.getAwait(): Long
suspend fun Counter.incrementAndGetAwait(): Long

io.vertx.core.shareddata.SharedData

suspend fun <K, V> SharedData.getAsyncMapAwait(name: String): AsyncMap<K, V>
suspend fun <K, V> SharedData.getClusterWideMapAwait(name: String): AsyncMap<K, V>
suspend fun SharedData.getCounterAwait(name: String): Counter
suspend fun <K, V> SharedData.getLocalAsyncMapAwait(name: String): AsyncMap<K, V>
suspend fun SharedData.getLocalCounterAwait(name: String): Counter
suspend fun SharedData.getLocalLockAwait(name: String): Lock
suspend fun SharedData.getLocalLockWithTimeoutAwait(name: String, timeout: Long): Lock
suspend fun SharedData.getLockAwait(name: String): Lock
suspend fun SharedData.getLockWithTimeoutAwait(name: String, timeout: Long): Lock

package io.vertx.kotlin.core.streams

inline fun <S : WriteStream<Buffer>> S.end(pretty: Boolean = false, block: Json.() -> Any): S
io.vertx.core.streams.Pipe

suspend fun <T> Pipe<T>.toAwait(dst: WriteStream<T>): Unit

io.vertx.core.streams.ReadStream

suspend fun <T> ReadStream<T>.pipeToAwait(dst: WriteStream<T>): Unit

io.vertx.core.streams.WriteStream

suspend fun <T> WriteStream<T>.endAwait(): Unit
suspend fun <T> WriteStream<T>.endAwait(data: T): Unit
suspend fun <T> WriteStream<T>.writeAwait(data: T): Unit

inline fun <S : WriteStream<Buffer>> S.write(pretty: Boolean = false, block: Json.() -> Any): S

package io.vertx.kotlin.core.tracing

fun tracingOptionsOf(enabled: Boolean? = null): TracingOptions

package io.vertx.kotlin.ext.auth

io.vertx.ext.auth.AuthProvider

suspend fun AuthProvider.authenticateAwait(authInfo: JsonObject): User

io.vertx.ext.auth.User

suspend fun User.isAuthorizedAwait(authority: String): Boolean

fun keyStoreOptionsOf(password: String? = null, path: String? = null, type: String? = null): KeyStoreOptions
fun pubSecKeyOptionsOf(algorithm: String? = null, certificate: Boolean? = null, publicKey: String? = null, secretKey: String? = null, symmetric: Boolean? = null): PubSecKeyOptions

package io.vertx.kotlin.ext.auth.htpasswd

fun htpasswdAuthOptionsOf(htpasswdFile: String? = null, plainTextEnabled: Boolean? = null): HtpasswdAuthOptions

package io.vertx.kotlin.ext.auth.jdbc

fun jdbcAuthOptionsOf(authenticationQuery: String? = null, config: JsonObject? = null, datasourceName: String? = null, permissionsQuery: String? = null, rolesPrefix: String? = null, rolesQuery: String? = null, shared: Boolean? = null): JDBCAuthOptions

package io.vertx.kotlin.ext.auth.jwt

fun jwtAuthOptionsOf(jwks: Iterable<JsonObject>? = null, jwtOptions: JWTOptions? = null, keyStore: KeyStoreOptions? = null, permissionsClaimKey: String? = null, pubSecKeys: Iterable<PubSecKeyOptions>? = null): JWTAuthOptions

package io.vertx.kotlin.ext.auth.mongo

io.vertx.ext.auth.mongo.MongoAuth

suspend fun MongoAuth.insertUserAwait(username: String, password: String, roles: List<String>, permissions: List<String>): String

fun mongoAuthOptionsOf(collectionName: String? = null, config: JsonObject? = null, datasourceName: String? = null, passwordField: String? = null, permissionField: String? = null, roleField: String? = null, saltField: String? = null, saltStyle: HashSaltStyle? = null, shared: Boolean? = null, usernameCredentialField: String? = null, usernameField: String? = null): MongoAuthOptions

package io.vertx.kotlin.ext.auth.oauth2

io.vertx.ext.auth.oauth2.AccessToken

suspend fun AccessToken.fetchAwait(resource: String): OAuth2Response
suspend fun AccessToken.fetchAwait(method: HttpMethod, resource: String, headers: JsonObject, payload: Buffer): OAuth2Response
suspend fun AccessToken.introspectAwait(): Unit
suspend fun AccessToken.introspectAwait(tokenType: String): Unit
suspend fun AccessToken.logoutAwait(): Unit
suspend fun AccessToken.refreshAwait(): Unit
suspend fun AccessToken.revokeAwait(token_type: String): Unit
suspend fun AccessToken.userInfoAwait(): JsonObject

io.vertx.ext.auth.oauth2.OAuth2Auth

suspend fun OAuth2Auth.decodeTokenAwait(token: String): AccessToken
suspend fun OAuth2Auth.introspectTokenAwait(token: String): AccessToken
suspend fun OAuth2Auth.introspectTokenAwait(token: String, tokenType: String): AccessToken
suspend fun OAuth2Auth.loadJWKAwait(): Unit

io.vertx.ext.auth.oauth2.OAuth2RBAC

suspend fun OAuth2RBAC.isAuthorizedAwait(user: AccessToken, authority: String): Boolean

fun oAuth2ClientOptionsOf(alpnVersions: Iterable<HttpVersion>? = null, authorizationPath: String? = null, clientID: String? = null, clientSecret: String? = null, clientSecretParameterName: String? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, decoderInitialBufferSize: Int? = null, defaultHost: String? = null, defaultPort: Int? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, extraParameters: JsonObject? = null, flow: OAuth2FlowType? = null, forceSni: Boolean? = null, headers: JsonObject? = null, http2ClearTextUpgrade: Boolean? = null, http2ConnectionWindowSize: Int? = null, http2KeepAliveTimeout: Int? = null, http2MaxPoolSize: Int? = null, http2MultiplexingLimit: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, introspectionPath: String? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, jwkPath: String? = null, jwtOptions: JWTOptions? = null, keepAlive: Boolean? = null, keepAliveTimeout: Int? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, logoutPath: String? = null, maxChunkSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxPoolSize: Int? = null, maxRedirects: Int? = null, maxWaitQueueSize: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = null, pipeliningLimit: Int? = null, poolCleanerPeriod: Int? = null, protocolVersion: HttpVersion? = null, proxyOptions: ProxyOptions? = null, pubSecKeys: Iterable<PubSecKeyOptions>? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, revocationPath: String? = null, scopeSeparator: String? = null, sendBufferSize: Int? = null, sendUnmaskedFrames: Boolean? = null, site: String? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, tenant: String? = null, tokenPath: String? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, useBasicAuthorizationHeader: Boolean? = null, userAgent: String? = null, userInfoParameters: JsonObject? = null, userInfoPath: String? = null, validateIssuer: Boolean? = null, verifyHost: Boolean? = null, websocketCompressionAllowClientNoContext: Boolean? = null, websocketCompressionLevel: Int? = null, websocketCompressionRequestServerNoContext: Boolean? = null): OAuth2ClientOptions

package io.vertx.kotlin.ext.auth.oauth2.providers

object AzureADAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object GoogleAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object KeycloakAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object OpenIDConnectAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

object SalesforceAuth

suspend fun discoverAwait(vertx: Vertx, config: OAuth2ClientOptions): OAuth2Auth

package io.vertx.kotlin.ext.auth.shiro

fun shiroAuthOptionsOf(config: JsonObject? = null, type: ShiroAuthRealmType? = null): ShiroAuthOptions

package io.vertx.kotlin.ext.bridge

fun bridgeOptionsOf(inboundPermitteds: Iterable<PermittedOptions>? = null, outboundPermitteds: Iterable<PermittedOptions>? = null): BridgeOptions
fun permittedOptionsOf(address: String? = null, addressRegex: String? = null, match: JsonObject? = null, requiredAuthority: String? = null): PermittedOptions

package io.vertx.kotlin.ext.consul

fun aclTokenOf(id: String? = null, name: String? = null, rules: String? = null, type: AclTokenType? = null): AclToken
fun blockingQueryOptionsOf(index: Long? = null, wait: String? = null): BlockingQueryOptions
fun checkListOf(index: Long? = null, list: Iterable<Check>? = null): CheckList
fun checkOf(id: String? = null, name: String? = null, nodeName: String? = null, notes: String? = null, output: String? = null, serviceId: String? = null, serviceName: String? = null, status: CheckStatus? = null): Check
fun checkOptionsOf(deregisterAfter: String? = null, grpc: String? = null, grpcTls: Boolean? = null, http: String? = null, id: String? = null, interval: String? = null, name: String? = null, notes: String? = null, scriptArgs: Iterable<String>? = null, serviceId: String? = null, status: CheckStatus? = null, tcp: String? = null, tlsSkipVerify: Boolean? = null, ttl: String? = null): CheckOptions
fun checkQueryOptionsOf(blockingOptions: BlockingQueryOptions? = null, near: String? = null): CheckQueryOptions
fun consulClientOptionsOf(aclToken: String? = null, alpnVersions: Iterable<HttpVersion>? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, dc: String? = null, decoderInitialBufferSize: Int? = null, defaultHost: String? = null, defaultPort: Int? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, followRedirects: Boolean? = null, forceSni: Boolean? = null, http2ClearTextUpgrade: Boolean? = null, http2ConnectionWindowSize: Int? = null, http2KeepAliveTimeout: Int? = null, http2MaxPoolSize: Int? = null, http2MultiplexingLimit: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keepAlive: Boolean? = null, keepAliveTimeout: Int? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxPoolSize: Int? = null, maxRedirects: Int? = null, maxWaitQueueSize: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = null, pipeliningLimit: Int? = null, poolCleanerPeriod: Int? = null, protocolVersion: HttpVersion? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sendUnmaskedFrames: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, timeout: Long? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, userAgent: String? = null, userAgentEnabled: Boolean? = null, verifyHost: Boolean? = null, websocketCompressionAllowClientNoContext: Boolean? = null, websocketCompressionLevel: Int? = null, websocketCompressionRequestServerNoContext: Boolean? = null): ConsulClientOptions
fun coordinateListOf(index: Long? = null, list: Iterable<Coordinate>? = null): CoordinateList
fun coordinateOf(adj: Float? = null, err: Float? = null, height: Float? = null, node: String? = null, vec: Iterable<Float>? = null): Coordinate
fun dcCoordinatesOf(datacenter: String? = null, servers: Iterable<Coordinate>? = null): DcCoordinates
fun eventListOf(index: Long? = null, list: Iterable<Event>? = null): EventList
fun eventListOptionsOf(blockingOptions: BlockingQueryOptions? = null, name: String? = null): EventListOptions
fun eventOf(id: String? = null, lTime: Int? = null, name: String? = null, node: String? = null, payload: String? = null, service: String? = null, tag: String? = null, version: Int? = null): Event
fun eventOptionsOf(node: String? = null, payload: String? = null, service: String? = null, tag: String? = null): EventOptions
io.vertx.ext.consul.ConsulClient

suspend fun ConsulClient.agentInfoAwait(): JsonObject
suspend fun ConsulClient.catalogDatacentersAwait(): List<String>
suspend fun ConsulClient.catalogNodeServicesAwait(node: String): ServiceList
suspend fun ConsulClient.catalogNodeServicesWithOptionsAwait(node: String, options: BlockingQueryOptions): ServiceList
suspend fun ConsulClient.catalogNodesAwait(): NodeList
suspend fun ConsulClient.catalogNodesWithOptionsAwait(options: NodeQueryOptions): NodeList
suspend fun ConsulClient.catalogServiceNodesAwait(service: String): ServiceList
suspend fun ConsulClient.catalogServiceNodesWithOptionsAwait(service: String, options: ServiceQueryOptions): ServiceList
suspend fun ConsulClient.catalogServicesAwait(): ServiceList
suspend fun ConsulClient.catalogServicesWithOptionsAwait(options: BlockingQueryOptions): ServiceList
suspend fun ConsulClient.cloneAclTokenAwait(id: String): String
suspend fun ConsulClient.coordinateDatacentersAwait(): List<DcCoordinates>
suspend fun ConsulClient.coordinateNodesAwait(): CoordinateList
suspend fun ConsulClient.coordinateNodesWithOptionsAwait(options: BlockingQueryOptions): CoordinateList
suspend fun ConsulClient.createAclTokenAwait(token: AclToken): String
suspend fun ConsulClient.createPreparedQueryAwait(definition: PreparedQueryDefinition): String
suspend fun ConsulClient.createSessionAwait(): String
suspend fun ConsulClient.createSessionWithOptionsAwait(options: SessionOptions): String
suspend fun ConsulClient.deletePreparedQueryAwait(id: String): Unit
suspend fun ConsulClient.deleteValueAwait(key: String): Unit
suspend fun ConsulClient.deleteValuesAwait(keyPrefix: String): Unit
suspend fun ConsulClient.deregisterCheckAwait(checkId: String): Unit
suspend fun ConsulClient.deregisterServiceAwait(id: String): Unit
suspend fun ConsulClient.destroyAclTokenAwait(id: String): Unit
suspend fun ConsulClient.destroySessionAwait(id: String): Unit
suspend fun ConsulClient.executePreparedQueryAwait(query: String): PreparedQueryExecuteResponse
suspend fun ConsulClient.executePreparedQueryWithOptionsAwait(query: String, options: PreparedQueryExecuteOptions): PreparedQueryExecuteResponse
suspend fun ConsulClient.failCheckAwait(checkId: String): Unit
suspend fun ConsulClient.failCheckWithNoteAwait(checkId: String, note: String): Unit
suspend fun ConsulClient.fireEventAwait(name: String): Event
suspend fun ConsulClient.fireEventWithOptionsAwait(name: String, options: EventOptions): Event
suspend fun ConsulClient.getAllPreparedQueriesAwait(): List<PreparedQueryDefinition>
suspend fun ConsulClient.getKeysAwait(keyPrefix: String): List<String>
suspend fun ConsulClient.getKeysWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): List<String>
suspend fun ConsulClient.getPreparedQueryAwait(id: String): PreparedQueryDefinition
suspend fun ConsulClient.getValueAwait(key: String): KeyValue
suspend fun ConsulClient.getValueWithOptionsAwait(key: String, options: BlockingQueryOptions): KeyValue
suspend fun ConsulClient.getValuesAwait(keyPrefix: String): KeyValueList
suspend fun ConsulClient.getValuesWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): KeyValueList
suspend fun ConsulClient.healthChecksAwait(service: String): CheckList
suspend fun ConsulClient.healthChecksWithOptionsAwait(service: String, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.healthServiceNodesAwait(service: String, passing: Boolean): ServiceEntryList
suspend fun ConsulClient.healthServiceNodesWithOptionsAwait(service: String, passing: Boolean, options: ServiceQueryOptions): ServiceEntryList
suspend fun ConsulClient.healthStateAwait(healthState: HealthState): CheckList
suspend fun ConsulClient.healthStateWithOptionsAwait(healthState: HealthState, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.infoAclTokenAwait(id: String): AclToken
suspend fun ConsulClient.infoSessionAwait(id: String): Session
suspend fun ConsulClient.infoSessionWithOptionsAwait(id: String, options: BlockingQueryOptions): Session
suspend fun ConsulClient.leaderStatusAwait(): String
suspend fun ConsulClient.listAclTokensAwait(): List<AclToken>
suspend fun ConsulClient.listEventsAwait(): EventList
suspend fun ConsulClient.listEventsWithOptionsAwait(options: EventListOptions): EventList
suspend fun ConsulClient.listNodeSessionsAwait(nodeId: String): SessionList
suspend fun ConsulClient.listNodeSessionsWithOptionsAwait(nodeId: String, options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.listSessionsAwait(): SessionList
suspend fun ConsulClient.listSessionsWithOptionsAwait(options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.localChecksAwait(): List<Check>
suspend fun ConsulClient.localServicesAwait(): List<Service>
suspend fun ConsulClient.maintenanceServiceAwait(maintenanceOptions: MaintenanceOptions): Unit
suspend fun ConsulClient.passCheckAwait(checkId: String): Unit
suspend fun ConsulClient.passCheckWithNoteAwait(checkId: String, note: String): Unit
suspend fun ConsulClient.peersStatusAwait(): List<String>
suspend fun ConsulClient.putValueAwait(key: String, value: String): Boolean
suspend fun ConsulClient.putValueWithOptionsAwait(key: String, value: String, options: KeyValueOptions): Boolean
suspend fun ConsulClient.registerCheckAwait(checkOptions: CheckOptions): Unit
suspend fun ConsulClient.registerServiceAwait(serviceOptions: ServiceOptions): Unit
suspend fun ConsulClient.renewSessionAwait(id: String): Session
suspend fun ConsulClient.transactionAwait(request: TxnRequest): TxnResponse
suspend fun ConsulClient.updateAclTokenAwait(token: AclToken): String
suspend fun ConsulClient.updateCheckAwait(checkId: String, status: CheckStatus): Unit
suspend fun ConsulClient.updateCheckWithNoteAwait(checkId: String, status: CheckStatus, note: String): Unit
suspend fun ConsulClient.updatePreparedQueryAwait(definition: PreparedQueryDefinition): Unit
suspend fun ConsulClient.warnCheckAwait(checkId: String): Unit
suspend fun ConsulClient.warnCheckWithNoteAwait(checkId: String, note: String): Unit

fun keyValueListOf(index: Long? = null, list: Iterable<KeyValue>? = null): KeyValueList
fun keyValueOf(createIndex: Long? = null, flags: Long? = null, key: String? = null, lockIndex: Long? = null, modifyIndex: Long? = null, session: String? = null, value: String? = null): KeyValue
fun keyValueOptionsOf(acquireSession: String? = null, casIndex: Long? = null, flags: Long? = null, releaseSession: String? = null): KeyValueOptions
fun maintenanceOptionsOf(enable: Boolean? = null, id: String? = null, reason: String? = null): MaintenanceOptions
fun nodeListOf(index: Long? = null, list: Iterable<Node>? = null): NodeList
fun nodeOf(address: String? = null, lanAddress: String? = null, name: String? = null, wanAddress: String? = null): Node
fun nodeQueryOptionsOf(blockingOptions: BlockingQueryOptions? = null, near: String? = null): NodeQueryOptions
fun preparedQueryDefinitionOf(dcs: Iterable<String>? = null, dnsTtl: String? = null, id: String? = null, meta: Map<String, String>? = null, name: String? = null, nearestN: Int? = null, passing: Boolean? = null, service: String? = null, session: String? = null, tags: Iterable<String>? = null, templateRegexp: String? = null, templateType: String? = null, token: String? = null): PreparedQueryDefinition
fun preparedQueryExecuteOptionsOf(limit: Int? = null, near: String? = null): PreparedQueryExecuteOptions
fun preparedQueryExecuteResponseOf(dc: String? = null, dnsTtl: String? = null, failovers: Int? = null, nodes: Iterable<ServiceEntry>? = null, service: String? = null): PreparedQueryExecuteResponse
fun serviceEntryListOf(index: Long? = null, list: Iterable<ServiceEntry>? = null): ServiceEntryList
fun serviceEntryOf(checks: Iterable<Check>? = null, node: Node? = null, service: Service? = null): ServiceEntry
fun serviceListOf(index: Long? = null, list: Iterable<Service>? = null): ServiceList
fun serviceOf(address: String? = null, id: String? = null, meta: Map<String, String>? = null, name: String? = null, node: String? = null, nodeAddress: String? = null, port: Int? = null, tags: Iterable<String>? = null): Service
fun serviceOptionsOf(address: String? = null, checkOptions: CheckOptions? = null, id: String? = null, meta: Map<String, String>? = null, name: String? = null, port: Int? = null, tags: Iterable<String>? = null): ServiceOptions
fun serviceQueryOptionsOf(blockingOptions: BlockingQueryOptions? = null, near: String? = null, tag: String? = null): ServiceQueryOptions
fun sessionListOf(index: Long? = null, list: Iterable<Session>? = null): SessionList
fun sessionOf(checks: Iterable<String>? = null, createIndex: Long? = null, id: String? = null, index: Long? = null, lockDelay: Long? = null, node: String? = null): Session
fun sessionOptionsOf(behavior: SessionBehavior? = null, checks: Iterable<String>? = null, lockDelay: Long? = null, name: String? = null, node: String? = null, ttl: Long? = null): SessionOptions
fun txnErrorOf(opIndex: Int? = null, what: String? = null): TxnError
fun txnKVOperationOf(flags: Long? = null, index: Long? = null, key: String? = null, session: String? = null, type: TxnKVVerb? = null, value: String? = null): TxnKVOperation
fun txnRequestOf(): TxnRequest
fun txnResponseOf(errors: Iterable<TxnError>? = null): TxnResponse

package io.vertx.kotlin.ext.dropwizard

fun dropwizardMetricsOptionsOf(baseName: String? = null, configPath: String? = null, enabled: Boolean? = null, jmxDomain: String? = null, jmxEnabled: Boolean? = null, monitoredEventBusHandlers: Iterable<Match>? = null, monitoredHttpClientEndpoints: Iterable<Match>? = null, monitoredHttpClientUris: Iterable<Match>? = null, monitoredHttpServerUris: Iterable<Match>? = null, registryName: String? = null): DropwizardMetricsOptions
fun matchOf(alias: String? = null, type: MatchType? = null, value: String? = null): Match

package io.vertx.kotlin.ext.eventbus.bridge.tcp

io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge

suspend fun TcpEventBusBridge.closeAwait(): Unit
suspend fun TcpEventBusBridge.listenAwait(): TcpEventBusBridge
suspend fun TcpEventBusBridge.listenAwait(port: Int, address: String): TcpEventBusBridge
suspend fun TcpEventBusBridge.listenAwait(port: Int): TcpEventBusBridge

package io.vertx.kotlin.ext.healthchecks

io.vertx.ext.healthchecks.HealthChecks

suspend fun HealthChecks.invokeAwait(name: String): JsonObject

fun statusOf(data: JsonObject? = null, ok: Boolean? = null, procedureInError: Boolean? = null): Status

package io.vertx.kotlin.ext.jdbc

io.vertx.ext.jdbc.JDBCClient

suspend fun JDBCClient.querySingleAwait(sql: String): JsonArray?
suspend fun JDBCClient.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?

package io.vertx.kotlin.ext.jwt

fun jwtOptionsOf(algorithm: String? = null, audience: Iterable<String>? = null, audiences: Iterable<String>? = null, expiresInMinutes: Int? = null, expiresInSeconds: Int? = null, header: JsonObject? = null, ignoreExpiration: Boolean? = null, issuer: String? = null, leeway: Int? = null, noTimestamp: Boolean? = null, permissions: Iterable<String>? = null, subject: String? = null): JWTOptions

package io.vertx.kotlin.ext.mail

io.vertx.ext.mail.MailClient

suspend fun MailClient.sendMailAwait(email: MailMessage): MailResult

fun mailConfigOf(allowRcptErrors: Boolean? = null, authMethods: String? = null, disableEsmtp: Boolean? = null, hostname: String? = null, keepAlive: Boolean? = null, keyStore: String? = null, keyStorePassword: String? = null, login: LoginOption? = null, maxPoolSize: Int? = null, ownHostname: String? = null, password: String? = null, port: Int? = null, ssl: Boolean? = null, starttls: StartTLSOptions? = null, trustAll: Boolean? = null, username: String? = null): MailConfig
fun mailMessageOf(attachment: Iterable<MailAttachment>? = null, bcc: Iterable<String>? = null, bounceAddress: String? = null, cc: Iterable<String>? = null, fixedHeaders: Boolean? = null, from: String? = null, headers: Map<String, String>? = null, html: String? = null, inlineAttachment: Iterable<MailAttachment>? = null, subject: String? = null, text: String? = null, to: Iterable<String>? = null): MailMessage
fun mailResultOf(messageID: String? = null, recipients: Iterable<String>? = null): MailResult

package io.vertx.kotlin.ext.mongo

fun aggregateOptionsOf(allowDiskUse: Boolean? = null, batchSize: Int? = null, maxAwaitTime: Long? = null, maxTime: Long? = null): AggregateOptions
fun bulkOperationOf(document: JsonObject? = null, filter: JsonObject? = null, multi: Boolean? = null, type: BulkOperationType? = null, upsert: Boolean? = null): BulkOperation
fun bulkWriteOptionsOf(ordered: Boolean? = null, writeOption: WriteOption? = null): BulkWriteOptions
fun findOptionsOf(batchSize: Int? = null, fields: JsonObject? = null, limit: Int? = null, skip: Int? = null, sort: JsonObject? = null): FindOptions
fun gridFsDownloadOptionsOf(revision: Int? = null): GridFsDownloadOptions
fun gridFsUploadOptionsOf(chunkSizeBytes: Int? = null, metadata: JsonObject? = null): GridFsUploadOptions
fun indexModelOf(): IndexModel
fun indexOptionsOf(): IndexOptions
io.vertx.ext.mongo.MongoClient

suspend fun MongoClient.bulkWriteAwait(collection: String, operations: List<BulkOperation>): MongoClientBulkWriteResult?
suspend fun MongoClient.bulkWriteWithOptionsAwait(collection: String, operations: List<BulkOperation>, bulkWriteOptions: BulkWriteOptions): MongoClientBulkWriteResult?
suspend fun MongoClient.countAwait(collection: String, query: JsonObject): Long
suspend fun MongoClient.createCollectionAwait(collectionName: String): Unit
suspend fun MongoClient.createDefaultGridFsBucketServiceAwait(): MongoGridFsClient
suspend fun MongoClient.createGridFsBucketServiceAwait(bucketName: String): MongoGridFsClient
suspend fun MongoClient.createIndexAwait(collection: String, key: JsonObject): Unit
suspend fun MongoClient.createIndexWithOptionsAwait(collection: String, key: JsonObject, options: IndexOptions): Unit
suspend fun MongoClient.createIndexesAwait(collection: String, indexes: List<IndexModel>): Unit
suspend fun MongoClient.distinctAwait(collection: String, fieldName: String, resultClassname: String): JsonArray
suspend fun MongoClient.distinctWithQueryAwait(collection: String, fieldName: String, resultClassname: String, query: JsonObject): JsonArray
suspend fun MongoClient.dropCollectionAwait(collection: String): Unit
suspend fun MongoClient.dropIndexAwait(collection: String, indexName: String): Unit
suspend fun MongoClient.findAwait(collection: String, query: JsonObject): List<JsonObject>
suspend fun MongoClient.findOneAndDeleteAwait(collection: String, query: JsonObject): JsonObject?
suspend fun MongoClient.findOneAndDeleteWithOptionsAwait(collection: String, query: JsonObject, findOptions: FindOptions): JsonObject?
suspend fun MongoClient.findOneAndReplaceAwait(collection: String, query: JsonObject, replace: JsonObject): JsonObject?
suspend fun MongoClient.findOneAndReplaceWithOptionsAwait(collection: String, query: JsonObject, replace: JsonObject, findOptions: FindOptions, updateOptions: UpdateOptions): JsonObject?
suspend fun MongoClient.findOneAndUpdateAwait(collection: String, query: JsonObject, update: JsonObject): JsonObject?
suspend fun MongoClient.findOneAndUpdateWithOptionsAwait(collection: String, query: JsonObject, update: JsonObject, findOptions: FindOptions, updateOptions: UpdateOptions): JsonObject?
suspend fun MongoClient.findOneAwait(collection: String, query: JsonObject, fields: JsonObject): JsonObject?
suspend fun MongoClient.findWithOptionsAwait(collection: String, query: JsonObject, options: FindOptions): List<JsonObject>
suspend fun MongoClient.getCollectionsAwait(): List<String>
suspend fun MongoClient.insertAwait(collection: String, document: JsonObject): String?
suspend fun MongoClient.insertWithOptionsAwait(collection: String, document: JsonObject, writeOption: WriteOption): String?
suspend fun MongoClient.listIndexesAwait(collection: String): JsonArray
suspend fun MongoClient.removeDocumentAwait(collection: String, query: JsonObject): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentsAwait(collection: String, query: JsonObject): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentsWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption): MongoClientDeleteResult?
suspend fun MongoClient.replaceDocumentsAwait(collection: String, query: JsonObject, replace: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.replaceDocumentsWithOptionsAwait(collection: String, query: JsonObject, replace: JsonObject, options: UpdateOptions): MongoClientUpdateResult?
suspend fun MongoClient.runCommandAwait(commandName: String, command: JsonObject): JsonObject?
suspend fun MongoClient.saveAwait(collection: String, document: JsonObject): String?
suspend fun MongoClient.saveWithOptionsAwait(collection: String, document: JsonObject, writeOption: WriteOption): String?
suspend fun MongoClient.updateCollectionAwait(collection: String, query: JsonObject, update: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.updateCollectionWithOptionsAwait(collection: String, query: JsonObject, update: JsonObject, options: UpdateOptions): MongoClientUpdateResult?

io.vertx.ext.mongo.MongoGridFsClient

suspend fun MongoGridFsClient.deleteAwait(id: String): Unit
suspend fun MongoGridFsClient.downloadByFileNameAwait(stream: WriteStream<Buffer>, fileName: String): Long
suspend fun MongoGridFsClient.downloadByFileNameWithOptionsAwait(stream: WriteStream<Buffer>, fileName: String, options: GridFsDownloadOptions): Long
suspend fun MongoGridFsClient.downloadByIdAwait(stream: WriteStream<Buffer>, id: String): Long
suspend fun MongoGridFsClient.downloadFileAsAwait(fileName: String, newFileName: String): Long
suspend fun MongoGridFsClient.downloadFileAwait(fileName: String): Long
suspend fun MongoGridFsClient.downloadFileByIDAwait(id: String, fileName: String): Long
suspend fun MongoGridFsClient.dropAwait(): Unit
suspend fun MongoGridFsClient.findAllIdsAwait(): List<String>
suspend fun MongoGridFsClient.findIdsAwait(query: JsonObject): List<String>
suspend fun MongoGridFsClient.uploadByFileNameAwait(stream: ReadStream<Buffer>, fileName: String): String
suspend fun MongoGridFsClient.uploadByFileNameWithOptionsAwait(stream: ReadStream<Buffer>, fileName: String, options: GridFsUploadOptions): String
suspend fun MongoGridFsClient.uploadFileAwait(fileName: String): String
suspend fun MongoGridFsClient.uploadFileWithOptionsAwait(fileName: String, options: GridFsUploadOptions): String

fun mongoClientBulkWriteResultOf(): MongoClientBulkWriteResult
fun mongoClientDeleteResultOf(): MongoClientDeleteResult
fun mongoClientUpdateResultOf(): MongoClientUpdateResult
fun updateOptionsOf(arrayFilters: JsonArray? = null, multi: Boolean? = null, returningNewDocument: Boolean? = null, upsert: Boolean? = null, writeOption: WriteOption? = null): UpdateOptions

package io.vertx.kotlin.ext.shell

io.vertx.ext.shell.ShellServer

suspend fun ShellServer.closeAwait(): Unit
suspend fun ShellServer.listenAwait(): Unit

io.vertx.ext.shell.ShellService

suspend fun ShellService.startAwait(): Unit
suspend fun ShellService.stopAwait(): Unit

fun shellServerOptionsOf(reaperInterval: Long? = null, sessionTimeout: Long? = null, welcomeMessage: String? = null): ShellServerOptions
fun shellServiceOptionsOf(httpOptions: HttpTermOptions? = null, reaperInterval: Long? = null, sessionTimeout: Long? = null, sshOptions: SSHTermOptions? = null, telnetOptions: TelnetTermOptions? = null, welcomeMessage: String? = null): ShellServiceOptions

package io.vertx.kotlin.ext.shell.command

io.vertx.ext.shell.command.CommandRegistry

suspend fun CommandRegistry.registerCommandAwait(command: Command): Command
suspend fun CommandRegistry.registerCommandsAwait(commands: List<Command>): List<Command>
suspend fun CommandRegistry.unregisterCommandAwait(commandName: String): Unit

package io.vertx.kotlin.ext.shell.term

fun httpTermOptionsOf(acceptBacklog: Int? = null, acceptUnmaskedFrames: Boolean? = null, alpnVersions: Iterable<HttpVersion>? = null, charset: String? = null, clientAuth: ClientAuth? = null, compressionLevel: Int? = null, compressionSupported: Boolean? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, decoderInitialBufferSize: Int? = null, decompressionSupported: Boolean? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, handle100ContinueAutomatically: Boolean? = null, host: String? = null, http2ConnectionWindowSize: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, intputrc: String? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, perFrameWebsocketCompressionSupported: Boolean? = null, perMessageWebsocketCompressionSupported: Boolean? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, shellHtmlResource: Buffer? = null, sni: Boolean? = null, soLinger: Int? = null, sockJSHandlerOptions: SockJSHandlerOptions? = null, sockJSPath: String? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, termJsResource: Buffer? = null, trafficClass: Int? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, vertsShellJsResource: Buffer? = null, websocketAllowServerNoContext: Boolean? = null, websocketCompressionLevel: Int? = null, websocketPreferredClientNoContext: Boolean? = null, websocketSubProtocols: String? = null): HttpTermOptions
io.vertx.ext.shell.term.TermServer

suspend fun TermServer.closeAwait(): Unit
suspend fun TermServer.listenAwait(): TermServer

fun sshTermOptionsOf(defaultCharset: String? = null, host: String? = null, intputrc: String? = null, keyPairOptions: JksOptions? = null, pemKeyPairOptions: PemKeyCertOptions? = null, pfxKeyPairOptions: PfxOptions? = null, port: Int? = null): SSHTermOptions
fun telnetTermOptionsOf(acceptBacklog: Int? = null, charset: String? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, inBinary: Boolean? = null, intputrc: String? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, outBinary: Boolean? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null): TelnetTermOptions

package io.vertx.kotlin.ext.sql

io.vertx.ext.sql.SQLClient

suspend fun SQLClient.callAwait(sql: String): ResultSet
suspend fun SQLClient.callWithParamsAwait(sql: String, params: JsonArray, outputs: JsonArray): ResultSet
suspend fun SQLClient.closeAwait(): Unit
suspend fun SQLClient.getConnectionAwait(): SQLConnection
suspend fun SQLClient.queryAwait(sql: String): ResultSet
suspend fun SQLClient.querySingleAwait(sql: String): JsonArray?
suspend fun SQLClient.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?
suspend fun SQLClient.queryStreamAwait(sql: String): SQLRowStream
suspend fun SQLClient.queryStreamWithParamsAwait(sql: String, params: JsonArray): SQLRowStream
suspend fun SQLClient.queryWithParamsAwait(sql: String, arguments: JsonArray): ResultSet
suspend fun SQLClient.updateAwait(sql: String): UpdateResult
suspend fun SQLClient.updateWithParamsAwait(sql: String, params: JsonArray): UpdateResult

io.vertx.ext.sql.SQLConnection

suspend fun SQLConnection.batchAwait(sqlStatements: List<String>): List<Int>
suspend fun SQLConnection.batchCallableWithParamsAwait(sqlStatement: String, inArgs: List<JsonArray>, outArgs: List<JsonArray>): List<Int>
suspend fun SQLConnection.batchWithParamsAwait(sqlStatement: String, args: List<JsonArray>): List<Int>
suspend fun SQLConnection.callAwait(sql: String): ResultSet
suspend fun SQLConnection.callWithParamsAwait(sql: String, params: JsonArray, outputs: JsonArray): ResultSet
suspend fun SQLConnection.closeAwait(): Unit
suspend fun SQLConnection.commitAwait(): Unit
suspend fun SQLConnection.executeAwait(sql: String): Unit
suspend fun SQLConnection.getTransactionIsolationAwait(): TransactionIsolation
suspend fun SQLConnection.queryAwait(sql: String): ResultSet
suspend fun SQLConnection.querySingleAwait(sql: String): JsonArray?
suspend fun SQLConnection.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?
suspend fun SQLConnection.queryStreamAwait(sql: String): SQLRowStream
suspend fun SQLConnection.queryStreamWithParamsAwait(sql: String, params: JsonArray): SQLRowStream
suspend fun SQLConnection.queryWithParamsAwait(sql: String, params: JsonArray): ResultSet
suspend fun SQLConnection.rollbackAwait(): Unit
suspend fun SQLConnection.setAutoCommitAwait(autoCommit: Boolean): Unit
suspend fun SQLConnection.setTransactionIsolationAwait(isolation: TransactionIsolation): Unit
suspend fun SQLConnection.updateAwait(sql: String): UpdateResult
suspend fun SQLConnection.updateWithParamsAwait(sql: String, params: JsonArray): UpdateResult

io.vertx.ext.sql.SQLOperations

suspend fun SQLOperations.callAwait(sql: String): ResultSet
suspend fun SQLOperations.callWithParamsAwait(sql: String, params: JsonArray, outputs: JsonArray): ResultSet
suspend fun SQLOperations.queryAwait(sql: String): ResultSet
suspend fun SQLOperations.querySingleAwait(sql: String): JsonArray?
suspend fun SQLOperations.querySingleWithParamsAwait(sql: String, arguments: JsonArray): JsonArray?
suspend fun SQLOperations.queryStreamAwait(sql: String): SQLRowStream
suspend fun SQLOperations.queryStreamWithParamsAwait(sql: String, params: JsonArray): SQLRowStream
suspend fun SQLOperations.queryWithParamsAwait(sql: String, params: JsonArray): ResultSet
suspend fun SQLOperations.updateAwait(sql: String): UpdateResult
suspend fun SQLOperations.updateWithParamsAwait(sql: String, params: JsonArray): UpdateResult

io.vertx.ext.sql.SQLRowStream

suspend fun SQLRowStream.closeAwait(): Unit
suspend fun SQLRowStream.pipeToAwait(dst: WriteStream<JsonArray>): Unit

fun resultSetOf(columnNames: Iterable<String>? = null, next: ResultSet? = null, output: JsonArray? = null, results: Iterable<JsonArray>? = null): ResultSet
fun sqlOptionsOf(autoGeneratedKeys: Boolean? = null, autoGeneratedKeysIndexes: JsonArray? = null, catalog: String? = null, fetchDirection: FetchDirection? = null, fetchSize: Int? = null, queryTimeout: Int? = null, readOnly: Boolean? = null, resultSetConcurrency: ResultSetConcurrency? = null, resultSetType: ResultSetType? = null, schema: String? = null, transactionIsolation: TransactionIsolation? = null): SQLOptions
fun updateResultOf(keys: JsonArray? = null, updated: Int? = null): UpdateResult

package io.vertx.kotlin.ext.stomp

fun bridgeOptionsOf(inboundPermitteds: Iterable<PermittedOptions>? = null, outboundPermitteds: Iterable<PermittedOptions>? = null, pointToPoint: Boolean? = null): BridgeOptions
fun frameOf(body: Buffer? = null, command: Command? = null, destination: String? = null, headers: Map<String, String>? = null, id: String? = null, transaction: String? = null): Frame
io.vertx.ext.stomp.StompClient

suspend fun StompClient.connectAwait(port: Int, host: String): StompClientConnection
suspend fun StompClient.connectAwait(net: NetClient): StompClientConnection
suspend fun StompClient.connectAwait(port: Int, host: String, net: NetClient): StompClientConnection
suspend fun StompClient.connectAwait(): StompClientConnection

io.vertx.ext.stomp.StompServer

suspend fun StompServer.closeAwait(): Unit
suspend fun StompServer.listenAwait(): StompServer
suspend fun StompServer.listenAwait(port: Int): StompServer
suspend fun StompServer.listenAwait(port: Int, host: String): StompServer

io.vertx.ext.stomp.StompServerHandler

suspend fun StompServerHandler.onAuthenticationRequestAwait(connection: StompServerConnection, login: String, passcode: String): Boolean

fun stompClientOptionsOf(acceptedVersions: Iterable<String>? = null, autoComputeContentLength: Boolean? = null, bypassHostHeader: Boolean? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, heartbeat: JsonObject? = null, host: String? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, login: String? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, passcode: String? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trailingLine: Boolean? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useStompFrame: Boolean? = null, virtualHost: String? = null): StompClientOptions
fun stompServerOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, heartbeat: JsonObject? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, maxBodyLength: Int? = null, maxFrameInTransaction: Int? = null, maxHeaderLength: Int? = null, maxHeaders: Int? = null, maxSubscriptionsByClient: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, secured: Boolean? = null, sendBufferSize: Int? = null, sendErrorOnNoSubscriptions: Boolean? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, supportedVersions: Iterable<String>? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, timeFactor: Int? = null, trafficClass: Int? = null, trailingLine: Boolean? = null, transactionChunkSize: Int? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, websocketBridge: Boolean? = null, websocketPath: String? = null): StompServerOptions

package io.vertx.kotlin.ext.unit

io.vertx.ext.unit.Async

suspend fun Async.handlerAwait(): Unit?

io.vertx.ext.unit.Completion

suspend fun <T> Completion<T>.handlerAwait(): T?

io.vertx.ext.unit.TestCompletion

suspend fun TestCompletion.handlerAwait(): Unit?

fun testOptionsOf(reporters: Iterable<ReportOptions>? = null, timeout: Long? = null, useEventLoop: Boolean? = null): TestOptions

package io.vertx.kotlin.ext.unit.report

io.vertx.ext.unit.report.TestSuiteReport

suspend fun TestSuiteReport.pipeToAwait(dst: WriteStream<TestCaseReport>): Unit

fun reportOptionsOf(format: String? = null, to: String? = null): ReportOptions
fun reportingOptionsOf(reporters: Iterable<ReportOptions>? = null): ReportingOptions

package io.vertx.kotlin.ext.web

fun http2PushMappingOf(extensionTarget: String? = null, filePath: String? = null, noPush: Boolean? = null): Http2PushMapping

package io.vertx.kotlin.ext.web.api

fun operationRequestOf(extra: JsonObject? = null, headers: MultiMap? = null, params: JsonObject? = null, user: JsonObject? = null): OperationRequest
fun operationResponseOf(headers: MultiMap? = null, payload: Buffer? = null, statusCode: Int? = null, statusMessage: String? = null): OperationResponse

package io.vertx.kotlin.ext.web.api.contract

fun routerFactoryOptionsOf(mountNotImplementedHandler: Boolean? = null, mountResponseContentTypeHandler: Boolean? = null, mountValidationFailureHandler: Boolean? = null, operationModelKey: String? = null, requireSecurityHandlers: Boolean? = null): RouterFactoryOptions

package io.vertx.kotlin.ext.web.api.contract.openapi3

object OpenAPI3RouterFactory

suspend fun createAwait(vertx: Vertx, url: String): OpenAPI3RouterFactory
suspend fun createAwait(vertx: Vertx, url: String, auth: List<JsonObject>): OpenAPI3RouterFactory

package io.vertx.kotlin.ext.web.client

io.vertx.ext.web.client.HttpRequest

suspend fun <T> HttpRequest<T>.sendAwait(): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendBufferAwait(body: Buffer): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendFormAwait(body: MultiMap): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendJsonAwait(body: Any): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendJsonObjectAwait(body: JsonObject): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendMultipartFormAwait(body: MultipartForm): HttpResponse<T>
suspend fun <T> HttpRequest<T>.sendStreamAwait(body: ReadStream<Buffer>): HttpResponse<T>

fun webClientOptionsOf(alpnVersions: Iterable<HttpVersion>? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, decoderInitialBufferSize: Int? = null, defaultHost: String? = null, defaultPort: Int? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, followRedirects: Boolean? = null, forceSni: Boolean? = null, http2ClearTextUpgrade: Boolean? = null, http2ConnectionWindowSize: Int? = null, http2KeepAliveTimeout: Int? = null, http2MaxPoolSize: Int? = null, http2MultiplexingLimit: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keepAlive: Boolean? = null, keepAliveTimeout: Int? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxPoolSize: Int? = null, maxRedirects: Int? = null, maxWaitQueueSize: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = null, pipeliningLimit: Int? = null, poolCleanerPeriod: Int? = null, protocolVersion: HttpVersion? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sendUnmaskedFrames: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, userAgent: String? = null, userAgentEnabled: Boolean? = null, verifyHost: Boolean? = null, websocketCompressionAllowClientNoContext: Boolean? = null, websocketCompressionLevel: Int? = null, websocketCompressionRequestServerNoContext: Boolean? = null): WebClientOptions

package io.vertx.kotlin.ext.web.common.template

io.vertx.ext.web.common.template.TemplateEngine

suspend fun TemplateEngine.renderAwait(context: JsonObject, templateFileName: String): Buffer
suspend fun TemplateEngine.renderAwait(context: Map<String, Any>, templateFileName: String): Buffer

package io.vertx.kotlin.ext.web.handler

io.vertx.ext.web.handler.AuthHandler

suspend fun AuthHandler.authorizeAwait(user: User): Unit
suspend fun AuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.BasicAuthHandler

suspend fun BasicAuthHandler.authorizeAwait(user: User): Unit
suspend fun BasicAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.ChainAuthHandler

suspend fun ChainAuthHandler.authorizeAwait(user: User): Unit
suspend fun ChainAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.DigestAuthHandler

suspend fun DigestAuthHandler.authorizeAwait(user: User): Unit
suspend fun DigestAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.JWTAuthHandler

suspend fun JWTAuthHandler.authorizeAwait(user: User): Unit
suspend fun JWTAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.OAuth2AuthHandler

suspend fun OAuth2AuthHandler.authorizeAwait(user: User): Unit
suspend fun OAuth2AuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

io.vertx.ext.web.handler.RedirectAuthHandler

suspend fun RedirectAuthHandler.authorizeAwait(user: User): Unit
suspend fun RedirectAuthHandler.parseCredentialsAwait(context: RoutingContext): JsonObject

package io.vertx.kotlin.ext.web.handler.graphql

fun apolloWSOptionsOf(keepAlive: Long? = null): ApolloWSOptions
fun graphQLHandlerOptionsOf(requestBatchingEnabled: Boolean? = null): GraphQLHandlerOptions
fun graphiQLHandlerOptionsOf(enabled: Boolean? = null, graphQLUri: String? = null, headers: Map<String, String>? = null, query: String? = null, variables: JsonObject? = null): GraphiQLHandlerOptions

package io.vertx.kotlin.ext.web.handler.sockjs

fun bridgeOptionsOf(inboundPermitted: Iterable<PermittedOptions>? = null, inboundPermitteds: Iterable<PermittedOptions>? = null, maxAddressLength: Int? = null, maxHandlersPerSocket: Int? = null, outboundPermitted: Iterable<PermittedOptions>? = null, outboundPermitteds: Iterable<PermittedOptions>? = null, pingTimeout: Long? = null, replyTimeout: Long? = null): BridgeOptions
io.vertx.ext.web.handler.sockjs.SockJSSocket

suspend fun SockJSSocket.endAwait(): Unit
suspend fun SockJSSocket.endAwait(data: Buffer): Unit
suspend fun SockJSSocket.pipeToAwait(dst: WriteStream<Buffer>): Unit
suspend fun SockJSSocket.writeAwait(data: String): Unit
suspend fun SockJSSocket.writeAwait(data: Buffer): Unit

fun sockJSHandlerOptionsOf(disabledTransports: Iterable<String>? = null, heartbeatInterval: Long? = null, insertJSESSIONID: Boolean? = null, libraryURL: String? = null, maxBytesStreaming: Int? = null, sessionTimeout: Long? = null): SockJSHandlerOptions

package io.vertx.kotlin.ext.web.sstore

io.vertx.ext.web.sstore.SessionStore

suspend fun SessionStore.clearAwait(): Unit
suspend fun SessionStore.deleteAwait(id: String): Unit
suspend fun SessionStore.getAwait(cookieValue: String): Session?
suspend fun SessionStore.putAwait(session: Session): Unit
suspend fun SessionStore.sizeAwait(): Int

package io.vertx.kotlin.kafka.admin

fun configEntryOf(default: Boolean? = null, name: String? = null, readOnly: Boolean? = null, sensitive: Boolean? = null, source: ConfigSource? = null, synonyms: Iterable<ConfigSynonym>? = null, value: String? = null): ConfigEntry
fun configOf(entries: Iterable<ConfigEntry>? = null): Config
fun configSynonymOf(name: String? = null, source: ConfigSource? = null, value: String? = null): ConfigSynonym
fun consumerGroupDescriptionOf(coordinator: Node? = null, groupId: String? = null, members: Iterable<MemberDescription>? = null, partitionAssignor: String? = null, simpleConsumerGroup: Boolean? = null, state: ConsumerGroupState? = null): ConsumerGroupDescription
fun consumerGroupListingOf(groupId: String? = null, simpleConsumerGroup: Boolean? = null): ConsumerGroupListing
io.vertx.kafka.admin.KafkaAdminClient

suspend fun KafkaAdminClient.createTopicsAwait(topics: List<NewTopic>): Unit
suspend fun KafkaAdminClient.deleteTopicsAwait(topicNames: List<String>): Unit
suspend fun KafkaAdminClient.describeConsumerGroupsAwait(groupIds: List<String>): Map<String, ConsumerGroupDescription>
suspend fun KafkaAdminClient.describeTopicsAwait(topicNames: List<String>): Map<String, TopicDescription>
suspend fun KafkaAdminClient.listConsumerGroupsAwait(): List<ConsumerGroupListing>
suspend fun KafkaAdminClient.listTopicsAwait(): Set<String>

fun memberAssignmentOf(topicPartitions: Iterable<TopicPartition>? = null): MemberAssignment
fun memberDescriptionOf(assignment: MemberAssignment? = null, clientId: String? = null, consumerId: String? = null, host: String? = null): MemberDescription
fun newTopicOf(config: Map<String, String>? = null, name: String? = null, numPartitions: Int? = null, replicationFactor: Short? = null): NewTopic
fun topicDescriptionOf(internal: Boolean? = null, name: String? = null, partitions: Iterable<TopicPartitionInfo>? = null): TopicDescription

package io.vertx.kotlin.kafka.client.common

fun configResourceOf(default: Boolean? = null, name: String? = null, type: Type? = null): ConfigResource
fun nodeOf(hasRack: Boolean? = null, host: String? = null, id: Int? = null, idString: String? = null, isEmpty: Boolean? = null, port: Int? = null, rack: String? = null): Node
fun partitionInfoOf(inSyncReplicas: Iterable<Node>? = null, leader: Node? = null, partition: Int? = null, replicas: Iterable<Node>? = null, topic: String? = null): PartitionInfo
fun topicPartitionInfoOf(isr: Iterable<Node>? = null, leader: Node? = null, partition: Int? = null, replicas: Iterable<Node>? = null): TopicPartitionInfo
fun topicPartitionOf(partition: Int? = null, topic: String? = null): TopicPartition

package io.vertx.kotlin.kafka.client.consumer

io.vertx.kafka.client.consumer.KafkaConsumer

suspend fun <K, V> KafkaConsumer<K, V>.assignAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.assignAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.assignmentAwait(): Set<TopicPartition>
suspend fun <K, V> KafkaConsumer<K, V>.beginningOffsetsAwait(topicPartition: TopicPartition): Long
suspend fun <K, V> KafkaConsumer<K, V>.closeAwait(): Unit
suspend fun <K, V> KafkaConsumer<K, V>.commitAwait(): Unit
suspend fun <K, V> KafkaConsumer<K, V>.committedAwait(topicPartition: TopicPartition): OffsetAndMetadata
suspend fun <K, V> KafkaConsumer<K, V>.endOffsetsAwait(topicPartition: TopicPartition): Long
suspend fun <K, V> KafkaConsumer<K, V>.offsetsForTimesAwait(topicPartition: TopicPartition, timestamp: Long): OffsetAndTimestamp
suspend fun <K, V> KafkaConsumer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>
suspend fun <K, V> KafkaConsumer<K, V>.pauseAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.pauseAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.pausedAwait(): Set<TopicPartition>
suspend fun <K, V> KafkaConsumer<K, V>.pipeToAwait(dst: WriteStream<KafkaConsumerRecord<K, V>>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.pollAwait(timeout: Long): KafkaConsumerRecords<K, V>
suspend fun <K, V> KafkaConsumer<K, V>.positionAwait(partition: TopicPartition): Long
suspend fun <K, V> KafkaConsumer<K, V>.resumeAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.resumeAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekAwait(topicPartition: TopicPartition, offset: Long): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToBeginningAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToBeginningAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartition: TopicPartition): Unit
suspend fun <K, V> KafkaConsumer<K, V>.seekToEndAwait(topicPartitions: Set<TopicPartition>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.subscribeAwait(topic: String): Unit
suspend fun <K, V> KafkaConsumer<K, V>.subscribeAwait(topics: Set<String>): Unit
suspend fun <K, V> KafkaConsumer<K, V>.subscriptionAwait(): Set<String>
suspend fun <K, V> KafkaConsumer<K, V>.unsubscribeAwait(): Unit

fun offsetAndMetadataOf(metadata: String? = null, offset: Long? = null): OffsetAndMetadata
fun offsetAndTimestampOf(offset: Long? = null, timestamp: Long? = null): OffsetAndTimestamp

package io.vertx.kotlin.kafka.client.producer

io.vertx.kafka.client.producer.KafkaProducer

suspend fun <K, V> KafkaProducer<K, V>.closeAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.closeAwait(timeout: Long): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(data: KafkaProducerRecord<K, V>): Unit
suspend fun <K, V> KafkaProducer<K, V>.flushAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.partitionsForAwait(topic: String): List<PartitionInfo>
suspend fun <K, V> KafkaProducer<K, V>.sendAwait(record: KafkaProducerRecord<K, V>): RecordMetadata
suspend fun <K, V> KafkaProducer<K, V>.writeAwait(data: KafkaProducerRecord<K, V>): Unit

fun recordMetadataOf(checksum: Long? = null, offset: Long? = null, partition: Int? = null, timestamp: Long? = null, topic: String? = null): RecordMetadata

package io.vertx.kotlin.micrometer

fun matchOf(alias: String? = null, domain: MetricsDomain? = null, label: String? = null, type: MatchType? = null, value: String? = null): Match
fun micrometerMetricsOptionsOf(disabledMetricsCategories: Iterable<MetricsDomain>? = null, enabled: Boolean? = null, influxDbOptions: VertxInfluxDbOptions? = null, jmxMetricsOptions: VertxJmxMetricsOptions? = null, jvmMetricsEnabled: Boolean? = null, labelMatches: Iterable<Match>? = null, labelMatchs: Iterable<Match>? = null, labels: Iterable<Label>? = null, prometheusOptions: VertxPrometheusOptions? = null, registryName: String? = null): MicrometerMetricsOptions
fun vertxInfluxDbOptionsOf(batchSize: Int? = null, compressed: Boolean? = null, connectTimeout: Int? = null, db: String? = null, enabled: Boolean? = null, numThreads: Int? = null, password: String? = null, readTimeout: Int? = null, retentionPolicy: String? = null, step: Int? = null, uri: String? = null, userName: String? = null): VertxInfluxDbOptions
fun vertxJmxMetricsOptionsOf(domain: String? = null, enabled: Boolean? = null, step: Int? = null): VertxJmxMetricsOptions
fun vertxPrometheusOptionsOf(embeddedServerEndpoint: String? = null, embeddedServerOptions: HttpServerOptions? = null, enabled: Boolean? = null, publishQuantiles: Boolean? = null, startEmbeddedServer: Boolean? = null): VertxPrometheusOptions

package io.vertx.kotlin.mqtt

io.vertx.mqtt.MqttClient

suspend fun MqttClient.connectAwait(port: Int, host: String): MqttConnAckMessage
suspend fun MqttClient.connectAwait(port: Int, host: String, serverName: String): MqttConnAckMessage
suspend fun MqttClient.disconnectAwait(): Unit
suspend fun MqttClient.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): Int
suspend fun MqttClient.subscribeAwait(topic: String, qos: Int): Int
suspend fun MqttClient.subscribeAwait(topics: Map<String, Int>): Int
suspend fun MqttClient.unsubscribeAwait(topic: String): Int

io.vertx.mqtt.MqttEndpoint

suspend fun MqttEndpoint.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): Int
suspend fun MqttEndpoint.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean, messageId: Int): Int

io.vertx.mqtt.MqttServer

suspend fun MqttServer.closeAwait(): Unit
suspend fun MqttServer.listenAwait(port: Int, host: String): MqttServer
suspend fun MqttServer.listenAwait(port: Int): MqttServer
suspend fun MqttServer.listenAwait(): MqttServer

fun mqttAuthOf(): MqttAuth
fun mqttClientOptionsOf(autoGeneratedClientId: Boolean? = null, autoKeepAlive: Boolean? = null, cleanSession: Boolean? = null, clientId: String? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keepAliveTimeSeconds: Int? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxInflightQueue: Int? = null, maxMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, password: String? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, username: String? = null, willFlag: Boolean? = null, willMessage: String? = null, willQoS: Int? = null, willRetain: Boolean? = null, willTopic: String? = null): MqttClientOptions
fun mqttServerOptionsOf(acceptBacklog: Int? = null, autoClientId: Boolean? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, maxMessageSize: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, timeoutOnConnect: Int? = null, trafficClass: Int? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null): MqttServerOptions
fun mqttWillOf(): MqttWill

package io.vertx.kotlin.mysqlclient

object MySQLConnection

suspend fun connectAwait(vertx: Vertx, connectOptions: MySQLConnectOptions): MySQLConnection
suspend fun connectAwait(vertx: Vertx, connectionUri: String): MySQLConnection

io.vertx.mysqlclient.MySQLConnection

suspend fun MySQLConnection.changeUserAwait(options: MySQLAuthOptions): Unit
suspend fun MySQLConnection.debugAwait(): Unit
suspend fun MySQLConnection.getInternalStatisticsAwait(): String
suspend fun MySQLConnection.pingAwait(): Unit
suspend fun MySQLConnection.prepareAwait(sql: String): PreparedQuery
suspend fun MySQLConnection.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun MySQLConnection.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun MySQLConnection.queryAwait(sql: String): RowSet<Row>
suspend fun MySQLConnection.resetConnectionAwait(): Unit
suspend fun MySQLConnection.setOptionAwait(option: MySQLSetOption): Unit
suspend fun MySQLConnection.specifySchemaAwait(schemaName: String): Unit

io.vertx.mysqlclient.MySQLPool

suspend fun MySQLPool.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun MySQLPool.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun MySQLPool.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun MySQLPool.queryAwait(sql: String): RowSet<Row>

fun mySQLAuthOptionsOf(charset: String? = null, collation: String? = null, database: String? = null, password: String? = null, properties: Map<String, String>? = null, serverRsaPublicKeyPath: String? = null, serverRsaPublicKeyValue: Buffer? = null, user: String? = null): MySQLAuthOptions
fun mySQLConnectOptionsOf(cachePreparedStatements: Boolean? = null, charset: String? = null, collation: String? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, database: String? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, password: String? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, preparedStatementCacheMaxSize: Int? = null, preparedStatementCacheSqlLimit: Int? = null, properties: Map<String, String>? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, serverRsaPublicKeyPath: String? = null, serverRsaPublicKeyValue: Buffer? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, sslMode: SslMode? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, user: String? = null): MySQLConnectOptions

package io.vertx.kotlin.pgclient

object PgConnection

suspend fun connectAwait(vertx: Vertx, options: PgConnectOptions): PgConnection
suspend fun connectAwait(vertx: Vertx): PgConnection
suspend fun connectAwait(vertx: Vertx, connectionUri: String): PgConnection

io.vertx.pgclient.PgConnection

suspend fun PgConnection.prepareAwait(sql: String): PreparedQuery
suspend fun PgConnection.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun PgConnection.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun PgConnection.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun PgConnection.queryAwait(sql: String): RowSet<Row>

io.vertx.pgclient.PgPool

suspend fun PgPool.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun PgPool.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun PgPool.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun PgPool.queryAwait(sql: String): RowSet<Row>

fun pgConnectOptionsOf(cachePreparedStatements: Boolean? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, database: String? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, password: String? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipeliningLimit: Int? = null, port: Int? = null, preparedStatementCacheMaxSize: Int? = null, preparedStatementCacheSqlLimit: Int? = null, properties: Map<String, String>? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, soLinger: Int? = null, ssl: Boolean? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, sslMode: SslMode? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, user: String? = null): PgConnectOptions
fun pgNotificationOf(channel: String? = null, payload: String? = null, processId: Int? = null): PgNotification

package io.vertx.kotlin.pgclient.data

fun boxOf(lowerLeftCorner: Point? = null, upperRightCorner: Point? = null): Box
fun circleOf(centerPoint: Point? = null, radius: Double? = null): Circle
fun intervalOf(days: Int? = null, hours: Int? = null, microseconds: Int? = null, minutes: Int? = null, months: Int? = null, seconds: Int? = null, years: Int? = null): Interval
fun lineOf(a: Double? = null, b: Double? = null, c: Double? = null): Line
fun lineSegmentOf(p1: Point? = null, p2: Point? = null): LineSegment
fun pathOf(open: Boolean? = null, points: Iterable<Point>? = null): Path
fun pointOf(x: Double? = null, y: Double? = null): Point
fun polygonOf(points: Iterable<Point>? = null): Polygon

package io.vertx.kotlin.pgclient.pubsub

io.vertx.pgclient.pubsub.PgChannel

suspend fun PgChannel.pipeToAwait(dst: WriteStream<String>): Unit

io.vertx.pgclient.pubsub.PgSubscriber

suspend fun PgSubscriber.connectAwait(): Unit

package io.vertx.kotlin.rabbitmq

io.vertx.rabbitmq.RabbitMQClient

suspend fun RabbitMQClient.basicAckAwait(deliveryTag: Long, multiple: Boolean): JsonObject
suspend fun RabbitMQClient.basicConsumerAwait(queue: String): RabbitMQConsumer
suspend fun RabbitMQClient.basicConsumerAwait(queue: String, options: QueueOptions): RabbitMQConsumer
suspend fun RabbitMQClient.basicGetAwait(queue: String, autoAck: Boolean): JsonObject
suspend fun RabbitMQClient.basicNackAwait(deliveryTag: Long, multiple: Boolean, requeue: Boolean): JsonObject
suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, message: JsonObject): Unit
suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int): Unit
suspend fun RabbitMQClient.basicQosAwait(prefetchCount: Int, global: Boolean): Unit
suspend fun RabbitMQClient.basicQosAwait(prefetchSize: Int, prefetchCount: Int, global: Boolean): Unit
suspend fun RabbitMQClient.confirmSelectAwait(): Unit
suspend fun RabbitMQClient.exchangeBindAwait(destination: String, source: String, routingKey: String): Unit
suspend fun RabbitMQClient.exchangeDeclareAwait(exchange: String, type: String, durable: Boolean, autoDelete: Boolean): Unit
suspend fun RabbitMQClient.exchangeDeclareAwait(exchange: String, type: String, durable: Boolean, autoDelete: Boolean, config: JsonObject): Unit
suspend fun RabbitMQClient.exchangeDeleteAwait(exchange: String): Unit
suspend fun RabbitMQClient.exchangeUnbindAwait(destination: String, source: String, routingKey: String): Unit
suspend fun RabbitMQClient.messageCountAwait(queue: String): Long
suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String): Unit
suspend fun RabbitMQClient.queueDeclareAutoAwait(): JsonObject
suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean): JsonObject
suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: JsonObject): JsonObject
suspend fun RabbitMQClient.queueDeleteAwait(queue: String): JsonObject
suspend fun RabbitMQClient.queueDeleteIfAwait(queue: String, ifUnused: Boolean, ifEmpty: Boolean): JsonObject
suspend fun RabbitMQClient.startAwait(): Unit
suspend fun RabbitMQClient.stopAwait(): Unit
suspend fun RabbitMQClient.waitForConfirmsAwait(): Unit
suspend fun RabbitMQClient.waitForConfirmsAwait(timeout: Long): Unit

io.vertx.rabbitmq.RabbitMQConsumer

suspend fun RabbitMQConsumer.cancelAwait(): Unit
suspend fun RabbitMQConsumer.pipeToAwait(dst: WriteStream<RabbitMQMessage>): Unit

fun queueOptionsOf(autoAck: Boolean? = null, keepMostRecent: Boolean? = null, maxInternalQueueSize: Int? = null): QueueOptions
fun rabbitMQOptionsOf(automaticRecoveryEnabled: Boolean? = null, connectionRetries: Int? = null, connectionRetryDelay: Long? = null, connectionTimeout: Int? = null, handshakeTimeout: Int? = null, host: String? = null, includeProperties: Boolean? = null, networkRecoveryInterval: Long? = null, password: String? = null, port: Int? = null, requestedChannelMax: Int? = null, requestedHeartbeat: Int? = null, uri: String? = null, user: String? = null, virtualHost: String? = null): RabbitMQOptions

package io.vertx.kotlin.redis.client

io.vertx.redis.client.Redis

suspend fun Redis.connectAwait(): RedisConnection

io.vertx.redis.client.RedisAPI

suspend fun RedisAPI.appendAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.askingAwait(): Response?
suspend fun RedisAPI.authAwait(arg0: String): Response?
suspend fun RedisAPI.bgrewriteaofAwait(): Response?
suspend fun RedisAPI.bgsaveAwait(args: List<String>): Response?
suspend fun RedisAPI.bitcountAwait(args: List<String>): Response?
suspend fun RedisAPI.bitfieldAwait(args: List<String>): Response?
suspend fun RedisAPI.bitopAwait(args: List<String>): Response?
suspend fun RedisAPI.bitposAwait(args: List<String>): Response?
suspend fun RedisAPI.blpopAwait(args: List<String>): Response?
suspend fun RedisAPI.brpopAwait(args: List<String>): Response?
suspend fun RedisAPI.brpoplpushAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.bzpopmaxAwait(args: List<String>): Response?
suspend fun RedisAPI.bzpopminAwait(args: List<String>): Response?
suspend fun RedisAPI.clientAwait(args: List<String>): Response?
suspend fun RedisAPI.clusterAwait(args: List<String>): Response?
suspend fun RedisAPI.commandAwait(): Response?
suspend fun RedisAPI.configAwait(args: List<String>): Response?
suspend fun RedisAPI.dbsizeAwait(): Response?
suspend fun RedisAPI.debugAwait(args: List<String>): Response?
suspend fun RedisAPI.decrAwait(arg0: String): Response?
suspend fun RedisAPI.decrbyAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.delAwait(args: List<String>): Response?
suspend fun RedisAPI.discardAwait(): Response?
suspend fun RedisAPI.dumpAwait(arg0: String): Response?
suspend fun RedisAPI.echoAwait(arg0: String): Response?
suspend fun RedisAPI.evalAwait(args: List<String>): Response?
suspend fun RedisAPI.evalshaAwait(args: List<String>): Response?
suspend fun RedisAPI.execAwait(): Response?
suspend fun RedisAPI.existsAwait(args: List<String>): Response?
suspend fun RedisAPI.expireAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.expireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.flushallAwait(args: List<String>): Response?
suspend fun RedisAPI.flushdbAwait(args: List<String>): Response?
suspend fun RedisAPI.geoaddAwait(args: List<String>): Response?
suspend fun RedisAPI.geodistAwait(args: List<String>): Response?
suspend fun RedisAPI.geohashAwait(args: List<String>): Response?
suspend fun RedisAPI.geoposAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusRoAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusbymemberAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusbymemberRoAwait(args: List<String>): Response?
suspend fun RedisAPI.getAwait(arg0: String): Response?
suspend fun RedisAPI.getbitAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.getrangeAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.getsetAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hdelAwait(args: List<String>): Response?
suspend fun RedisAPI.hexistsAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hgetAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hgetallAwait(arg0: String): Response?
suspend fun RedisAPI.hincrbyAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.hincrbyfloatAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.hkeysAwait(arg0: String): Response?
suspend fun RedisAPI.hlenAwait(arg0: String): Response?
suspend fun RedisAPI.hmgetAwait(args: List<String>): Response?
suspend fun RedisAPI.hmsetAwait(args: List<String>): Response?
suspend fun RedisAPI.hostAwait(args: List<String>): Response?
suspend fun RedisAPI.hscanAwait(args: List<String>): Response?
suspend fun RedisAPI.hsetAwait(args: List<String>): Response?
suspend fun RedisAPI.hsetnxAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.hstrlenAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.hvalsAwait(arg0: String): Response?
suspend fun RedisAPI.incrAwait(arg0: String): Response?
suspend fun RedisAPI.incrbyAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.incrbyfloatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.infoAwait(args: List<String>): Response?
suspend fun RedisAPI.keysAwait(arg0: String): Response?
suspend fun RedisAPI.lastsaveAwait(): Response?
suspend fun RedisAPI.latencyAwait(args: List<String>): Response?
suspend fun RedisAPI.lindexAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.linsertAwait(arg0: String, arg1: String, arg2: String, arg3: String): Response?
suspend fun RedisAPI.llenAwait(arg0: String): Response?
suspend fun RedisAPI.lolwutAwait(args: List<String>): Response?
suspend fun RedisAPI.lpopAwait(arg0: String): Response?
suspend fun RedisAPI.lpushAwait(args: List<String>): Response?
suspend fun RedisAPI.lpushxAwait(args: List<String>): Response?
suspend fun RedisAPI.lrangeAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.lremAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.lsetAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.ltrimAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.memoryAwait(args: List<String>): Response?
suspend fun RedisAPI.mgetAwait(args: List<String>): Response?
suspend fun RedisAPI.migrateAwait(args: List<String>): Response?
suspend fun RedisAPI.moduleAwait(args: List<String>): Response?
suspend fun RedisAPI.monitorAwait(): Response?
suspend fun RedisAPI.moveAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.msetAwait(args: List<String>): Response?
suspend fun RedisAPI.msetnxAwait(args: List<String>): Response?
suspend fun RedisAPI.multiAwait(): Response?
suspend fun RedisAPI.objectAwait(args: List<String>): Response?
suspend fun RedisAPI.persistAwait(arg0: String): Response?
suspend fun RedisAPI.pexpireAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pexpireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pfaddAwait(args: List<String>): Response?
suspend fun RedisAPI.pfcountAwait(args: List<String>): Response?
suspend fun RedisAPI.pfdebugAwait(args: List<String>): Response?
suspend fun RedisAPI.pfmergeAwait(args: List<String>): Response?
suspend fun RedisAPI.pfselftestAwait(): Response?
suspend fun RedisAPI.pingAwait(args: List<String>): Response?
suspend fun RedisAPI.postAwait(args: List<String>): Response?
suspend fun RedisAPI.psetexAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.psubscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.psyncAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pttlAwait(arg0: String): Response?
suspend fun RedisAPI.publishAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pubsubAwait(args: List<String>): Response?
suspend fun RedisAPI.punsubscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.randomkeyAwait(): Response?
suspend fun RedisAPI.readonlyAwait(): Response?
suspend fun RedisAPI.readwriteAwait(): Response?
suspend fun RedisAPI.renameAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.renamenxAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.replconfAwait(args: List<String>): Response?
suspend fun RedisAPI.replicaofAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.restoreAskingAwait(args: List<String>): Response?
suspend fun RedisAPI.restoreAwait(args: List<String>): Response?
suspend fun RedisAPI.roleAwait(): Response?
suspend fun RedisAPI.rpopAwait(arg0: String): Response?
suspend fun RedisAPI.rpoplpushAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.rpushAwait(args: List<String>): Response?
suspend fun RedisAPI.rpushxAwait(args: List<String>): Response?
suspend fun RedisAPI.saddAwait(args: List<String>): Response?
suspend fun RedisAPI.saveAwait(): Response?
suspend fun RedisAPI.scanAwait(args: List<String>): Response?
suspend fun RedisAPI.scardAwait(arg0: String): Response?
suspend fun RedisAPI.scriptAwait(args: List<String>): Response?
suspend fun RedisAPI.sdiffAwait(args: List<String>): Response?
suspend fun RedisAPI.sdiffstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.selectAwait(arg0: String): Response?
suspend fun RedisAPI.setAwait(args: List<String>): Response?
suspend fun RedisAPI.setbitAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.setexAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.setnxAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.setrangeAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.shutdownAwait(args: List<String>): Response?
suspend fun RedisAPI.sinterAwait(args: List<String>): Response?
suspend fun RedisAPI.sinterstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.sismemberAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.slaveofAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.slowlogAwait(args: List<String>): Response?
suspend fun RedisAPI.smembersAwait(arg0: String): Response?
suspend fun RedisAPI.smoveAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.sortAwait(args: List<String>): Response?
suspend fun RedisAPI.spopAwait(args: List<String>): Response?
suspend fun RedisAPI.srandmemberAwait(args: List<String>): Response?
suspend fun RedisAPI.sremAwait(args: List<String>): Response?
suspend fun RedisAPI.sscanAwait(args: List<String>): Response?
suspend fun RedisAPI.strlenAwait(arg0: String): Response?
suspend fun RedisAPI.subscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.substrAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.sunionAwait(args: List<String>): Response?
suspend fun RedisAPI.sunionstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.swapdbAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.syncAwait(): Response?
suspend fun RedisAPI.timeAwait(): Response?
suspend fun RedisAPI.touchAwait(args: List<String>): Response?
suspend fun RedisAPI.ttlAwait(arg0: String): Response?
suspend fun RedisAPI.typeAwait(arg0: String): Response?
suspend fun RedisAPI.unlinkAwait(args: List<String>): Response?
suspend fun RedisAPI.unsubscribeAwait(args: List<String>): Response?
suspend fun RedisAPI.unwatchAwait(): Response?
suspend fun RedisAPI.waitAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.watchAwait(args: List<String>): Response?
suspend fun RedisAPI.xackAwait(args: List<String>): Response?
suspend fun RedisAPI.xaddAwait(args: List<String>): Response?
suspend fun RedisAPI.xclaimAwait(args: List<String>): Response?
suspend fun RedisAPI.xdelAwait(args: List<String>): Response?
suspend fun RedisAPI.xgroupAwait(args: List<String>): Response?
suspend fun RedisAPI.xinfoAwait(args: List<String>): Response?
suspend fun RedisAPI.xlenAwait(arg0: String): Response?
suspend fun RedisAPI.xpendingAwait(args: List<String>): Response?
suspend fun RedisAPI.xrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.xreadAwait(args: List<String>): Response?
suspend fun RedisAPI.xreadgroupAwait(args: List<String>): Response?
suspend fun RedisAPI.xrevrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.xsetidAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.xtrimAwait(args: List<String>): Response?
suspend fun RedisAPI.zaddAwait(args: List<String>): Response?
suspend fun RedisAPI.zcardAwait(arg0: String): Response?
suspend fun RedisAPI.zcountAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zincrbyAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zinterstoreAwait(args: List<String>): Response?
suspend fun RedisAPI.zlexcountAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zpopmaxAwait(args: List<String>): Response?
suspend fun RedisAPI.zpopminAwait(args: List<String>): Response?
suspend fun RedisAPI.zrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.zrangebylexAwait(args: List<String>): Response?
suspend fun RedisAPI.zrangebyscoreAwait(args: List<String>): Response?
suspend fun RedisAPI.zrankAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.zremAwait(args: List<String>): Response?
suspend fun RedisAPI.zremrangebylexAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zremrangebyrankAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zremrangebyscoreAwait(arg0: String, arg1: String, arg2: String): Response?
suspend fun RedisAPI.zrevrangeAwait(args: List<String>): Response?
suspend fun RedisAPI.zrevrangebylexAwait(args: List<String>): Response?
suspend fun RedisAPI.zrevrangebyscoreAwait(args: List<String>): Response?
suspend fun RedisAPI.zrevrankAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.zscanAwait(args: List<String>): Response?
suspend fun RedisAPI.zscoreAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.zunionstoreAwait(args: List<String>): Response?

io.vertx.redis.client.RedisConnection

suspend fun RedisConnection.batchAwait(commands: List<Request>): List<Response>
suspend fun RedisConnection.pipeToAwait(dst: WriteStream<Response>): Unit
suspend fun RedisConnection.sendAwait(command: Request): Response?

fun redisOptionsOf(endpoint: String? = null, endpoints: Iterable<String>? = null, masterName: String? = null, maxNestedArrays: Int? = null, maxPoolSize: Int? = null, maxPoolWaiting: Int? = null, maxWaitingHandlers: Int? = null, netClientOptions: NetClientOptions? = null, poolCleanerInterval: Int? = null, poolRecycleTimeout: Int? = null, role: RedisRole? = null, type: RedisClientType? = null, useSlave: RedisSlaves? = null): RedisOptions

package io.vertx.kotlin.servicediscovery

io.vertx.servicediscovery.ServiceDiscovery

suspend fun ServiceDiscovery.getRecordAwait(filter: JsonObject): Record?
suspend fun ServiceDiscovery.getRecordAwait(filter: (Record) -> Boolean): Record?
suspend fun ServiceDiscovery.getRecordAwait(filter: (Record) -> Boolean, includeOutOfService: Boolean): Record?
suspend fun ServiceDiscovery.getRecordsAwait(filter: JsonObject): List<Record>
suspend fun ServiceDiscovery.getRecordsAwait(filter: (Record) -> Boolean): List<Record>
suspend fun ServiceDiscovery.getRecordsAwait(filter: (Record) -> Boolean, includeOutOfService: Boolean): List<Record>
suspend fun ServiceDiscovery.publishAwait(record: Record): Record
suspend fun ServiceDiscovery.registerServiceExporterAwait(exporter: ServiceExporter, configuration: JsonObject): Unit
suspend fun ServiceDiscovery.registerServiceImporterAwait(importer: ServiceImporter, configuration: JsonObject): Unit
suspend fun ServiceDiscovery.unpublishAwait(id: String): Unit
suspend fun ServiceDiscovery.updateAwait(record: Record): Record

fun recordOf(location: JsonObject? = null, metadata: JsonObject? = null, name: String? = null, registration: String? = null, status: Status? = null, type: String? = null): Record
fun serviceDiscoveryOptionsOf(announceAddress: String? = null, autoRegistrationOfImporters: Boolean? = null, backendConfiguration: JsonObject? = null, name: String? = null, usageAddress: String? = null): ServiceDiscoveryOptions

package io.vertx.kotlin.servicediscovery.spi

io.vertx.servicediscovery.spi.ServicePublisher

suspend fun ServicePublisher.publishAwait(record: Record): Record
suspend fun ServicePublisher.unpublishAwait(id: String): Unit
suspend fun ServicePublisher.updateAwait(record: Record): Record

package io.vertx.kotlin.servicediscovery.types

object HttpEndpoint

suspend fun getClientAwait(discovery: ServiceDiscovery, filter: JsonObject): HttpClient
suspend fun getClientAwait(discovery: ServiceDiscovery, filter: JsonObject, conf: JsonObject): HttpClient
suspend fun getClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): HttpClient
suspend fun getClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, conf: JsonObject): HttpClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: JsonObject): WebClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: JsonObject, conf: JsonObject): WebClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): WebClient
suspend fun getWebClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, conf: JsonObject): WebClient

object JDBCDataSource

suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: JsonObject): JDBCClient
suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): JDBCClient
suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): JDBCClient
suspend fun getJDBCClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, consumerConfiguration: JsonObject): JDBCClient

object MessageSource

suspend fun <T> getConsumerAwait(discovery: ServiceDiscovery, filter: JsonObject): MessageConsumer<T>
suspend fun <T> getConsumerAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): MessageConsumer<T>

object MongoDataSource

suspend fun getMongoClientAwait(discovery: ServiceDiscovery, filter: JsonObject): MongoClient
suspend fun getMongoClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): MongoClient
suspend fun getMongoClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): MongoClient

object RedisDataSource

suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: JsonObject): Redis
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): Redis
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): Redis
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, consumerConfiguration: JsonObject): Redis

fun httpLocationOf(endpoint: String? = null, host: String? = null, port: Int? = null, root: String? = null, ssl: Boolean? = null): HttpLocation

package io.vertx.kotlin.sqlclient

io.vertx.sqlclient.Cursor

suspend fun Cursor.closeAwait(): Unit
suspend fun Cursor.readAwait(count: Int): RowSet<Row>

io.vertx.sqlclient.Pool

suspend fun Pool.beginAwait(): Transaction
suspend fun Pool.getConnectionAwait(): SqlConnection
suspend fun Pool.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun Pool.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun Pool.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun Pool.queryAwait(sql: String): RowSet<Row>

io.vertx.sqlclient.PreparedQuery

suspend fun PreparedQuery.batchAwait(argsList: List<Tuple>): RowSet<Row>
suspend fun PreparedQuery.closeAwait(): Unit
suspend fun PreparedQuery.executeAwait(): RowSet<Row>
suspend fun PreparedQuery.executeAwait(args: Tuple): RowSet<Row>

io.vertx.sqlclient.RowStream

suspend fun <T> RowStream<T>.closeAwait(): Unit
suspend fun <T> RowStream<T>.pipeToAwait(dst: WriteStream<T>): Unit

io.vertx.sqlclient.SqlClient

suspend fun SqlClient.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun SqlClient.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun SqlClient.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun SqlClient.queryAwait(sql: String): RowSet<Row>

io.vertx.sqlclient.SqlConnection

suspend fun SqlConnection.prepareAwait(sql: String): PreparedQuery
suspend fun SqlConnection.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun SqlConnection.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun SqlConnection.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun SqlConnection.queryAwait(sql: String): RowSet<Row>

io.vertx.sqlclient.Transaction

suspend fun Transaction.commitAwait(): Unit
suspend fun Transaction.prepareAwait(sql: String): PreparedQuery
suspend fun Transaction.preparedBatchAwait(sql: String, batch: List<Tuple>): RowSet<Row>
suspend fun Transaction.preparedQueryAwait(sql: String): RowSet<Row>
suspend fun Transaction.preparedQueryAwait(sql: String, arguments: Tuple): RowSet<Row>
suspend fun Transaction.queryAwait(sql: String): RowSet<Row>
suspend fun Transaction.rollbackAwait(): Unit

fun poolOptionsOf(maxSize: Int? = null, maxWaitQueueSize: Int? = null): PoolOptions