vertx

alltypes

object AzureADAuth

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

object DB2Connection

suspend fun connectAwait(vertx: Vertx, connectOptions: DB2ConnectOptions): DB2Connection
suspend fun connectAwait(vertx: Vertx, connectionUri: String): DB2Connection

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): RedisClient
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): RedisClient
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): RedisClient
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, consumerConfiguration: JsonObject): RedisClient

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.amqpbridge.AmqpBridge

suspend fun AmqpBridge.closeAwait(): Unit
suspend fun AmqpBridge.startAwait(hostname: String, port: Int, username: String, password: String): AmqpBridge
suspend fun AmqpBridge.startAwait(hostname: String, port: Int): AmqpBridge

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

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(data: Buffer): Unit
suspend fun AsyncFile.endAwait(): 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.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.pipeToAwait(dst: WriteStream<HttpClientResponse>): Unit
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.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
suspend fun HttpServerRequest.toNetSocketAwait(): NetSocket
suspend fun HttpServerRequest.toWebSocketAwait(): ServerWebSocket

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.setHandshakeAwait(future: Future<Int>): Int
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.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.db2client.DB2Connection

suspend fun DB2Connection.debugAwait(): Unit
suspend fun DB2Connection.pingAwait(): Unit
suspend fun DB2Connection.prepareAwait(sql: String): PreparedStatement

io.vertx.ext.asyncsql.AsyncSQLClient

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

io.vertx.ext.asyncsql.MySQLClient

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

io.vertx.ext.asyncsql.PostgreSQLClient

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

io.vertx.ext.auth.AuthProvider

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

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.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.consul.ConsulService

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

suspend fun MailService.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.createIndexAwait(collection: String, key: JsonObject): Unit
suspend fun MongoClient.createIndexWithOptionsAwait(collection: String, key: JsonObject, options: IndexOptions): 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.MongoService

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

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.SessionHandler

suspend fun SessionHandler.flushAwait(ctx: RoutingContext): Unit

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: 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.closeAwait(): Unit
suspend fun KafkaAdminClient.closeAwait(timeout: Long): Unit
suspend fun KafkaAdminClient.createTopicsAwait(topics: List<NewTopic>): Unit
suspend fun KafkaAdminClient.deleteConsumerGroupOffsetsAwait(groupId: String, partitions: Set<TopicPartition>): Unit
suspend fun KafkaAdminClient.deleteConsumerGroupsAwait(groupIds: List<String>): Unit
suspend fun KafkaAdminClient.deleteTopicsAwait(topicNames: List<String>): Unit
suspend fun KafkaAdminClient.describeClusterAwait(): ClusterDescription
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: Duration): 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>.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): PreparedStatement
suspend fun MySQLConnection.resetConnectionAwait(): Unit
suspend fun MySQLConnection.setOptionAwait(option: MySQLSetOption): Unit
suspend fun MySQLConnection.specifySchemaAwait(schemaName: String): Unit

io.vertx.pgclient.PgConnection

suspend fun PgConnection.prepareAwait(sql: String): PreparedStatement

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.exchangeBindAwait(destination: String, source: String, routingKey: String, arguments: Map<String, Any>): 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.exchangeUnbindAwait(destination: String, source: String, routingKey: String, arguments: Map<String, Any>): Unit
suspend fun RabbitMQClient.messageCountAwait(queue: String): Long
suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String): Unit
suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String, arguments: Map<String, Any>): 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.queueUnbindAwait(queue: String, exchange: String, routingKey: String): Unit
suspend fun RabbitMQClient.queueUnbindAwait(queue: String, exchange: String, routingKey: String, arguments: Map<String, Any>): Unit
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.RedisClient

