vertx
Module Contents
alltypes
Module Contents
object AmazonCognitoAuth
object AzureADAuth
object GoogleAuth
object HttpEndpoint
Module Contents
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 IBMCloudAuth
io.vertx.amqp.AmqpClient
io.vertx.amqp.AmqpConnection
io.vertx.amqp.AmqpReceiver
io.vertx.amqp.AmqpSender
io.vertx.cassandra.CassandraClient
io.vertx.circuitbreaker.CircuitBreaker
io.vertx.config.ConfigRetriever
io.vertx.core.buffer.Buffer
io.vertx.core.CompositeFuture
io.vertx.core.Context
io.vertx.core.datagram.DatagramSocket
Module Contents
suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, networkInterface: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.closeAwait(): Unit
suspend fun DatagramSocket.listenAwait(port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String?): Unit
suspend fun DatagramSocket.pipeToAwait(dst: WriteStream<DatagramPacket>): Unit
suspend fun DatagramSocket.sendAwait(packet: Buffer, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, enc: String, port: Int, host: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String?): Unit
io.vertx.core.dns.DnsClient
io.vertx.core.eventbus.EventBus
io.vertx.core.eventbus.Message
io.vertx.core.eventbus.MessageConsumer
io.vertx.core.eventbus.MessageProducer
io.vertx.core.file.AsyncFile
io.vertx.core.file.FileSystem
Module Contents
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.Future
io.vertx.core.http.HttpClient
Module Contents
suspend fun HttpClient.closeAwait(): Unit
suspend fun HttpClient.deleteAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.deleteAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.deleteAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.deleteAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.deleteAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.deleteAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.deleteAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.getAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.getAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.getAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.getAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.getAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.headAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.headAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.headAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.headAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.headAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.optionsAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.optionsAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.optionsAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.optionsAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(options: RequestOptions, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(options: RequestOptions, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(options: RequestOptions, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(options: RequestOptions, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.sendAwait(options: RequestOptions, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(options: RequestOptions, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.webSocketAbsAwait(url: String, : 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
io.vertx.core.http.HttpClientResponse
io.vertx.core.http.HttpConnection
io.vertx.core.http.HttpServer
io.vertx.core.http.HttpServerFileUpload
io.vertx.core.http.HttpServerRequest
io.vertx.core.http.HttpServerResponse
Module Contents
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, : MultiMap): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, path: String): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, host: String, path: String, : 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
io.vertx.core.http.WebSocket
io.vertx.core.http.WebSocketBase
io.vertx.core.json.JsonArray
io.vertx.core.json.JsonObject
io.vertx.core.net.NetClient
io.vertx.core.net.NetServer
io.vertx.core.net.NetSocket
io.vertx.core.parsetools.JsonParser
io.vertx.core.parsetools.RecordParser
io.vertx.core.shareddata.AsyncMap
Module Contents
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
io.vertx.core.shareddata.SharedData
io.vertx.core.streams.Pipe
io.vertx.core.streams.ReadStream
io.vertx.core.streams.WriteStream
io.vertx.core.TimeoutStream
io.vertx.core.Vertx
io.vertx.core.WorkerExecutor
io.vertx.ext.auth.authentication.AuthenticationProvider
io.vertx.ext.auth.authorization.AuthorizationProvider
io.vertx.ext.auth.htdigest.HtdigestAuth
io.vertx.ext.auth.htpasswd.HtpasswdAuth
io.vertx.ext.auth.jdbc.JDBCAuthentication
io.vertx.ext.auth.jdbc.JDBCUserUtil
io.vertx.ext.auth.jwt.JWTAuth
io.vertx.ext.auth.mongo.MongoAuthentication
io.vertx.ext.auth.mongo.MongoUserUtil
io.vertx.ext.auth.oauth2.AccessToken
io.vertx.ext.auth.oauth2.OAuth2Auth
io.vertx.ext.auth.webauthn.CredentialStore
io.vertx.ext.auth.webauthn.WebAuthn
io.vertx.ext.consul.ConsulClient
Module Contents
suspend fun ConsulClient.agentInfoAwait(): JsonObject
suspend fun ConsulClient.catalogDatacentersAwait(): List<String>
suspend fun ConsulClient.catalogNodesAwait(): NodeList
suspend fun ConsulClient.catalogNodeServicesAwait(node: String): ServiceList
suspend fun ConsulClient.catalogNodeServicesWithOptionsAwait(node: String, options: BlockingQueryOptions): ServiceList
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.getValuesAwait(keyPrefix: String): KeyValueList
suspend fun ConsulClient.getValuesWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): KeyValueList
suspend fun ConsulClient.getValueWithOptionsAwait(key: String, options: BlockingQueryOptions): KeyValue
suspend fun ConsulClient.healthChecksAwait(service: String): CheckList
suspend fun ConsulClient.healthChecksWithOptionsAwait(service: String, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.healthServiceNodesAwait(service: String, passing: Boolean): ServiceEntryList
suspend fun ConsulClient.healthServiceNodesWithOptionsAwait(service: String, passing: Boolean, options: ServiceQueryOptions): ServiceEntryList
suspend fun ConsulClient.healthStateAwait(healthState: HealthState): CheckList
suspend fun ConsulClient.healthStateWithOptionsAwait(healthState: HealthState, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.infoAclTokenAwait(id: String): AclToken
suspend fun ConsulClient.infoSessionAwait(id: String): Session
suspend fun ConsulClient.infoSessionWithOptionsAwait(id: String, options: BlockingQueryOptions): Session
suspend fun ConsulClient.leaderStatusAwait(): String
suspend fun ConsulClient.listAclTokensAwait(): List<AclToken>
suspend fun ConsulClient.listEventsAwait(): EventList
suspend fun ConsulClient.listEventsWithOptionsAwait(options: EventListOptions): EventList
suspend fun ConsulClient.listNodeSessionsAwait(nodeId: String): SessionList
suspend fun ConsulClient.listNodeSessionsWithOptionsAwait(nodeId: String, options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.listSessionsAwait(): SessionList
suspend fun ConsulClient.listSessionsWithOptionsAwait(options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.localChecksAwait(): List<Check>
suspend fun ConsulClient.localServicesAwait(): List<Service>
suspend fun ConsulClient.maintenanceServiceAwait(maintenanceOptions: MaintenanceOptions): Unit
suspend fun ConsulClient.passCheckAwait(checkId: String): Unit
suspend fun ConsulClient.passCheckWithNoteAwait(checkId: String, note: String): Unit
suspend fun ConsulClient.peersStatusAwait(): List<String>
suspend fun ConsulClient.putValueAwait(key: String, value: String): Boolean
suspend fun ConsulClient.putValueWithOptionsAwait(key: String, value: String, options: KeyValueOptions): Boolean
suspend fun ConsulClient.registerCheckAwait(checkOptions: CheckOptions): Unit
suspend fun ConsulClient.registerServiceAwait(serviceOptions: ServiceOptions): Unit
suspend fun ConsulClient.renewSessionAwait(id: String): Session
suspend fun ConsulClient.transactionAwait(request: TxnRequest): TxnResponse
suspend fun ConsulClient.updateAclTokenAwait(token: AclToken): String
suspend fun ConsulClient.updateCheckAwait(checkId: String, status: CheckStatus): Unit
suspend fun ConsulClient.updateCheckWithNoteAwait(checkId: String, status: CheckStatus, note: String): Unit
suspend fun ConsulClient.updatePreparedQueryAwait(definition: PreparedQueryDefinition): Unit
suspend fun ConsulClient.warnCheckAwait(checkId: String): Unit
suspend fun ConsulClient.warnCheckWithNoteAwait(checkId: String, note: String): Unit
io.vertx.ext.eventbus.bridge.tcp.TcpEventBusBridge
io.vertx.ext.healthchecks.HealthChecks
io.vertx.ext.jdbc.JDBCClient
io.vertx.ext.mail.MailClient
io.vertx.ext.mongo.MongoClient
Module Contents
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.closeAwait(): Unit
suspend fun MongoClient.countAwait(collection: String, query: JsonObject): Long
suspend fun MongoClient.createCollectionAwait(collectionName: String): Unit
suspend fun MongoClient.createDefaultGridFsBucketServiceAwait(): MongoGridFsClient
suspend fun MongoClient.createGridFsBucketServiceAwait(bucketName: String): MongoGridFsClient
suspend fun MongoClient.createIndexAwait(collection: String, key: JsonObject): Unit
suspend fun MongoClient.createIndexesAwait(collection: String, indexes: List<IndexModel>): 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.removeDocumentsAwait(collection: String, query: JsonObject): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentsWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption?): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption?): MongoClientDeleteResult?
suspend fun MongoClient.replaceDocumentsAwait(collection: String, query: JsonObject, replace: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.replaceDocumentsWithOptionsAwait(collection: String, query: JsonObject, replace: JsonObject, options: UpdateOptions): MongoClientUpdateResult?
suspend fun MongoClient.runCommandAwait(commandName: String, command: JsonObject): JsonObject?
suspend fun MongoClient.saveAwait(collection: String, document: JsonObject): String?
suspend fun MongoClient.saveWithOptionsAwait(collection: String, document: JsonObject, writeOption: WriteOption?): String?
suspend fun MongoClient.updateCollectionAwait(collection: String, query: JsonObject, update: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.updateCollectionWithOptionsAwait(collection: String, query: JsonObject, update: JsonObject, options: UpdateOptions): MongoClientUpdateResult?
io.vertx.ext.mongo.MongoGridFsClient
Module Contents
suspend fun MongoGridFsClient.deleteAwait(id: String): Unit
suspend fun MongoGridFsClient.downloadByFileNameAwait(stream: WriteStream<Buffer>, fileName: String): Long
suspend fun MongoGridFsClient.downloadByFileNameWithOptionsAwait(stream: WriteStream<Buffer>, fileName: String, options: GridFsDownloadOptions): Long
suspend fun MongoGridFsClient.downloadByIdAwait(stream: WriteStream<Buffer>, id: String): Long
suspend fun MongoGridFsClient.downloadFileAsAwait(fileName: String, newFileName: String): Long
suspend fun MongoGridFsClient.downloadFileAwait(fileName: String): Long
suspend fun MongoGridFsClient.downloadFileByIDAwait(id: String, fileName: String): Long
suspend fun MongoGridFsClient.dropAwait(): Unit
suspend fun MongoGridFsClient.findAllIdsAwait(): List<String>
suspend fun MongoGridFsClient.findIdsAwait(query: JsonObject): List<String>
suspend fun MongoGridFsClient.uploadByFileNameAwait(stream: ReadStream<Buffer>, fileName: String): String
suspend fun MongoGridFsClient.uploadByFileNameWithOptionsAwait(stream: ReadStream<Buffer>, fileName: String, options: GridFsUploadOptions): String
suspend fun MongoGridFsClient.uploadFileAwait(fileName: String): String
suspend fun MongoGridFsClient.uploadFileWithOptionsAwait(fileName: String, options: GridFsUploadOptions): String
io.vertx.ext.shell.command.CommandRegistry
io.vertx.ext.shell.ShellServer
io.vertx.ext.shell.ShellService
io.vertx.ext.shell.term.TermServer
io.vertx.ext.sql.SQLClient
io.vertx.ext.sql.SQLConnection
io.vertx.ext.sql.SQLOperations
io.vertx.ext.sql.SQLRowStream
io.vertx.ext.stomp.StompClient
io.vertx.ext.stomp.StompClientConnection
Module Contents
suspend fun StompClientConnection.abortAwait(id: String): Frame
suspend fun StompClientConnection.abortAwait(id: String, : Map<String, String>): Frame
suspend fun StompClientConnection.ackAwait(id: String): Frame
suspend fun StompClientConnection.ackAwait(id: String, txId: String): Frame
suspend fun StompClientConnection.beginTXAwait(id: String): Frame
suspend fun StompClientConnection.beginTXAwait(id: String, : Map<String, String>): Frame
suspend fun StompClientConnection.commitAwait(id: String): Frame
suspend fun StompClientConnection.commitAwait(id: String, : Map<String, String>): Frame
suspend fun StompClientConnection.disconnectAwait(): Frame
suspend fun StompClientConnection.disconnectAwait(frame: Frame): Frame
suspend fun StompClientConnection.nackAwait(id: String): Frame
suspend fun StompClientConnection.nackAwait(id: String, txId: String): Frame
suspend fun StompClientConnection.sendAwait(: Map<String, String>, body: Buffer): Frame
suspend fun StompClientConnection.sendAwait(destination: String, body: Buffer): Frame
suspend fun StompClientConnection.sendAwait(frame: Frame): Frame
suspend fun StompClientConnection.sendAwait(destination: String, : Map<String, String>, body: Buffer): Frame
suspend fun StompClientConnection.subscribeAwait(destination: String, handler: (Frame) -> Unit): String
suspend fun StompClientConnection.subscribeAwait(destination: String, : Map<String, String>, handler: (Frame) -> Unit): String
suspend fun StompClientConnection.unsubscribeAwait(destination: String): Frame
suspend fun StompClientConnection.unsubscribeAwait(destination: String, : Map<String, String>): Frame
io.vertx.ext.stomp.StompServer
io.vertx.ext.stomp.StompServerHandler
io.vertx.ext.unit.Async
io.vertx.ext.unit.Completion
io.vertx.ext.unit.report.TestSuiteReport
io.vertx.ext.unit.TestCompletion
io.vertx.ext.web.client.HttpRequest
io.vertx.ext.web.common.template.TemplateEngine
io.vertx.ext.web.handler.AuthenticationHandler
io.vertx.ext.web.handler.BasicAuthHandler
io.vertx.ext.web.handler.ChainAuthHandler
io.vertx.ext.web.handler.DigestAuthHandler
io.vertx.ext.web.handler.JWTAuthHandler
io.vertx.ext.web.handler.OAuth2AuthHandler
io.vertx.ext.web.handler.RedirectAuthHandler
io.vertx.ext.web.handler.SessionHandler
io.vertx.ext.web.handler.sockjs.SockJSSocket
io.vertx.ext.web.sstore.SessionStore
io.vertx.kafka.admin.KafkaAdminClient
io.vertx.kafka.client.consumer.KafkaConsumer
Module Contents
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
Module Contents
suspend fun <K, V> KafkaProducer<K, V>.abortTransactionAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.beginTransactionAwait(): Unit
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>.commitTransactionAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(data: KafkaProducerRecord<K, V>): Unit
suspend fun <K, V> KafkaProducer<K, V>.flushAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.initTransactionsAwait(): 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
io.vertx.mqtt.MqttEndpoint
io.vertx.mqtt.MqttServer
io.vertx.mysqlclient.MySQLConnection
io.vertx.pgclient.PgConnection
io.vertx.pgclient.pubsub.PgChannel
io.vertx.pgclient.pubsub.PgSubscriber
io.vertx.rabbitmq.RabbitMQClient
Module Contents
suspend fun RabbitMQClient.basicAckAwait(deliveryTag: Long, multiple: Boolean): Unit
suspend fun RabbitMQClient.basicConsumerAwait(queue: String): RabbitMQConsumer
suspend fun RabbitMQClient.basicConsumerAwait(queue: String, options: QueueOptions): RabbitMQConsumer
suspend fun RabbitMQClient.basicGetAwait(queue: String, autoAck: Boolean): RabbitMQMessage
suspend fun RabbitMQClient.basicNackAwait(deliveryTag: Long, multiple: Boolean, requeue: Boolean): Unit
suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, body: Buffer): Unit
suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, properties: BasicProperties, body: Buffer): 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): DeclareOk
suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: JsonObject): DeclareOk
suspend fun RabbitMQClient.queueDeleteAwait(queue: String): DeleteOk
suspend fun RabbitMQClient.queueDeleteIfAwait(queue: String, ifUnused: Boolean, ifEmpty: Boolean): DeleteOk
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
io.vertx.redis.client.Redis
io.vertx.redis.client.RedisAPI
Module Contents
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.expireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.expireAwait(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.georadiusbymemberAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusbymemberRoAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusRoAwait(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.hgetallAwait(arg0: String): Response?
suspend fun RedisAPI.hgetAwait(arg0: String, arg1: 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.pexpireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pexpireAwait(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
io.vertx.servicediscovery.ServiceDiscovery
io.vertx.servicediscovery.spi.ServicePublisher
io.vertx.sqlclient.Cursor
io.vertx.sqlclient.Pool
io.vertx.sqlclient.PreparedQuery
io.vertx.sqlclient.PreparedStatement
io.vertx.sqlclient.Query
io.vertx.sqlclient.RowStream
io.vertx.sqlclient.SqlClient
io.vertx.sqlclient.SqlConnection
io.vertx.sqlclient.Transaction
object JDBCDataSource
object Json
object KeycloakAuth
object MessageSource
object MongoDataSource
object MySQLConnection
object OpenAPI3RouterFactory
object OpenIDConnectAuth
object PgConnection
object RedisDataSource
object SalesforceAuth
object Vertx
package io.vertx.ext.json.schema.kotlin
package io.vertx.kotlin.amqp
Module Contents
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, keyCertOptions: KeyCertOptions? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, username: String? = null, virtualHost: String? = null): AmqpClientOptions
fun amqpReceiverOptionsOf(autoAcknowledgement: Boolean? = null, capabilities: Iterable<String>? = null, capabilitys: Iterable<String>? = null, durable: Boolean? = null, dynamic: Boolean? = null, linkName: String? = null, maxBufferedMessages: Int? = null, qos: String? = null): AmqpReceiverOptions
fun amqpSenderOptionsOf(autoDrained: Boolean? = null, dynamic: Boolean? = null, linkName: String? = null): AmqpSenderOptions
io.vertx.amqp.AmqpClient
io.vertx.amqp.AmqpConnection
io.vertx.amqp.AmqpReceiver
io.vertx.amqp.AmqpSender
package io.vertx.kotlin.cassandra
package io.vertx.kotlin.circuitbreaker
package io.vertx.kotlin.config
package io.vertx.kotlin.core
Module Contents
fun deploymentOptionsOf(config: JsonObject? = null, ha: Boolean? = null, instances: Int? = null, maxWorkerExecuteTime: Long? = null, maxWorkerExecuteTimeUnit: TimeUnit? = null, worker: Boolean? = null, workerPoolName: String? = null, workerPoolSize: Int? = null): DeploymentOptions
io.vertx.core.CompositeFuture
io.vertx.core.Context
io.vertx.core.Future
io.vertx.core.TimeoutStream
io.vertx.core.Vertx
io.vertx.core.WorkerExecutor
object Vertx
fun vertxOptionsOf(addressResolverOptions: AddressResolverOptions? = null, blockedThreadCheckInterval: Long? = null, blockedThreadCheckIntervalUnit: TimeUnit? = null, clusterManager: ClusterManager? = null, eventBusOptions: EventBusOptions? = null, eventLoopPoolSize: Int? = null, fileSystemOptions: FileSystemOptions? = null, haEnabled: Boolean? = null, haGroup: String? = null, internalBlockingPoolSize: Int? = null, maxEventLoopExecuteTime: Long? = null, maxEventLoopExecuteTimeUnit: TimeUnit? = null, maxWorkerExecuteTime: Long? = null, maxWorkerExecuteTimeUnit: TimeUnit? = null, metricsOptions: MetricsOptions? = null, preferNativeTransport: Boolean? = null, quorumSize: Int? = null, tracingOptions: TracingOptions? = null, warningExceptionTime: Long? = null, warningExceptionTimeUnit: TimeUnit? = null, workerPoolSize: Int? = null): VertxOptions
package io.vertx.kotlin.core.buffer
package io.vertx.kotlin.core.cli
Module Contents
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
Module Contents
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
Module Contents
suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.blockMulticastGroupAwait(multicastAddress: String, networkInterface: String, sourceToBlock: String): Unit
suspend fun DatagramSocket.closeAwait(): Unit
suspend fun DatagramSocket.listenAwait(port: Int, host: String): DatagramSocket
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.listenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String?): Unit
suspend fun DatagramSocket.pipeToAwait(dst: WriteStream<DatagramPacket>): Unit
suspend fun DatagramSocket.sendAwait(packet: Buffer, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, port: Int, host: String): Unit
suspend fun DatagramSocket.sendAwait(str: String, enc: String, port: Int, host: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String): Unit
suspend fun DatagramSocket.unlistenMulticastGroupAwait(multicastAddress: String, networkInterface: String, source: String?): Unit
package io.vertx.kotlin.core.dns
Module Contents
fun addressResolverOptionsOf(cacheMaxTimeToLive: Int? = null, cacheMinTimeToLive: Int? = null, cacheNegativeTimeToLive: Int? = null, hostsPath: String? = null, hostsValue: Buffer? = null, maxQueries: Int? = null, ndots: Int? = null, optResourceEnabled: Boolean? = null, queryTimeout: Long? = null, rdFlag: Boolean? = null, rotateServers: Boolean? = null, searchDomains: Iterable<String>? = null, servers: Iterable<String>? = null): AddressResolverOptions
fun dnsClientOptionsOf(host: String? = null, logActivity: Boolean? = null, port: Int? = null, queryTimeout: Long? = null, recursionDesired: Boolean? = null): DnsClientOptions
io.vertx.core.dns.DnsClient
package io.vertx.kotlin.core.eventbus
Module Contents
fun deliveryOptionsOf(codecName: String? = null, : Map<String, String>? = null, localOnly: Boolean? = null, sendTimeout: Long? = null): DeliveryOptions
fun eventBusOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, clusterNodeMetadata: JsonObject? = null, clusterPingInterval: Long? = null, clusterPingReplyInterval: Long? = null, clusterPublicHost: String? = null, clusterPublicPort: Int? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null): EventBusOptions
io.vertx.core.eventbus.EventBus
io.vertx.core.eventbus.Message
io.vertx.core.eventbus.MessageConsumer
io.vertx.core.eventbus.MessageProducer
package io.vertx.kotlin.core.file
Module Contents
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
io.vertx.core.file.FileSystem
Module Contents
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
Module Contents
fun goAwayOf(debugData: Buffer? = null, errorCode: Long? = null, lastStreamId: Int? = null): GoAway
fun http2SettingsOf(: Long? = null, initialWindowSize: Int? = null, maxConcurrentStreams: Long? = null, maxFrameSize: Int? = null, : 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, keyCertOptions: KeyCertOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, : Int? = null, maxInitialLineLength: Int? = null, maxPoolSize: Int? = null, maxRedirects: Int? = null, maxWaitQueueSize: Int? = null, maxWebSocketFrameSize: Int? = null, maxWebSocketMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = null, pipeliningLimit: Int? = null, poolCleanerPeriod: Int? = null, protocolVersion: HttpVersion? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sendUnmaskedFrames: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebSocketCompression: Boolean? = null, tryUsePerMessageWebSocketCompression: Boolean? = null, useAlpn: Boolean? = null, verifyHost: Boolean? = null, webSocketCompressionAllowClientNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketCompressionRequestServerNoContext: Boolean? = null): HttpClientOptions
fun httpMethodOf(): HttpMethod
fun httpServerOptionsOf(acceptBacklog: Int? = null, acceptUnmaskedFrames: Boolean? = null, alpnVersions: Iterable<HttpVersion>? = null, clientAuth: ClientAuth? = null, compressionLevel: Int? = null, compressionSupported: Boolean? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, decoderInitialBufferSize: Int? = null, decompressionSupported: Boolean? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, handle100ContinueAutomatically: Boolean? = null, host: String? = null, http2ConnectionWindowSize: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyCertOptions: KeyCertOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, : Int? = null, maxInitialLineLength: Int? = null, maxWebSocketFrameSize: Int? = null, maxWebSocketMessageSize: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, perFrameWebSocketCompressionSupported: Boolean? = null, perMessageWebSocketCompressionSupported: Boolean? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, proxyProtocolTimeout: Long? = null, proxyProtocolTimeoutUnit: TimeUnit? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useProxyProtocol: Boolean? = null, webSocketAllowServerNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketPreferredClientNoContext: Boolean? = null, webSocketSubProtocols: Iterable<String>? = null): HttpServerOptions
io.vertx.core.http.HttpClient
Module Contents
suspend fun HttpClient.closeAwait(): Unit
suspend fun HttpClient.deleteAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.deleteAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.deleteAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.deleteAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.deleteAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.deleteAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.deleteAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.getAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.getAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.getAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.getAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.getAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.getAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.headAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.headAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.headAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.headAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.headAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.headAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsAwait(port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.optionsAwait(host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.optionsAwait(requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.optionsAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.optionsAwait(port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsAwait(host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.optionsAwait(requestURI: String): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(options: RequestOptions, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(options: RequestOptions, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(port: Int, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.postAwait(requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(options: RequestOptions, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(options: RequestOptions, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(port: Int, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.putAwait(requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(options: RequestOptions): HttpClientResponse
suspend fun HttpClient.sendAwait(options: RequestOptions, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(options: RequestOptions, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, port: Int, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, host: String, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, : MultiMap): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, : MultiMap, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, : MultiMap, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, body: Buffer): HttpClientResponse
suspend fun HttpClient.sendAwait(method: HttpMethod, requestURI: String, body: ReadStream<Buffer>): HttpClientResponse
suspend fun HttpClient.webSocketAbsAwait(url: String, : 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
io.vertx.core.http.HttpClientResponse
io.vertx.core.http.HttpConnection
io.vertx.core.http.HttpServer
io.vertx.core.http.HttpServerFileUpload
io.vertx.core.http.HttpServerRequest
io.vertx.core.http.HttpServerResponse
Module Contents
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, : MultiMap): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, path: String): HttpServerResponse
suspend fun HttpServerResponse.pushAwait(method: HttpMethod, host: String, path: String, : 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
io.vertx.core.http.WebSocket
io.vertx.core.http.WebSocketBase
fun requestOptionsOf(absoluteURI: String? = null, followRedirects: Boolean? = null, : Map<String, String>? = null, host: String? = null, method: HttpMethod? = null, port: Int? = null, ssl: Boolean? = null, timeout: Long? = null, uri: String? = null): RequestOptions
fun streamPriorityOf(dependency: Int? = null, exclusive: Boolean? = null, weight: Short? = null): StreamPriority
fun webSocketConnectOptionsOf(absoluteURI: String? = null, followRedirects: Boolean? = null, : Map<String, String>? = null, host: String? = null, method: HttpMethod? = null, port: Int? = null, ssl: Boolean? = null, subProtocols: Iterable<String>? = null, timeout: Long? = null, uri: String? = null, version: WebsocketVersion? = null): WebSocketConnectOptions
package io.vertx.kotlin.core.json
package io.vertx.kotlin.core.metrics
package io.vertx.kotlin.core.net
Module Contents
io.vertx.core.net.NetClient
io.vertx.core.net.NetServer
io.vertx.core.net.NetSocket
fun jdkSSLEngineOptionsOf(): JdkSSLEngineOptions
fun jksOptionsOf(password: String? = null, path: String? = null, value: Buffer? = null): JksOptions
fun netClientOptionsOf(connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyCertOptions: KeyCertOptions? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null): NetClientOptions
fun netServerOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyCertOptions: KeyCertOptions? = 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, proxyProtocolTimeout: Long? = null, proxyProtocolTimeoutUnit: TimeUnit? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useProxyProtocol: 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
package io.vertx.kotlin.core.shareddata
Module Contents
io.vertx.core.shareddata.AsyncMap
Module Contents
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
io.vertx.core.shareddata.SharedData
package io.vertx.kotlin.core.streams
package io.vertx.kotlin.core.tracing
package io.vertx.kotlin.ext.auth
Module Contents
fun jwtOptionsOf(algorithm: String? = null, audience: Iterable<String>? = null, audiences: Iterable<String>? = null, expiresInMinutes: Int? = null, expiresInSeconds: Int? = null, : JsonObject? = null, ignoreExpiration: Boolean? = null, issuer: String? = null, leeway: Int? = null, noTimestamp: Boolean? = null, permissions: Iterable<String>? = null, scopes: Iterable<String>? = null, subject: String? = null): JWTOptions
fun keyStoreOptionsOf(password: String? = null, passwordProtection: Map<String, String>? = null, path: String? = null, type: String? = null): KeyStoreOptions
fun pubSecKeyOptionsOf(algorithm: String? = null, buffer: String? = null, certificate: Boolean? = null, id: String? = null, publicKey: String? = null, secretKey: String? = null, symmetric: Boolean? = null): PubSecKeyOptions
package io.vertx.kotlin.ext.auth.authentication
package io.vertx.kotlin.ext.auth.authorization
package io.vertx.kotlin.ext.auth.htdigest
package io.vertx.kotlin.ext.auth.htpasswd
package io.vertx.kotlin.ext.auth.jdbc
package io.vertx.kotlin.ext.auth.jwt
package io.vertx.kotlin.ext.auth.mongo
Module Contents
io.vertx.ext.auth.mongo.MongoAuthentication
io.vertx.ext.auth.mongo.MongoUserUtil
fun mongoAuthenticationOptionsOf(collectionName: String? = null, passwordCredentialField: String? = null, passwordField: String? = null, usernameCredentialField: String? = null, usernameField: String? = null): MongoAuthenticationOptions
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
fun mongoAuthorizationOptionsOf(collectionName: String? = null, permissionField: String? = null, roleField: String? = null, usernameField: String? = null): MongoAuthorizationOptions
package io.vertx.kotlin.ext.auth.oauth2
Module Contents
io.vertx.ext.auth.oauth2.AccessToken
io.vertx.ext.auth.oauth2.OAuth2Auth
fun oauth2CredentialsOf(accessToken: String? = null, code: String? = null, : JsonObject? = null, password: String? = null, redirectUri: String? = null, username: String? = null): Oauth2Credentials
fun oAuth2OptionsOf(authorizationPath: String? = null, clientID: String? = null, clientSecret: String? = null, clientSecretParameterName: String? = null, : JsonObject? = null, flow: OAuth2FlowType? = null, : JsonObject? = null, httpClientOptions: HttpClientOptions? = null, introspectionPath: String? = null, jwkPath: String? = null, jwtOptions: JWTOptions? = null, logoutPath: String? = null, pubSecKeys: Iterable<PubSecKeyOptions>? = null, revocationPath: String? = null, scopeSeparator: String? = null, site: String? = null, tenant: String? = null, tokenPath: String? = null, : Boolean? = null, userAgent: String? = null, userInfoParameters: JsonObject? = null, userInfoPath: String? = null, validateIssuer: Boolean? = null): OAuth2Options
package io.vertx.kotlin.ext.auth.oauth2.providers
package io.vertx.kotlin.ext.auth.shiro
package io.vertx.kotlin.ext.auth.webauthn
Module Contents
io.vertx.ext.auth.webauthn.CredentialStore
io.vertx.ext.auth.webauthn.WebAuthn
fun relayPartyOf(icon: String? = null, id: String? = null, name: String? = null): RelayParty
fun webAuthnCredentialsOf(challenge: String? = null, username: String? = null, webauthn: JsonObject? = null): WebAuthnCredentials
fun webAuthnOptionsOf(attestation: Attestation? = null, authenticatorAttachment: AuthenticatorAttachment? = null, challengeLength: Int? = null, origin: String? = null, pubKeyCredParams: Iterable<String>? = null, relayParty: RelayParty? = null, requireResidentKey: Boolean? = null, timeout: Int? = null, transports: Iterable<String>? = null, userVerification: UserVerification? = null): WebAuthnOptions
package io.vertx.kotlin.ext.bridge
package io.vertx.kotlin.ext.consul
Module Contents
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, keyCertOptions: KeyCertOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, : Int? = null, maxInitialLineLength: Int? = null, maxPoolSize: Int? = null, maxRedirects: Int? = null, maxWaitQueueSize: Int? = null, maxWebSocketFrameSize: Int? = null, maxWebSocketMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = null, pipeliningLimit: Int? = null, poolCleanerPeriod: Int? = null, protocolVersion: HttpVersion? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sendUnmaskedFrames: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebSocketCompression: Boolean? = null, tryUsePerMessageWebSocketCompression: Boolean? = null, useAlpn: Boolean? = null, userAgent: String? = null, userAgentEnabled: Boolean? = null, verifyHost: Boolean? = null, webSocketCompressionAllowClientNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketCompressionRequestServerNoContext: Boolean? = null): ConsulClientOptions
fun coordinateListOf(index: Long? = null, list: Iterable<Coordinate>? = null): CoordinateList
fun coordinateOf(adj: Float? = null, err: Float? = null, height: Float? = null, node: String? = null, vec: Iterable<Float>? = null): Coordinate
fun dcCoordinatesOf(datacenter: String? = null, servers: Iterable<Coordinate>? = null): DcCoordinates
fun eventListOf(index: Long? = null, list: Iterable<Event>? = null): EventList
fun eventListOptionsOf(blockingOptions: BlockingQueryOptions? = null, name: String? = null): EventListOptions
fun eventOf(id: String? = null, lTime: Int? = null, name: String? = null, node: String? = null, payload: String? = null, service: String? = null, tag: String? = null, version: Int? = null): Event
fun eventOptionsOf(node: String? = null, payload: String? = null, service: String? = null, tag: String? = null): EventOptions
io.vertx.ext.consul.ConsulClient
Module Contents
suspend fun ConsulClient.agentInfoAwait(): JsonObject
suspend fun ConsulClient.catalogDatacentersAwait(): List<String>
suspend fun ConsulClient.catalogNodesAwait(): NodeList
suspend fun ConsulClient.catalogNodeServicesAwait(node: String): ServiceList
suspend fun ConsulClient.catalogNodeServicesWithOptionsAwait(node: String, options: BlockingQueryOptions): ServiceList
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.getValuesAwait(keyPrefix: String): KeyValueList
suspend fun ConsulClient.getValuesWithOptionsAwait(keyPrefix: String, options: BlockingQueryOptions): KeyValueList
suspend fun ConsulClient.getValueWithOptionsAwait(key: String, options: BlockingQueryOptions): KeyValue
suspend fun ConsulClient.healthChecksAwait(service: String): CheckList
suspend fun ConsulClient.healthChecksWithOptionsAwait(service: String, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.healthServiceNodesAwait(service: String, passing: Boolean): ServiceEntryList
suspend fun ConsulClient.healthServiceNodesWithOptionsAwait(service: String, passing: Boolean, options: ServiceQueryOptions): ServiceEntryList
suspend fun ConsulClient.healthStateAwait(healthState: HealthState): CheckList
suspend fun ConsulClient.healthStateWithOptionsAwait(healthState: HealthState, options: CheckQueryOptions): CheckList
suspend fun ConsulClient.infoAclTokenAwait(id: String): AclToken
suspend fun ConsulClient.infoSessionAwait(id: String): Session
suspend fun ConsulClient.infoSessionWithOptionsAwait(id: String, options: BlockingQueryOptions): Session
suspend fun ConsulClient.leaderStatusAwait(): String
suspend fun ConsulClient.listAclTokensAwait(): List<AclToken>
suspend fun ConsulClient.listEventsAwait(): EventList
suspend fun ConsulClient.listEventsWithOptionsAwait(options: EventListOptions): EventList
suspend fun ConsulClient.listNodeSessionsAwait(nodeId: String): SessionList
suspend fun ConsulClient.listNodeSessionsWithOptionsAwait(nodeId: String, options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.listSessionsAwait(): SessionList
suspend fun ConsulClient.listSessionsWithOptionsAwait(options: BlockingQueryOptions): SessionList
suspend fun ConsulClient.localChecksAwait(): List<Check>
suspend fun ConsulClient.localServicesAwait(): List<Service>
suspend fun ConsulClient.maintenanceServiceAwait(maintenanceOptions: MaintenanceOptions): Unit
suspend fun ConsulClient.passCheckAwait(checkId: String): Unit
suspend fun ConsulClient.passCheckWithNoteAwait(checkId: String, note: String): Unit
suspend fun ConsulClient.peersStatusAwait(): List<String>
suspend fun ConsulClient.putValueAwait(key: String, value: String): Boolean
suspend fun ConsulClient.putValueWithOptionsAwait(key: String, value: String, options: KeyValueOptions): Boolean
suspend fun ConsulClient.registerCheckAwait(checkOptions: CheckOptions): Unit
suspend fun ConsulClient.registerServiceAwait(serviceOptions: ServiceOptions): Unit
suspend fun ConsulClient.renewSessionAwait(id: String): Session
suspend fun ConsulClient.transactionAwait(request: TxnRequest): TxnResponse
suspend fun ConsulClient.updateAclTokenAwait(token: AclToken): String
suspend fun ConsulClient.updateCheckAwait(checkId: String, status: CheckStatus): Unit
suspend fun ConsulClient.updateCheckWithNoteAwait(checkId: String, status: CheckStatus, note: String): Unit
suspend fun ConsulClient.updatePreparedQueryAwait(definition: PreparedQueryDefinition): Unit
suspend fun ConsulClient.warnCheckAwait(checkId: String): Unit
suspend fun ConsulClient.warnCheckWithNoteAwait(checkId: String, note: String): Unit
fun keyValueListOf(index: Long? = null, list: Iterable<KeyValue>? = null): KeyValueList
fun keyValueOf(createIndex: Long? = null, flags: Long? = null, key: String? = null, lockIndex: Long? = null, modifyIndex: Long? = null, session: String? = null, value: String? = null): KeyValue
fun keyValueOptionsOf(acquireSession: String? = null, casIndex: Long? = null, flags: Long? = null, releaseSession: String? = null): KeyValueOptions
fun maintenanceOptionsOf(enable: Boolean? = null, id: String? = null, reason: String? = null): MaintenanceOptions
fun nodeListOf(index: Long? = null, list: Iterable<Node>? = null): NodeList
fun nodeOf(address: String? = null, lanAddress: String? = null, name: String? = null, wanAddress: String? = null): Node
fun nodeQueryOptionsOf(blockingOptions: BlockingQueryOptions? = null, near: String? = null): NodeQueryOptions
fun preparedQueryDefinitionOf(dcs: Iterable<String>? = null, dnsTtl: String? = null, id: String? = null, meta: Map<String, String>? = null, name: String? = null, nearestN: Int? = null, passing: Boolean? = null, service: String? = null, session: String? = null, tags: Iterable<String>? = null, templateRegexp: String? = null, templateType: String? = null, token: String? = null): PreparedQueryDefinition
fun preparedQueryExecuteOptionsOf(limit: Int? = null, near: String? = null): PreparedQueryExecuteOptions
fun preparedQueryExecuteResponseOf(dc: String? = null, dnsTtl: String? = null, failovers: Int? = null, nodes: Iterable<ServiceEntry>? = null, service: String? = null): PreparedQueryExecuteResponse
fun serviceEntryListOf(index: Long? = null, list: Iterable<ServiceEntry>? = null): ServiceEntryList
fun serviceEntryOf(checks: Iterable<Check>? = null, node: Node? = null, service: Service? = null): ServiceEntry
fun serviceListOf(index: Long? = null, list: Iterable<Service>? = null): ServiceList
fun serviceOf(address: String? = null, id: String? = null, meta: Map<String, String>? = null, name: String? = null, node: String? = null, nodeAddress: String? = null, port: Int? = null, tags: Iterable<String>? = null): Service
fun serviceOptionsOf(address: String? = null, 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(operations: Iterable<TxnOperation>? = null): TxnRequest
fun txnResponseOf(errors: Iterable<TxnError>? = null, results: Iterable<TxnResult>? = null): TxnResponse
package io.vertx.kotlin.ext.dropwizard
Module Contents
fun dropwizardMetricsOptionsOf(baseName: String? = null, configPath: String? = null, enabled: Boolean? = null, factory: VertxMetricsFactory? = null, jmxDomain: String? = null, jmxEnabled: Boolean? = null, metricRegistry: MetricRegistry? = 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
package io.vertx.kotlin.ext.healthchecks
package io.vertx.kotlin.ext.jdbc
package io.vertx.kotlin.ext.mail
Module Contents
fun dkimSignOptionsOf(auid: String? = null, bodyCanonAlgo: CanonicalizationAlgorithm? = null, bodyLimit: Int? = null, : Iterable<String>? = null, expireTime: Long? = null, : CanonicalizationAlgorithm? = null, privateKey: String? = null, privateKeyPath: String? = null, sdid: String? = null, selector: String? = null, signAlgo: DKIMSignAlgorithm? = null, signatureTimestamp: Boolean? = null, : Iterable<String>? = null): DKIMSignOptions
io.vertx.ext.mail.MailClient
fun mailConfigOf(allowRcptErrors: Boolean? = null, authMethods: String? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, disableEsmtp: Boolean? = null, dkimSignOption: DKIMSignOptions? = null, dkimSignOptions: Iterable<DKIMSignOptions>? = null, enableDKIM: Boolean? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, hostname: String? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keepAlive: Boolean? = null, keyCertOptions: KeyCertOptions? = null, keyStore: String? = null, keyStoreOptions: JksOptions? = null, keyStorePassword: String? = null, localAddress: String? = null, logActivity: Boolean? = null, login: LoginOption? = null, maxPoolSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, ownHostname: String? = null, password: String? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = 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, sslEngineOptions: SSLEngineOptions? = null, sslHandshakeTimeout: Long? = null, sslHandshakeTimeoutUnit: TimeUnit? = null, starttls: StartTLSOptions? = null, tcpCork: Boolean? = null, tcpFastOpen: Boolean? = null, tcpKeepAlive: Boolean? = null, tcpNoDelay: Boolean? = null, tcpQuickAck: Boolean? = null, trafficClass: Int? = null, trustAll: Boolean? = null, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, userAgent: String? = null, username: String? = null): MailConfig
fun mailMessageOf(attachment: Iterable<MailAttachment>? = null, bcc: Iterable<String>? = null, bounceAddress: String? = null, cc: Iterable<String>? = null, : Boolean? = null, from: String? = null, : 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
Module Contents
fun aggregateOptionsOf(allowDiskUse: Boolean? = null, batchSize: Int? = null, maxTime: Long? = null): AggregateOptions
fun bulkOperationOf(document: JsonObject? = null, filter: JsonObject? = null, multi: Boolean? = null, type: BulkOperationType? = null, upsert: Boolean? = null): BulkOperation
fun bulkWriteOptionsOf(ordered: Boolean? = null, writeOption: WriteOption? = null): BulkWriteOptions
fun findOptionsOf(batchSize: Int? = null, fields: JsonObject? = null, limit: Int? = null, skip: Int? = null, sort: JsonObject? = null): FindOptions
fun gridFsDownloadOptionsOf(revision: Int? = null): GridFsDownloadOptions
fun gridFsUploadOptionsOf(chunkSizeBytes: Int? = null, metadata: JsonObject? = null): GridFsUploadOptions
fun indexModelOf(): IndexModel
fun indexOptionsOf(): IndexOptions
io.vertx.ext.mongo.MongoClient
Module Contents
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.closeAwait(): Unit
suspend fun MongoClient.countAwait(collection: String, query: JsonObject): Long
suspend fun MongoClient.createCollectionAwait(collectionName: String): Unit
suspend fun MongoClient.createDefaultGridFsBucketServiceAwait(): MongoGridFsClient
suspend fun MongoClient.createGridFsBucketServiceAwait(bucketName: String): MongoGridFsClient
suspend fun MongoClient.createIndexAwait(collection: String, key: JsonObject): Unit
suspend fun MongoClient.createIndexesAwait(collection: String, indexes: List<IndexModel>): 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.removeDocumentsAwait(collection: String, query: JsonObject): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentsWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption?): MongoClientDeleteResult?
suspend fun MongoClient.removeDocumentWithOptionsAwait(collection: String, query: JsonObject, writeOption: WriteOption?): MongoClientDeleteResult?
suspend fun MongoClient.replaceDocumentsAwait(collection: String, query: JsonObject, replace: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.replaceDocumentsWithOptionsAwait(collection: String, query: JsonObject, replace: JsonObject, options: UpdateOptions): MongoClientUpdateResult?
suspend fun MongoClient.runCommandAwait(commandName: String, command: JsonObject): JsonObject?
suspend fun MongoClient.saveAwait(collection: String, document: JsonObject): String?
suspend fun MongoClient.saveWithOptionsAwait(collection: String, document: JsonObject, writeOption: WriteOption?): String?
suspend fun MongoClient.updateCollectionAwait(collection: String, query: JsonObject, update: JsonObject): MongoClientUpdateResult?
suspend fun MongoClient.updateCollectionWithOptionsAwait(collection: String, query: JsonObject, update: JsonObject, options: UpdateOptions): MongoClientUpdateResult?
io.vertx.ext.mongo.MongoGridFsClient
Module Contents
suspend fun MongoGridFsClient.deleteAwait(id: String): Unit
suspend fun MongoGridFsClient.downloadByFileNameAwait(stream: WriteStream<Buffer>, fileName: String): Long
suspend fun MongoGridFsClient.downloadByFileNameWithOptionsAwait(stream: WriteStream<Buffer>, fileName: String, options: GridFsDownloadOptions): Long
suspend fun MongoGridFsClient.downloadByIdAwait(stream: WriteStream<Buffer>, id: String): Long
suspend fun MongoGridFsClient.downloadFileAsAwait(fileName: String, newFileName: String): Long
suspend fun MongoGridFsClient.downloadFileAwait(fileName: String): Long
suspend fun MongoGridFsClient.downloadFileByIDAwait(id: String, fileName: String): Long
suspend fun MongoGridFsClient.dropAwait(): Unit
suspend fun MongoGridFsClient.findAllIdsAwait(): List<String>
suspend fun MongoGridFsClient.findIdsAwait(query: JsonObject): List<String>
suspend fun MongoGridFsClient.uploadByFileNameAwait(stream: ReadStream<Buffer>, fileName: String): String
suspend fun MongoGridFsClient.uploadByFileNameWithOptionsAwait(stream: ReadStream<Buffer>, fileName: String, options: GridFsUploadOptions): String
suspend fun MongoGridFsClient.uploadFileAwait(fileName: String): String
suspend fun MongoGridFsClient.uploadFileWithOptionsAwait(fileName: String, options: GridFsUploadOptions): String
fun mongoClientBulkWriteResultOf(): MongoClientBulkWriteResult
fun mongoClientDeleteResultOf(): MongoClientDeleteResult
fun mongoClientUpdateResultOf(): MongoClientUpdateResult
fun updateOptionsOf(arrayFilters: JsonArray? = null, multi: Boolean? = null, returningNewDocument: Boolean? = null, upsert: Boolean? = null, writeOption: WriteOption? = null): UpdateOptions
package io.vertx.kotlin.ext.shell
package io.vertx.kotlin.ext.shell.command
package io.vertx.kotlin.ext.shell.term
Module Contents
fun httpTermOptionsOf(acceptBacklog: Int? = null, acceptUnmaskedFrames: Boolean? = null, alpnVersions: Iterable<HttpVersion>? = null, authOptions: JsonObject? = null, charset: String? = null, clientAuth: ClientAuth? = null, compressionLevel: Int? = null, compressionSupported: Boolean? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, decoderInitialBufferSize: Int? = null, decompressionSupported: Boolean? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, handle100ContinueAutomatically: Boolean? = null, host: String? = null, http2ConnectionWindowSize: Int? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, initialSettings: Http2Settings? = null, intputrc: String? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyCertOptions: KeyCertOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, maxHeaderSize: Int? = null, maxInitialLineLength: Int? = null, maxWebSocketFrameSize: Int? = null, maxWebSocketMessageSize: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, perFrameWebSocketCompressionSupported: Boolean? = null, perMessageWebSocketCompressionSupported: Boolean? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, proxyProtocolTimeout: Long? = null, proxyProtocolTimeoutUnit: TimeUnit? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useProxyProtocol: Boolean? = null, vertsShellJsResource: Buffer? = null, webSocketAllowServerNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketPreferredClientNoContext: Boolean? = null, webSocketSubProtocols: Iterable<String>? = null): HttpTermOptions
io.vertx.ext.shell.term.TermServer
fun sshTermOptionsOf(authOptions: JsonObject? = null, defaultCharset: String? = null, host: String? = null, intputrc: String? = null, keyPairOptions: JksOptions? = null, pemKeyPairOptions: PemKeyCertOptions? = null, pfxKeyPairOptions: PfxOptions? = null, port: Int? = null): SSHTermOptions
fun telnetTermOptionsOf(acceptBacklog: Int? = null, charset: String? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, inBinary: Boolean? = null, intputrc: String? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyCertOptions: KeyCertOptions? = 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, proxyProtocolTimeout: Long? = null, proxyProtocolTimeoutUnit: TimeUnit? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useProxyProtocol: Boolean? = null): TelnetTermOptions
package io.vertx.kotlin.ext.sql
Module Contents
io.vertx.ext.sql.SQLClient
io.vertx.ext.sql.SQLConnection
io.vertx.ext.sql.SQLOperations
io.vertx.ext.sql.SQLRowStream
fun resultSetOf(columnNames: Iterable<String>? = null, next: ResultSet? = null, output: JsonArray? = null, results: Iterable<JsonArray>? = null): ResultSet
fun sqlOptionsOf(autoGeneratedKeys: Boolean? = null, autoGeneratedKeysIndexes: JsonArray? = null, catalog: String? = null, fetchDirection: FetchDirection? = null, fetchSize: Int? = null, queryTimeout: Int? = null, readOnly: Boolean? = null, resultSetConcurrency: ResultSetConcurrency? = null, resultSetType: ResultSetType? = null, schema: String? = null, transactionIsolation: TransactionIsolation? = null): SQLOptions
fun updateResultOf(keys: JsonArray? = null, updated: Int? = null): UpdateResult
package io.vertx.kotlin.ext.stomp
Module Contents
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
io.vertx.ext.stomp.StompClientConnection
Module Contents
suspend fun StompClientConnection.abortAwait(id: String): Frame
suspend fun StompClientConnection.abortAwait(id: String, : Map<String, String>): Frame
suspend fun StompClientConnection.ackAwait(id: String): Frame
suspend fun StompClientConnection.ackAwait(id: String, txId: String): Frame
suspend fun StompClientConnection.beginTXAwait(id: String): Frame
suspend fun StompClientConnection.beginTXAwait(id: String, : Map<String, String>): Frame
suspend fun StompClientConnection.commitAwait(id: String): Frame
suspend fun StompClientConnection.commitAwait(id: String, : Map<String, String>): Frame
suspend fun StompClientConnection.disconnectAwait(): Frame
suspend fun StompClientConnection.disconnectAwait(frame: Frame): Frame
suspend fun StompClientConnection.nackAwait(id: String): Frame
suspend fun StompClientConnection.nackAwait(id: String, txId: String): Frame
suspend fun StompClientConnection.sendAwait(: Map<String, String>, body: Buffer): Frame
suspend fun StompClientConnection.sendAwait(destination: String, body: Buffer): Frame
suspend fun StompClientConnection.sendAwait(frame: Frame): Frame
suspend fun StompClientConnection.sendAwait(destination: String, : Map<String, String>, body: Buffer): Frame
suspend fun StompClientConnection.subscribeAwait(destination: String, handler: (Frame) -> Unit): String
suspend fun StompClientConnection.subscribeAwait(destination: String, : Map<String, String>, handler: (Frame) -> Unit): String
suspend fun StompClientConnection.unsubscribeAwait(destination: String): Frame
suspend fun StompClientConnection.unsubscribeAwait(destination: String, : Map<String, String>): Frame
io.vertx.ext.stomp.StompServer
io.vertx.ext.stomp.StompServerHandler
fun stompClientOptionsOf(acceptedVersions: Iterable<String>? = null, autoComputeContentLength: Boolean? = null, : 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, keyCertOptions: KeyCertOptions? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useStompFrame: Boolean? = null, virtualHost: String? = null): StompClientOptions
fun stompServerOptionsOf(acceptBacklog: Int? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, heartbeat: JsonObject? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyCertOptions: KeyCertOptions? = null, keyStoreOptions: JksOptions? = null, logActivity: Boolean? = null, maxBodyLength: Int? = null, maxFrameInTransaction: Int? = null, : Int? = null, : Int? = null, maxSubscriptionsByClient: Int? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, port: Int? = null, proxyProtocolTimeout: Long? = null, proxyProtocolTimeoutUnit: TimeUnit? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useProxyProtocol: Boolean? = null, websocketBridge: Boolean? = null, websocketPath: String? = null): StompServerOptions
package io.vertx.kotlin.ext.unit
package io.vertx.kotlin.ext.unit.report
package io.vertx.kotlin.ext.web
package io.vertx.kotlin.ext.web.api
package io.vertx.kotlin.ext.web.api.contract
package io.vertx.kotlin.ext.web.api.contract.openapi3
package io.vertx.kotlin.ext.web.client
Module Contents
io.vertx.ext.web.client.HttpRequest
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, keyCertOptions: KeyCertOptions? = null, keyStoreOptions: JksOptions? = null, localAddress: String? = null, logActivity: Boolean? = null, maxChunkSize: Int? = null, : Int? = null, maxInitialLineLength: Int? = null, maxPoolSize: Int? = null, maxRedirects: Int? = null, maxWaitQueueSize: Int? = null, maxWebSocketFrameSize: Int? = null, maxWebSocketMessageSize: Int? = null, metricsName: String? = null, openSslEngineOptions: OpenSSLEngineOptions? = null, pemKeyCertOptions: PemKeyCertOptions? = null, pemTrustOptions: PemTrustOptions? = null, pfxKeyCertOptions: PfxOptions? = null, pfxTrustOptions: PfxOptions? = null, pipelining: Boolean? = null, pipeliningLimit: Int? = null, poolCleanerPeriod: Int? = null, protocolVersion: HttpVersion? = null, proxyOptions: ProxyOptions? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sendUnmaskedFrames: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, tryUseCompression: Boolean? = null, tryUsePerFrameWebSocketCompression: Boolean? = null, tryUsePerMessageWebSocketCompression: Boolean? = null, useAlpn: Boolean? = null, userAgent: String? = null, userAgentEnabled: Boolean? = null, verifyHost: Boolean? = null, webSocketCompressionAllowClientNoContext: Boolean? = null, webSocketCompressionLevel: Int? = null, webSocketCompressionRequestServerNoContext: Boolean? = null): WebClientOptions
package io.vertx.kotlin.ext.web.common.template
package io.vertx.kotlin.ext.web.handler
package io.vertx.kotlin.ext.web.handler.graphql
package io.vertx.kotlin.ext.web.handler.sockjs
Module Contents
io.vertx.ext.web.handler.sockjs.SockJSSocket
fun sockJSBridgeOptionsOf(inboundPermitteds: Iterable<PermittedOptions>? = null, maxAddressLength: Int? = null, maxHandlersPerSocket: Int? = 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
package io.vertx.kotlin.kafka.admin
Module Contents
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
fun memberAssignmentOf(topicPartitions: Iterable<TopicPartition>? = null): MemberAssignment
fun memberDescriptionOf(assignment: MemberAssignment? = null, clientId: String? = null, consumerId: String? = null, host: String? = null): MemberDescription
fun newTopicOf(config: Map<String, String>? = null, name: String? = null, numPartitions: Int? = null, replicationFactor: Short? = null): NewTopic
fun topicDescriptionOf(internal: Boolean? = null, name: String? = null, partitions: Iterable<TopicPartitionInfo>? = null): TopicDescription
package io.vertx.kotlin.kafka.client.common
Module Contents
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
Module Contents
io.vertx.kafka.client.consumer.KafkaConsumer
Module Contents
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
Module Contents
io.vertx.kafka.client.producer.KafkaProducer
Module Contents
suspend fun <K, V> KafkaProducer<K, V>.abortTransactionAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.beginTransactionAwait(): Unit
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>.commitTransactionAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.endAwait(data: KafkaProducerRecord<K, V>): Unit
suspend fun <K, V> KafkaProducer<K, V>.flushAwait(): Unit
suspend fun <K, V> KafkaProducer<K, V>.initTransactionsAwait(): 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
Module Contents
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, factory: VertxMetricsFactory? = null, influxDbOptions: VertxInfluxDbOptions? = null, jmxMetricsOptions: VertxJmxMetricsOptions? = null, jvmMetricsEnabled: Boolean? = null, labelMatches: Iterable<Match>? = null, labelMatchs: Iterable<Match>? = null, labels: Iterable<Label>? = null, micrometerRegistry: MeterRegistry? = 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
Module Contents
io.vertx.mqtt.MqttClient
io.vertx.mqtt.MqttEndpoint
io.vertx.mqtt.MqttServer
fun mqttAuthOf(): MqttAuth
fun mqttClientOptionsOf(autoGeneratedClientId: Boolean? = null, autoKeepAlive: Boolean? = null, cleanSession: Boolean? = null, clientId: String? = null, connectTimeout: Int? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, hostnameVerificationAlgorithm: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keepAliveTimeSeconds: Int? = null, keyCertOptions: KeyCertOptions? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, username: String? = null, willFlag: Boolean? = null, willMessage: String? = null, willQoS: Int? = null, willRetain: Boolean? = null, willTopic: String? = null): MqttClientOptions
fun mqttServerOptionsOf(acceptBacklog: Int? = null, autoClientId: Boolean? = null, clientAuth: ClientAuth? = null, crlPaths: Iterable<String>? = null, crlValues: Iterable<Buffer>? = null, enabledCipherSuites: Iterable<String>? = null, enabledSecureTransportProtocols: Iterable<String>? = null, host: String? = null, idleTimeout: Int? = null, idleTimeoutUnit: TimeUnit? = null, jdkSslEngineOptions: JdkSSLEngineOptions? = null, keyCertOptions: KeyCertOptions? = 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, proxyProtocolTimeout: Long? = null, proxyProtocolTimeoutUnit: TimeUnit? = null, receiveBufferSize: Int? = null, reuseAddress: Boolean? = null, reusePort: Boolean? = null, sendBufferSize: Int? = null, sni: Boolean? = null, soLinger: Int? = null, ssl: Boolean? = null, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, useProxyProtocol: Boolean? = null): MqttServerOptions
fun mqttWillOf(): MqttWill
package io.vertx.kotlin.mysqlclient
Module Contents
io.vertx.mysqlclient.MySQLConnection
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
object MySQLConnection
fun mySQLConnectOptionsOf(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, keyCertOptions: KeyCertOptions? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAffectedRows: Boolean? = null, useAlpn: Boolean? = null, user: String? = null): MySQLConnectOptions
package io.vertx.kotlin.pgclient
Module Contents
io.vertx.pgclient.PgConnection
object PgConnection
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, keyCertOptions: KeyCertOptions? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, user: String? = null): PgConnectOptions
fun pgNotificationOf(channel: String? = null, payload: String? = null, processId: Int? = null): PgNotification
package io.vertx.kotlin.pgclient.pubsub
package io.vertx.kotlin.rabbitmq
Module Contents
io.vertx.rabbitmq.RabbitMQClient
Module Contents
suspend fun RabbitMQClient.basicAckAwait(deliveryTag: Long, multiple: Boolean): Unit
suspend fun RabbitMQClient.basicConsumerAwait(queue: String): RabbitMQConsumer
suspend fun RabbitMQClient.basicConsumerAwait(queue: String, options: QueueOptions): RabbitMQConsumer
suspend fun RabbitMQClient.basicGetAwait(queue: String, autoAck: Boolean): RabbitMQMessage
suspend fun RabbitMQClient.basicNackAwait(deliveryTag: Long, multiple: Boolean, requeue: Boolean): Unit
suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, body: Buffer): Unit
suspend fun RabbitMQClient.basicPublishAwait(exchange: String, routingKey: String, properties: BasicProperties, body: Buffer): 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): DeclareOk
suspend fun RabbitMQClient.queueDeclareAwait(queue: String, durable: Boolean, exclusive: Boolean, autoDelete: Boolean, config: JsonObject): DeclareOk
suspend fun RabbitMQClient.queueDeleteAwait(queue: String): DeleteOk
suspend fun RabbitMQClient.queueDeleteIfAwait(queue: String, ifUnused: Boolean, ifEmpty: Boolean): DeleteOk
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
fun queueOptionsOf(autoAck: Boolean? = null, keepMostRecent: Boolean? = null, maxInternalQueueSize: Int? = null): QueueOptions
fun rabbitMQOptionsOf(addresses: Iterable<Address>? = null, automaticRecoveryEnabled: Boolean? = null, connectionRetries: Int? = null, connectionRetryDelay: Long? = null, connectionTimeout: Int? = null, handshakeTimeout: Int? = null, host: String? = null, includeProperties: Boolean? = null, networkRecoveryInterval: Long? = null, password: String? = null, port: Int? = null, requestedChannelMax: Int? = null, requestedHeartbeat: Int? = null, uri: String? = null, user: String? = null, virtualHost: String? = null): RabbitMQOptions
package io.vertx.kotlin.redis.client
Module Contents
io.vertx.redis.client.Redis
io.vertx.redis.client.RedisAPI
Module Contents
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.expireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.expireAwait(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.georadiusbymemberAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusbymemberRoAwait(args: List<String>): Response?
suspend fun RedisAPI.georadiusRoAwait(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.hgetallAwait(arg0: String): Response?
suspend fun RedisAPI.hgetAwait(arg0: String, arg1: 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.pexpireatAwait(arg0: String, arg1: String): Response?
suspend fun RedisAPI.pexpireAwait(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
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.servicediscovery
package io.vertx.kotlin.servicediscovery.spi
package io.vertx.kotlin.servicediscovery.types
Module Contents
object HttpEndpoint
Module Contents
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
fun httpLocationOf(endpoint: String? = null, host: String? = null, port: Int? = null, root: String? = null, ssl: Boolean? = null): HttpLocation
object JDBCDataSource
object MessageSource
object MongoDataSource
object RedisDataSource
package io.vertx.kotlin.sqlclient
Module Contents
io.vertx.sqlclient.Cursor
io.vertx.sqlclient.Pool
io.vertx.sqlclient.PreparedQuery
io.vertx.sqlclient.PreparedStatement
io.vertx.sqlclient.Query
io.vertx.sqlclient.RowStream
io.vertx.sqlclient.SqlClient
io.vertx.sqlclient.SqlConnection
io.vertx.sqlclient.Transaction
fun poolOptionsOf(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, keyCertOptions: KeyCertOptions? = 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, sslEngineOptions: SSLEngineOptions? = 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, trustOptions: TrustOptions? = null, trustStoreOptions: JksOptions? = null, useAlpn: Boolean? = null, user: String? = null): SqlConnectOptions