suspend fun RedisClient.appendAwait(key: String, value: String): Long
suspend fun RedisClient.authAwait(password: String): String
suspend fun RedisClient.bgrewriteaofAwait(): String
suspend fun RedisClient.bgsaveAwait(): String
suspend fun RedisClient.bitcountAwait(key: String): Long
suspend fun RedisClient.bitcountRangeAwait(key: String, start: Long, end: Long): Long
suspend fun RedisClient.bitfieldAwait(key: String, bitFieldOptions: BitFieldOptions): JsonArray
suspend fun RedisClient.bitfieldWithOverflowAwait(key: String, commands: BitFieldOptions, overflow: BitFieldOverflowOptions): JsonArray
suspend fun RedisClient.bitopAwait(operation: BitOperation, destkey: String, keys: List<String>): Long
suspend fun RedisClient.bitposAwait(key: String, bit: Int): Long
suspend fun RedisClient.bitposFromAwait(key: String, bit: Int, start: Int): Long
suspend fun RedisClient.bitposRangeAwait(key: String, bit: Int, start: Int, stop: Int): Long
suspend fun RedisClient.blpopAwait(key: String, seconds: Int): JsonArray
suspend fun RedisClient.blpopManyAwait(keys: List<String>, seconds: Int): JsonArray
suspend fun RedisClient.brpopAwait(key: String, seconds: Int): JsonArray
suspend fun RedisClient.brpopManyAwait(keys: List<String>, seconds: Int): JsonArray
suspend fun RedisClient.brpoplpushAwait(key: String, destkey: String, seconds: Int): String
suspend fun RedisClient.clientGetnameAwait(): String
suspend fun RedisClient.clientKillAwait(filter: KillFilter): Long
suspend fun RedisClient.clientListAwait(): String
suspend fun RedisClient.clientPauseAwait(millis: Long): String
suspend fun RedisClient.clientReplyAwait(options: ClientReplyOptions): String
suspend fun RedisClient.clientSetnameAwait(name: String): String
suspend fun RedisClient.closeAwait(): Unit
suspend fun RedisClient.clusterAddslotsAwait(slots: List<Long>): Unit
suspend fun RedisClient.clusterCountFailureReportsAwait(nodeId: String): Long
suspend fun RedisClient.clusterCountkeysinslotAwait(slot: Long): Long
suspend fun RedisClient.clusterDelslotsAwait(slot: Long): Unit
suspend fun RedisClient.clusterDelslotsManyAwait(slots: List<Long>): Unit
suspend fun RedisClient.clusterFailOverWithOptionsAwait(options: FailoverOptions): Unit
suspend fun RedisClient.clusterFailoverAwait(): Unit
suspend fun RedisClient.clusterForgetAwait(nodeId: String): Unit
suspend fun RedisClient.clusterGetkeysinslotAwait(slot: Long, count: Long): JsonArray
suspend fun RedisClient.clusterInfoAwait(): JsonArray
suspend fun RedisClient.clusterKeyslotAwait(key: String): Long
suspend fun RedisClient.clusterMeetAwait(ip: String, port: Long): Unit
suspend fun RedisClient.clusterNodesAwait(): JsonArray
suspend fun RedisClient.clusterReplicateAwait(nodeId: String): Unit
suspend fun RedisClient.clusterResetAwait(): Unit
suspend fun RedisClient.clusterResetWithOptionsAwait(options: ResetOptions): Unit
suspend fun RedisClient.clusterSaveconfigAwait(): Unit
suspend fun RedisClient.clusterSetConfigEpochAwait(epoch: Long): Unit
suspend fun RedisClient.clusterSetslotAwait(slot: Long, subcommand: SlotCmd): Unit
suspend fun RedisClient.clusterSetslotWithNodeAwait(slot: Long, subcommand: SlotCmd, nodeId: String): Unit
suspend fun RedisClient.clusterSlavesAwait(nodeId: String): JsonArray
suspend fun RedisClient.clusterSlotsAwait(): JsonArray
suspend fun RedisClient.commandAwait(): JsonArray
suspend fun RedisClient.commandCountAwait(): Long
suspend fun RedisClient.commandGetkeysAwait(): JsonArray
suspend fun RedisClient.commandInfoAwait(commands: List<String>): JsonArray
suspend fun RedisClient.configGetAwait(parameter: String): JsonArray
suspend fun RedisClient.configResetstatAwait(): String
suspend fun RedisClient.configRewriteAwait(): String
suspend fun RedisClient.configSetAwait(parameter: String, value: String): String
suspend fun RedisClient.dbsizeAwait(): Long
suspend fun RedisClient.debugObjectAwait(key: String): String
suspend fun RedisClient.debugSegfaultAwait(): String
suspend fun RedisClient.decrAwait(key: String): Long
suspend fun RedisClient.decrbyAwait(key: String, decrement: Long): Long
suspend fun RedisClient.delAwait(key: String): Long
suspend fun RedisClient.delManyAwait(keys: List<String>): Long
suspend fun RedisClient.dumpAwait(key: String): String
suspend fun RedisClient.echoAwait(message: String): String
suspend fun RedisClient.evalAwait(script: String, keys: List<String>, args: List<String>): JsonArray
suspend fun RedisClient.evalScriptAwait(script: Script, keys: List<String>, args: List<String>): JsonArray
suspend fun RedisClient.evalshaAwait(sha1: String, keys: List<String>, values: List<String>): JsonArray
suspend fun RedisClient.existsAwait(key: String): Long
suspend fun RedisClient.existsManyAwait(keys: List<String>): Long
suspend fun RedisClient.expireAwait(key: String, seconds: Long): Long
suspend fun RedisClient.expireatAwait(key: String, seconds: Long): Long
suspend fun RedisClient.flushallAwait(): String
suspend fun RedisClient.flushdbAwait(): String
suspend fun RedisClient.geoaddAwait(key: String, longitude: Double, latitude: Double, member: String): Long
suspend fun RedisClient.geoaddManyAwait(key: String, members: List<GeoMember>): Long
suspend fun RedisClient.geodistAwait(key: String, member1: String, member2: String): String
suspend fun RedisClient.geodistWithUnitAwait(key: String, member1: String, member2: String, unit: GeoUnit): String
suspend fun RedisClient.geohashAwait(key: String, member: String): JsonArray
suspend fun RedisClient.geohashManyAwait(key: String, members: List<String>): JsonArray
suspend fun RedisClient.geoposAwait(key: String, member: String): JsonArray
suspend fun RedisClient.geoposManyAwait(key: String, members: List<String>): JsonArray
suspend fun RedisClient.georadiusAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit): JsonArray
suspend fun RedisClient.georadiusWithOptionsAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): JsonArray
suspend fun RedisClient.georadiusbymemberAwait(key: String, member: String, radius: Double, unit: GeoUnit): JsonArray
suspend fun RedisClient.georadiusbymemberWithOptionsAwait(key: String, member: String, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): JsonArray
suspend fun RedisClient.getAwait(key: String): String?
suspend fun RedisClient.getBinaryAwait(key: String): Buffer?
suspend fun RedisClient.getbitAwait(key: String, offset: Long): Long
suspend fun RedisClient.getrangeAwait(key: String, start: Long, end: Long): String
suspend fun RedisClient.getsetAwait(key: String, value: String): String?
suspend fun RedisClient.hdelAwait(key: String, field: String): Long
suspend fun RedisClient.hdelManyAwait(key: String, fields: List<String>): Long
suspend fun RedisClient.hexistsAwait(key: String, field: String): Long
suspend fun RedisClient.hgetAwait(key: String, field: String): String?
suspend fun RedisClient.hgetallAwait(key: String): JsonObject
suspend fun RedisClient.hincrbyAwait(key: String, field: String, increment: Long): Long
suspend fun RedisClient.hincrbyfloatAwait(key: String, field: String, increment: Double): String
suspend fun RedisClient.hkeysAwait(key: String): JsonArray
suspend fun RedisClient.hlenAwait(key: String): Long
suspend fun RedisClient.hmgetAwait(key: String, fields: List<String>): JsonArray
suspend fun RedisClient.hmsetAwait(key: String, values: JsonObject): String
suspend fun RedisClient.hscanAwait(key: String, cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.hsetAwait(key: String, field: String, value: String): Long
suspend fun RedisClient.hsetnxAwait(key: String, field: String, value: String): Long
suspend fun RedisClient.hstrlenAwait(key: String, field: String): Long
suspend fun RedisClient.hvalsAwait(key: String): JsonArray
suspend fun RedisClient.incrAwait(key: String): Long
suspend fun RedisClient.incrbyAwait(key: String, increment: Long): Long
suspend fun RedisClient.incrbyfloatAwait(key: String, increment: Double): String
suspend fun RedisClient.infoAwait(): JsonObject
suspend fun RedisClient.infoSectionAwait(section: String): JsonObject
suspend fun RedisClient.keysAwait(pattern: String): JsonArray
suspend fun RedisClient.lastsaveAwait(): Long
suspend fun RedisClient.lindexAwait(key: String, index: Int): String
suspend fun RedisClient.linsertAwait(key: String, option: InsertOptions, pivot: String, value: String): Long
suspend fun RedisClient.llenAwait(key: String): Long
suspend fun RedisClient.lpopAwait(key: String): String?
suspend fun RedisClient.lpushAwait(key: String, value: String): Long
suspend fun RedisClient.lpushManyAwait(key: String, values: List<String>): Long
suspend fun RedisClient.lpushxAwait(key: String, value: String): Long
suspend fun RedisClient.lrangeAwait(key: String, from: Long, to: Long): JsonArray
suspend fun RedisClient.lremAwait(key: String, count: Long, value: String): Long
suspend fun RedisClient.lsetAwait(key: String, index: Long, value: String): String
suspend fun RedisClient.ltrimAwait(key: String, from: Long, to: Long): String
suspend fun RedisClient.mgetAwait(key: String): JsonArray
suspend fun RedisClient.mgetManyAwait(keys: List<String>): JsonArray
suspend fun RedisClient.migrateAwait(host: String, port: Int, key: String, destdb: Int, timeout: Long, options: MigrateOptions): String
suspend fun RedisClient.monitorAwait(): Unit
suspend fun RedisClient.moveAwait(key: String, destdb: Int): Long
suspend fun RedisClient.msetAwait(keyvals: JsonObject): String
suspend fun RedisClient.msetnxAwait(keyvals: JsonObject): Long
suspend fun RedisClient.objectAwait(key: String, cmd: ObjectCmd): Unit
suspend fun RedisClient.persistAwait(key: String): Long
suspend fun RedisClient.pexpireAwait(key: String, millis: Long): Long
suspend fun RedisClient.pexpireatAwait(key: String, millis: Long): Long
suspend fun RedisClient.pfaddAwait(key: String, element: String): Long
suspend fun RedisClient.pfaddManyAwait(key: String, elements: List<String>): Long
suspend fun RedisClient.pfcountAwait(key: String): Long
suspend fun RedisClient.pfcountManyAwait(keys: List<String>): Long
suspend fun RedisClient.pfmergeAwait(destkey: String, keys: List<String>): String
suspend fun RedisClient.pingAwait(): String
suspend fun RedisClient.psetexAwait(key: String, millis: Long, value: String): Unit
suspend fun RedisClient.psubscribeAwait(pattern: String): JsonArray
suspend fun RedisClient.psubscribeManyAwait(patterns: List<String>): JsonArray
suspend fun RedisClient.pttlAwait(key: String): Long
suspend fun RedisClient.publishAwait(channel: String, message: String): Long
suspend fun RedisClient.pubsubChannelsAwait(pattern: String): JsonArray
suspend fun RedisClient.pubsubNumpatAwait(): Long
suspend fun RedisClient.pubsubNumsubAwait(channels: List<String>): JsonArray
suspend fun RedisClient.punsubscribeAwait(patterns: List<String>): Unit
suspend fun RedisClient.randomkeyAwait(): String
suspend fun RedisClient.renameAwait(key: String, newkey: String): String
suspend fun RedisClient.renamenxAwait(key: String, newkey: String): Long
suspend fun RedisClient.restoreAwait(key: String, millis: Long, serialized: String): String
suspend fun RedisClient.roleAwait(): JsonArray
suspend fun RedisClient.rpopAwait(key: String): String
suspend fun RedisClient.rpoplpushAwait(key: String, destkey: String): String
suspend fun RedisClient.rpushAwait(key: String, value: String): Long
suspend fun RedisClient.rpushManyAwait(key: String, values: List<String>): Long
suspend fun RedisClient.rpushxAwait(key: String, value: String): Long
suspend fun RedisClient.saddAwait(key: String, member: String): Long
suspend fun RedisClient.saddManyAwait(key: String, members: List<String>): Long
suspend fun RedisClient.saveAwait(): String
suspend fun RedisClient.scanAwait(cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.scardAwait(key: String): Long
suspend fun RedisClient.scriptDebugAwait(scriptDebugOptions: ScriptDebugOptions): String
suspend fun RedisClient.scriptExistsAwait(script: String): JsonArray
suspend fun RedisClient.scriptExistsManyAwait(scripts: List<String>): JsonArray
suspend fun RedisClient.scriptFlushAwait(): String
suspend fun RedisClient.scriptKillAwait(): String
suspend fun RedisClient.scriptLoadAwait(script: String): String
suspend fun RedisClient.sdiffAwait(key: String, cmpkeys: List<String>): JsonArray
suspend fun RedisClient.sdiffstoreAwait(destkey: String, key: String, cmpkeys: List<String>): Long
suspend fun RedisClient.selectAwait(dbindex: Int): String
suspend fun RedisClient.setAwait(key: String, value: String): Unit
suspend fun RedisClient.setBinaryAwait(key: String, value: Buffer): Unit
suspend fun RedisClient.setBinaryWithOptionsAwait(key: String, value: Buffer, options: SetOptions): Unit
suspend fun RedisClient.setWithOptionsAwait(key: String, value: String, options: SetOptions): String
suspend fun RedisClient.setbitAwait(key: String, offset: Long, bit: Int): Long
suspend fun RedisClient.setexAwait(key: String, seconds: Long, value: String): String
suspend fun RedisClient.setnxAwait(key: String, value: String): Long
suspend fun RedisClient.setrangeAwait(key: String, offset: Int, value: String): Long
suspend fun RedisClient.sinterAwait(keys: List<String>): JsonArray
suspend fun RedisClient.sinterstoreAwait(destkey: String, keys: List<String>): Long
suspend fun RedisClient.sismemberAwait(key: String, member: String): Long
suspend fun RedisClient.slaveofAwait(host: String, port: Int): String
suspend fun RedisClient.slaveofNooneAwait(): String
suspend fun RedisClient.slowlogGetAwait(limit: Int): JsonArray
suspend fun RedisClient.slowlogLenAwait(): Long
suspend fun RedisClient.slowlogResetAwait(): Unit
suspend fun RedisClient.smembersAwait(key: String): JsonArray
suspend fun RedisClient.smoveAwait(key: String, destkey: String, member: String): Long
suspend fun RedisClient.sortAwait(key: String, options: SortOptions): JsonArray
suspend fun RedisClient.spopAwait(key: String): String?
suspend fun RedisClient.spopManyAwait(key: String, count: Int): JsonArray
suspend fun RedisClient.srandmemberAwait(key: String): String
suspend fun RedisClient.srandmemberCountAwait(key: String, count: Int): JsonArray
suspend fun RedisClient.sremAwait(key: String, member: String): Long
suspend fun RedisClient.sremManyAwait(key: String, members: List<String>): Long
suspend fun RedisClient.sscanAwait(key: String, cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.strlenAwait(key: String): Long
suspend fun RedisClient.subscribeAwait(channel: String): JsonArray
suspend fun RedisClient.subscribeManyAwait(channels: List<String>): JsonArray
suspend fun RedisClient.sunionAwait(keys: List<String>): JsonArray
suspend fun RedisClient.sunionstoreAwait(destkey: String, keys: List<String>): Long
suspend fun RedisClient.swapdbAwait(index1: Int, index2: Int): String
suspend fun RedisClient.syncAwait(): Unit
suspend fun RedisClient.timeAwait(): JsonArray
suspend fun RedisClient.touchAwait(key: String): Long
suspend fun RedisClient.touchManyAwait(keys: List<String>): Long
suspend fun RedisClient.ttlAwait(key: String): Long
suspend fun RedisClient.typeAwait(key: String): String
suspend fun RedisClient.unlinkAwait(key: String): Long
suspend fun RedisClient.unlinkManyAwait(keys: List<String>): Long
suspend fun RedisClient.unsubscribeAwait(channels: List<String>): Unit
suspend fun RedisClient.waitAwait(numSlaves: Long, timeout: Long): String
suspend fun RedisClient.zaddAwait(key: String, score: Double, member: String): Long
suspend fun RedisClient.zaddManyAwait(key: String, members: Map<String, Double>): Long
suspend fun RedisClient.zcardAwait(key: String): Long
suspend fun RedisClient.zcountAwait(key: String, min: Double, max: Double): Long
suspend fun RedisClient.zincrbyAwait(key: String, increment: Double, member: String): String
suspend fun RedisClient.zinterstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): Long
suspend fun RedisClient.zinterstoreWeighedAwait(destkey: String, sets: Map<String, Double>, options: AggregateOptions): Long
suspend fun RedisClient.zlexcountAwait(key: String, min: String, max: String): Long
suspend fun RedisClient.zrangeAwait(key: String, start: Long, stop: Long): JsonArray
suspend fun RedisClient.zrangeWithOptionsAwait(key: String, start: Long, stop: Long, options: RangeOptions): JsonArray
suspend fun RedisClient.zrangebylexAwait(key: String, min: String, max: String, options: LimitOptions): JsonArray
suspend fun RedisClient.zrangebyscoreAwait(key: String, min: String, max: String, options: RangeLimitOptions): JsonArray
suspend fun RedisClient.zrankAwait(key: String, member: String): Long
suspend fun RedisClient.zremAwait(key: String, member: String): Long
suspend fun RedisClient.zremManyAwait(key: String, members: List<String>): Long
suspend fun RedisClient.zremrangebylexAwait(key: String, min: String, max: String): Long
suspend fun RedisClient.zremrangebyrankAwait(key: String, start: Long, stop: Long): Long
suspend fun RedisClient.zremrangebyscoreAwait(key: String, min: String, max: String): Long
suspend fun RedisClient.zrevrangeAwait(key: String, start: Long, stop: Long, options: RangeOptions): JsonArray
suspend fun RedisClient.zrevrangebylexAwait(key: String, max: String, min: String, options: LimitOptions): JsonArray
suspend fun RedisClient.zrevrangebyscoreAwait(key: String, max: String, min: String, options: RangeLimitOptions): JsonArray
suspend fun RedisClient.zrevrankAwait(key: String, member: String): Long
suspend fun RedisClient.zscanAwait(key: String, cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.zscoreAwait(key: String, member: String): String
suspend fun RedisClient.zunionstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): Long
suspend fun RedisClient.zunionstoreWeighedAwait(key: String, sets: Map<String, Double>, options: AggregateOptions): Long

io.vertx.redis.RedisTransaction

suspend fun RedisTransaction.appendAwait(key: String, value: String): String
suspend fun RedisTransaction.authAwait(password: String): String
suspend fun RedisTransaction.bgrewriteaofAwait(): String
suspend fun RedisTransaction.bgsaveAwait(): String
suspend fun RedisTransaction.bitcountAwait(key: String): String
suspend fun RedisTransaction.bitcountRangeAwait(key: String, start: Long, end: Long): String
suspend fun RedisTransaction.bitopAwait(operation: BitOperation, destkey: String, keys: List<String>): String
suspend fun RedisTransaction.bitposAwait(key: String, bit: Int): String
suspend fun RedisTransaction.bitposFromAwait(key: String, bit: Int, start: Int): String
suspend fun RedisTransaction.bitposRangeAwait(key: String, bit: Int, start: Int, stop: Int): String
suspend fun RedisTransaction.blpopAwait(key: String, seconds: Int): String
suspend fun RedisTransaction.blpopManyAwait(keys: List<String>, seconds: Int): String
suspend fun RedisTransaction.brpopAwait(key: String, seconds: Int): String
suspend fun RedisTransaction.brpopManyAwait(keys: List<String>, seconds: Int): String
suspend fun RedisTransaction.brpoplpushAwait(key: String, destkey: String, seconds: Int): String
suspend fun RedisTransaction.clientGetnameAwait(): String
suspend fun RedisTransaction.clientKillAwait(filter: KillFilter): String
suspend fun RedisTransaction.clientListAwait(): String
suspend fun RedisTransaction.clientPauseAwait(millis: Long): String
suspend fun RedisTransaction.clientSetnameAwait(name: String): String
suspend fun RedisTransaction.closeAwait(): Unit
suspend fun RedisTransaction.clusterAddslotsAwait(slots: List<String>): String
suspend fun RedisTransaction.clusterCountFailureReportsAwait(nodeId: String): String
suspend fun RedisTransaction.clusterCountkeysinslotAwait(slot: Long): String
suspend fun RedisTransaction.clusterDelslotsAwait(slot: Long): String
suspend fun RedisTransaction.clusterDelslotsManyAwait(slots: List<String>): String
suspend fun RedisTransaction.clusterFailOverWithOptionsAwait(options: FailoverOptions): String
suspend fun RedisTransaction.clusterFailoverAwait(): String
suspend fun RedisTransaction.clusterForgetAwait(nodeId: String): String
suspend fun RedisTransaction.clusterGetkeysinslotAwait(slot: Long, count: Long): String
suspend fun RedisTransaction.clusterInfoAwait(): String
suspend fun RedisTransaction.clusterKeyslotAwait(key: String): String
suspend fun RedisTransaction.clusterMeetAwait(ip: String, port: Long): String
suspend fun RedisTransaction.clusterNodesAwait(): String
suspend fun RedisTransaction.clusterReplicateAwait(nodeId: String): String
suspend fun RedisTransaction.clusterResetAwait(): String
suspend fun RedisTransaction.clusterResetWithOptionsAwait(options: ResetOptions): String
suspend fun RedisTransaction.clusterSaveconfigAwait(): String
suspend fun RedisTransaction.clusterSetConfigEpochAwait(epoch: Long): String
suspend fun RedisTransaction.clusterSetslotAwait(slot: Long, subcommand: SlotCmd): String
suspend fun RedisTransaction.clusterSetslotWithNodeAwait(slot: Long, subcommand: SlotCmd, nodeId: String): String
suspend fun RedisTransaction.clusterSlavesAwait(nodeId: String): String
suspend fun RedisTransaction.clusterSlotsAwait(): String
suspend fun RedisTransaction.commandAwait(): String
suspend fun RedisTransaction.commandCountAwait(): String
suspend fun RedisTransaction.commandGetkeysAwait(): String
suspend fun RedisTransaction.commandInfoAwait(commands: List<String>): String
suspend fun RedisTransaction.configGetAwait(parameter: String): String
suspend fun RedisTransaction.configResetstatAwait(): String
suspend fun RedisTransaction.configRewriteAwait(): String
suspend fun RedisTransaction.configSetAwait(parameter: String, value: String): String
suspend fun RedisTransaction.dbsizeAwait(): String
suspend fun RedisTransaction.debugObjectAwait(key: String): String
suspend fun RedisTransaction.debugSegfaultAwait(): String
suspend fun RedisTransaction.decrAwait(key: String): String
suspend fun RedisTransaction.decrbyAwait(key: String, decrement: Long): String
suspend fun RedisTransaction.delAwait(key: String): String
suspend fun RedisTransaction.delManyAwait(keys: List<String>): String
suspend fun RedisTransaction.discardAwait(): String
suspend fun RedisTransaction.dumpAwait(key: String): String
suspend fun RedisTransaction.echoAwait(message: String): String
suspend fun RedisTransaction.evalAwait(script: String, keys: List<String>, args: List<String>): String
suspend fun RedisTransaction.evalshaAwait(sha1: String, keys: List<String>, values: List<String>): String
suspend fun RedisTransaction.execAwait(): JsonArray
suspend fun RedisTransaction.existsAwait(key: String): String
suspend fun RedisTransaction.existsManyAwait(keys: List<String>): String
suspend fun RedisTransaction.expireAwait(key: String, seconds: Int): String
suspend fun RedisTransaction.expireatAwait(key: String, seconds: Long): String
suspend fun RedisTransaction.flushallAwait(): String
suspend fun RedisTransaction.flushdbAwait(): String
suspend fun RedisTransaction.geoaddAwait(key: String, longitude: Double, latitude: Double, member: String): String
suspend fun RedisTransaction.geoaddManyAwait(key: String, members: List<GeoMember>): String
suspend fun RedisTransaction.geodistAwait(key: String, member1: String, member2: String): String
suspend fun RedisTransaction.geodistWithUnitAwait(key: String, member1: String, member2: String, unit: GeoUnit): String
suspend fun RedisTransaction.geohashAwait(key: String, member: String): String
suspend fun RedisTransaction.geohashManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.geoposAwait(key: String, member: String): String
suspend fun RedisTransaction.geoposManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.georadiusAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit): String
suspend fun RedisTransaction.georadiusWithOptionsAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): String
suspend fun RedisTransaction.georadiusbymemberAwait(key: String, member: String, radius: Double, unit: GeoUnit): String
suspend fun RedisTransaction.georadiusbymemberWithOptionsAwait(key: String, member: String, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): String
suspend fun RedisTransaction.getAwait(key: String): String
suspend fun RedisTransaction.getBinaryAwait(key: String): Buffer
suspend fun RedisTransaction.getbitAwait(key: String, offset: Long): String
suspend fun RedisTransaction.getrangeAwait(key: String, start: Long, end: Long): String
suspend fun RedisTransaction.getsetAwait(key: String, value: String): String
suspend fun RedisTransaction.hdelAwait(key: String, field: String): String
suspend fun RedisTransaction.hdelManyAwait(key: String, fields: List<String>): String
suspend fun RedisTransaction.hexistsAwait(key: String, field: String): String
suspend fun RedisTransaction.hgetAwait(key: String, field: String): String
suspend fun RedisTransaction.hgetallAwait(key: String): String
suspend fun RedisTransaction.hincrbyAwait(key: String, field: String, increment: Long): String
suspend fun RedisTransaction.hincrbyfloatAwait(key: String, field: String, increment: Double): String
suspend fun RedisTransaction.hkeysAwait(key: String): String
suspend fun RedisTransaction.hlenAwait(key: String): String
suspend fun RedisTransaction.hmgetAwait(key: String, fields: List<String>): String
suspend fun RedisTransaction.hmsetAwait(key: String, values: JsonObject): String
suspend fun RedisTransaction.hscanAwait(key: String, cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.hsetAwait(key: String, field: String, value: String): String
suspend fun RedisTransaction.hsetnxAwait(key: String, field: String, value: String): String
suspend fun RedisTransaction.hvalsAwait(key: String): String
suspend fun RedisTransaction.incrAwait(key: String): String
suspend fun RedisTransaction.incrbyAwait(key: String, increment: Long): String
suspend fun RedisTransaction.incrbyfloatAwait(key: String, increment: Double): String
suspend fun RedisTransaction.infoAwait(): String
suspend fun RedisTransaction.infoSectionAwait(section: String): String
suspend fun RedisTransaction.keysAwait(pattern: String): String
suspend fun RedisTransaction.lastsaveAwait(): String
suspend fun RedisTransaction.lindexAwait(key: String, index: Int): String
suspend fun RedisTransaction.linsertAwait(key: String, option: InsertOptions, pivot: String, value: String): String
suspend fun RedisTransaction.llenAwait(key: String): String
suspend fun RedisTransaction.lpopAwait(key: String): String
suspend fun RedisTransaction.lpushAwait(key: String, value: String): String
suspend fun RedisTransaction.lpushManyAwait(key: String, values: List<String>): String
suspend fun RedisTransaction.lpushxAwait(key: String, value: String): String
suspend fun RedisTransaction.lrangeAwait(key: String, from: Long, to: Long): String
suspend fun RedisTransaction.lremAwait(key: String, count: Long, value: String): String
suspend fun RedisTransaction.lsetAwait(key: String, index: Long, value: String): String
suspend fun RedisTransaction.ltrimAwait(key: String, from: Long, to: Long): String
suspend fun RedisTransaction.mgetAwait(key: String): String
suspend fun RedisTransaction.mgetManyAwait(keys: List<String>): String
suspend fun RedisTransaction.migrateAwait(host: String, port: Int, key: String, destdb: Int, timeout: Long, options: MigrateOptions): String
suspend fun RedisTransaction.monitorAwait(): String
suspend fun RedisTransaction.moveAwait(key: String, destdb: Int): String
suspend fun RedisTransaction.msetAwait(keyvals: JsonObject): String
suspend fun RedisTransaction.msetnxAwait(keyvals: JsonObject): String
suspend fun RedisTransaction.multiAwait(): String
suspend fun RedisTransaction.objectAwait(key: String, cmd: ObjectCmd): String
suspend fun RedisTransaction.persistAwait(key: String): String
suspend fun RedisTransaction.pexpireAwait(key: String, millis: Long): String
suspend fun RedisTransaction.pexpireatAwait(key: String, millis: Long): String
suspend fun RedisTransaction.pfaddAwait(key: String, element: String): String
suspend fun RedisTransaction.pfaddManyAwait(key: String, elements: List<String>): String
suspend fun RedisTransaction.pfcountAwait(key: String): String
suspend fun RedisTransaction.pfcountManyAwait(keys: List<String>): String
suspend fun RedisTransaction.pfmergeAwait(destkey: String, keys: List<String>): String
suspend fun RedisTransaction.pingAwait(): String
suspend fun RedisTransaction.psetexAwait(key: String, millis: Long, value: String): String
suspend fun RedisTransaction.psubscribeAwait(pattern: String): String
suspend fun RedisTransaction.psubscribeManyAwait(patterns: List<String>): String
suspend fun RedisTransaction.pttlAwait(key: String): String
suspend fun RedisTransaction.publishAwait(channel: String, message: String): String
suspend fun RedisTransaction.pubsubChannelsAwait(pattern: String): String
suspend fun RedisTransaction.pubsubNumpatAwait(): String
suspend fun RedisTransaction.pubsubNumsubAwait(channels: List<String>): String
suspend fun RedisTransaction.punsubscribeAwait(patterns: List<String>): String
suspend fun RedisTransaction.randomkeyAwait(): String
suspend fun RedisTransaction.renameAwait(key: String, newkey: String): String
suspend fun RedisTransaction.renamenxAwait(key: String, newkey: String): String
suspend fun RedisTransaction.restoreAwait(key: String, millis: Long, serialized: String): String
suspend fun RedisTransaction.roleAwait(): String
suspend fun RedisTransaction.rpopAwait(key: String): String
suspend fun RedisTransaction.rpoplpushAwait(key: String, destkey: String): String
suspend fun RedisTransaction.rpushAwait(key: String, value: String): String
suspend fun RedisTransaction.rpushManyAwait(key: String, values: List<String>): String
suspend fun RedisTransaction.rpushxAwait(key: String, value: String): String
suspend fun RedisTransaction.saddAwait(key: String, member: String): String
suspend fun RedisTransaction.saddManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.saveAwait(): String
suspend fun RedisTransaction.scanAwait(cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.scardAwait(key: String): String
suspend fun RedisTransaction.scriptExistsAwait(script: String): String
suspend fun RedisTransaction.scriptExistsManyAwait(scripts: List<String>): String
suspend fun RedisTransaction.scriptFlushAwait(): String
suspend fun RedisTransaction.scriptKillAwait(): String
suspend fun RedisTransaction.scriptLoadAwait(script: String): String
suspend fun RedisTransaction.sdiffAwait(key: String, cmpkeys: List<String>): String
suspend fun RedisTransaction.sdiffstoreAwait(destkey: String, key: String, cmpkeys: List<String>): String
suspend fun RedisTransaction.selectAwait(dbindex: Int): String
suspend fun RedisTransaction.setAwait(key: String, value: String): String
suspend fun RedisTransaction.setBinaryAwait(key: String, value: Buffer): String
suspend fun RedisTransaction.setBinaryWithOptionsAwait(key: String, value: Buffer, options: SetOptions): String
suspend fun RedisTransaction.setWithOptionsAwait(key: String, value: String, options: SetOptions): String
suspend fun RedisTransaction.setbitAwait(key: String, offset: Long, bit: Int): String
suspend fun RedisTransaction.setexAwait(key: String, seconds: Long, value: String): String
suspend fun RedisTransaction.setnxAwait(key: String, value: String): String
suspend fun RedisTransaction.setrangeAwait(key: String, offset: Int, value: String): String
suspend fun RedisTransaction.sinterAwait(keys: List<String>): String
suspend fun RedisTransaction.sinterstoreAwait(destkey: String, keys: List<String>): String
suspend fun RedisTransaction.sismemberAwait(key: String, member: String): String
suspend fun RedisTransaction.slaveofAwait(host: String, port: Int): String
suspend fun RedisTransaction.slaveofNooneAwait(): String
suspend fun RedisTransaction.slowlogGetAwait(limit: Int): String
suspend fun RedisTransaction.slowlogLenAwait(): String
suspend fun RedisTransaction.slowlogResetAwait(): String
suspend fun RedisTransaction.smembersAwait(key: String): JsonArray
suspend fun RedisTransaction.smoveAwait(key: String, destkey: String, member: String): String
suspend fun RedisTransaction.sortAwait(key: String, options: SortOptions): String
suspend fun RedisTransaction.spopAwait(key: String): String
suspend fun RedisTransaction.spopManyAwait(key: String, count: Int): String
suspend fun RedisTransaction.srandmemberAwait(key: String): String
suspend fun RedisTransaction.srandmemberCountAwait(key: String, count: Int): String
suspend fun RedisTransaction.sremAwait(key: String, member: String): String
suspend fun RedisTransaction.sremManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.sscanAwait(key: String, cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.strlenAwait(key: String): String
suspend fun RedisTransaction.subscribeAwait(channel: String): String
suspend fun RedisTransaction.subscribeManyAwait(channels: List<String>): String
suspend fun RedisTransaction.sunionAwait(keys: List<String>): String
suspend fun RedisTransaction.sunionstoreAwait(destkey: String, keys: List<String>): String
suspend fun RedisTransaction.swapdbAwait(index1: Int, index2: Int): String
suspend fun RedisTransaction.syncAwait(): String
suspend fun RedisTransaction.timeAwait(): String
suspend fun RedisTransaction.ttlAwait(key: String): String
suspend fun RedisTransaction.typeAwait(key: String): String
suspend fun RedisTransaction.unlinkAwait(key: String): String
suspend fun RedisTransaction.unlinkManyAwait(keys: List<String>): String
suspend fun RedisTransaction.unsubscribeAwait(channels: List<String>): String
suspend fun RedisTransaction.unwatchAwait(): String
suspend fun RedisTransaction.waitAwait(numSlaves: Long, timeout: Long): String
suspend fun RedisTransaction.watchAwait(key: String): String
suspend fun RedisTransaction.watchManyAwait(keys: List<String>): String
suspend fun RedisTransaction.zaddAwait(key: String, score: Double, member: String): String
suspend fun RedisTransaction.zaddManyAwait(key: String, members: Map<String, Double>): String
suspend fun RedisTransaction.zcardAwait(key: String): String
suspend fun RedisTransaction.zcountAwait(key: String, min: Double, max: Double): String
suspend fun RedisTransaction.zincrbyAwait(key: String, increment: Double, member: String): String
suspend fun RedisTransaction.zinterstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): String
suspend fun RedisTransaction.zinterstoreWeighedAwait(destkey: String, sets: Map<String, Double>, options: AggregateOptions): String
suspend fun RedisTransaction.zlexcountAwait(key: String, min: String, max: String): String
suspend fun RedisTransaction.zrangeAwait(key: String, start: Long, stop: Long): String
suspend fun RedisTransaction.zrangeWithOptionsAwait(key: String, start: Long, stop: Long, options: RangeOptions): String
suspend fun RedisTransaction.zrangebylexAwait(key: String, min: String, max: String, options: LimitOptions): String
suspend fun RedisTransaction.zrangebyscoreAwait(key: String, min: String, max: String, options: RangeLimitOptions): String
suspend fun RedisTransaction.zrankAwait(key: String, member: String): String
suspend fun RedisTransaction.zremAwait(key: String, member: String): String
suspend fun RedisTransaction.zremManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.zremrangebylexAwait(key: String, min: String, max: String): String
suspend fun RedisTransaction.zremrangebyrankAwait(key: String, start: Long, stop: Long): String
suspend fun RedisTransaction.zremrangebyscoreAwait(key: String, min: String, max: String): String
suspend fun RedisTransaction.zrevrangeAwait(key: String, start: Long, stop: Long, options: RangeOptions): String
suspend fun RedisTransaction.zrevrangebylexAwait(key: String, max: String, min: String, options: LimitOptions): String
suspend fun RedisTransaction.zrevrangebyscoreAwait(key: String, max: String, min: String, options: RangeLimitOptions): String
suspend fun RedisTransaction.zrevrankAwait(key: String, member: String): String
suspend fun RedisTransaction.zscanAwait(key: String, cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.zscoreAwait(key: String, member: String): String
suspend fun RedisTransaction.zunionstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): String
suspend fun RedisTransaction.zunionstoreWeighedAwait(key: String, sets: Map<String, Double>, options: AggregateOptions): String

io.vertx.redis.client.Redis

suspend fun Redis.batchAwait(commands: List<Request>): List<Response?>
suspend fun Redis.connectAwait(): RedisConnection
suspend fun Redis.sendAwait(command: Request): Response?

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.redis.sentinel.RedisSentinel

suspend fun RedisSentinel.ckquorumAwait(name: String): String
suspend fun RedisSentinel.closeAwait(): Unit
suspend fun RedisSentinel.failoverAwait(name: String): String
suspend fun RedisSentinel.flushConfigAwait(): Unit
suspend fun RedisSentinel.getMasterAddrByNameAwait(name: String): JsonArray
suspend fun RedisSentinel.masterAwait(name: String): JsonArray
suspend fun RedisSentinel.mastersAwait(): JsonArray
suspend fun RedisSentinel.resetAwait(pattern: String): Unit
suspend fun RedisSentinel.sentinelsAwait(name: String): JsonArray
suspend fun RedisSentinel.slavesAwait(name: String): JsonArray

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

io.vertx.sqlclient.PreparedQuery

suspend fun <T> PreparedQuery<T>.executeAwait(): T
suspend fun <T> PreparedQuery<T>.executeAwait(tuple: Tuple): T
suspend fun <T> PreparedQuery<T>.executeBatchAwait(batch: List<Tuple>): T

io.vertx.sqlclient.PreparedStatement

suspend fun PreparedStatement.closeAwait(): Unit

io.vertx.sqlclient.Query

suspend fun <T> Query<T>.executeAwait(): T

io.vertx.sqlclient.RowStream

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

io.vertx.sqlclient.SqlConnection

suspend fun SqlConnection.prepareAwait(sql: String): PreparedStatement

io.vertx.sqlclient.Transaction

suspend fun Transaction.commitAwait(): Unit
suspend fun Transaction.prepareAwait(sql: String): PreparedStatement
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, usePooledBuffers: 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, capabilities: Iterable<String>? = null, capabilitys: Iterable<String>? = 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.amqpbridge

fun amqpBridgeOptionsOf(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, 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, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reconnectAttempts: Int? = null, reconnectInterval: Long? = null, replyHandlingSupport: Boolean? = 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, usePooledBuffers: Boolean? = null, vhost: String? = null, virtualHost: String? = null): AmqpBridgeOptions
io.vertx.amqpbridge.AmqpBridge

suspend fun AmqpBridge.closeAwait(): Unit
suspend fun AmqpBridge.startAwait(hostname: String, port: Int, username: String, password: String): AmqpBridge
suspend fun AmqpBridge.startAwait(hostname: String, port: Int): AmqpBridge

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, multiThreaded: Boolean? = null, worker: Boolean? = null, workerPoolName: String? = null, workerPoolSize: Int? = null): DeploymentOptions
io.vertx.core.CompositeFuture

suspend fun CompositeFuture.onCompleteAwait(): 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>.onCompleteAwait(): 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, fileResolverCachingEnabled: Boolean? = 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, 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): DatagramSocket
suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, networkInterface: String, sourceToBlock: String): DatagramSocket
suspend fun DatagramSocket.closeAwait(): Unit
suspend fun DatagramSocket.listenAwait(port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String): DatagramSocket
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String?): DatagramSocket
suspend fun DatagramSocket.pipeToAwait(dst: WriteStream<DatagramPacket>): Unit
suspend fun DatagramSocket.sendAwait(packet: Buffer, port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.sendAwait(str: String, port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.sendAwait(str: String, enc: String, port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String): DatagramSocket
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String?): DatagramSocket

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, roundRobinInetAddress: 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, usePooledBuffers: 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(data: Buffer): Unit
suspend fun AsyncFile.endAwait(): 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, 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, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebSocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, usePooledBuffers: Boolean? = null, verifyHost: Boolean? = null, webSocketClosingTimeout: Int? = null, webSocketCompressionAllowClientNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketCompressionRequestServerNoContext: 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, clientAuthRequired: Boolean? = 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, maxFormAttributeSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxWebSocketFrameSize: Int? = null, maxWebSocketMessageSize: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, perFrameWebSocketCompressionSupported: Boolean? = null, perFrameWebsocketCompressionSupported: Boolean? = null, perMessageWebSocketCompressionSupported: 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, usePooledBuffers: Boolean? = null, webSocketAllowServerNoContext: Boolean? = null, webSocketClosingTimeout: Int? = null, webSocketCompressionLevel: Int? = null, webSocketPreferredClientNoContext: Boolean? = null, webSocketSubProtocols: Iterable<String>? = null, websocketAllowServerNoContext: Boolean? = null, websocketCompressionLevel: Int? = null, websocketPreferredClientNoContext: Boolean? = null, websocketSubProtocols: String? = null): HttpServerOptions
io.vertx.core.http.HttpClient

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.pipeToAwait(dst: WriteStream<HttpClientResponse>): Unit
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.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
suspend fun HttpServerRequest.toNetSocketAwait(): NetSocket
suspend fun HttpServerRequest.toWebSocketAwait(): ServerWebSocket

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.setHandshakeAwait(future: Future<Int>): Int
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(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.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 keyStoreOptionsOf(password: String? = null, path: String? = null, provider: String? = null, type: String? = null, value: Buffer? = null): KeyStoreOptions
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, usePooledBuffers: Boolean? = null): NetClientOptions
fun netServerOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, clientAuthRequired: Boolean? = 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, usePooledBuffers: 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.db2client

object DB2Connection

suspend fun connectAwait(vertx: Vertx, connectOptions: DB2ConnectOptions): DB2Connection
suspend fun connectAwait(vertx: Vertx, connectionUri: String): DB2Connection

fun db2ConnectOptionsOf(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, 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, 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, usePooledBuffers: Boolean? = null, user: String? = null): DB2ConnectOptions
io.vertx.db2client.DB2Connection

suspend fun DB2Connection.debugAwait(): Unit
suspend fun DB2Connection.pingAwait(): Unit
suspend fun DB2Connection.prepareAwait(sql: String): PreparedStatement

package io.vertx.kotlin.ext.asyncsql

io.vertx.ext.asyncsql.AsyncSQLClient

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

io.vertx.ext.asyncsql.MySQLClient

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

io.vertx.ext.asyncsql.PostgreSQLClient

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

package io.vertx.kotlin.ext.auth

io.vertx.ext.auth.AuthProvider

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

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
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
fun secretOptionsOf(secret: String? = null, type: String? = null): SecretOptions

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, secrets: Iterable<SecretOptions>? = null): JWTAuthOptions
fun jwtKeyStoreOptionsOf(password: String? = null, path: String? = null, type: String? = null): JWTKeyStoreOptions
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.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.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, 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, tokenPath: String? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebSocketCompression: Boolean? = null, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebSocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, useBasicAuthorizationHeader: Boolean? = null, usePooledBuffers: Boolean? = null, userAgent: String? = null, userInfoParameters: JsonObject? = null, userInfoPath: String? = null, validateIssuer: Boolean? = null, verifyHost: Boolean? = null, webSocketClosingTimeout: Int? = null, webSocketCompressionAllowClientNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketCompressionRequestServerNoContext: 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, 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, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebSocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, usePooledBuffers: Boolean? = null, userAgent: String? = null, userAgentEnabled: Boolean? = null, verifyHost: Boolean? = null, webSocketClosingTimeout: Int? = null, webSocketCompressionAllowClientNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketCompressionRequestServerNoContext: 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

io.vertx.ext.consul.ConsulService

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

io.vertx.ext.mail.MailService

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

fun mailAttachmentOf(contentId: String? = null, contentType: String? = null, data: Buffer? = null, description: String? = null, disposition: String? = null, headers: Map<String, String>? = null, name: String? = null): MailAttachment
fun mailConfigOf(allowRcptErrors: Boolean? = null, authMethods: String? = null, disableEsmtp: Boolean? = null, enabledSecureTransportProtocols: Iterable<String>? = 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 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.createIndexAwait(collection: String, key: JsonObject): Unit
suspend fun MongoClient.createIndexWithOptionsAwait(collection: String, key: JsonObject, options: IndexOptions): 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.MongoService

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

fun mongoClientBulkWriteResultOf(): MongoClientBulkWriteResult
fun mongoClientDeleteResultOf(): MongoClientDeleteResult
fun mongoClientUpdateResultOf(): MongoClientUpdateResult
fun updateOptionsOf(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, clientAuthRequired: Boolean? = 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, maxFormAttributeSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxWebSocketFrameSize: Int? = null, maxWebSocketMessageSize: Int? = null, maxWebsocketFrameSize: Int? = null, maxWebsocketMessageSize: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, perFrameWebSocketCompressionSupported: Boolean? = null, perFrameWebsocketCompressionSupported: Boolean? = null, perMessageWebSocketCompressionSupported: 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, usePooledBuffers: Boolean? = null, vertsShellJsResource: Buffer? = null, webSocketAllowServerNoContext: Boolean? = null, webSocketClosingTimeout: Int? = null, webSocketCompressionLevel: Int? = null, webSocketPreferredClientNoContext: Boolean? = null, webSocketSubProtocols: Iterable<String>? = 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, clientAuthRequired: Boolean? = 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, usePooledBuffers: 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, maxRows: 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, usePooledBuffers: Boolean? = null, useStompFrame: Boolean? = null, virtualHost: String? = null): StompClientOptions
fun stompServerOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, clientAuthRequired: Boolean? = 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, usePooledBuffers: 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, 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, tryUsePerFrameWebsocketCompression: Boolean? = null, tryUsePerMessageWebSocketCompression: Boolean? = null, tryUsePerMessageWebsocketCompression: Boolean? = null, useAlpn: Boolean? = null, usePooledBuffers: Boolean? = null, userAgent: String? = null, userAgentEnabled: Boolean? = null, verifyHost: Boolean? = null, webSocketClosingTimeout: Int? = null, webSocketCompressionAllowClientNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketCompressionRequestServerNoContext: 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

io.vertx.ext.web.handler.SessionHandler

suspend fun SessionHandler.flushAwait(ctx: RoutingContext): Unit

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: Buffer): Unit

fun permittedOptionsOf(address: String? = null, addressRegex: String? = null, match: JsonObject? = null, requiredAuthority: String? = null): PermittedOptions
fun sockJSBridgeOptionsOf(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): SockJSBridgeOptions
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 clusterDescriptionOf(clusterId: String? = null, controller: Node? = null, nodes: Iterable<Node>? = null): ClusterDescription
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.closeAwait(): Unit
suspend fun KafkaAdminClient.closeAwait(timeout: Long): Unit
suspend fun KafkaAdminClient.createTopicsAwait(topics: List<NewTopic>): Unit
suspend fun KafkaAdminClient.deleteConsumerGroupOffsetsAwait(groupId: String, partitions: Set<TopicPartition>): Unit
suspend fun KafkaAdminClient.deleteConsumerGroupsAwait(groupIds: List<String>): Unit
suspend fun KafkaAdminClient.deleteTopicsAwait(topicNames: List<String>): Unit
suspend fun KafkaAdminClient.describeClusterAwait(): ClusterDescription
suspend fun KafkaAdminClient.listConsumerGroupsAwait(): List<ConsumerGroupListing>
suspend fun KafkaAdminClient.listTopicsAwait(): Set<String>

fun listConsumerGroupOffsetsOptionsOf(): ListConsumerGroupOffsetsOptions
fun listOffsetsResultInfoOf(offset: Long? = null, timestamp: Long? = null): ListOffsetsResultInfo
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 offsetSpecOf(spec: Long? = null): OffsetSpec
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: Duration): 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>.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(ackTimeout: Int? = null, 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, keepAliveInterval: Int? = 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, usePooledBuffers: 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, clientAuthRequired: Boolean? = 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, usePooledBuffers: 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): PreparedStatement
suspend fun MySQLConnection.resetConnectionAwait(): Unit
suspend fun MySQLConnection.setOptionAwait(option: MySQLSetOption): Unit
suspend fun MySQLConnection.specifySchemaAwait(schemaName: String): Unit

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(authenticationPlugin: MySQLAuthenticationPlugin? = null, cachePreparedStatements: Boolean? = null, characterEncoding: String? = 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, useAffectedRows: Boolean? = null, useAlpn: Boolean? = null, usePooledBuffers: 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): PreparedStatement

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, usePooledBuffers: 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.exchangeBindAwait(destination: String, source: String, routingKey: String, arguments: Map<String, Any>): 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.exchangeUnbindAwait(destination: String, source: String, routingKey: String, arguments: Map<String, Any>): Unit
suspend fun RabbitMQClient.messageCountAwait(queue: String): Long
suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String): Unit
suspend fun RabbitMQClient.queueBindAwait(queue: String, exchange: String, routingKey: String, arguments: Map<String, Any>): 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.queueUnbindAwait(queue: String, exchange: String, routingKey: String): Unit
suspend fun RabbitMQClient.queueUnbindAwait(queue: String, exchange: String, routingKey: String, arguments: Map<String, Any>): Unit
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

io.vertx.redis.RedisClient

suspend fun RedisClient.appendAwait(key: String, value: String): Long
suspend fun RedisClient.authAwait(password: String): String
suspend fun RedisClient.bgrewriteaofAwait(): String
suspend fun RedisClient.bgsaveAwait(): String
suspend fun RedisClient.bitcountAwait(key: String): Long
suspend fun RedisClient.bitcountRangeAwait(key: String, start: Long, end: Long): Long
suspend fun RedisClient.bitfieldAwait(key: String, bitFieldOptions: BitFieldOptions): JsonArray
suspend fun RedisClient.bitfieldWithOverflowAwait(key: String, commands: BitFieldOptions, overflow: BitFieldOverflowOptions): JsonArray
suspend fun RedisClient.bitopAwait(operation: BitOperation, destkey: String, keys: List<String>): Long
suspend fun RedisClient.bitposAwait(key: String, bit: Int): Long
suspend fun RedisClient.bitposFromAwait(key: String, bit: Int, start: Int): Long
suspend fun RedisClient.bitposRangeAwait(key: String, bit: Int, start: Int, stop: Int): Long
suspend fun RedisClient.blpopAwait(key: String, seconds: Int): JsonArray
suspend fun RedisClient.blpopManyAwait(keys: List<String>, seconds: Int): JsonArray
suspend fun RedisClient.brpopAwait(key: String, seconds: Int): JsonArray
suspend fun RedisClient.brpopManyAwait(keys: List<String>, seconds: Int): JsonArray
suspend fun RedisClient.brpoplpushAwait(key: String, destkey: String, seconds: Int): String
suspend fun RedisClient.clientGetnameAwait(): String
suspend fun RedisClient.clientKillAwait(filter: KillFilter): Long
suspend fun RedisClient.clientListAwait(): String
suspend fun RedisClient.clientPauseAwait(millis: Long): String
suspend fun RedisClient.clientReplyAwait(options: ClientReplyOptions): String
suspend fun RedisClient.clientSetnameAwait(name: String): String
suspend fun RedisClient.closeAwait(): Unit
suspend fun RedisClient.clusterAddslotsAwait(slots: List<Long>): Unit
suspend fun RedisClient.clusterCountFailureReportsAwait(nodeId: String): Long
suspend fun RedisClient.clusterCountkeysinslotAwait(slot: Long): Long
suspend fun RedisClient.clusterDelslotsAwait(slot: Long): Unit
suspend fun RedisClient.clusterDelslotsManyAwait(slots: List<Long>): Unit
suspend fun RedisClient.clusterFailOverWithOptionsAwait(options: FailoverOptions): Unit
suspend fun RedisClient.clusterFailoverAwait(): Unit
suspend fun RedisClient.clusterForgetAwait(nodeId: String): Unit
suspend fun RedisClient.clusterGetkeysinslotAwait(slot: Long, count: Long): JsonArray
suspend fun RedisClient.clusterInfoAwait(): JsonArray
suspend fun RedisClient.clusterKeyslotAwait(key: String): Long
suspend fun RedisClient.clusterMeetAwait(ip: String, port: Long): Unit
suspend fun RedisClient.clusterNodesAwait(): JsonArray
suspend fun RedisClient.clusterReplicateAwait(nodeId: String): Unit
suspend fun RedisClient.clusterResetAwait(): Unit
suspend fun RedisClient.clusterResetWithOptionsAwait(options: ResetOptions): Unit
suspend fun RedisClient.clusterSaveconfigAwait(): Unit
suspend fun RedisClient.clusterSetConfigEpochAwait(epoch: Long): Unit
suspend fun RedisClient.clusterSetslotAwait(slot: Long, subcommand: SlotCmd): Unit
suspend fun RedisClient.clusterSetslotWithNodeAwait(slot: Long, subcommand: SlotCmd, nodeId: String): Unit
suspend fun RedisClient.clusterSlavesAwait(nodeId: String): JsonArray
suspend fun RedisClient.clusterSlotsAwait(): JsonArray
suspend fun RedisClient.commandAwait(): JsonArray
suspend fun RedisClient.commandCountAwait(): Long
suspend fun RedisClient.commandGetkeysAwait(): JsonArray
suspend fun RedisClient.commandInfoAwait(commands: List<String>): JsonArray
suspend fun RedisClient.configGetAwait(parameter: String): JsonArray
suspend fun RedisClient.configResetstatAwait(): String
suspend fun RedisClient.configRewriteAwait(): String
suspend fun RedisClient.configSetAwait(parameter: String, value: String): String
suspend fun RedisClient.dbsizeAwait(): Long
suspend fun RedisClient.debugObjectAwait(key: String): String
suspend fun RedisClient.debugSegfaultAwait(): String
suspend fun RedisClient.decrAwait(key: String): Long
suspend fun RedisClient.decrbyAwait(key: String, decrement: Long): Long
suspend fun RedisClient.delAwait(key: String): Long
suspend fun RedisClient.delManyAwait(keys: List<String>): Long
suspend fun RedisClient.dumpAwait(key: String): String
suspend fun RedisClient.echoAwait(message: String): String
suspend fun RedisClient.evalAwait(script: String, keys: List<String>, args: List<String>): JsonArray
suspend fun RedisClient.evalScriptAwait(script: Script, keys: List<String>, args: List<String>): JsonArray
suspend fun RedisClient.evalshaAwait(sha1: String, keys: List<String>, values: List<String>): JsonArray
suspend fun RedisClient.existsAwait(key: String): Long
suspend fun RedisClient.existsManyAwait(keys: List<String>): Long
suspend fun RedisClient.expireAwait(key: String, seconds: Long): Long
suspend fun RedisClient.expireatAwait(key: String, seconds: Long): Long
suspend fun RedisClient.flushallAwait(): String
suspend fun RedisClient.flushdbAwait(): String
suspend fun RedisClient.geoaddAwait(key: String, longitude: Double, latitude: Double, member: String): Long
suspend fun RedisClient.geoaddManyAwait(key: String, members: List<GeoMember>): Long
suspend fun RedisClient.geodistAwait(key: String, member1: String, member2: String): String
suspend fun RedisClient.geodistWithUnitAwait(key: String, member1: String, member2: String, unit: GeoUnit): String
suspend fun RedisClient.geohashAwait(key: String, member: String): JsonArray
suspend fun RedisClient.geohashManyAwait(key: String, members: List<String>): JsonArray
suspend fun RedisClient.geoposAwait(key: String, member: String): JsonArray
suspend fun RedisClient.geoposManyAwait(key: String, members: List<String>): JsonArray
suspend fun RedisClient.georadiusAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit): JsonArray
suspend fun RedisClient.georadiusWithOptionsAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): JsonArray
suspend fun RedisClient.georadiusbymemberAwait(key: String, member: String, radius: Double, unit: GeoUnit): JsonArray
suspend fun RedisClient.georadiusbymemberWithOptionsAwait(key: String, member: String, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): JsonArray
suspend fun RedisClient.getAwait(key: String): String?
suspend fun RedisClient.getBinaryAwait(key: String): Buffer?
suspend fun RedisClient.getbitAwait(key: String, offset: Long): Long
suspend fun RedisClient.getrangeAwait(key: String, start: Long, end: Long): String
suspend fun RedisClient.getsetAwait(key: String, value: String): String?
suspend fun RedisClient.hdelAwait(key: String, field: String): Long
suspend fun RedisClient.hdelManyAwait(key: String, fields: List<String>): Long
suspend fun RedisClient.hexistsAwait(key: String, field: String): Long
suspend fun RedisClient.hgetAwait(key: String, field: String): String?
suspend fun RedisClient.hgetallAwait(key: String): JsonObject
suspend fun RedisClient.hincrbyAwait(key: String, field: String, increment: Long): Long
suspend fun RedisClient.hincrbyfloatAwait(key: String, field: String, increment: Double): String
suspend fun RedisClient.hkeysAwait(key: String): JsonArray
suspend fun RedisClient.hlenAwait(key: String): Long
suspend fun RedisClient.hmgetAwait(key: String, fields: List<String>): JsonArray
suspend fun RedisClient.hmsetAwait(key: String, values: JsonObject): String
suspend fun RedisClient.hscanAwait(key: String, cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.hsetAwait(key: String, field: String, value: String): Long
suspend fun RedisClient.hsetnxAwait(key: String, field: String, value: String): Long
suspend fun RedisClient.hstrlenAwait(key: String, field: String): Long
suspend fun RedisClient.hvalsAwait(key: String): JsonArray
suspend fun RedisClient.incrAwait(key: String): Long
suspend fun RedisClient.incrbyAwait(key: String, increment: Long): Long
suspend fun RedisClient.incrbyfloatAwait(key: String, increment: Double): String
suspend fun RedisClient.infoAwait(): JsonObject
suspend fun RedisClient.infoSectionAwait(section: String): JsonObject
suspend fun RedisClient.keysAwait(pattern: String): JsonArray
suspend fun RedisClient.lastsaveAwait(): Long
suspend fun RedisClient.lindexAwait(key: String, index: Int): String
suspend fun RedisClient.linsertAwait(key: String, option: InsertOptions, pivot: String, value: String): Long
suspend fun RedisClient.llenAwait(key: String): Long
suspend fun RedisClient.lpopAwait(key: String): String?
suspend fun RedisClient.lpushAwait(key: String, value: String): Long
suspend fun RedisClient.lpushManyAwait(key: String, values: List<String>): Long
suspend fun RedisClient.lpushxAwait(key: String, value: String): Long
suspend fun RedisClient.lrangeAwait(key: String, from: Long, to: Long): JsonArray
suspend fun RedisClient.lremAwait(key: String, count: Long, value: String): Long
suspend fun RedisClient.lsetAwait(key: String, index: Long, value: String): String
suspend fun RedisClient.ltrimAwait(key: String, from: Long, to: Long): String
suspend fun RedisClient.mgetAwait(key: String): JsonArray
suspend fun RedisClient.mgetManyAwait(keys: List<String>): JsonArray
suspend fun RedisClient.migrateAwait(host: String, port: Int, key: String, destdb: Int, timeout: Long, options: MigrateOptions): String
suspend fun RedisClient.monitorAwait(): Unit
suspend fun RedisClient.moveAwait(key: String, destdb: Int): Long
suspend fun RedisClient.msetAwait(keyvals: JsonObject): String
suspend fun RedisClient.msetnxAwait(keyvals: JsonObject): Long
suspend fun RedisClient.objectAwait(key: String, cmd: ObjectCmd): Unit
suspend fun RedisClient.persistAwait(key: String): Long
suspend fun RedisClient.pexpireAwait(key: String, millis: Long): Long
suspend fun RedisClient.pexpireatAwait(key: String, millis: Long): Long
suspend fun RedisClient.pfaddAwait(key: String, element: String): Long
suspend fun RedisClient.pfaddManyAwait(key: String, elements: List<String>): Long
suspend fun RedisClient.pfcountAwait(key: String): Long
suspend fun RedisClient.pfcountManyAwait(keys: List<String>): Long
suspend fun RedisClient.pfmergeAwait(destkey: String, keys: List<String>): String
suspend fun RedisClient.pingAwait(): String
suspend fun RedisClient.psetexAwait(key: String, millis: Long, value: String): Unit
suspend fun RedisClient.psubscribeAwait(pattern: String): JsonArray
suspend fun RedisClient.psubscribeManyAwait(patterns: List<String>): JsonArray
suspend fun RedisClient.pttlAwait(key: String): Long
suspend fun RedisClient.publishAwait(channel: String, message: String): Long
suspend fun RedisClient.pubsubChannelsAwait(pattern: String): JsonArray
suspend fun RedisClient.pubsubNumpatAwait(): Long
suspend fun RedisClient.pubsubNumsubAwait(channels: List<String>): JsonArray
suspend fun RedisClient.punsubscribeAwait(patterns: List<String>): Unit
suspend fun RedisClient.randomkeyAwait(): String
suspend fun RedisClient.renameAwait(key: String, newkey: String): String
suspend fun RedisClient.renamenxAwait(key: String, newkey: String): Long
suspend fun RedisClient.restoreAwait(key: String, millis: Long, serialized: String): String
suspend fun RedisClient.roleAwait(): JsonArray
suspend fun RedisClient.rpopAwait(key: String): String
suspend fun RedisClient.rpoplpushAwait(key: String, destkey: String): String
suspend fun RedisClient.rpushAwait(key: String, value: String): Long
suspend fun RedisClient.rpushManyAwait(key: String, values: List<String>): Long
suspend fun RedisClient.rpushxAwait(key: String, value: String): Long
suspend fun RedisClient.saddAwait(key: String, member: String): Long
suspend fun RedisClient.saddManyAwait(key: String, members: List<String>): Long
suspend fun RedisClient.saveAwait(): String
suspend fun RedisClient.scanAwait(cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.scardAwait(key: String): Long
suspend fun RedisClient.scriptDebugAwait(scriptDebugOptions: ScriptDebugOptions): String
suspend fun RedisClient.scriptExistsAwait(script: String): JsonArray
suspend fun RedisClient.scriptExistsManyAwait(scripts: List<String>): JsonArray
suspend fun RedisClient.scriptFlushAwait(): String
suspend fun RedisClient.scriptKillAwait(): String
suspend fun RedisClient.scriptLoadAwait(script: String): String
suspend fun RedisClient.sdiffAwait(key: String, cmpkeys: List<String>): JsonArray
suspend fun RedisClient.sdiffstoreAwait(destkey: String, key: String, cmpkeys: List<String>): Long
suspend fun RedisClient.selectAwait(dbindex: Int): String
suspend fun RedisClient.setAwait(key: String, value: String): Unit
suspend fun RedisClient.setBinaryAwait(key: String, value: Buffer): Unit
suspend fun RedisClient.setBinaryWithOptionsAwait(key: String, value: Buffer, options: SetOptions): Unit
suspend fun RedisClient.setWithOptionsAwait(key: String, value: String, options: SetOptions): String
suspend fun RedisClient.setbitAwait(key: String, offset: Long, bit: Int): Long
suspend fun RedisClient.setexAwait(key: String, seconds: Long, value: String): String
suspend fun RedisClient.setnxAwait(key: String, value: String): Long
suspend fun RedisClient.setrangeAwait(key: String, offset: Int, value: String): Long
suspend fun RedisClient.sinterAwait(keys: List<String>): JsonArray
suspend fun RedisClient.sinterstoreAwait(destkey: String, keys: List<String>): Long
suspend fun RedisClient.sismemberAwait(key: String, member: String): Long
suspend fun RedisClient.slaveofAwait(host: String, port: Int): String
suspend fun RedisClient.slaveofNooneAwait(): String
suspend fun RedisClient.slowlogGetAwait(limit: Int): JsonArray
suspend fun RedisClient.slowlogLenAwait(): Long
suspend fun RedisClient.slowlogResetAwait(): Unit
suspend fun RedisClient.smembersAwait(key: String): JsonArray
suspend fun RedisClient.smoveAwait(key: String, destkey: String, member: String): Long
suspend fun RedisClient.sortAwait(key: String, options: SortOptions): JsonArray
suspend fun RedisClient.spopAwait(key: String): String?
suspend fun RedisClient.spopManyAwait(key: String, count: Int): JsonArray
suspend fun RedisClient.srandmemberAwait(key: String): String
suspend fun RedisClient.srandmemberCountAwait(key: String, count: Int): JsonArray
suspend fun RedisClient.sremAwait(key: String, member: String): Long
suspend fun RedisClient.sremManyAwait(key: String, members: List<String>): Long
suspend fun RedisClient.sscanAwait(key: String, cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.strlenAwait(key: String): Long
suspend fun RedisClient.subscribeAwait(channel: String): JsonArray
suspend fun RedisClient.subscribeManyAwait(channels: List<String>): JsonArray
suspend fun RedisClient.sunionAwait(keys: List<String>): JsonArray
suspend fun RedisClient.sunionstoreAwait(destkey: String, keys: List<String>): Long
suspend fun RedisClient.swapdbAwait(index1: Int, index2: Int): String
suspend fun RedisClient.syncAwait(): Unit
suspend fun RedisClient.timeAwait(): JsonArray
suspend fun RedisClient.touchAwait(key: String): Long
suspend fun RedisClient.touchManyAwait(keys: List<String>): Long
suspend fun RedisClient.ttlAwait(key: String): Long
suspend fun RedisClient.typeAwait(key: String): String
suspend fun RedisClient.unlinkAwait(key: String): Long
suspend fun RedisClient.unlinkManyAwait(keys: List<String>): Long
suspend fun RedisClient.unsubscribeAwait(channels: List<String>): Unit
suspend fun RedisClient.waitAwait(numSlaves: Long, timeout: Long): String
suspend fun RedisClient.zaddAwait(key: String, score: Double, member: String): Long
suspend fun RedisClient.zaddManyAwait(key: String, members: Map<String, Double>): Long
suspend fun RedisClient.zcardAwait(key: String): Long
suspend fun RedisClient.zcountAwait(key: String, min: Double, max: Double): Long
suspend fun RedisClient.zincrbyAwait(key: String, increment: Double, member: String): String
suspend fun RedisClient.zinterstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): Long
suspend fun RedisClient.zinterstoreWeighedAwait(destkey: String, sets: Map<String, Double>, options: AggregateOptions): Long
suspend fun RedisClient.zlexcountAwait(key: String, min: String, max: String): Long
suspend fun RedisClient.zrangeAwait(key: String, start: Long, stop: Long): JsonArray
suspend fun RedisClient.zrangeWithOptionsAwait(key: String, start: Long, stop: Long, options: RangeOptions): JsonArray
suspend fun RedisClient.zrangebylexAwait(key: String, min: String, max: String, options: LimitOptions): JsonArray
suspend fun RedisClient.zrangebyscoreAwait(key: String, min: String, max: String, options: RangeLimitOptions): JsonArray
suspend fun RedisClient.zrankAwait(key: String, member: String): Long
suspend fun RedisClient.zremAwait(key: String, member: String): Long
suspend fun RedisClient.zremManyAwait(key: String, members: List<String>): Long
suspend fun RedisClient.zremrangebylexAwait(key: String, min: String, max: String): Long
suspend fun RedisClient.zremrangebyrankAwait(key: String, start: Long, stop: Long): Long
suspend fun RedisClient.zremrangebyscoreAwait(key: String, min: String, max: String): Long
suspend fun RedisClient.zrevrangeAwait(key: String, start: Long, stop: Long, options: RangeOptions): JsonArray
suspend fun RedisClient.zrevrangebylexAwait(key: String, max: String, min: String, options: LimitOptions): JsonArray
suspend fun RedisClient.zrevrangebyscoreAwait(key: String, max: String, min: String, options: RangeLimitOptions): JsonArray
suspend fun RedisClient.zrevrankAwait(key: String, member: String): Long
suspend fun RedisClient.zscanAwait(key: String, cursor: String, options: ScanOptions): JsonArray
suspend fun RedisClient.zscoreAwait(key: String, member: String): String
suspend fun RedisClient.zunionstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): Long
suspend fun RedisClient.zunionstoreWeighedAwait(key: String, sets: Map<String, Double>, options: AggregateOptions): Long

io.vertx.redis.RedisTransaction

suspend fun RedisTransaction.appendAwait(key: String, value: String): String
suspend fun RedisTransaction.authAwait(password: String): String
suspend fun RedisTransaction.bgrewriteaofAwait(): String
suspend fun RedisTransaction.bgsaveAwait(): String
suspend fun RedisTransaction.bitcountAwait(key: String): String
suspend fun RedisTransaction.bitcountRangeAwait(key: String, start: Long, end: Long): String
suspend fun RedisTransaction.bitopAwait(operation: BitOperation, destkey: String, keys: List<String>): String
suspend fun RedisTransaction.bitposAwait(key: String, bit: Int): String
suspend fun RedisTransaction.bitposFromAwait(key: String, bit: Int, start: Int): String
suspend fun RedisTransaction.bitposRangeAwait(key: String, bit: Int, start: Int, stop: Int): String
suspend fun RedisTransaction.blpopAwait(key: String, seconds: Int): String
suspend fun RedisTransaction.blpopManyAwait(keys: List<String>, seconds: Int): String
suspend fun RedisTransaction.brpopAwait(key: String, seconds: Int): String
suspend fun RedisTransaction.brpopManyAwait(keys: List<String>, seconds: Int): String
suspend fun RedisTransaction.brpoplpushAwait(key: String, destkey: String, seconds: Int): String
suspend fun RedisTransaction.clientGetnameAwait(): String
suspend fun RedisTransaction.clientKillAwait(filter: KillFilter): String
suspend fun RedisTransaction.clientListAwait(): String
suspend fun RedisTransaction.clientPauseAwait(millis: Long): String
suspend fun RedisTransaction.clientSetnameAwait(name: String): String
suspend fun RedisTransaction.closeAwait(): Unit
suspend fun RedisTransaction.clusterAddslotsAwait(slots: List<String>): String
suspend fun RedisTransaction.clusterCountFailureReportsAwait(nodeId: String): String
suspend fun RedisTransaction.clusterCountkeysinslotAwait(slot: Long): String
suspend fun RedisTransaction.clusterDelslotsAwait(slot: Long): String
suspend fun RedisTransaction.clusterDelslotsManyAwait(slots: List<String>): String
suspend fun RedisTransaction.clusterFailOverWithOptionsAwait(options: FailoverOptions): String
suspend fun RedisTransaction.clusterFailoverAwait(): String
suspend fun RedisTransaction.clusterForgetAwait(nodeId: String): String
suspend fun RedisTransaction.clusterGetkeysinslotAwait(slot: Long, count: Long): String
suspend fun RedisTransaction.clusterInfoAwait(): String
suspend fun RedisTransaction.clusterKeyslotAwait(key: String): String
suspend fun RedisTransaction.clusterMeetAwait(ip: String, port: Long): String
suspend fun RedisTransaction.clusterNodesAwait(): String
suspend fun RedisTransaction.clusterReplicateAwait(nodeId: String): String
suspend fun RedisTransaction.clusterResetAwait(): String
suspend fun RedisTransaction.clusterResetWithOptionsAwait(options: ResetOptions): String
suspend fun RedisTransaction.clusterSaveconfigAwait(): String
suspend fun RedisTransaction.clusterSetConfigEpochAwait(epoch: Long): String
suspend fun RedisTransaction.clusterSetslotAwait(slot: Long, subcommand: SlotCmd): String
suspend fun RedisTransaction.clusterSetslotWithNodeAwait(slot: Long, subcommand: SlotCmd, nodeId: String): String
suspend fun RedisTransaction.clusterSlavesAwait(nodeId: String): String
suspend fun RedisTransaction.clusterSlotsAwait(): String
suspend fun RedisTransaction.commandAwait(): String
suspend fun RedisTransaction.commandCountAwait(): String
suspend fun RedisTransaction.commandGetkeysAwait(): String
suspend fun RedisTransaction.commandInfoAwait(commands: List<String>): String
suspend fun RedisTransaction.configGetAwait(parameter: String): String
suspend fun RedisTransaction.configResetstatAwait(): String
suspend fun RedisTransaction.configRewriteAwait(): String
suspend fun RedisTransaction.configSetAwait(parameter: String, value: String): String
suspend fun RedisTransaction.dbsizeAwait(): String
suspend fun RedisTransaction.debugObjectAwait(key: String): String
suspend fun RedisTransaction.debugSegfaultAwait(): String
suspend fun RedisTransaction.decrAwait(key: String): String
suspend fun RedisTransaction.decrbyAwait(key: String, decrement: Long): String
suspend fun RedisTransaction.delAwait(key: String): String
suspend fun RedisTransaction.delManyAwait(keys: List<String>): String
suspend fun RedisTransaction.discardAwait(): String
suspend fun RedisTransaction.dumpAwait(key: String): String
suspend fun RedisTransaction.echoAwait(message: String): String
suspend fun RedisTransaction.evalAwait(script: String, keys: List<String>, args: List<String>): String
suspend fun RedisTransaction.evalshaAwait(sha1: String, keys: List<String>, values: List<String>): String
suspend fun RedisTransaction.execAwait(): JsonArray
suspend fun RedisTransaction.existsAwait(key: String): String
suspend fun RedisTransaction.existsManyAwait(keys: List<String>): String
suspend fun RedisTransaction.expireAwait(key: String, seconds: Int): String
suspend fun RedisTransaction.expireatAwait(key: String, seconds: Long): String
suspend fun RedisTransaction.flushallAwait(): String
suspend fun RedisTransaction.flushdbAwait(): String
suspend fun RedisTransaction.geoaddAwait(key: String, longitude: Double, latitude: Double, member: String): String
suspend fun RedisTransaction.geoaddManyAwait(key: String, members: List<GeoMember>): String
suspend fun RedisTransaction.geodistAwait(key: String, member1: String, member2: String): String
suspend fun RedisTransaction.geodistWithUnitAwait(key: String, member1: String, member2: String, unit: GeoUnit): String
suspend fun RedisTransaction.geohashAwait(key: String, member: String): String
suspend fun RedisTransaction.geohashManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.geoposAwait(key: String, member: String): String
suspend fun RedisTransaction.geoposManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.georadiusAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit): String
suspend fun RedisTransaction.georadiusWithOptionsAwait(key: String, longitude: Double, latitude: Double, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): String
suspend fun RedisTransaction.georadiusbymemberAwait(key: String, member: String, radius: Double, unit: GeoUnit): String
suspend fun RedisTransaction.georadiusbymemberWithOptionsAwait(key: String, member: String, radius: Double, unit: GeoUnit, options: GeoRadiusOptions): String
suspend fun RedisTransaction.getAwait(key: String): String
suspend fun RedisTransaction.getBinaryAwait(key: String): Buffer
suspend fun RedisTransaction.getbitAwait(key: String, offset: Long): String
suspend fun RedisTransaction.getrangeAwait(key: String, start: Long, end: Long): String
suspend fun RedisTransaction.getsetAwait(key: String, value: String): String
suspend fun RedisTransaction.hdelAwait(key: String, field: String): String
suspend fun RedisTransaction.hdelManyAwait(key: String, fields: List<String>): String
suspend fun RedisTransaction.hexistsAwait(key: String, field: String): String
suspend fun RedisTransaction.hgetAwait(key: String, field: String): String
suspend fun RedisTransaction.hgetallAwait(key: String): String
suspend fun RedisTransaction.hincrbyAwait(key: String, field: String, increment: Long): String
suspend fun RedisTransaction.hincrbyfloatAwait(key: String, field: String, increment: Double): String
suspend fun RedisTransaction.hkeysAwait(key: String): String
suspend fun RedisTransaction.hlenAwait(key: String): String
suspend fun RedisTransaction.hmgetAwait(key: String, fields: List<String>): String
suspend fun RedisTransaction.hmsetAwait(key: String, values: JsonObject): String
suspend fun RedisTransaction.hscanAwait(key: String, cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.hsetAwait(key: String, field: String, value: String): String
suspend fun RedisTransaction.hsetnxAwait(key: String, field: String, value: String): String
suspend fun RedisTransaction.hvalsAwait(key: String): String
suspend fun RedisTransaction.incrAwait(key: String): String
suspend fun RedisTransaction.incrbyAwait(key: String, increment: Long): String
suspend fun RedisTransaction.incrbyfloatAwait(key: String, increment: Double): String
suspend fun RedisTransaction.infoAwait(): String
suspend fun RedisTransaction.infoSectionAwait(section: String): String
suspend fun RedisTransaction.keysAwait(pattern: String): String
suspend fun RedisTransaction.lastsaveAwait(): String
suspend fun RedisTransaction.lindexAwait(key: String, index: Int): String
suspend fun RedisTransaction.linsertAwait(key: String, option: InsertOptions, pivot: String, value: String): String
suspend fun RedisTransaction.llenAwait(key: String): String
suspend fun RedisTransaction.lpopAwait(key: String): String
suspend fun RedisTransaction.lpushAwait(key: String, value: String): String
suspend fun RedisTransaction.lpushManyAwait(key: String, values: List<String>): String
suspend fun RedisTransaction.lpushxAwait(key: String, value: String): String
suspend fun RedisTransaction.lrangeAwait(key: String, from: Long, to: Long): String
suspend fun RedisTransaction.lremAwait(key: String, count: Long, value: String): String
suspend fun RedisTransaction.lsetAwait(key: String, index: Long, value: String): String
suspend fun RedisTransaction.ltrimAwait(key: String, from: Long, to: Long): String
suspend fun RedisTransaction.mgetAwait(key: String): String
suspend fun RedisTransaction.mgetManyAwait(keys: List<String>): String
suspend fun RedisTransaction.migrateAwait(host: String, port: Int, key: String, destdb: Int, timeout: Long, options: MigrateOptions): String
suspend fun RedisTransaction.monitorAwait(): String
suspend fun RedisTransaction.moveAwait(key: String, destdb: Int): String
suspend fun RedisTransaction.msetAwait(keyvals: JsonObject): String
suspend fun RedisTransaction.msetnxAwait(keyvals: JsonObject): String
suspend fun RedisTransaction.multiAwait(): String
suspend fun RedisTransaction.objectAwait(key: String, cmd: ObjectCmd): String
suspend fun RedisTransaction.persistAwait(key: String): String
suspend fun RedisTransaction.pexpireAwait(key: String, millis: Long): String
suspend fun RedisTransaction.pexpireatAwait(key: String, millis: Long): String
suspend fun RedisTransaction.pfaddAwait(key: String, element: String): String
suspend fun RedisTransaction.pfaddManyAwait(key: String, elements: List<String>): String
suspend fun RedisTransaction.pfcountAwait(key: String): String
suspend fun RedisTransaction.pfcountManyAwait(keys: List<String>): String
suspend fun RedisTransaction.pfmergeAwait(destkey: String, keys: List<String>): String
suspend fun RedisTransaction.pingAwait(): String
suspend fun RedisTransaction.psetexAwait(key: String, millis: Long, value: String): String
suspend fun RedisTransaction.psubscribeAwait(pattern: String): String
suspend fun RedisTransaction.psubscribeManyAwait(patterns: List<String>): String
suspend fun RedisTransaction.pttlAwait(key: String): String
suspend fun RedisTransaction.publishAwait(channel: String, message: String): String
suspend fun RedisTransaction.pubsubChannelsAwait(pattern: String): String
suspend fun RedisTransaction.pubsubNumpatAwait(): String
suspend fun RedisTransaction.pubsubNumsubAwait(channels: List<String>): String
suspend fun RedisTransaction.punsubscribeAwait(patterns: List<String>): String
suspend fun RedisTransaction.randomkeyAwait(): String
suspend fun RedisTransaction.renameAwait(key: String, newkey: String): String
suspend fun RedisTransaction.renamenxAwait(key: String, newkey: String): String
suspend fun RedisTransaction.restoreAwait(key: String, millis: Long, serialized: String): String
suspend fun RedisTransaction.roleAwait(): String
suspend fun RedisTransaction.rpopAwait(key: String): String
suspend fun RedisTransaction.rpoplpushAwait(key: String, destkey: String): String
suspend fun RedisTransaction.rpushAwait(key: String, value: String): String
suspend fun RedisTransaction.rpushManyAwait(key: String, values: List<String>): String
suspend fun RedisTransaction.rpushxAwait(key: String, value: String): String
suspend fun RedisTransaction.saddAwait(key: String, member: String): String
suspend fun RedisTransaction.saddManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.saveAwait(): String
suspend fun RedisTransaction.scanAwait(cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.scardAwait(key: String): String
suspend fun RedisTransaction.scriptExistsAwait(script: String): String
suspend fun RedisTransaction.scriptExistsManyAwait(scripts: List<String>): String
suspend fun RedisTransaction.scriptFlushAwait(): String
suspend fun RedisTransaction.scriptKillAwait(): String
suspend fun RedisTransaction.scriptLoadAwait(script: String): String
suspend fun RedisTransaction.sdiffAwait(key: String, cmpkeys: List<String>): String
suspend fun RedisTransaction.sdiffstoreAwait(destkey: String, key: String, cmpkeys: List<String>): String
suspend fun RedisTransaction.selectAwait(dbindex: Int): String
suspend fun RedisTransaction.setAwait(key: String, value: String): String
suspend fun RedisTransaction.setBinaryAwait(key: String, value: Buffer): String
suspend fun RedisTransaction.setBinaryWithOptionsAwait(key: String, value: Buffer, options: SetOptions): String
suspend fun RedisTransaction.setWithOptionsAwait(key: String, value: String, options: SetOptions): String
suspend fun RedisTransaction.setbitAwait(key: String, offset: Long, bit: Int): String
suspend fun RedisTransaction.setexAwait(key: String, seconds: Long, value: String): String
suspend fun RedisTransaction.setnxAwait(key: String, value: String): String
suspend fun RedisTransaction.setrangeAwait(key: String, offset: Int, value: String): String
suspend fun RedisTransaction.sinterAwait(keys: List<String>): String
suspend fun RedisTransaction.sinterstoreAwait(destkey: String, keys: List<String>): String
suspend fun RedisTransaction.sismemberAwait(key: String, member: String): String
suspend fun RedisTransaction.slaveofAwait(host: String, port: Int): String
suspend fun RedisTransaction.slaveofNooneAwait(): String
suspend fun RedisTransaction.slowlogGetAwait(limit: Int): String
suspend fun RedisTransaction.slowlogLenAwait(): String
suspend fun RedisTransaction.slowlogResetAwait(): String
suspend fun RedisTransaction.smembersAwait(key: String): JsonArray
suspend fun RedisTransaction.smoveAwait(key: String, destkey: String, member: String): String
suspend fun RedisTransaction.sortAwait(key: String, options: SortOptions): String
suspend fun RedisTransaction.spopAwait(key: String): String
suspend fun RedisTransaction.spopManyAwait(key: String, count: Int): String
suspend fun RedisTransaction.srandmemberAwait(key: String): String
suspend fun RedisTransaction.srandmemberCountAwait(key: String, count: Int): String
suspend fun RedisTransaction.sremAwait(key: String, member: String): String
suspend fun RedisTransaction.sremManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.sscanAwait(key: String, cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.strlenAwait(key: String): String
suspend fun RedisTransaction.subscribeAwait(channel: String): String
suspend fun RedisTransaction.subscribeManyAwait(channels: List<String>): String
suspend fun RedisTransaction.sunionAwait(keys: List<String>): String
suspend fun RedisTransaction.sunionstoreAwait(destkey: String, keys: List<String>): String
suspend fun RedisTransaction.swapdbAwait(index1: Int, index2: Int): String
suspend fun RedisTransaction.syncAwait(): String
suspend fun RedisTransaction.timeAwait(): String
suspend fun RedisTransaction.ttlAwait(key: String): String
suspend fun RedisTransaction.typeAwait(key: String): String
suspend fun RedisTransaction.unlinkAwait(key: String): String
suspend fun RedisTransaction.unlinkManyAwait(keys: List<String>): String
suspend fun RedisTransaction.unsubscribeAwait(channels: List<String>): String
suspend fun RedisTransaction.unwatchAwait(): String
suspend fun RedisTransaction.waitAwait(numSlaves: Long, timeout: Long): String
suspend fun RedisTransaction.watchAwait(key: String): String
suspend fun RedisTransaction.watchManyAwait(keys: List<String>): String
suspend fun RedisTransaction.zaddAwait(key: String, score: Double, member: String): String
suspend fun RedisTransaction.zaddManyAwait(key: String, members: Map<String, Double>): String
suspend fun RedisTransaction.zcardAwait(key: String): String
suspend fun RedisTransaction.zcountAwait(key: String, min: Double, max: Double): String
suspend fun RedisTransaction.zincrbyAwait(key: String, increment: Double, member: String): String
suspend fun RedisTransaction.zinterstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): String
suspend fun RedisTransaction.zinterstoreWeighedAwait(destkey: String, sets: Map<String, Double>, options: AggregateOptions): String
suspend fun RedisTransaction.zlexcountAwait(key: String, min: String, max: String): String
suspend fun RedisTransaction.zrangeAwait(key: String, start: Long, stop: Long): String
suspend fun RedisTransaction.zrangeWithOptionsAwait(key: String, start: Long, stop: Long, options: RangeOptions): String
suspend fun RedisTransaction.zrangebylexAwait(key: String, min: String, max: String, options: LimitOptions): String
suspend fun RedisTransaction.zrangebyscoreAwait(key: String, min: String, max: String, options: RangeLimitOptions): String
suspend fun RedisTransaction.zrankAwait(key: String, member: String): String
suspend fun RedisTransaction.zremAwait(key: String, member: String): String
suspend fun RedisTransaction.zremManyAwait(key: String, members: List<String>): String
suspend fun RedisTransaction.zremrangebylexAwait(key: String, min: String, max: String): String
suspend fun RedisTransaction.zremrangebyrankAwait(key: String, start: Long, stop: Long): String
suspend fun RedisTransaction.zremrangebyscoreAwait(key: String, min: String, max: String): String
suspend fun RedisTransaction.zrevrangeAwait(key: String, start: Long, stop: Long, options: RangeOptions): String
suspend fun RedisTransaction.zrevrangebylexAwait(key: String, max: String, min: String, options: LimitOptions): String
suspend fun RedisTransaction.zrevrangebyscoreAwait(key: String, max: String, min: String, options: RangeLimitOptions): String
suspend fun RedisTransaction.zrevrankAwait(key: String, member: String): String
suspend fun RedisTransaction.zscanAwait(key: String, cursor: String, options: ScanOptions): String
suspend fun RedisTransaction.zscoreAwait(key: String, member: String): String
suspend fun RedisTransaction.zunionstoreAwait(destkey: String, sets: List<String>, options: AggregateOptions): String
suspend fun RedisTransaction.zunionstoreWeighedAwait(key: String, sets: Map<String, Double>, options: AggregateOptions): String

fun redisOptionsOf(address: String? = null, auth: String? = null, binary: Boolean? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, domainSocket: Boolean? = null, domainSocketAddress: String? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, encoding: 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, masterName: String? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = 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, select: Int? = null, sendBufferSize: Int? = null, sentinels: Iterable<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, usePooledBuffers: Boolean? = null): RedisOptions

package io.vertx.kotlin.redis.client

io.vertx.redis.client.Redis

suspend fun Redis.batchAwait(commands: List<Request>): List<Response?>
suspend fun Redis.connectAwait(): RedisConnection
suspend fun Redis.sendAwait(command: Request): Response?

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(connectionString: String? = null, connectionStrings: Iterable<String>? = null, 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.redis.op

fun bitFieldGetCommandOf(offset: Long? = null, type: String? = null): BitFieldGetCommand
fun bitFieldIncrbyCommandOf(increment: Long? = null, offset: Long? = null, type: String? = null): BitFieldIncrbyCommand
fun bitFieldOptionsOf(get: BitFieldGetCommand? = null, incrby: BitFieldIncrbyCommand? = null, set: BitFieldSetCommand? = null): BitFieldOptions
fun bitFieldSetCommandOf(offset: Long? = null, type: String? = null, value: Long? = null): BitFieldSetCommand
fun geoMemberOf(latitude: Double? = null, longitude: Double? = null, member: String? = null): GeoMember
fun geoRadiusOptionsOf(count: Long? = null, withCoord: Boolean? = null, withDist: Boolean? = null, withHash: Boolean? = null): GeoRadiusOptions
fun killFilterOf(addr: String? = null, id: String? = null, skipme: Boolean? = null, type: Type? = null): KillFilter
fun limitOptionsOf(count: Long? = null, offset: Long? = null): LimitOptions
fun migrateOptionsOf(copy: Boolean? = null, replace: Boolean? = null): MigrateOptions
fun rangeLimitOptionsOf(count: Long? = null, offset: Long? = null, withscores: Boolean? = null): RangeLimitOptions
fun scanOptionsOf(count: Int? = null, match: String? = null): ScanOptions
fun setOptionsOf(ex: Long? = null, nx: Boolean? = null, px: Long? = null, xx: Boolean? = null): SetOptions
fun sortOptionsOf(alpha: Boolean? = null, by: String? = null, descending: Boolean? = null, gets: Iterable<String>? = null, store: String? = null): SortOptions

package io.vertx.kotlin.redis.sentinel

io.vertx.redis.sentinel.RedisSentinel

suspend fun RedisSentinel.ckquorumAwait(name: String): String
suspend fun RedisSentinel.closeAwait(): Unit
suspend fun RedisSentinel.failoverAwait(name: String): String
suspend fun RedisSentinel.flushConfigAwait(): Unit
suspend fun RedisSentinel.getMasterAddrByNameAwait(name: String): JsonArray
suspend fun RedisSentinel.masterAwait(name: String): JsonArray
suspend fun RedisSentinel.mastersAwait(): JsonArray
suspend fun RedisSentinel.resetAwait(pattern: String): Unit
suspend fun RedisSentinel.sentinelsAwait(name: String): JsonArray
suspend fun RedisSentinel.slavesAwait(name: String): JsonArray

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): RedisClient
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean): RedisClient
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: JsonObject, consumerConfiguration: JsonObject): RedisClient
suspend fun getRedisClientAwait(discovery: ServiceDiscovery, filter: (Record) -> Boolean, consumerConfiguration: JsonObject): RedisClient

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

io.vertx.sqlclient.PreparedQuery

suspend fun <T> PreparedQuery<T>.executeAwait(): T
suspend fun <T> PreparedQuery<T>.executeAwait(tuple: Tuple): T
suspend fun <T> PreparedQuery<T>.executeBatchAwait(batch: List<Tuple>): T

io.vertx.sqlclient.PreparedStatement

suspend fun PreparedStatement.closeAwait(): Unit

io.vertx.sqlclient.Query

suspend fun <T> Query<T>.executeAwait(): T

io.vertx.sqlclient.RowStream

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

io.vertx.sqlclient.SqlConnection

suspend fun SqlConnection.prepareAwait(sql: String): PreparedStatement

io.vertx.sqlclient.Transaction

suspend fun Transaction.commitAwait(): Unit
suspend fun Transaction.prepareAwait(sql: String): PreparedStatement
suspend fun Transaction.rollbackAwait(): Unit

fun poolOptionsOf(idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, maxSize: Int? = null, maxWaitQueueSize: Int? = null): PoolOptions
fun sqlConnectOptionsOf(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, 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, 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, usePooledBuffers: Boolean? = null, user: String? = null): SqlConnectOptions