Modifier and Type | Method and Description |
---|---|
JsonObject |
AmqpMessage.applicationProperties() |
JsonObject |
AmqpMessage.bodyAsJsonObject() |
JsonObject |
AmqpReceiverOptions.toJson() |
JsonObject |
AmqpClientOptions.toJson() |
JsonObject |
AmqpSenderOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.applicationProperties(JsonObject props) |
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonObjectAsBody(JsonObject json) |
Constructor and Description |
---|
AmqpClientOptions(JsonObject json) |
AmqpReceiverOptions(JsonObject json) |
AmqpSenderOptions(JsonObject json) |
Constructor and Description |
---|
CamelBridgeOptions(JsonObject json)
Comply with the
DataObject contract, however calling this constructor will always throw. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
CassandraClientOptions.toJson() |
Constructor and Description |
---|
CassandraClientOptions(JsonObject json)
Constructor to create options from JSON.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
CircuitBreakerOptions.toJson() |
Constructor and Description |
---|
CircuitBreakerOptions(JsonObject json)
Creates a new instance of
CircuitBreakerOptions from the given json object. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ConfigRetriever.getCachedConfig()
Gets the last computed configuration.
|
JsonObject |
ConfigStoreOptions.getConfig() |
JsonObject |
ConfigChange.getNewConfiguration() |
JsonObject |
ConfigChange.getPreviousConfiguration() |
JsonObject |
ConfigRetrieverOptions.toJson() |
JsonObject |
ConfigStoreOptions.toJson() |
JsonObject |
ConfigChange.toJson() |
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
ConfigRetriever.configStream() |
Future<JsonObject> |
ConfigRetriever.getConfig()
Like
ConfigRetriever.getConfig(Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
ConfigStoreOptions |
ConfigStoreOptions.setConfig(JsonObject config)
Sets the configuration of the store
|
ConfigChange |
ConfigChange.setNewConfiguration(JsonObject conf)
Sets the new configuration.
|
ConfigChange |
ConfigChange.setPreviousConfiguration(JsonObject conf)
Sets the previous configuration.
|
Modifier and Type | Method and Description |
---|---|
void |
ConfigRetriever.getConfig(Handler<AsyncResult<JsonObject>> completionHandler)
Reads the configuration from the different
ConfigStore
and computes the final configuration. |
ConfigRetriever |
ConfigRetriever.setConfigurationProcessor(java.util.function.Function<JsonObject,JsonObject> processor)
Registers a handler that process the configuration before being injected into
ConfigRetriever.getConfig(Handler) or ConfigRetriever.listen(Handler) . |
ConfigRetriever |
ConfigRetriever.setConfigurationProcessor(java.util.function.Function<JsonObject,JsonObject> processor)
Registers a handler that process the configuration before being injected into
ConfigRetriever.getConfig(Handler) or ConfigRetriever.listen(Handler) . |
Constructor and Description |
---|
ConfigChange(JsonObject json)
Creates a new
ConfigChange instance from the given JSON object. |
ConfigChange(JsonObject prevConf,
JsonObject newConf)
Creates a new
ConfigChange instance. |
ConfigRetrieverOptions(JsonObject json) |
ConfigStoreOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
ConsulConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
GitConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
Constructor and Description |
---|
GitConfigStore(Vertx vertx,
JsonObject configuration) |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
HoconProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
HoconProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
ConfigMapStoreFactory.create(Vertx vertx,
JsonObject configuration) |
Constructor and Description |
---|
ConfigMapStore(Vertx vertx,
JsonObject configuration) |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
RedisConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
Constructor and Description |
---|
RedisConfigStore(Vertx vertx,
JsonObject config) |
Modifier and Type | Method and Description |
---|---|
default Future<JsonObject> |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input)
Transforms the given
input into a JsonObject . |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
ConfigStoreFactory.create(Vertx vertx,
JsonObject configuration)
Creates an instance of the
ConfigStore . |
default Future<JsonObject> |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input)
Transforms the given
input into a JsonObject . |
default void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Deprecated.
implement
ConfigProcessor.process(Vertx, JsonObject, Buffer) instead |
Modifier and Type | Method and Description |
---|---|
default void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Deprecated.
implement
ConfigProcessor.process(Vertx, JsonObject, Buffer) instead |
Modifier and Type | Method and Description |
---|---|
static JsonObject |
JsonObjectHelper.from(Properties props) |
static JsonObject |
JsonObjectHelper.from(Properties props,
boolean rawData) |
static JsonObject |
JsonObjectHelper.from(Properties props,
boolean rawData,
boolean hierarchical) |
static JsonObject |
JsonObjectHelper.toJson(List<String> paths,
String value,
boolean rawData) |
Modifier and Type | Method and Description |
---|---|
static void |
JsonObjectHelper.put(JsonObject json,
String name,
String value,
boolean rawData) |
static Buffer |
JsonObjectHelper.toBuffer(JsonObject json)
Deprecated.
use
toBuffer() instead |
Modifier and Type | Method and Description |
---|---|
void |
FileSet.buildConfiguration(List<File> files,
Handler<AsyncResult<JsonObject>> handler)
Iterates over the given set of files, and for each matching file, computes the resulting configuration.
|
Constructor and Description |
---|
FileSet(Vertx vertx,
File root,
JsonObject set)
Creates a new
FileSet from a json object. |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
SpringConfigServerStoreFactory.create(Vertx vertx,
JsonObject configuration) |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
VaultConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
Constructor and Description |
---|
VaultConfigStore(Vertx vertx,
JsonObject config)
Creates an instance of
VaultConfigStore . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
Secret.getData() |
JsonObject |
Lookup.getMetadata() |
JsonObject |
Auth.getMetadata() |
JsonObject |
Lookup.toJson() |
JsonObject |
Secret.toJson() |
JsonObject |
Auth.toJson() |
JsonObject |
TokenRequest.toPayload() |
Modifier and Type | Method and Description |
---|---|
Secret |
Secret.setData(JsonObject data) |
Lookup |
Lookup.setMetadata(JsonObject metadata) |
Auth |
Auth.setMetadata(JsonObject metadata) |
void |
SlimVaultClient.write(String path,
JsonObject secrets,
Handler<AsyncResult<Secret>> resultHandler)
Write a secret to `path`.
|
Constructor and Description |
---|
Auth(JsonObject json) |
Lookup(JsonObject json) |
Secret(JsonObject json) |
SlimVaultClient(Vertx vertx,
JsonObject configuration)
Creates an instance of
SlimVaultClient . |
TokenRequest(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input) |
Modifier and Type | Method and Description |
---|---|
ConfigStore |
ZookeeperConfigStoreFactory.create(Vertx vertx,
JsonObject configuration) |
Constructor and Description |
---|
ZookeeperConfigStore(Vertx vertx,
JsonObject configuration) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
Context.config()
If the context is associated with a Verticle deployment, this returns the configuration that was specified when
the verticle was deployed.
|
JsonObject |
AbstractVerticle.config()
Get the configuration of the verticle.
|
JsonObject |
DeploymentOptions.getConfig()
Get the JSON configuration that will be passed to the verticle(s) when deployed.
|
JsonObject |
VertxOptions.toJson() |
JsonObject |
DeploymentOptions.toJson()
Convert this to JSON
|
Modifier and Type | Method and Description |
---|---|
void |
Launcher.afterConfigParsed(JsonObject config)
Hook for sub-classes of
Launcher after the config has been parsed. |
DeploymentOptions |
DeploymentOptions.setConfig(JsonObject config)
Set the JSON configuration that will be passed to the verticle(s) when it's deployed
|
Constructor and Description |
---|
DeploymentOptions(JsonObject json)
Constructor for creating a instance from JSON
|
VertxOptions(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
JsonObject |
Buffer.toJsonObject()
Returns a
JsonObject representation of this buffer's content. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
Argument.toJson()
Exports this
Argument to its corresponding JSON representation. |
JsonObject |
Option.toJson()
Gets the json representation of this
Option . |
Constructor and Description |
---|
Argument(JsonObject json)
Creates a new instance of
Argument from the given JSON object. |
Option(JsonObject json)
Creates a new instance of
Option from the given JsonObject |
Constructor and Description |
---|
DatagramSocketOptions(JsonObject json)
Constructor to create options from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
DnsClientOptions.toJson() |
JsonObject |
AddressResolverOptions.toJson() |
Constructor and Description |
---|
AddressResolverOptions(JsonObject json) |
DnsClientOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
EventBusOptions.getClusterNodeMetadata()
User-supplied information about this node when Vert.x is clustered.
|
JsonObject |
EventBusOptions.toJson()
Builds a JSON object representing the current
EventBusOptions . |
JsonObject |
DeliveryOptions.toJson()
Convert to JSON.
|
Modifier and Type | Method and Description |
---|---|
EventBusOptions |
EventBusOptions.setClusterNodeMetadata(JsonObject clusterNodeMetadata)
Set information about this node when Vert.x is clustered.
|
Constructor and Description |
---|
DeliveryOptions(JsonObject json)
Create a delivery options from JSON
|
EventBusOptions(JsonObject json)
Creates a new instance of
EventBusOptions from the JSON object. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
FileSystemOptions.toJson()
Builds a JSON object representing the current
FileSystemOptions . |
Constructor and Description |
---|
CopyOptions(JsonObject json)
Constructor to create options from JSON.
|
FileSystemOptions(JsonObject json)
Creates a new instance of
FileSystemOptions from the JSON object. |
OpenOptions(JsonObject json)
Constructor to create options from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Http2Settings.toJson() |
JsonObject |
HttpMethod.toJson() |
JsonObject |
WebSocketConnectOptions.toJson() |
JsonObject |
WebSocketClientOptions.toJson()
Convert to JSON
|
JsonObject |
PoolOptions.toJson() |
JsonObject |
StreamPriority.toJson() |
JsonObject |
HttpClientOptions.toJson()
Convert to JSON
|
JsonObject |
RequestOptions.toJson() |
JsonObject |
GoAway.toJson() |
JsonObject |
HttpServerOptions.toJson()
Convert to JSON
|
Constructor and Description |
---|
GoAway(JsonObject json) |
Http2Settings(JsonObject json)
Create an settings from JSON
|
HttpClientOptions(JsonObject json)
Constructor to create an options from JSON
|
HttpServerOptions(JsonObject json)
Create an options from JSON
|
PoolOptions(JsonObject json)
Constructor to create an options from JSON
|
RequestOptions(JsonObject json)
Create options from JSON
|
StreamPriority(JsonObject json) |
WebSocketClientOptions(JsonObject json)
Constructor to create an options from JSON
|
WebSocketConnectOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonObject.clear()
Remove all the entries in this JSON object
|
JsonObject |
JsonObject.copy()
Deep copy of this JSON object.
|
JsonObject |
JsonObject.copy(java.util.function.Function<Object,?> cloner)
Deep copy of this JSON object.
|
JsonObject |
JsonArray.getJsonObject(int pos)
Get the JsonObject at position
pos in the array. |
JsonObject |
JsonObject.getJsonObject(String key)
Get the JsonObject value with the specified key
|
JsonObject |
JsonObject.getJsonObject(String key,
JsonObject def)
Like
getJsonObject(String) but specifying a default value to return if there is no entry. |
static JsonObject |
JsonObject.mapFrom(Object obj)
Create a JsonObject from the fields of a Java object.
|
JsonObject |
JsonObject.mergeIn(JsonObject other)
Merge in another JSON object.
|
JsonObject |
JsonObject.mergeIn(JsonObject other,
boolean deep)
Merge in another JSON object.
|
JsonObject |
JsonObject.mergeIn(JsonObject other,
int depth)
Merge in another JSON object.
|
static JsonObject |
JsonObject.of()
Create a JsonObject containing zero mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1)
Create a JsonObject containing a single mapping.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2)
Create a JsonObject containing two mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3)
Create a JsonObject containing three mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3,
String k4,
Object v4)
Create a JsonObject containing four mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3,
String k4,
Object v4,
String k5,
Object v5)
Create a JsonObject containing five mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3,
String k4,
Object v4,
String k5,
Object v5,
String k6,
Object v6)
Create a JsonObject containing six mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3,
String k4,
Object v4,
String k5,
Object v5,
String k6,
Object v6,
String k7,
Object v7)
Create a JsonObject containing seven mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3,
String k4,
Object v4,
String k5,
Object v5,
String k6,
Object v6,
String k7,
Object v7,
String k8,
Object v8)
Create a JsonObject containing eight mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3,
String k4,
Object v4,
String k5,
Object v5,
String k6,
Object v6,
String k7,
Object v7,
String k8,
Object v8,
String k9,
Object v9)
Create a JsonObject containing nine mappings.
|
static JsonObject |
JsonObject.of(String k1,
Object v1,
String k2,
Object v2,
String k3,
Object v3,
String k4,
Object v4,
String k5,
Object v5,
String k6,
Object v6,
String k7,
Object v7,
String k8,
Object v8,
String k9,
Object v9,
String k10,
Object v10)
Create a JsonObject containing ten mappings.
|
JsonObject |
JsonObject.put(String key,
Object value)
Put an Object into the JSON object with the specified key.
|
JsonObject |
JsonObject.putNull(String key)
Put a null value into the JSON object with the specified key.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonObject.getJsonObject(String key,
JsonObject def)
Like
getJsonObject(String) but specifying a default value to return if there is no entry. |
JsonObject |
JsonObject.mergeIn(JsonObject other)
Merge in another JSON object.
|
JsonObject |
JsonObject.mergeIn(JsonObject other,
boolean deep)
Merge in another JSON object.
|
JsonObject |
JsonObject.mergeIn(JsonObject other,
int depth)
Merge in another JSON object.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsOptions.toJson() |
Constructor and Description |
---|
MetricsOptions(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
JsonObject |
TCPSSLOptions.toJson()
Convert to JSON
|
JsonObject |
NetServerOptions.toJson()
Convert to JSON
|
JsonObject |
ClientOptionsBase.toJson()
Convert to JSON
|
JsonObject |
JdkSSLEngineOptions.toJson() |
JsonObject |
KeyStoreOptions.toJson()
Convert to JSON
|
JsonObject |
PfxOptions.toJson()
Convert to JSON
|
JsonObject |
PemKeyCertOptions.toJson()
Convert to JSON
|
JsonObject |
NetworkOptions.toJson()
Convert to JSON
|
JsonObject |
JksOptions.toJson()
Convert to JSON
|
JsonObject |
NetClientOptions.toJson() |
JsonObject |
TrafficShapingOptions.toJson() |
JsonObject |
ProxyOptions.toJson()
Convert to JSON
|
JsonObject |
SSLOptions.toJson()
Convert to JSON
|
JsonObject |
OpenSSLEngineOptions.toJson() |
JsonObject |
PemTrustOptions.toJson()
Convert to JSON
|
Constructor and Description |
---|
ClientOptionsBase(JsonObject json)
Create options from some JSON
|
JdkSSLEngineOptions(JsonObject json) |
JksOptions(JsonObject json)
Create options from JSON
|
KeyStoreOptions(JsonObject json)
Create options from JSON
|
NetClientOptions(JsonObject json)
Create options from JSON
|
NetServerOptions(JsonObject json)
Create some options from JSON
|
NetworkOptions(JsonObject json)
Constructor from JSON
|
OpenSSLEngineOptions(JsonObject json) |
PemKeyCertOptions(JsonObject json)
Create options from JSON
|
PemTrustOptions(JsonObject json)
Create options from JSON
|
PfxOptions(JsonObject json)
Create options from JSON
|
ProxyOptions(JsonObject json)
Create options from JSON.
|
SSLEngineOptions(JsonObject json) |
SSLOptions(JsonObject json)
Create options from JSON
|
TCPSSLOptions(JsonObject json)
Create options from JSON
|
TrafficShapingOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonEvent.objectValue() |
Modifier and Type | Method and Description |
---|---|
default TracingOptions |
VertxTracerFactory.newOptions(JsonObject jsonObject)
Create tracing options from the provided
jsonObject . |
default MetricsOptions |
VertxMetricsFactory.newOptions(JsonObject jsonObject)
Create metrics options from the provided
jsonObject . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
NodeInfo.metadata() |
Constructor and Description |
---|
NodeInfo(String host,
int port,
JsonObject metadata) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
TracingOptions.toJson() |
Constructor and Description |
---|
TracingOptions(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
JsonObject |
DB2ConnectOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
DB2ConnectOptions |
DB2ConnectOptions.merge(JsonObject other) |
Constructor and Description |
---|
DB2ConnectOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
User.attributes()
Gets extra attributes of the user.
|
JsonObject |
JWTOptions.getHeader() |
JsonObject |
User.principal()
Get the underlying principal for the User.
|
JsonObject |
JWTOptions.toJson() |
JsonObject |
PubSecKeyOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static User |
User.create(JsonObject principal)
Factory for user instances that are free form.
|
static User |
User.create(JsonObject principal,
JsonObject attributes)
Factory for user instances that are free form.
|
JWTOptions |
JWTOptions.setHeader(JsonObject header) |
Constructor and Description |
---|
JWTOptions(JsonObject json) |
KeyStoreOptions(JsonObject json)
Constructor to create an options from JSON
|
PubSecKeyOptions(JsonObject json)
Constructor to create an options from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
TokenCredentials.toJson() |
JsonObject |
Credentials.toJson()
Simple interop to downcast back to JSON for backwards compatibility.
|
JsonObject |
UsernamePasswordCredentials.toJson() |
Modifier and Type | Method and Description |
---|---|
default Future<User> |
AuthenticationProvider.authenticate(JsonObject credentials)
Deprecated.
For type safety this method should be avoided and
AuthenticationProvider.authenticate(Credentials) should be
used instead. |
void |
AuthenticationProvider.authenticate(JsonObject credentials,
Handler<AsyncResult<User>> resultHandler)
Deprecated.
For type safety this method should be avoided and
AuthenticationProvider.authenticate(Credentials, Handler) should be
used instead. |
Constructor and Description |
---|
TokenCredentials(JsonObject jsonObject) |
UsernamePasswordCredentials(JsonObject jsonObject) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
HtdigestCredentials.toJson() |
Constructor and Description |
---|
HtdigestCredentials(JsonObject jsonObject) |
Constructor and Description |
---|
HtpasswdAuthOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
JDBCAuthOptions.getConfig()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JDBCAuthOptions |
JDBCAuthOptions.setConfig(JsonObject config)
Deprecated.
The configuration of the JDBC client: refer to the Vert.x JDBC Client configuration.
|
Constructor and Description |
---|
JDBCAuthenticationOptions(JsonObject json)
Deprecated.
|
JDBCAuthOptions(JsonObject json)
Deprecated.
|
JDBCAuthorizationOptions(JsonObject json)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
List<JsonObject> |
JWTAuthOptions.getJwks() |
Modifier and Type | Method and Description |
---|---|
JWTAuthOptions |
JWTAuthOptions.addJwk(JsonObject jwk) |
String |
JWTAuth.generateToken(JsonObject claims)
Generate a new JWT token.
|
String |
JWTAuth.generateToken(JsonObject claims,
JWTOptions options)
Generate a new JWT token.
|
Modifier and Type | Method and Description |
---|---|
JWTAuthOptions |
JWTAuthOptions.setJwks(List<JsonObject> jwks) |
Constructor and Description |
---|
JWTAuthOptions(JsonObject json)
Constructor to create an options from JSON
|
Constructor and Description |
---|
LdapAuthenticationOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MongoAuthOptions.getConfig()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static MongoAuth |
MongoAuth.create(MongoClient mongoClient,
JsonObject config)
Deprecated.
Creates an instance of MongoAuth by using the given
MongoClient and configuration object. |
MongoAuthOptions |
MongoAuthOptions.setConfig(JsonObject config)
Deprecated.
The mongo client configuration: see Mongo Client documentation.
|
Constructor and Description |
---|
MongoAuthenticationOptions(JsonObject json) |
MongoAuthOptions(JsonObject json)
Deprecated.
|
MongoAuthorizationOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
OAuth2Options.getExtraParameters()
Extra parameters to send to the provider
|
JsonObject |
OAuth2Options.getHeaders()
Custom headers to send along with every request.
|
JsonObject |
Oauth2Credentials.getJwt() |
JsonObject |
OAuth2Options.getUserInfoParameters()
Set the provider custom userInfo parameters to send when requesting them.
|
JsonObject |
OAuth2Options.toJson() |
JsonObject |
OAuth2AuthorizationURL.toJson() |
JsonObject |
Oauth2Credentials.toJson() |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
OAuth2Auth.userInfo(User user)
Retrieve profile information and other attributes for a logged-in end-user.
|
Modifier and Type | Method and Description |
---|---|
String |
OAuth2Auth.authorizeURL(JsonObject params)
Deprecated.
For type safety this method should be avoided and
OAuth2Auth.authorizeURL(OAuth2AuthorizationURL) should be
used instead. |
String |
OAuth2Auth.endSessionURL(User user,
JsonObject params)
The logout (end-session) endpoint is specified in OpenID Connect Session Management 1.0.
|
OAuth2Options |
OAuth2Options.setExtraParameters(JsonObject extraParams)
Set extra parameters to be sent to the provider on each request
|
OAuth2Options |
OAuth2Options.setHeaders(JsonObject headers)
Set custom headers to be sent with every request to the provider
|
Oauth2Credentials |
Oauth2Credentials.setJwt(JsonObject jwt) |
OAuth2Options |
OAuth2Options.setUserInfoParameters(JsonObject userInfoParams)
Set custom parameters to be sent during the userInfo resource request
|
Modifier and Type | Method and Description |
---|---|
default OAuth2Auth |
OAuth2Auth.userInfo(User user,
Handler<AsyncResult<JsonObject>> handler)
Retrieve profile information and other attributes for a logged-in end-user.
|
Constructor and Description |
---|
OAuth2AuthorizationURL(JsonObject json)
Constructor to create an options from JSON
|
Oauth2Credentials(JsonObject json) |
OAuth2Options(JsonObject json)
Constructor to create an options from JSON
|
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
OtpKey.toJson() |
JsonObject |
OtpCredentials.toJson() |
JsonObject |
Authenticator.toJson() |
Constructor and Description |
---|
Authenticator(JsonObject json) |
OtpCredentials(JsonObject jsonObject) |
OtpKey(JsonObject json) |
Constructor and Description |
---|
HotpAuthOptions(JsonObject jsonObject) |
Constructor and Description |
---|
TotpAuthOptions(JsonObject jsonObject) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ShiroAuthOptions.getConfig()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
ShiroAuthOptions |
ShiroAuthOptions.setConfig(JsonObject config)
Deprecated.
Set the Shiro auth config.
|
Constructor and Description |
---|
ShiroAuthOptions(JsonObject json)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
SqlAuthorizationOptions.toJson() |
JsonObject |
SqlAuthenticationOptions.toJson() |
Constructor and Description |
---|
SqlAuthenticationOptions(JsonObject json) |
SqlAuthorizationOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
WebAuthnOptions.getExtensions() |
JsonObject |
WebAuthnCredentials.getWebauthn() |
JsonObject |
WebAuthnOptions.toJson() |
JsonObject |
Authenticator.toJson() |
JsonObject |
RelyingParty.toJson() |
JsonObject |
WebAuthnCredentials.toJson() |
JsonObject |
AttestationCertificates.toJson() |
JsonObject |
MetaDataService.verify(Authenticator authenticator)
Verify the metadata for a given authenticator.
|
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
WebAuthn.createCredentialsOptions(JsonObject user)
Same as
WebAuthn.createCredentialsOptions(JsonObject, Handler) but returning a Future. |
Future<JsonObject> |
WebAuthn.getCredentialsOptions(String username)
Same as
WebAuthn.getCredentialsOptions(String, Handler) but returning a Future. |
Modifier and Type | Method and Description |
---|---|
MetaDataService |
MetaDataService.addStatement(JsonObject statement)
Manually feed a Meta Data Statement to the service.
|
Future<JsonObject> |
WebAuthn.createCredentialsOptions(JsonObject user)
Same as
WebAuthn.createCredentialsOptions(JsonObject, Handler) but returning a Future. |
default WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user,
Handler<AsyncResult<JsonObject>> handler)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
WebAuthnOptions |
WebAuthnOptions.setExtensions(JsonObject extensions) |
WebAuthnCredentials |
WebAuthnCredentials.setWebauthn(JsonObject webauthn) |
Modifier and Type | Method and Description |
---|---|
default WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user,
Handler<AsyncResult<JsonObject>> handler)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
default WebAuthn |
WebAuthn.getCredentialsOptions(String name,
Handler<AsyncResult<JsonObject>> handler)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
Constructor and Description |
---|
AttestationCertificates(JsonObject json) |
Authenticator(JsonObject json) |
RelyingParty(JsonObject json) |
WebAuthnCredentials(JsonObject json) |
WebAuthnOptions(JsonObject json) |
Modifier and Type | Field and Description |
---|---|
static JsonObject |
PermittedOptions.DEFAULT_MATCH
The default permitted match :
null . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
PermittedOptions.getMatch() |
JsonObject |
BaseBridgeEvent.getRawMessage()
Get the raw JSON message for the event.
|
JsonObject |
BridgeOptions.toJson()
Serializes the current
BridgeOptions to JSON. |
JsonObject |
PermittedOptions.toJson()
Serializes the current instance of
PermittedOptions to JSON. |
Modifier and Type | Method and Description |
---|---|
PermittedOptions |
PermittedOptions.setMatch(JsonObject match)
This allows you to allow messages based on their structure.
|
BaseBridgeEvent |
BaseBridgeEvent.setRawMessage(JsonObject message)
Override the raw JSON message for the event.
|
Constructor and Description |
---|
BridgeOptions(JsonObject json)
Creates a new instance of
BridgeOptions from its JSON representation. |
PermittedOptions(JsonObject json)
Creates a new instance of
PermittedOptions from its JSON representation. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
KeyValueList.toJson()
Convert to JSON
|
JsonObject |
CheckOptions.toJson()
Convert to JSON
|
JsonObject |
ServiceQueryOptions.toJson()
Convert to JSON
|
JsonObject |
CheckList.toJson()
Convert to JSON
|
JsonObject |
Node.toJson()
Convert to JSON
|
JsonObject |
PreparedQueryExecuteResponse.toJson()
Convert to JSON
|
JsonObject |
TxnResponse.toJson()
Convert to JSON
|
JsonObject |
PreparedQueryDefinition.toJson()
Convert to JSON
|
JsonObject |
PreparedQueryExecuteOptions.toJson()
Convert to JSON
|
JsonObject |
SessionOptions.toJson()
Convert to JSON
|
JsonObject |
AclToken.toJson()
Deprecated.
Convert to JSON
|
JsonObject |
KeyValueOptions.toJson()
Convert to JSON
|
JsonObject |
EventListOptions.toJson()
Convert to JSON
|
JsonObject |
TxnRequest.toJson()
Convert to JSON
|
JsonObject |
CheckQueryOptions.toJson()
Convert to JSON
|
JsonObject |
NodeQueryOptions.toJson()
Convert to JSON
|
JsonObject |
Check.toJson()
Convert to JSON
|
JsonObject |
NodeList.toJson()
Convert to JSON
|
JsonObject |
Event.toJson()
Convert to JSON
|
JsonObject |
DcCoordinates.toJson()
Convert to JSON
|
JsonObject |
EventOptions.toJson()
Convert to JSON
|
JsonObject |
Service.toJson()
Convert to JSON
|
JsonObject |
ServiceList.toJson()
Convert to JSON
|
JsonObject |
EventList.toJson()
Convert to JSON
|
JsonObject |
TxnKVOperation.toJson()
Convert to JSON
|
JsonObject |
ServiceEntry.toJson()
Convert to JSON
|
JsonObject |
Coordinate.toJson()
Convert to JSON
|
JsonObject |
TxnError.toJson()
Convert to JSON
|
JsonObject |
TxnServiceOperation.toJson()
Convert to JSON
|
JsonObject |
ServiceOptions.toJson()
Convert to JSON
|
JsonObject |
ConsulClientOptions.toJson()
Convert to JSON
|
JsonObject |
Session.toJson()
Convert to JSON
|
JsonObject |
CoordinateList.toJson()
Convert to JSON
|
JsonObject |
BlockingQueryOptions.toJson()
Convert to JSON
|
JsonObject |
ServiceEntryList.toJson()
Convert to JSON
|
JsonObject |
KeyValue.toJson()
Convert to JSON
|
JsonObject |
MaintenanceOptions.toJson()
Convert to JSON
|
JsonObject |
SessionList.toJson()
Convert to JSON
|
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
ConsulClient.agentInfo()
Like
ConsulClient.agentInfo(Handler) but returns a Future of the asynchronous result. |
Modifier and Type | Method and Description |
---|---|
static void |
TxnServiceOperationConverter.toJson(TxnServiceOperation obj,
JsonObject json) |
Modifier and Type | Method and Description |
---|---|
ConsulClient |
ConsulClient.agentInfo(Handler<AsyncResult<JsonObject>> resultHandler)
Returns the configuration and member information of the local agent
|
Constructor and Description |
---|
AclToken(JsonObject token)
Deprecated.
Constructor from JSON
|
BlockingQueryOptions(JsonObject options)
Constructor from JSON
|
Check(JsonObject check)
Constructor from JSON
|
CheckList(JsonObject json)
Constructor from JSON
|
CheckOptions(JsonObject options)
Constructor from JSON
|
CheckQueryOptions(JsonObject json)
Constructor from JSON
|
ConsulClientOptions(JsonObject json)
Constructor from JSON
|
Coordinate(JsonObject coordinate)
Constructor from JSON
|
CoordinateList(JsonObject json)
Constructor from JSON
|
DcCoordinates(JsonObject coords)
Constructor from JSON
|
Event(JsonObject json)
Constructor from JSON
|
EventList(JsonObject json)
Constructor from JSON
|
EventListOptions(JsonObject json)
Constructor from JSON
|
EventOptions(JsonObject options)
Constructor from JSON
|
KeyValue(JsonObject json)
Constructor from JSON
|
KeyValueList(JsonObject json)
Constructor from JSON
|
KeyValueOptions(JsonObject options)
Constructor from JSON
|
MaintenanceOptions(JsonObject options)
Constructor from JSON
|
Node(JsonObject json)
Constructor from JSON
|
NodeList(JsonObject json)
Constructor from JSON
|
NodeQueryOptions(JsonObject json)
Constructor from JSON
|
PreparedQueryDefinition(JsonObject json)
Constructor from JSON
|
PreparedQueryExecuteOptions(JsonObject json)
Constructor from JSON
|
PreparedQueryExecuteResponse(JsonObject json)
Constructor from JSON
|
Service(JsonObject service)
Constructor from JSON
|
ServiceEntry(JsonObject json)
Constructor from JSON
|
ServiceEntryList(JsonObject json)
Constructor from JSON
|
ServiceList(JsonObject json)
Constructor from JSON
|
ServiceOptions(JsonObject options)
Constructor from JSON
|
ServiceQueryOptions(JsonObject json)
Constructor from JSON
|
Session(JsonObject session)
Constructor from JSON
|
SessionList(JsonObject json)
Constructor from JSON
|
SessionOptions(JsonObject options)
Constructor from JSON
|
TxnError(JsonObject json)
Constructor from JSON
|
TxnKVOperation(JsonObject json)
Constructor from JSON
|
TxnRequest(JsonObject json)
Constructor from JSON
|
TxnResponse(JsonObject json)
Constructor from JSON
|
TxnServiceOperation(JsonObject json)
Constructor from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
AclPolicy.toJson() |
Constructor and Description |
---|
AclPolicy(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
PolicyLink.toJson() |
JsonObject |
TokenApplyingOptions.toJson() |
JsonObject |
AclToken.toJson() |
JsonObject |
CloneAclTokenOptions.toJson() |
JsonObject |
NodeTokenApplyingOptions.toJson() |
JsonObject |
ServiceTokenApplyingOptions.toJson() |
Constructor and Description |
---|
AclToken(JsonObject json) |
CloneAclTokenOptions(JsonObject json) |
NodeTokenApplyingOptions(JsonObject json) |
PolicyLink(JsonObject json) |
ServiceTokenApplyingOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot(Measured measured)
Will return the metrics that correspond with the
measured object, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
JsonObject |
DropwizardMetricsOptions.toJson() |
JsonObject |
Match.toJson() |
Modifier and Type | Method and Description |
---|---|
MetricsOptions |
DropwizardVertxMetricsFactory.newOptions(JsonObject jsonObject) |
Constructor and Description |
---|
DropwizardMetricsOptions(JsonObject json)
Create an instance from a
JsonObject |
Match(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Status.getData() |
JsonObject |
CheckResult.getData() |
JsonObject |
Status.toJson()
Builds the JSON representation of the current
Status instance. |
JsonObject |
CheckResult.toJson()
Get a JSON version of this result, it computes the overall outcome.
|
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
HealthChecks.invoke(String name)
Like
HealthChecks.invoke(String, Handler) but with a future of the result. |
Modifier and Type | Method and Description |
---|---|
static Status |
Status.KO(JsonObject data)
Creates a status when something bad is detected.
|
static Status |
Status.OK(JsonObject data)
Creates a status when everything is fine and adds metadata.
|
Status |
Status.setData(JsonObject data)
Sets the metadata.
|
Modifier and Type | Method and Description |
---|---|
HealthChecks |
HealthChecks.invoke(Handler<JsonObject> resultHandler)
Invokes the registered procedures and computes the outcome.
|
HealthChecks |
HealthChecks.invoke(String name,
Handler<AsyncResult<JsonObject>> resultHandler)
Invokes the registered procedure with the given name and sub-procedures.
|
Constructor and Description |
---|
Status(JsonObject json)
Creates a new instance of
Status from the given JSON structure. |
Modifier and Type | Method and Description |
---|---|
static JDBCClient |
JDBCClient.create(Vertx vertx,
JsonObject config)
Create a JDBC client which maintains its own data source.
|
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config)
Like
JDBCClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default data source name |
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a JDBC client which shares its data source with any other JDBC clients created with the same
data source name
|
Modifier and Type | Method and Description |
---|---|
default JsonObject |
DataSourceProvider.getInitialConfig()
Get the SQL initial configuration
|
default JsonObject |
DataSourceProvider.toJson(JDBCConnectOptions connectOptions,
PoolOptions poolOptions)
Transforms the
JDBCConnectOptions and PoolOptions into a config suitable to be passed
as DataSourceProvider.create(JsonObject) argument. |
Modifier and Type | Method and Description |
---|---|
static DataSourceProvider |
DataSourceProvider.create(DataSource dataSource,
JsonObject config)
Init provider with specific
DataSource and config. |
static DataSourceProvider |
DataSourceProvider.create(JsonObject config) |
DataSource |
DataSourceProvider.getDataSource(JsonObject config) |
default DataSourceProvider |
DataSourceProvider.init(JsonObject sqlConfig)
Init provider with specific configuration
|
int |
DataSourceProvider.maximumPoolSize(DataSource dataSource,
JsonObject config) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MailConfig.toJson()
convert config object to Json representation
|
JsonObject |
MailAttachment.toJson()
convert this object to JSON representation
|
JsonObject |
MailResult.toJson() |
JsonObject |
MailMessage.toJson()
convert the mail message to Json representation
|
JsonObject |
DKIMSignOptions.toJson()
Converts to JsonObject
|
Modifier and Type | Method and Description |
---|---|
static MailAttachment |
MailAttachment.create(JsonObject json)
create a MailAttachment object from a JsonObject representation
|
Constructor and Description |
---|
DKIMSignOptions(JsonObject config)
Constructor from a JsonObject.
|
MailConfig(JsonObject config)
construct config object from Json representation
|
MailMessage(JsonObject json)
construct object from a JsonObject representation
|
MailResult(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
BulkOperation.getDocument()
Returns the document, used by insert, replace, and update operations
|
JsonObject |
MongoClientUpdateResult.getDocUpsertedId()
Get the document id that's upserted
|
JsonObject |
FindOptions.getFields()
Get the fields
|
JsonObject |
BulkOperation.getFilter()
Returns the filter document, used by replace, update, and delete operations
|
JsonObject |
BulkOperation.getHint()
Returns the operation hint
|
JsonObject |
FindOptions.getHint()
Get the hint.
|
JsonObject |
CountOptions.getHint()
Gets the hint to apply.
|
JsonObject |
UpdateOptions.getHint()
Get the hint.
|
JsonObject |
CreateCollectionOptions.getIndexOptionDefaults() |
JsonObject |
IndexModel.getKey()
Get the index key
|
JsonObject |
GridFsUploadOptions.getMetadata() |
JsonObject |
IndexOptions.getPartialFilterExpression()
Get the filter expression for the documents to be included in the index or null if not set
|
JsonObject |
FindOptions.getSort()
Get the sort document
|
JsonObject |
IndexOptions.getStorageEngine()
Gets the storage engine options document for this index.
|
JsonObject |
CreateCollectionOptions.getStorageEngineOptions() |
JsonObject |
ValidationOptions.getValidator() |
JsonObject |
IndexOptions.getWeights()
Gets the weighting object for use with a text index
|
JsonObject |
BulkWriteOptions.toJson() |
JsonObject |
AggregateOptions.toJson()
Convert to JSON
|
JsonObject |
IndexOptions.toJson()
Convert to JSON
|
JsonObject |
GridFsDownloadOptions.toJson()
Convert to JSON
|
JsonObject |
MongoClientDeleteResult.toJson()
Convert to JSON
|
JsonObject |
BulkOperation.toJson()
Generate a json from this object
|
JsonObject |
TimeSeriesOptions.toJson() |
JsonObject |
FindOptions.toJson()
Convert to JSON
|
JsonObject |
ValidationOptions.toJson() |
JsonObject |
MongoClientUpdateResult.toJson()
Convert to JSON
|
JsonObject |
CollationOptions.toJson()
Convert to JSON
|
JsonObject |
DistinctOptions.toJson() |
JsonObject |
IndexModel.toJson()
Convert to JSON
|
JsonObject |
CountOptions.toJson() |
JsonObject |
GridFsUploadOptions.toJson()
Convert to JSON
|
JsonObject |
UpdateOptions.toJson() |
JsonObject |
CreateCollectionOptions.toJson() |
JsonObject |
MongoClientBulkWriteResult.toJson()
Convert to JSON
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Future<List<JsonObject>> |
MongoClient.find(String collection,
JsonObject query)
Like
MongoClient.find(String, JsonObject, Handler) but returns a Future of the asynchronous result |
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Future<JsonObject> |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields)
Like
MongoClient.findOne(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
Future<JsonObject> |
MongoClient.findOneAndDelete(String collection,
JsonObject query)
Like
MongoClient.findOneAndDelete(String, JsonObject, Handler) but returns a Future of the asynchronous result |
Future<JsonObject> |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Like
MongoClient.findOneAndDeleteWithOptions(String, JsonObject, FindOptions, Handler) but returns a Future of the asynchronous result |
Future<JsonObject> |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Like
MongoClient.findOneAndReplace(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
Future<JsonObject> |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Like
MongoClient.findOneAndReplaceWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler) but returns a Future of the asynchronous result |
Future<JsonObject> |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Like
MongoClient.findOneAndUpdate(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
Future<JsonObject> |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Like
MongoClient.findOneAndUpdateWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler) but returns a Future of the asynchronous result |
Future<List<JsonObject>> |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options)
Like
MongoClient.findWithOptions(String, JsonObject, FindOptions, Handler) but returns a Future of the asynchronous result |
List<JsonObject> |
MongoClientBulkWriteResult.getInserts()
An unmodifiable list of inserts data.
|
List<JsonObject> |
MongoClientBulkWriteResult.getUpserts()
An unmodifiable list of upsert data.
|
Future<JsonObject> |
MongoClient.runCommand(String commandName,
JsonObject command)
Like
MongoClient.runCommand(String, JsonObject, Handler) but returns a Future of the asynchronous result |
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
Future<Long> |
MongoClient.count(String collection,
JsonObject query)
Like
MongoClient.count(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
Future<Long> |
MongoClient.countWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Like
MongoClient.count(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.countWithOptions(String collection,
JsonObject query,
CountOptions countOptions,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
static MongoClient |
MongoClient.create(Vertx vertx,
JsonObject config)
Create a Mongo client which maintains its own data source.
|
static BulkOperation |
BulkOperation.createDelete(JsonObject filter)
Create a new delete operation with the given filter
|
Future<Void> |
MongoClient.createIndex(String collection,
JsonObject key)
Like
MongoClient.createIndex(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.createIndex(String collection,
JsonObject key,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
Future<Void> |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Like
MongoClient.createIndexWithOptions(String, JsonObject, IndexOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
static BulkOperation |
BulkOperation.createInsert(JsonObject document)
Create a new insert operation with the given document
|
static BulkOperation |
BulkOperation.createReplace(JsonObject filter,
JsonObject document)
Create a new replace operation with the given filter and replace document
|
static BulkOperation |
BulkOperation.createReplace(JsonObject filter,
JsonObject document,
boolean upsert)
Create a new replace operation with the given filter, replace document, and the upsert flag
|
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config)
Like
MongoClient.createShared(io.vertx.core.Vertx, JsonObject, String) but with the default data source name |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a Mongo client which shares its data source with any other Mongo clients created with the same
data source name
|
static BulkOperation |
BulkOperation.createUpdate(JsonObject filter,
JsonObject document)
Create a new update operation with the given filter and update document
|
static BulkOperation |
BulkOperation.createUpdate(JsonObject filter,
JsonObject document,
boolean upsert,
boolean multi)
Create a new update operation with the given filter, update document, the upsert flag, and multi flag
|
static MongoClient |
MongoClient.createWithMongoSettings(Vertx vertx,
JsonObject config,
String dataSourceName,
com.mongodb.MongoClientSettings settings)
Constructor targeting the jvm, like standard constructor
MongoClient.createShared(Vertx, JsonObject, String) , but it accepts default mongoClientSettings
to configure mongo |
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Future<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Like
MongoClient.distinctWithQuery(String, String, String, JsonObject, Handler) but returns a Future of the asynchronous result |
Future<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Like
MongoClient.distinctWithQuery(String, String, String, JsonObject, DistinctOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
Future<List<JsonObject>> |
MongoClient.find(String collection,
JsonObject query)
Like
MongoClient.find(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Future<List<String>> |
MongoGridFsClient.findIds(JsonObject query)
Like
MongoGridFsClient.findIds(JsonObject, Handler) but returns a Future of the asynchronous result |
MongoGridFsClient |
MongoGridFsClient.findIds(JsonObject query,
Handler<AsyncResult<List<String>>> resultHandler)
Finds all file ids that match a query.
|
Future<JsonObject> |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields)
Like
MongoClient.findOne(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
Future<JsonObject> |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields)
Like
MongoClient.findOne(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
Future<JsonObject> |
MongoClient.findOneAndDelete(String collection,
JsonObject query)
Like
MongoClient.findOneAndDelete(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
Future<JsonObject> |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Like
MongoClient.findOneAndDeleteWithOptions(String, JsonObject, FindOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
Future<JsonObject> |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Like
MongoClient.findOneAndReplace(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
Future<JsonObject> |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Like
MongoClient.findOneAndReplaceWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
Future<JsonObject> |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Like
MongoClient.findOneAndUpdate(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
Future<JsonObject> |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Like
MongoClient.findOneAndUpdateWithOptions(String, JsonObject, JsonObject, FindOptions, UpdateOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
Future<List<JsonObject>> |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options)
Like
MongoClient.findWithOptions(String, JsonObject, FindOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
Future<String> |
MongoClient.insert(String collection,
JsonObject document)
Like
MongoClient.insert(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
Future<String> |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Like
MongoClient.insertWithOptions(String, JsonObject, WriteOption, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
IndexOptions |
IndexOptions.partialFilterExpression(JsonObject partialFilterExpression)
Sets the filter expression for the documents to be included in the index
|
Future<MongoClientDeleteResult> |
MongoClient.removeDocument(String collection,
JsonObject query)
Like
MongoClient.removeDocument(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
Future<MongoClientDeleteResult> |
MongoClient.removeDocuments(String collection,
JsonObject query)
Like
MongoClient.removeDocuments(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
Future<MongoClientDeleteResult> |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Like
MongoClient.removeDocumentsWithOptions(String, JsonObject, WriteOption, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Future<MongoClientDeleteResult> |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Like
MongoClient.removeDocumentWithOptions(String, JsonObject, WriteOption, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Future<MongoClientUpdateResult> |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Like
MongoClient.replaceDocuments(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Future<MongoClientUpdateResult> |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Like
MongoClient.replaceDocumentsWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Future<JsonObject> |
MongoClient.runCommand(String commandName,
JsonObject command)
Like
MongoClient.runCommand(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Future<String> |
MongoClient.save(String collection,
JsonObject document)
Like
MongoClient.save(String, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
Future<String> |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Like
MongoClient.saveWithOptions(String, JsonObject, WriteOption, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
BulkOperation |
BulkOperation.setDocument(JsonObject document)
Sets the document, used by insert, replace, and update operations
|
FindOptions |
FindOptions.setFields(JsonObject fields)
Set the fields
|
BulkOperation |
BulkOperation.setFilter(JsonObject filter)
Sets the filter document, used by replace, update, and delete operations
|
BulkOperation |
BulkOperation.setHint(JsonObject hint)
Sets the operation hint
|
FindOptions |
FindOptions.setHint(JsonObject hint)
Set the hint
|
CountOptions |
CountOptions.setHint(JsonObject hint)
Optional.
|
UpdateOptions |
UpdateOptions.setHint(JsonObject hint)
Set the hint.
|
CreateCollectionOptions |
CreateCollectionOptions.setIndexOptionDefaults(JsonObject indexOptionDefaults)
Optional.
|
IndexModel |
IndexModel.setKey(JsonObject key)
Sets the index key
|
GridFsUploadOptions |
GridFsUploadOptions.setMetadata(JsonObject metadata) |
FindOptions |
FindOptions.setSort(JsonObject sort)
Set the sort document
|
CreateCollectionOptions |
CreateCollectionOptions.setStorageEngineOptions(JsonObject storageEngineOptions)
Optional.
|
ValidationOptions |
ValidationOptions.setValidator(JsonObject validator)
Optional.
|
IndexOptions |
IndexOptions.storageEngine(JsonObject storageEngine)
Sets the storage engine options document for this index.
|
Future<MongoClientUpdateResult> |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Like
MongoClient.updateCollection(String, JsonObject, JsonArray, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Future<MongoClientUpdateResult> |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update)
Like
MongoClient.updateCollection(String, JsonObject, JsonObject, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Future<MongoClientUpdateResult> |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Like
MongoClient.updateCollectionWithOptions(String, JsonObject, JsonArray, UpdateOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Future<MongoClientUpdateResult> |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Like
MongoClient.updateCollectionWithOptions(String, JsonObject, JsonObject, UpdateOptions, Handler) but returns a Future of the asynchronous result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
IndexOptions |
IndexOptions.weights(JsonObject weights)
Sets the weighting object for use with a text index.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Constructor and Description |
---|
AggregateOptions(JsonObject options)
Constructor from JSON
|
BulkOperation(JsonObject json)
Json constructor
|
BulkWriteOptions(JsonObject json)
Constructor from JSON
|
CollationOptions(JsonObject json)
Constructing from a JsonObject with provided attributes
|
CountOptions(JsonObject json) |
CreateCollectionOptions(JsonObject json) |
DistinctOptions(JsonObject json) |
FindOptions(JsonObject options)
Constructor from JSON
|
GridFsDownloadOptions(JsonObject options)
Constructor from JSON
|
GridFsUploadOptions(JsonObject options)
Constructor from JSON
|
IndexModel(JsonObject json)
Json constructor
|
IndexModel(JsonObject key,
IndexOptions options) |
IndexOptions(JsonObject options)
Constructor from JSON
|
MongoClientBulkWriteResult(JsonObject mongoClientBulkWriteResultJson)
Constructor from JSON
|
MongoClientDeleteResult(JsonObject mongoClientDeleteResultJson)
Constructor form JSON
|
MongoClientUpdateResult(JsonObject mongoClientUpdateResultJson)
Constructor from JSON
|
MongoClientUpdateResult(long docMatched,
JsonObject docUpsertedId,
long docModified)
Constructor to specify the status of the operation.
|
TimeSeriesOptions(JsonObject json) |
UpdateOptions(JsonObject json)
Constructor from JSON
|
ValidationOptions(JsonObject json) |
Constructor and Description |
---|
MongoClientBulkWriteResult(long insertedCount,
long matchedCount,
long deletedCount,
long modifiedCount,
List<JsonObject> upserts,
List<JsonObject> inserts)
Constructor to specify the result of the bulk write operation.
|
MongoClientBulkWriteResult(long insertedCount,
long matchedCount,
long deletedCount,
long modifiedCount,
List<JsonObject> upserts,
List<JsonObject> inserts)
Constructor to specify the result of the bulk write operation.
|
Constructor and Description |
---|
ShellServerOptions(JsonObject json) |
ShellServiceOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
HttpTermOptions.getAuthOptions() |
JsonObject |
SSHTermOptions.getAuthOptions() |
Modifier and Type | Method and Description |
---|---|
HttpTermOptions |
HttpTermOptions.setAuthOptions(JsonObject authOptions)
Set the auth options.
|
SSHTermOptions |
SSHTermOptions.setAuthOptions(JsonObject authOptions)
Set the auth options.
|
Constructor and Description |
---|
HttpTermOptions(JsonObject json) |
SSHTermOptions(JsonObject json) |
TelnetTermOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ResultSet.toJson()
Convert to JSON
|
JsonObject |
UpdateResult.toJson()
Convert to JSON
|
Modifier and Type | Method and Description |
---|---|
List<JsonObject> |
ResultSet.getRows()
Get the rows - each row represented as a JsonObject where the keys are the column names and the values are
the column values.
|
List<JsonObject> |
ResultSet.getRows(boolean caseInsensitive)
Get the rows - each row represented as a JsonObject where the keys are the column names and the values are
the column values.
|
Constructor and Description |
---|
ResultSet(JsonObject json)
Create a result-set from JSON
|
SQLOptions(JsonObject json)
Constructor from JSON
|
UpdateResult(JsonObject json)
Constructor from JSON
|
Modifier and Type | Field and Description |
---|---|
static JsonObject |
StompOptions.DEFAULT_STOMP_HEARTBEAT |
Modifier and Type | Method and Description |
---|---|
JsonObject |
StompClientOptions.getHeartbeat()
Gets the heartbeat configuration.
|
JsonObject |
StompServerOptions.getHeartbeat()
Gets the heartbeat configuration.
|
JsonObject |
BridgeOptions.toJson() |
JsonObject |
StompClientOptions.toJson() |
JsonObject |
Frame.toJson() |
JsonObject |
StompServerOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static Frame.Heartbeat |
Frame.Heartbeat.create(JsonObject json)
Creates an instance of
Frame.Heartbeat from the JSON configuration provides in the
client / server options. |
StompClientOptions |
StompClientOptions.setHeartbeat(JsonObject heartbeat)
Sets the heartbeat configuration.
|
StompServerOptions |
StompServerOptions.setHeartbeat(JsonObject heartbeat)
Sets the heartbeat configuration.
|
Constructor and Description |
---|
BridgeOptions(JsonObject json) |
Frame(JsonObject json)
Creates a new instance of
Frame from its JSON representation. |
StompClientOptions(JsonObject json)
Creates an instance from a
JsonObject . |
StompServerOptions(JsonObject json)
Create an instance from a
JsonObject . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
TestOptions.toJson() |
Constructor and Description |
---|
TestOptions(JsonObject json)
Create a new options from the specified json.
|
Modifier and Type | Method and Description |
---|---|
Handler<Message<JsonObject>> |
EventBusCollector.asMessageHandler() |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ReportingOptions.toJson() |
JsonObject |
ReportOptions.toJson() |
Constructor and Description |
---|
ReportingOptions(JsonObject json)
Create a new options from the specified json.
|
ReportOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
default JsonObject |
RequestBody.asJsonObject() |
JsonObject |
RequestBody.asJsonObject(int maxAllowedLength)
Gets the current body buffer as a
JsonObject . |
default JsonObject |
RoutingContext.getBodyAsJson()
Deprecated.
Use
RoutingContext.body() instead. |
default JsonObject |
RoutingContext.getBodyAsJson(int maxAllowedLength)
Deprecated.
Use
RoutingContext.body() instead.
Gets the current body buffer as a JsonObject . If a positive limit is provided the parsing will only happen
if the buffer length is smaller or equal to the limit. Otherwise an IllegalStateException is thrown.
When the application is only handling uploads in JSON format, it is recommended to set a limit on
BodyHandler.setBodyLimit(long) as this will avoid the upload to be parsed and
loaded into the application memory. |
JsonObject |
Http2PushMapping.toJson() |
Constructor and Description |
---|
Http2PushMapping(JsonObject json)
Constructor from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
OperationRequest.getExtra()
Deprecated.
Get extra payload
|
JsonObject |
RequestParameter.getJsonObject()
Deprecated.
Returns null if value is not a JsonObject, otherwise it returns value
|
JsonObject |
OperationRequest.getParams()
Deprecated.
Get request parsedParameters as JSON
|
JsonObject |
OperationRequest.getUser()
Deprecated.
Get request principal user as routingContext.user().principal(), null if no user is authenticated
|
JsonObject |
RequestParameters.toJson()
Deprecated.
This method converts RequestParameters in an unique JsonObject with 6 fields: cookie, path, query, header, form, body
cookie, path, query, header, form are JsonObject where keys are param names and values are param values, while body depends on body's shape and may not exist |
JsonObject |
OperationRequest.toJson()
Deprecated.
|
JsonObject |
OperationResponse.toJson()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static OperationResponse |
OperationResponse.completedWithJson(JsonObject jsonObject)
Deprecated.
|
OperationRequest |
OperationRequest.setExtra(JsonObject extra)
Deprecated.
|
OperationRequest |
OperationRequest.setParams(JsonObject params)
Deprecated.
|
OperationRequest |
OperationRequest.setUser(JsonObject user)
Deprecated.
|
Constructor and Description |
---|
OperationRequest(JsonObject json)
Deprecated.
|
OperationRequest(JsonObject params,
MultiMap headers,
JsonObject user,
JsonObject extra)
Deprecated.
|
OperationResponse(JsonObject json)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RouterFactoryOptions.toJson()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RouterFactory |
RouterFactory.setExtraOperationContextPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
When set, this function is called while creating the payload of
OperationRequest |
Constructor and Description |
---|
RouterFactoryOptions(JsonObject json)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Future<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Deprecated.
Create a new OpenAPI3RouterFactory
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
ServiceRequest.getExtra()
Get extra payload
|
JsonObject |
ServiceRequest.getParams()
Get request parsedParameters as JSON
|
JsonObject |
ServiceRequest.getUser()
Get request principal user as routingContext.user().principal(), null if no user is authenticated
|
JsonObject |
ServiceResponse.toJson() |
JsonObject |
ServiceRequest.toJson() |
Modifier and Type | Method and Description |
---|---|
static ServiceResponse |
ServiceResponse.completedWithJson(JsonObject jsonObject)
Creates a
ServiceResponse with status code 200, status message OK, content type application/json and jsonObject as body |
ServiceRequest |
ServiceRequest.setExtra(JsonObject extra) |
ServiceRequest |
ServiceRequest.setParams(JsonObject params) |
ServiceRequest |
ServiceRequest.setUser(JsonObject user) |
Modifier and Type | Method and Description |
---|---|
RouteToEBServiceHandler |
RouteToEBServiceHandler.extraPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraPayloadMapper)
When
extraPayloadMapper is configured, this handler puts the evaluation result into ServiceRequest.getExtra() |
Constructor and Description |
---|
ServiceRequest(JsonObject json) |
ServiceRequest(JsonObject params,
MultiMap headers,
JsonObject user,
JsonObject extra) |
ServiceResponse(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
default JsonObject |
HttpResponse.bodyAsJsonObject() |
JsonObject |
CachingWebClientOptions.toJson()
Convert to JSON
|
JsonObject |
OAuth2WebClientOptions.toJson()
Convert to JSON
|
JsonObject |
WebClientOptions.toJson()
Convert to JSON
|
Modifier and Type | Method and Description |
---|---|
default Future<HttpResponse<T>> |
HttpRequest.sendJsonObject(JsonObject body) |
void |
HttpRequest.sendJsonObject(JsonObject body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body object encoded as json and the content type
set to application/json . |
Constructor and Description |
---|
CachingWebClientOptions(JsonObject json) |
OAuth2WebClientOptions(JsonObject json)
Creates a new instance from JSON.
|
WebClientOptions(JsonObject json)
Creates a new instance from JSON.
|
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonObject> |
BodyCodec.jsonObject() |
Modifier and Type | Method and Description |
---|---|
default Future<Buffer> |
TemplateEngine.render(JsonObject context,
String templateFileName) |
default void |
TemplateEngine.render(JsonObject context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
Modifier and Type | Method and Description |
---|---|
OAuth2AuthHandler |
OAuth2AuthHandler.extraParams(JsonObject extraParams)
Extra parameters needed to be passed while requesting a token.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
ApolloWSMessage.content()
Deprecated.
|
JsonObject |
GraphiQLHandlerOptions.getVariables() |
JsonObject |
GraphiQLHandlerOptions.getWsConnectionParams() |
JsonObject |
ApolloWSOptions.toJson()
Deprecated.
|
JsonObject |
GraphQLHandlerOptions.toJson() |
JsonObject |
GraphiQLHandlerOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
GraphiQLHandlerOptions |
GraphiQLHandlerOptions.setVariables(JsonObject variables)
Initial value of the variables area in the GraphiQL user interface.
|
GraphiQLHandlerOptions |
GraphiQLHandlerOptions.setWsConnectionParams(JsonObject wsConnectionParams)
Initial GraphQLWS connection params.
|
Constructor and Description |
---|
ApolloWSOptions(JsonObject json)
Deprecated.
Constructor to create options from JSON.
|
GraphiQLHandlerOptions(JsonObject json)
Constructor to create options from JSON.
|
GraphQLHandlerOptions(JsonObject json)
Constructor to create options from JSON.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Message.message() |
JsonObject |
GraphQLWSOptions.toJson() |
Constructor and Description |
---|
GraphQLWSOptions(JsonObject json)
Constructor to create options from JSON.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
SockJSBridgeOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Set the raw JSON message for the event.
|
Constructor and Description |
---|
SockJSBridgeOptions(JsonObject json)
Constructor from JSON
|
SockJSHandlerOptions(JsonObject json)
Constructor to create options from JSON.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIHolder.getCached(JsonPointer pointer)
Get cached object using
pointer |
JsonObject |
OpenAPIHolder.getOpenAPI() |
JsonObject |
Operation.getOperationModel() |
JsonObject |
OpenAPIHolder.solveIfNeeded(JsonObject obj)
if
obj contains $ref , it tries to solve it and return the resolved object, otherwise it returns obj |
JsonObject |
RouterBuilderOptions.toJson() |
JsonObject |
OpenAPILoaderOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static RouterBuilderException |
RouterBuilderException.cannotFindParameterProcessorGenerator(JsonPointer pointer,
JsonObject parameter) |
JsonObject |
OpenAPIHolder.solveIfNeeded(JsonObject obj)
if
obj contains $ref , it tries to solve it and return the resolved object, otherwise it returns obj |
Modifier and Type | Method and Description |
---|---|
Future<RouterBuilder> |
SecurityScheme.bind(java.util.function.Function<JsonObject,Future<AuthenticationHandler>> factory) |
RouterBuilder |
SecurityScheme.bindBlocking(java.util.function.Function<JsonObject,AuthenticationHandler> factory) |
RouterBuilder |
RouterBuilder.serviceExtraPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> serviceExtraPayloadMapper)
When set, this function is called while creating the payload of
ServiceRequest |
Constructor and Description |
---|
OpenAPILoaderOptions(JsonObject obj) |
RouterBuilderOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
static SessionStore |
SessionStore.create(Vertx vertx,
JsonObject options)
Create a Session store given a backend and configuration JSON.
|
SessionStore |
SessionStore.init(Vertx vertx,
JsonObject options)
Initialize this store.
|
protected void |
AbstractSession.setData(JsonObject data) |
Modifier and Type | Method and Description |
---|---|
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options)
Create a new
InfinispanSessionStore for the given configuration. |
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options,
org.infinispan.client.hotrod.RemoteCacheManager remoteCacheManager)
Like
InfinispanSessionStore.create(Vertx, JsonObject) but with a pre-configured Infinispan Client. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestParameter.getJsonObject()
Returns null if value is not a
JsonObject , otherwise it returns value |
JsonObject |
RequestParameters.toJson()
This method converts RequestParameters in an unique JsonObject with 6 fields: cookie, path, query, header, form, body
cookie, path, query, header, form are JsonObject where keys are param names and values are param values, while body depends on body's shape and may not exist |
JsonObject |
BodyProcessorException.toJson() |
JsonObject |
BadRequestException.toJson()
Returns a Json representation of the exception
|
JsonObject |
ParameterProcessorException.toJson() |
Constructor and Description |
---|
GrpcClientOptions(JsonObject json) |
Constructor and Description |
---|
GrpcServerOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ProxyOptions.toJson() |
Constructor and Description |
---|
ProxyOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
CacheOptions.toJson() |
Constructor and Description |
---|
CacheOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
JDBCConnectOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
DataSource dataSource,
JsonObject config)
Deprecated.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
JsonObject config)
Deprecated.
|
Constructor and Description |
---|
JDBCConnectOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonSchema.resolve()
Deprecated.
will be removed in Vert.x 5
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given JsonObject . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given JsonObject . |
default JsonObject |
SchemaRepository.resolve(JsonSchema schema)
Deprecated.
will be removed in Vert.x 5
|
default JsonObject |
SchemaRepository.resolve(String ref)
Deprecated.
will be removed in Vert.x 5
|
JsonObject |
JsonSchemaOptions.toJson() |
JsonObject |
OutputUnit.toJson() |
JsonObject |
SchemaRouterOptions.toJson()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
default SchemaRouter |
SchemaRouter.addJson(String uri,
JsonObject object)
Deprecated.
Add one or more json documents including schemas on top or inner levels.
|
SchemaRouter |
SchemaRouter.addJson(URI uri,
JsonObject object)
Deprecated.
Add one or more json documents including schemas on top or inner levels.
|
static JsonSchema |
JsonSchema.of(JsonObject json)
Factory method to create a
JsonSchema from a JsonObject . |
static JsonSchema |
JsonSchema.of(String id,
JsonObject json)
Factory method to create a
JsonSchema from a JsonObject . |
Schema |
SchemaParser.parse(JsonObject jsonSchema)
Deprecated.
Build a schema from provided json assigning a random scope.
|
Schema |
SchemaParser.parse(JsonObject jsonSchema,
JsonPointer schemaPointer)
Deprecated.
Build a schema from provided json.
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given JsonObject . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given JsonObject . |
Constructor and Description |
---|
JsonSchemaOptions(JsonObject json) |
OutputUnit(JsonObject json) |
SchemaRouterOptions(JsonObject obj)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
SchemaImpl.getJson() |
Modifier and Type | Method and Description |
---|---|
SchemaRouter |
SchemaRouterImpl.addJson(URI uri,
JsonObject object) |
boolean |
MinItemsValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
RequiredValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
PatternValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
UniqueItemsValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
ValidatorFactory.canConsumeSchema(JsonObject schema)
Returns true if this factory can consume the provided schema, eventually returning an instance of
Validator |
boolean |
ConstValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MaxPropertiesValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MinPropertiesValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MultipleOfValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
EnumValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
DefinitionsValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MaxLengthValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
PropertiesValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MinLengthValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
BaseFormatValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
BaseSingleSchemaValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
BaseCombinatorsValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MaxItemsValidatorFactory.canConsumeSchema(JsonObject schema) |
protected SchemaImpl |
BaseSchemaParser.createSchema(JsonObject schema,
JsonPointer scope,
MutableStateValidator parent)
Deprecated.
|
Validator |
MinItemsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
RequiredValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator validator) |
Validator |
PatternValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
UniqueItemsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator validator) |
Validator |
ValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent)
This method consume the schema eventually creating a new
Validator . |
Validator |
ConstValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MaxPropertiesValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MinPropertiesValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MultipleOfValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
EnumValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
DefinitionsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MaxLengthValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
PropertiesValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MinLengthValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
BaseFormatValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
BaseSingleSchemaValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
BaseCombinatorsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MaxItemsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
default SchemaInternal |
SchemaParserInternal.parse(JsonObject jsonSchema)
Deprecated.
|
default SchemaInternal |
SchemaParserInternal.parse(JsonObject jsonSchema,
JsonPointer schemaPointer)
Deprecated.
|
protected Map.Entry<Optional<JsonPointer>,Optional<String>> |
BaseSchemaParser.resolveIdAndAlias(JsonObject schema,
URI scope)
Deprecated.
|
Constructor and Description |
---|
RecursiveRefSchema(JsonObject schema,
JsonPointer scope,
SchemaParser schemaParser,
MutableStateValidator parent) |
RefSchema(JsonObject schema,
JsonPointer scope,
SchemaParser schemaParser,
MutableStateValidator parent,
boolean executeSchemaValidators) |
SchemaImpl(JsonObject schema,
JsonPointer scope,
MutableStateValidator parent) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
SchemaBuilder.toJson() |
JsonObject |
ObjectSchemaBuilder.toJson() |
JsonObject |
TupleSchemaBuilder.toJson() |
Modifier and Type | Method and Description |
---|---|
T |
SchemaBuilder.fromJson(JsonObject object) |
Modifier and Type | Method and Description |
---|---|
boolean |
DependentRequiredValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
DependentSchemasValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
ContainsValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
UnevaluatedItemsValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
UnevaluatedPropertiesValidatorFactory.canConsumeSchema(JsonObject schema) |
protected SchemaImpl |
Draft201909SchemaParser.createSchema(JsonObject schema,
JsonPointer scope,
MutableStateValidator parent)
Deprecated.
|
Validator |
DependentRequiredValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
DependentSchemasValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
ContainsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
UnevaluatedItemsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
UnevaluatedPropertiesValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
static Schema |
Draft201909SchemaParser.parse(Vertx vertx,
JsonObject schema,
URI scope)
Deprecated.
Parse a draft2019-09 schema
|
protected Map.Entry<Optional<JsonPointer>,Optional<String>> |
Draft201909SchemaParser.resolveIdAndAlias(JsonObject schema,
URI scope)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ExclusiveMinimumValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MaximumValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
DependenciesValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
TypeValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MinimumValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
IfThenElseValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
ExclusiveMaximumValidatorFactory.canConsumeSchema(JsonObject schema) |
Validator |
ExclusiveMinimumValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
ItemsValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MaximumValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
DependenciesValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
TypeValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MinimumValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
IfThenElseValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
ExclusiveMaximumValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
static Schema |
Draft7SchemaParser.parse(Vertx vertx,
JsonObject schema,
URI scope)
Deprecated.
Parse a draft-7 schema
|
Modifier and Type | Method and Description |
---|---|
boolean |
MaximumValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
TypeValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
MinimumValidatorFactory.canConsumeSchema(JsonObject schema) |
boolean |
NullableValidatorFactory.canConsumeSchema(JsonObject schema) |
Validator |
MaximumValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
TypeValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
MinimumValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
Validator |
NullableValidatorFactory.createValidator(JsonObject schema,
JsonPointer scope,
SchemaParserInternal parser,
MutableStateValidator parent) |
static Schema |
OpenAPI3SchemaParser.parse(Vertx vertx,
JsonObject schema,
URI scope)
Deprecated.
Parse an OpenAPI 3 schema
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
VertxParameterProvider.getVertxOptions() |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ConsumerGroupDescription.toJson()
Convert object to JSON representation
|
JsonObject |
TopicDescription.toJson()
Convert object to JSON representation
|
JsonObject |
ListOffsetsResultInfo.toJson()
Convert object to JSON representation
|
JsonObject |
DescribeTopicsOptions.toJson()
Convert object to JSON representation
|
JsonObject |
DescribeConsumerGroupsOptions.toJson()
Convert object to JSON representation
|
JsonObject |
NewTopic.toJson()
Convert object to JSON representation
|
JsonObject |
ConfigSynonym.toJson()
Convert object to JSON representation
|
JsonObject |
ClusterDescription.toJson()
Convert object to JSON representation
|
JsonObject |
OffsetSpec.toJson()
Convert object to JSON representation
|
JsonObject |
MemberAssignment.toJson()
Convert object to JSON representation
|
JsonObject |
ListConsumerGroupOffsetsOptions.toJson()
Convert object to JSON representation
|
JsonObject |
MemberDescription.toJson()
Convert object to JSON representation
|
JsonObject |
Config.toJson()
Convert object to JSON representation
|
JsonObject |
NewPartitions.toJson()
Convert object to JSON representation
|
JsonObject |
DescribeClusterOptions.toJson()
Convert object to JSON representation
|
JsonObject |
ConfigEntry.toJson()
Convert object to JSON representation
|
JsonObject |
ConsumerGroupListing.toJson()
Convert object to JSON representation
|
Constructor and Description |
---|
ClusterDescription(JsonObject json)
Constructor (from JSON representation)
|
Config(JsonObject json)
Constructor (from JSON representation)
|
ConfigEntry(JsonObject json)
Constructor (from JSON representation)
|
ConfigSynonym(JsonObject json)
Constructor (from JSON representation)
|
ConsumerGroupDescription(JsonObject json)
Constructor (from JSON representation)
|
ConsumerGroupListing(JsonObject json)
Constructor (from JSON representation)
|
DescribeClusterOptions(JsonObject json)
Constructor (from JSON representation)
|
DescribeConsumerGroupsOptions(JsonObject json)
Constructor (from JSON representation)
|
DescribeTopicsOptions(JsonObject json)
Constructor (from JSON representation)
|
ListConsumerGroupOffsetsOptions(JsonObject json)
Constructor (from JSON representation)
|
ListOffsetsResultInfo(JsonObject json)
Constructor (from JSON representation)
|
MemberAssignment(JsonObject json)
Constructor (from JSON representation)
|
MemberDescription(JsonObject json)
Constructor (from JSON representation)
|
NewPartitions(JsonObject json)
Constructor (from JSON representation)
|
NewTopic(JsonObject json)
Constructor (from JSON representation)
|
OffsetSpec(JsonObject json)
Constructor (from JSON representation)
|
TopicDescription(JsonObject json)
Constructor (from JSON representation)
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
PartitionInfo.toJson()
Convert object to JSON representation
|
JsonObject |
Node.toJson()
Convert object to JSON representation
|
JsonObject |
ConfigResource.toJson()
Convert object to JSON representation
|
JsonObject |
TopicPartition.toJson()
Convert object to JSON representation
|
JsonObject |
KafkaClientOptions.toJson() |
JsonObject |
TopicPartitionInfo.toJson()
Convert object to JSON representation
|
Constructor and Description |
---|
ConfigResource(JsonObject json)
Constructor (from JSON representation)
|
KafkaClientOptions(JsonObject json) |
Node(JsonObject json)
Constructor (from JSON representation)
|
PartitionInfo(JsonObject json)
Constructor (from JSON representation)
|
TopicPartition(JsonObject json)
Constructor (from JSON representation)
|
TopicPartitionInfo(JsonObject json)
Constructor (from JSON representation)
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
OffsetAndTimestamp.toJson()
Convert object to JSON representation
|
JsonObject |
OffsetAndMetadata.toJson()
Convert object to JSON representation
|
Constructor and Description |
---|
OffsetAndMetadata(JsonObject json)
Constructor (from JSON representation)
|
OffsetAndTimestamp(JsonObject json)
Constructor (from JSON representation)
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RecordMetadata.toJson()
Convert object to JSON representation
|
Constructor and Description |
---|
RecordMetadata(JsonObject json)
Constructor (from JSON representation)
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonObjectDeserializer.deserialize(String topic,
byte[] data) |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.serialization.Serde<JsonObject> |
VertxSerdes.JsonObject() |
Modifier and Type | Method and Description |
---|---|
byte[] |
JsonObjectSerializer.serialize(String topic,
JsonObject data) |
Modifier and Type | Method and Description |
---|---|
static Object |
VertxExtensionModule.getAt(JsonObject json,
String key)
Subscript operator for
JsonObject , the read part. |
static Object |
VertxExtensionModule.putAt(JsonObject json,
String key,
Object value)
Subscript operator for
JsonObject , the write part. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot()
Will return the metrics that correspond with the
measured object, null if no metrics is available. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available. |
JsonObject |
VertxJmxMetricsOptions.toJson() |
JsonObject |
MicrometerMetricsOptions.toJson() |
JsonObject |
MetricsNaming.toJson() |
JsonObject |
VertxInfluxDbOptions.toJson() |
JsonObject |
VertxPrometheusOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
MetricsOptions |
MicrometerMetricsFactory.newOptions(JsonObject jsonObject) |
Constructor and Description |
---|
Match(JsonObject json)
Create an instance from a
JsonObject |
MetricsNaming(JsonObject json)
Create an instance from a
JsonObject |
MicrometerMetricsOptions(JsonObject json)
Creates new options object for Micrometer metrics from
json input. |
VertxInfluxDbOptions(JsonObject json)
Creates new options object for InfluxDB reporting from
json input. |
VertxJmxMetricsOptions(JsonObject json)
Create an instance from a
JsonObject |
VertxPrometheusOptions(JsonObject json)
Create an instance from a
JsonObject |
Modifier and Type | Method and Description |
---|---|
static JsonObject |
MqttWill.propertyToJson(MqttProperties.MqttProperty<?> prop) |
JsonObject |
MqttWill.toJson()
Convert instance in JSON
|
JsonObject |
MqttAuth.toJson()
Convert instance in JSON
|
JsonObject |
MqttClientOptions.toJson() |
JsonObject |
MqttServerOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
static MqttProperties.MqttProperty<?> |
MqttWill.propertyFromJson(JsonObject obj) |
Constructor and Description |
---|
MqttAuth(JsonObject json)
Create instance from JSON
|
MqttClientOptions(JsonObject json)
Create an instance of MqttClientOptions from JSON
|
MqttServerOptions(JsonObject json)
Create an options from JSON
|
MqttWill(JsonObject json)
Create instance from JSON
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MSSQLInfo.toJson() |
JsonObject |
MSSQLConnectOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
MSSQLConnectOptions |
MSSQLConnectOptions.merge(JsonObject other) |
Constructor and Description |
---|
MSSQLConnectOptions(JsonObject json) |
MSSQLInfo(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MySQLConnectOptions.toJson() |
JsonObject |
MySQLAuthOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
MySQLConnectOptions |
MySQLConnectOptions.merge(JsonObject other) |
Constructor and Description |
---|
MySQLAuthOptions(JsonObject json) |
MySQLConnectOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIObject.getOpenAPIModel()
Returns the part of the related OpenAPI specification which is represented by the OpenAPI object that is
implementing this interface.
|
JsonObject |
OpenAPIContract.getRawContract() |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
OpenAPIVersion.resolve(Vertx vertx,
SchemaRepository repo,
JsonObject contract) |
Modifier and Type | Method and Description |
---|---|
static Future<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Future<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static OpenAPIVersion |
OpenAPIVersion.fromContract(JsonObject contract) |
Future<JsonObject> |
OpenAPIVersion.resolve(Vertx vertx,
SchemaRepository repo,
JsonObject contract) |
Future<Void> |
OpenAPIVersion.validateAdditionalContractFile(Vertx vertx,
SchemaRepository repo,
JsonObject file)
Validates additional contract files against the openapi schema.
|
Future<OutputUnit> |
OpenAPIVersion.validateContract(Vertx vertx,
SchemaRepository repo,
JsonObject contract) |
Modifier and Type | Method and Description |
---|---|
static Future<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
Modifier and Type | Method and Description |
---|---|
default JsonObject |
Parameter.getJsonObject() |
default JsonObject |
Parameter.getJsonObject(JsonObject defaultValue) |
Modifier and Type | Method and Description |
---|---|
default JsonObject |
Parameter.getJsonObject(JsonObject defaultValue) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
PgNotification.toJson() |
JsonObject |
PgConnectOptions.toJson() |
JsonObject |
PgNotice.toJson() |
Modifier and Type | Method and Description |
---|---|
PgConnectOptions |
PgConnectOptions.merge(JsonObject other) |
Constructor and Description |
---|
PgConnectOptions(JsonObject json) |
PgNotice(JsonObject json) |
PgNotification(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RabbitMQPublisherConfirmation.toJson() |
JsonObject |
RabbitMQConfirmation.toJson() |
JsonObject |
RabbitMQOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
Future<JsonObject> |
RabbitMQClient.queueDeclareAuto()
Like
RabbitMQClient.queueDeclareAuto(Handler) but returns a Future of the asynchronous result |
Modifier and Type | Method and Description |
---|---|
static RabbitMQClient |
RabbitMQClient.create(Vertx vertx,
JsonObject config)
Like
RabbitMQClient.create(Vertx, RabbitMQOptions) but with a JsonObject config object. |
Future<Void> |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config)
Like
RabbitMQClient.exchangeDeclare(String, String, boolean, boolean, JsonObject, Handler) but returns a Future of the asynchronous result |
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<Void>> resultHandler)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
Future<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config)
Like
RabbitMQClient.queueDeclare(String, boolean, boolean, boolean, JsonObject, Handler) but returns a Future of the asynchronous result |
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<com.rabbitmq.client.AMQP.Queue.DeclareOk>> resultHandler)
Declare a queue with config options
|
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Constructor and Description |
---|
QueueOptions(JsonObject json) |
RabbitMQConfirmation(JsonObject json) |
RabbitMQOptions(JsonObject json) |
RabbitMQPublisherConfirmation(JsonObject json) |
RabbitMQPublisherOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
AmqpMessage.applicationProperties() |
JsonObject |
AmqpMessage.bodyAsJsonObject() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.applicationProperties(JsonObject props) |
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonObjectAsBody(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ConfigRetriever.getCachedConfig()
Gets the last computed configuration.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
ConfigRetriever.configStream() |
Single<JsonObject> |
ConfigRetriever.rxGetConfig()
Reads the configuration from the different
and computes the final configuration.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Context.config()
If the context is associated with a Verticle deployment, this returns the configuration that was specified when
the verticle was deployed.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Buffer.toJsonObject()
Returns a representation of this buffer's content.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonEvent.objectValue() |
Modifier and Type | Method and Description |
---|---|
JsonObject |
User.attributes()
Gets extra attributes of the user.
|
JsonObject |
User.principal()
Get the underlying principal for the User.
|
Modifier and Type | Method and Description |
---|---|
static User |
User.create(JsonObject principal)
Factory for user instances that are free form.
|
static User |
User.create(JsonObject principal,
JsonObject attributes)
Factory for user instances that are free form.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthenticationProvider.authenticate(JsonObject credentials)
Deprecated.
|
void |
AuthenticationProvider.authenticate(JsonObject credentials,
Handler<AsyncResult<User>> resultHandler)
Deprecated.
|
Single<User> |
AuthenticationProvider.rxAuthenticate(JsonObject credentials)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
String |
JWTAuth.generateToken(JsonObject claims)
Generate a new JWT token.
|
String |
JWTAuth.generateToken(JsonObject claims,
JWTOptions options)
Generate a new JWT token.
|
Modifier and Type | Method and Description |
---|---|
static MongoAuth |
MongoAuth.create(MongoClient mongoClient,
JsonObject config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
OAuth2Auth.rxUserInfo(User user)
Retrieve profile information and other attributes for a logged-in end-user.
|
Modifier and Type | Method and Description |
---|---|
String |
OAuth2Auth.authorizeURL(JsonObject params)
Deprecated.
|
String |
OAuth2Auth.endSessionURL(User user,
JsonObject params)
The logout (end-session) endpoint is specified in OpenID Connect Session Management 1.0.
|
Modifier and Type | Method and Description |
---|---|
OAuth2Auth |
OAuth2Auth.userInfo(User user,
Handler<AsyncResult<JsonObject>> handler)
Retrieve profile information and other attributes for a logged-in end-user.
|
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetaDataService.verify(Authenticator authenticator)
Verify the metadata for a given authenticator.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
WebAuthn.rxCreateCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Single<JsonObject> |
WebAuthn.rxGetCredentialsOptions(String name)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
Modifier and Type | Method and Description |
---|---|
MetaDataService |
MetaDataService.addStatement(JsonObject statement)
Manually feed a Meta Data Statement to the service.
|
WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user,
Handler<AsyncResult<JsonObject>> handler)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Single<JsonObject> |
WebAuthn.rxCreateCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Modifier and Type | Method and Description |
---|---|
WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user,
Handler<AsyncResult<JsonObject>> handler)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
WebAuthn |
WebAuthn.getCredentialsOptions(String name,
Handler<AsyncResult<JsonObject>> handler)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
BaseBridgeEvent.getRawMessage()
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
BaseBridgeEvent |
BaseBridgeEvent.setRawMessage(JsonObject message)
Override the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
ConsulClient.rxAgentInfo()
Returns the configuration and member information of the local agent
|
Modifier and Type | Method and Description |
---|---|
ConsulClient |
ConsulClient.agentInfo(Handler<AsyncResult<JsonObject>> resultHandler)
Returns the configuration and member information of the local agent
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot(Measured measured)
Will return the metrics that correspond with the
measured object, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
HealthChecks.rxInvoke(String name)
Invokes the registered procedure with the given name and sub-procedures.
|
Modifier and Type | Method and Description |
---|---|
HealthChecks |
HealthChecks.invoke(Handler<JsonObject> resultHandler)
Invokes the registered procedures and computes the outcome.
|
HealthChecks |
HealthChecks.invoke(String name,
Handler<AsyncResult<JsonObject>> resultHandler)
Invokes the registered procedure with the given name and sub-procedures.
|
Modifier and Type | Method and Description |
---|---|
static JDBCClient |
JDBCClient.create(Vertx vertx,
JsonObject config)
Create a JDBC client which maintains its own data source.
|
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config)
Like
JDBCClient.createShared(io.vertx.reactivex.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default data source name |
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a JDBC client which shares its data source with any other JDBC clients created with the same
data source name
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MailAttachment.toJson()
convert this object to JSON representation
|
Modifier and Type | Method and Description |
---|---|
static MailAttachment |
MailAttachment.create(JsonObject json)
create a MailAttachment object from a JsonObject representation
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Single<List<JsonObject>> |
MongoClient.rxFind(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Maybe<JsonObject> |
MongoClient.rxFindOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.rxFindWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Maybe<JsonObject> |
MongoClient.rxRunCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.count(String collection,
JsonObject query)
Count matching documents in a collection.
|
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
MongoClient |
MongoClient.countWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
MongoClient |
MongoClient.countWithOptions(String collection,
JsonObject query,
CountOptions countOptions,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
static MongoClient |
MongoClient.create(Vertx vertx,
JsonObject config)
Create a Mongo client which maintains its own data source.
|
MongoClient |
MongoClient.createIndex(String collection,
JsonObject key)
Creates an index.
|
MongoClient |
MongoClient.createIndex(String collection,
JsonObject key,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
MongoClient |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
MongoClient |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config)
Like
MongoClient.createShared(io.vertx.reactivex.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default data source name |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a Mongo client which shares its data source with any other Mongo clients created with the same
data source name
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.find(String collection,
JsonObject query)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
MongoGridFsClient |
MongoGridFsClient.findIds(JsonObject query)
Finds all file ids that match a query.
|
MongoGridFsClient |
MongoGridFsClient.findIds(JsonObject query,
Handler<AsyncResult<List<String>>> resultHandler)
Finds all file ids that match a query.
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Single<Long> |
MongoClient.rxCount(String collection,
JsonObject query)
Count matching documents in a collection.
|
Single<Long> |
MongoClient.rxCountWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
Completable |
MongoClient.rxCreateIndex(String collection,
JsonObject key)
Creates an index.
|
Completable |
MongoClient.rxCreateIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<List<JsonObject>> |
MongoClient.rxFind(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Single<List<String>> |
MongoGridFsClient.rxFindIds(JsonObject query)
Finds all file ids that match a query.
|
Maybe<JsonObject> |
MongoClient.rxFindOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.rxFindWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Maybe<String> |
MongoClient.rxInsert(String collection,
JsonObject document)
Insert a document in the specified collection
|
Maybe<String> |
MongoClient.rxInsertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxReplaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxReplaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<JsonObject> |
MongoClient.rxRunCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
Maybe<String> |
MongoClient.rxSave(String collection,
JsonObject document)
Save a document in the specified collection
|
Maybe<String> |
MongoClient.rxSaveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.save(String collection,
JsonObject document)
Save a document in the specified collection
|
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestBody.asJsonObject() |
JsonObject |
RequestBody.asJsonObject(int maxAllowedLength)
Gets the current body buffer as a .
|
JsonObject |
RoutingContext.getBodyAsJson()
Deprecated.
|
JsonObject |
RoutingContext.getBodyAsJson(int maxAllowedLength)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestParameter.getJsonObject()
Deprecated.
|
JsonObject |
RequestParameters.toJson()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RouterFactory |
RouterFactory.setExtraOperationContextPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Deprecated.
|
static Single<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.rxCreate(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
RouterFactory |
OpenAPI3RouterFactory.setExtraOperationContextPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
HttpResponse.bodyAsJsonObject() |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonObject> |
BodyCodec.jsonObject() |
Modifier and Type | Method and Description |
---|---|
void |
TemplateEngine.render(JsonObject context,
String templateFileName)
Render the template.
|
void |
TemplateEngine.render(JsonObject context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
Single<Buffer> |
TemplateEngine.rxRender(JsonObject context,
String templateFileName)
Render the template.
|
Modifier and Type | Method and Description |
---|---|
OAuth2AuthHandler |
OAuth2AuthHandler.extraParams(JsonObject extraParams)
Extra parameters needed to be passed while requesting a token.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
ApolloWSMessage.content()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Message.message() |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Set the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIHolder.getCached(JsonPointer pointer)
Get cached object using
pointer |
JsonObject |
OpenAPIHolder.getOpenAPI() |
JsonObject |
Operation.getOperationModel() |
JsonObject |
OpenAPIHolder.solveIfNeeded(JsonObject obj)
if
obj contains $ref , it tries to solve it and return the resolved object, otherwise it returns obj |
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIHolder.solveIfNeeded(JsonObject obj)
if
obj contains $ref , it tries to solve it and return the resolved object, otherwise it returns obj |
Modifier and Type | Method and Description |
---|---|
Future<RouterBuilder> |
SecurityScheme.bind(java.util.function.Function<JsonObject,Future<AuthenticationHandler>> factory) |
Future<RouterBuilder> |
SecurityScheme.bind(Function<JsonObject,Single<AuthenticationHandler>> factory) |
RouterBuilder |
SecurityScheme.bindBlocking(java.util.function.Function<JsonObject,AuthenticationHandler> factory) |
RouterBuilder |
RouterBuilder.serviceExtraPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> serviceExtraPayloadMapper)
When set, this function is called while creating the payload of
|
Modifier and Type | Method and Description |
---|---|
static SessionStore |
SessionStore.create(Vertx vertx,
JsonObject options)
Create a Session store given a backend and configuration JSON.
|
SessionStore |
SessionStore.init(Vertx vertx,
JsonObject options)
Initialize this store.
|
Modifier and Type | Method and Description |
---|---|
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options)
Create a new
InfinispanSessionStore for the given configuration. |
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options,
org.infinispan.client.hotrod.RemoteCacheManager remoteCacheManager)
Like
InfinispanSessionStore.create(io.vertx.reactivex.core.Vertx, io.vertx.core.json.JsonObject) but with a pre-configured Infinispan Client. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestParameter.getJsonObject()
Returns null if value is not a , otherwise it returns value
|
JsonObject |
RequestParameters.toJson()
This method converts RequestParameters in an unique JsonObject with 6 fields: cookie, path, query, header, form, body
cookie, path, query, header, form are JsonObject where keys are param names and values are param values, while body depends on body's shape and may not exist |
Modifier and Type | Method and Description |
---|---|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
DataSource dataSource,
JsonObject config)
Deprecated.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
JsonObject config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonSchema.resolve()
Tries to resolve all internal references.
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonSchema schema)
Tries to resolve all internal and repository local references.
|
JsonObject |
SchemaRepository.resolve(String ref)
Tries to resolve all internal and repository local references.
|
Modifier and Type | Method and Description |
---|---|
SchemaRouter |
SchemaRouter.addJson(String uri,
JsonObject object)
Deprecated.
|
SchemaRouter |
SchemaRouter.addJson(URI uri,
JsonObject object)
Deprecated.
|
static JsonSchema |
JsonSchema.of(JsonObject json)
Factory method to create a
JsonSchema from a . |
static JsonSchema |
JsonSchema.of(String id,
JsonObject json)
Factory method to create a
JsonSchema from a . |
Schema |
SchemaParser.parse(JsonObject jsonSchema)
Deprecated.
|
Schema |
SchemaParser.parse(JsonObject jsonSchema,
JsonPointer schemaPointer)
Deprecated.
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot()
Will return the metrics that correspond with the
measured object, null if no metrics is available. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIContract.getRawContract() |
Modifier and Type | Method and Description |
---|---|
static Future<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Future<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Single<OpenAPIContract> |
OpenAPIContract.rxFrom(Vertx vertx,
JsonObject unresolvedContract)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Single<OpenAPIContract> |
OpenAPIContract.rxFrom(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
Modifier and Type | Method and Description |
---|---|
static Future<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Single<OpenAPIContract> |
OpenAPIContract.rxFrom(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
RabbitMQClient.rxQueueDeclareAuto()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<Void>> resultHandler)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config)
Declare a queue with config options
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<com.rabbitmq.client.AMQP.Queue.DeclareOk>> resultHandler)
Declare a queue with config options
|
Completable |
RabbitMQClient.rxExchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
RabbitMQClient.rxQueueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config)
Declare a queue with config options
|
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(JsonObject arg)
Adds a JsonObject argument, the encoding will serialize the json as key0, value0, key1, value1, ...
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceDiscovery.getRecord(JsonObject filter)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecords(JsonObject filter)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery bridge.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery service importer.
|
Maybe<Record> |
ServiceDiscovery.rxGetRecord(JsonObject filter)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(JsonObject filter)
Lookups for a set of records.
|
Completable |
ServiceDiscovery.rxRegisterServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
Completable |
ServiceDiscovery.rxRegisterServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceExporter.init(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the importer.
|
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but let you configure whether or not the
service is using https . |
static Record |
MongoDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Mongo data source.
|
static Record |
RedisDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Redis data source.
|
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured .
|
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
Modifier and Type | Method and Description |
---|---|
JsonObject[] |
Tuple.getArrayOfJsonObjects(int pos)
Get an array of value at
pos . |
JsonObject[] |
Row.getArrayOfJsonObjects(String column)
Get an array of value for the given
column . |
JsonObject |
Tuple.getJsonObject(int pos)
Get a value at
pos . |
JsonObject |
Row.getJsonObject(String column)
Get a value for the given
column . |
JsonObject |
Row.toJson()
Return a JSON object representation of the row.
|
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.addArrayOfJsonObject(JsonObject[] value)
Add an array of value at the end of the tuple.
|
Tuple |
Tuple.addJsonObject(JsonObject value)
Add a value at the end of the tuple.
|
Modifier and Type | Method and Description |
---|---|
static TupleMapper<JsonObject> |
TupleMapper.jsonObject()
Map a to a .
|
Modifier and Type | Method and Description |
---|---|
Variables |
Variables.addAll(JsonObject json)
Populates with a JSON object:
null are conserved
JsonArray is converted to List
JsonObject is converted to Map
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
Variables |
Variables.setAll(JsonObject json)
Like
Variables.addAll(io.vertx.core.json.JsonObject) but overwrites previous variables. |
static Variables |
Variables.variables(JsonObject json)
Create an instance populated from a JSON object:
null are conserved
JsonArray is converted to List
JsonObject is converted to Map
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RedisClusterConnectOptions.toJson()
Converts this object to JSON notation.
|
JsonObject |
RedisOptions.toJson()
Converts this object to JSON notation.
|
JsonObject |
PoolOptions.toJson()
Converts this object to JSON notation.
|
JsonObject |
RedisSentinelConnectOptions.toJson()
Converts this object to JSON notation.
|
JsonObject |
RedisReplicationConnectOptions.toJson()
Converts this object to JSON notation.
|
JsonObject |
RedisStandaloneConnectOptions.toJson()
Converts this object to JSON notation.
|
JsonObject |
RedisConnectOptions.toJson()
Converts this object to JSON notation.
|
Modifier and Type | Method and Description |
---|---|
default Request |
Request.arg(JsonObject arg)
Adds a JsonObject argument, the encoding will serialize the json as key0, value0, key1, value1, ...
|
Constructor and Description |
---|
PoolOptions(JsonObject json) |
RedisClusterConnectOptions(JsonObject json) |
RedisConnectOptions(JsonObject json) |
RedisOptions(JsonObject json)
Copy from JSON constructor.
|
RedisReplicationConnectOptions(JsonObject json) |
RedisSentinelConnectOptions(JsonObject json) |
RedisStandaloneConnectOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
AmqpMessage.applicationProperties() |
JsonObject |
AmqpMessage.bodyAsJsonObject() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.applicationProperties(JsonObject props) |
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonObjectAsBody(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ConfigRetriever.getCachedConfig()
Gets the last computed configuration.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
ConfigRetriever.configStream() |
Single<JsonObject> |
ConfigRetriever.rxGetConfig()
Reads the configuration from the different
and computes the final configuration.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Context.config()
If the context is associated with a Verticle deployment, this returns the configuration that was specified when
the verticle was deployed.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Buffer.toJsonObject()
Returns a representation of this buffer's content.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonEvent.objectValue() |
Modifier and Type | Method and Description |
---|---|
JsonObject |
User.attributes()
Gets extra attributes of the user.
|
JsonObject |
User.principal()
Get the underlying principal for the User.
|
Modifier and Type | Method and Description |
---|---|
static User |
User.create(JsonObject principal)
Factory for user instances that are free form.
|
static User |
User.create(JsonObject principal,
JsonObject attributes)
Factory for user instances that are free form.
|
Modifier and Type | Method and Description |
---|---|
void |
AuthenticationProvider.authenticate(JsonObject credentials)
Deprecated.
|
void |
AuthenticationProvider.authenticate(JsonObject credentials,
Handler<AsyncResult<User>> resultHandler)
Deprecated.
|
Single<User> |
AuthenticationProvider.rxAuthenticate(JsonObject credentials)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
String |
JWTAuth.generateToken(JsonObject claims)
Generate a new JWT token.
|
String |
JWTAuth.generateToken(JsonObject claims,
JWTOptions options)
Generate a new JWT token.
|
Modifier and Type | Method and Description |
---|---|
static MongoAuth |
MongoAuth.create(MongoClient mongoClient,
JsonObject config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
OAuth2Auth.rxUserInfo(User user)
Retrieve profile information and other attributes for a logged-in end-user.
|
Modifier and Type | Method and Description |
---|---|
String |
OAuth2Auth.authorizeURL(JsonObject params)
Deprecated.
|
String |
OAuth2Auth.endSessionURL(User user,
JsonObject params)
The logout (end-session) endpoint is specified in OpenID Connect Session Management 1.0.
|
Modifier and Type | Method and Description |
---|---|
OAuth2Auth |
OAuth2Auth.userInfo(User user,
Handler<AsyncResult<JsonObject>> handler)
Retrieve profile information and other attributes for a logged-in end-user.
|
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetaDataService.verify(Authenticator authenticator)
Verify the metadata for a given authenticator.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
WebAuthn.rxCreateCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Single<JsonObject> |
WebAuthn.rxGetCredentialsOptions(String name)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
Modifier and Type | Method and Description |
---|---|
MetaDataService |
MetaDataService.addStatement(JsonObject statement)
Manually feed a Meta Data Statement to the service.
|
WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user,
Handler<AsyncResult<JsonObject>> handler)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Single<JsonObject> |
WebAuthn.rxCreateCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Modifier and Type | Method and Description |
---|---|
WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user,
Handler<AsyncResult<JsonObject>> handler)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
WebAuthn |
WebAuthn.getCredentialsOptions(String name,
Handler<AsyncResult<JsonObject>> handler)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
BaseBridgeEvent.getRawMessage()
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
BaseBridgeEvent |
BaseBridgeEvent.setRawMessage(JsonObject message)
Override the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
ConsulClient.rxAgentInfo()
Returns the configuration and member information of the local agent
|
Modifier and Type | Method and Description |
---|---|
ConsulClient |
ConsulClient.agentInfo(Handler<AsyncResult<JsonObject>> resultHandler)
Returns the configuration and member information of the local agent
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot(Measured measured)
Will return the metrics that correspond with the
measured object, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
HealthChecks.rxInvoke(String name)
Invokes the registered procedure with the given name and sub-procedures.
|
Modifier and Type | Method and Description |
---|---|
HealthChecks |
HealthChecks.invoke(Handler<JsonObject> resultHandler)
Invokes the registered procedures and computes the outcome.
|
HealthChecks |
HealthChecks.invoke(String name,
Handler<AsyncResult<JsonObject>> resultHandler)
Invokes the registered procedure with the given name and sub-procedures.
|
Modifier and Type | Method and Description |
---|---|
static JDBCClient |
JDBCClient.create(Vertx vertx,
JsonObject config)
Create a JDBC client which maintains its own data source.
|
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config)
Like
JDBCClient.createShared(io.vertx.rxjava.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default data source name |
static JDBCClient |
JDBCClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a JDBC client which shares its data source with any other JDBC clients created with the same
data source name
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MailAttachment.toJson()
convert this object to JSON representation
|
Modifier and Type | Method and Description |
---|---|
static MailAttachment |
MailAttachment.create(JsonObject json)
create a MailAttachment object from a JsonObject representation
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Single<List<JsonObject>> |
MongoClient.rxFind(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Single<JsonObject> |
MongoClient.rxFindOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Single<JsonObject> |
MongoClient.rxFindOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.rxFindWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Single<JsonObject> |
MongoClient.rxRunCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.count(String collection,
JsonObject query)
Count matching documents in a collection.
|
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
MongoClient |
MongoClient.countWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
MongoClient |
MongoClient.countWithOptions(String collection,
JsonObject query,
CountOptions countOptions,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
static MongoClient |
MongoClient.create(Vertx vertx,
JsonObject config)
Create a Mongo client which maintains its own data source.
|
MongoClient |
MongoClient.createIndex(String collection,
JsonObject key)
Creates an index.
|
MongoClient |
MongoClient.createIndex(String collection,
JsonObject key,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
MongoClient |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
MongoClient |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config)
Like
MongoClient.createShared(io.vertx.rxjava.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default data source name |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a Mongo client which shares its data source with any other Mongo clients created with the same
data source name
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoClient |
MongoClient.find(String collection,
JsonObject query)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
MongoGridFsClient |
MongoGridFsClient.findIds(JsonObject query)
Finds all file ids that match a query.
|
MongoGridFsClient |
MongoGridFsClient.findIds(JsonObject query,
Handler<AsyncResult<List<String>>> resultHandler)
Finds all file ids that match a query.
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Single<Long> |
MongoClient.rxCount(String collection,
JsonObject query)
Count matching documents in a collection.
|
Single<Long> |
MongoClient.rxCountWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
Single<Void> |
MongoClient.rxCreateIndex(String collection,
JsonObject key)
Creates an index.
|
Single<Void> |
MongoClient.rxCreateIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<List<JsonObject>> |
MongoClient.rxFind(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Single<List<String>> |
MongoGridFsClient.rxFindIds(JsonObject query)
Finds all file ids that match a query.
|
Single<JsonObject> |
MongoClient.rxFindOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Single<JsonObject> |
MongoClient.rxFindOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Single<JsonObject> |
MongoClient.rxFindOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.rxFindWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Single<String> |
MongoClient.rxInsert(String collection,
JsonObject document)
Insert a document in the specified collection
|
Single<String> |
MongoClient.rxInsertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
Single<MongoClientDeleteResult> |
MongoClient.rxRemoveDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
Single<MongoClientDeleteResult> |
MongoClient.rxRemoveDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
Single<MongoClientDeleteResult> |
MongoClient.rxRemoveDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Single<MongoClientDeleteResult> |
MongoClient.rxRemoveDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Single<MongoClientUpdateResult> |
MongoClient.rxReplaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Single<MongoClientUpdateResult> |
MongoClient.rxReplaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Single<JsonObject> |
MongoClient.rxRunCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
Single<String> |
MongoClient.rxSave(String collection,
JsonObject document)
Save a document in the specified collection
|
Single<String> |
MongoClient.rxSaveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
Single<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Single<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Single<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Single<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.save(String collection,
JsonObject document)
Save a document in the specified collection
|
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Modifier and Type | Method and Description |
---|---|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestBody.asJsonObject() |
JsonObject |
RequestBody.asJsonObject(int maxAllowedLength)
Gets the current body buffer as a .
|
JsonObject |
RoutingContext.getBodyAsJson()
Deprecated.
|
JsonObject |
RoutingContext.getBodyAsJson(int maxAllowedLength)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestParameter.getJsonObject()
Deprecated.
|
JsonObject |
RequestParameters.toJson()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RouterFactory |
RouterFactory.setExtraOperationContextPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Deprecated.
|
static Single<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.rxCreate(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
RouterFactory |
OpenAPI3RouterFactory.setExtraOperationContextPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
HttpResponse.bodyAsJsonObject() |
Modifier and Type | Method and Description |
---|---|
Single<HttpResponse<T>> |
HttpRequest.rxSendJsonObject(JsonObject body)
Like
HttpRequest.send(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.ext.web.client.HttpResponse<T>>>) but with an HTTP request body object encoded as json and the content type
set to application/json . |
void |
HttpRequest.sendJsonObject(JsonObject body)
Like
HttpRequest.send(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.ext.web.client.HttpResponse<T>>>) but with an HTTP request body object encoded as json and the content type
set to application/json . |
void |
HttpRequest.sendJsonObject(JsonObject body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.ext.web.client.HttpResponse<T>>>) but with an HTTP request body object encoded as json and the content type
set to application/json . |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonObject> |
BodyCodec.jsonObject() |
Modifier and Type | Method and Description |
---|---|
void |
TemplateEngine.render(JsonObject context,
String templateFileName)
Render the template.
|
void |
TemplateEngine.render(JsonObject context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
Single<Buffer> |
TemplateEngine.rxRender(JsonObject context,
String templateFileName)
Render the template.
|
Modifier and Type | Method and Description |
---|---|
OAuth2AuthHandler |
OAuth2AuthHandler.extraParams(JsonObject extraParams)
Extra parameters needed to be passed while requesting a token.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
ApolloWSMessage.content()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Message.message() |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Set the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
static SessionStore |
SessionStore.create(Vertx vertx,
JsonObject options)
Create a Session store given a backend and configuration JSON.
|
SessionStore |
SessionStore.init(Vertx vertx,
JsonObject options)
Initialize this store.
|
Modifier and Type | Method and Description |
---|---|
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options)
Create a new
InfinispanSessionStore for the given configuration. |
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options,
org.infinispan.client.hotrod.RemoteCacheManager remoteCacheManager)
Like
InfinispanSessionStore.create(io.vertx.rxjava.core.Vertx, io.vertx.core.json.JsonObject) but with a pre-configured Infinispan Client. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestParameter.getJsonObject()
Returns null if value is not a , otherwise it returns value
|
JsonObject |
RequestParameters.toJson()
This method converts RequestParameters in an unique JsonObject with 6 fields: cookie, path, query, header, form, body
cookie, path, query, header, form are JsonObject where keys are param names and values are param values, while body depends on body's shape and may not exist |
Modifier and Type | Method and Description |
---|---|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
DataSource dataSource,
JsonObject config)
Deprecated.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
JsonObject config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonSchema.resolve()
Tries to resolve all internal references.
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonSchema schema)
Tries to resolve all internal and repository local references.
|
JsonObject |
SchemaRepository.resolve(String ref)
Tries to resolve all internal and repository local references.
|
Modifier and Type | Method and Description |
---|---|
SchemaRouter |
SchemaRouter.addJson(String uri,
JsonObject object)
Deprecated.
|
SchemaRouter |
SchemaRouter.addJson(URI uri,
JsonObject object)
Deprecated.
|
static JsonSchema |
JsonSchema.of(JsonObject json)
Factory method to create a
JsonSchema from a . |
static JsonSchema |
JsonSchema.of(String id,
JsonObject json)
Factory method to create a
JsonSchema from a . |
Schema |
SchemaParser.parse(JsonObject jsonSchema)
Deprecated.
|
Schema |
SchemaParser.parse(JsonObject jsonSchema,
JsonPointer schemaPointer)
Deprecated.
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot()
Will return the metrics that correspond with the
measured object, null if no metrics is available. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available. |
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
RabbitMQClient.rxQueueDeclareAuto()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<Void>> resultHandler)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config)
Declare a queue with config options
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<com.rabbitmq.client.AMQP.Queue.DeclareOk>> resultHandler)
Declare a queue with config options
|
Single<Void> |
RabbitMQClient.rxExchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
RabbitMQClient.rxQueueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config)
Declare a queue with config options
|
Modifier and Type | Method and Description |
---|---|
void |
RabbitMQClient.queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(JsonObject arg)
Adds a JsonObject argument, the encoding will serialize the json as key0, value0, key1, value1, ...
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceDiscovery.getRecord(JsonObject filter)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
void |
ServiceDiscovery.getRecords(JsonObject filter)
Lookups for a set of records.
|
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery bridge.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery service importer.
|
Single<Record> |
ServiceDiscovery.rxGetRecord(JsonObject filter)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(JsonObject filter)
Lookups for a set of records.
|
Single<Void> |
ServiceDiscovery.rxRegisterServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
Single<Void> |
ServiceDiscovery.rxRegisterServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceExporter.init(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the importer.
|
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but let you configure whether or not the
service is using https . |
static Record |
MongoDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Mongo data source.
|
static Record |
RedisDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Redis data source.
|
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured .
|
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<JDBCClient> |
JDBCDataSource.rxGetJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
Modifier and Type | Method and Description |
---|---|
JsonObject[] |
Tuple.getArrayOfJsonObjects(int pos)
Get an array of value at
pos . |
JsonObject[] |
Row.getArrayOfJsonObjects(String column)
Get an array of value for the given
column . |
JsonObject |
Tuple.getJsonObject(int pos)
Get a value at
pos . |
JsonObject |
Row.getJsonObject(String column)
Get a value for the given
column . |
JsonObject |
Row.toJson()
Return a JSON object representation of the row.
|
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.addArrayOfJsonObject(JsonObject[] value)
Add an array of value at the end of the tuple.
|
Tuple |
Tuple.addJsonObject(JsonObject value)
Add a value at the end of the tuple.
|
Modifier and Type | Method and Description |
---|---|
Variables |
Variables.addAll(JsonObject json)
Populates with a JSON object:
null are conserved
JsonArray is converted to List
JsonObject is converted to Map
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
Variables |
Variables.setAll(JsonObject json)
Like
Variables.addAll(io.vertx.core.json.JsonObject) but overwrites previous variables. |
static Variables |
Variables.variables(JsonObject json)
Create an instance populated from a JSON object:
null are conserved
JsonArray is converted to List
JsonObject is converted to Map
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
Modifier and Type | Method and Description |
---|---|
JsonObject |
AmqpMessage.applicationProperties() |
JsonObject |
AmqpMessage.bodyAsJsonObject() |
Modifier and Type | Method and Description |
---|---|
AmqpMessageBuilder |
AmqpMessageBuilder.applicationProperties(JsonObject props) |
AmqpMessageBuilder |
AmqpMessageBuilder.withJsonObjectAsBody(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ConfigRetriever.getCachedConfig()
Gets the last computed configuration.
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
ConfigRetriever.configStream() |
Single<JsonObject> |
ConfigRetriever.getConfig()
Reads the configuration from the different
and computes the final configuration.
|
Single<JsonObject> |
ConfigRetriever.rxGetConfig()
Reads the configuration from the different
and computes the final configuration.
|
Modifier and Type | Method and Description |
---|---|
ConfigRetriever |
ConfigRetriever.setConfigurationProcessor(java.util.function.Function<JsonObject,JsonObject> processor)
Registers a handler that process the configuration before being injected into
ConfigRetriever.getConfig() or ConfigRetriever.listen(io.vertx.core.Handler<io.vertx.config.ConfigChange>) . |
ConfigRetriever |
ConfigRetriever.setConfigurationProcessor(java.util.function.Function<JsonObject,JsonObject> processor)
Registers a handler that process the configuration before being injected into
ConfigRetriever.getConfig() or ConfigRetriever.listen(io.vertx.core.Handler<io.vertx.config.ConfigChange>) . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
Context.config()
If the context is associated with a Verticle deployment, this returns the configuration that was specified when
the verticle was deployed.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Buffer.toJsonObject()
Returns a representation of this buffer's content.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonEvent.objectValue() |
Modifier and Type | Method and Description |
---|---|
JsonObject |
User.attributes()
Gets extra attributes of the user.
|
JsonObject |
User.principal()
Get the underlying principal for the User.
|
Modifier and Type | Method and Description |
---|---|
static User |
User.create(JsonObject principal)
Factory for user instances that are free form.
|
static User |
User.create(JsonObject principal,
JsonObject attributes)
Factory for user instances that are free form.
|
Modifier and Type | Method and Description |
---|---|
Single<User> |
AuthenticationProvider.authenticate(JsonObject credentials)
Deprecated.
|
Single<User> |
AuthenticationProvider.rxAuthenticate(JsonObject credentials)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
String |
JWTAuth.generateToken(JsonObject claims)
Generate a new JWT token.
|
String |
JWTAuth.generateToken(JsonObject claims,
JWTOptions options)
Generate a new JWT token.
|
Modifier and Type | Method and Description |
---|---|
static MongoAuth |
MongoAuth.create(MongoClient mongoClient,
JsonObject config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
OAuth2Auth.rxUserInfo(User user)
Retrieve profile information and other attributes for a logged-in end-user.
|
Single<JsonObject> |
OAuth2Auth.userInfo(User user)
Retrieve profile information and other attributes for a logged-in end-user.
|
Modifier and Type | Method and Description |
---|---|
String |
OAuth2Auth.authorizeURL(JsonObject params)
Deprecated.
|
String |
OAuth2Auth.endSessionURL(User user,
JsonObject params)
The logout (end-session) endpoint is specified in OpenID Connect Session Management 1.0.
|
Modifier and Type | Method and Description |
---|---|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
GoogleAuth.create(Vertx vertx,
JsonObject serviceAccountJson,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Google Service Account (Server to Server)
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config)
Create a OAuth2Auth provider for Keycloak
|
static OAuth2Auth |
KeycloakAuth.create(Vertx vertx,
OAuth2FlowType flow,
JsonObject config,
HttpClientOptions httpClientOptions)
Create a OAuth2Auth provider for Keycloak
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetaDataService.verify(Authenticator authenticator)
Verify the metadata for a given authenticator.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
WebAuthn.createCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Single<JsonObject> |
WebAuthn.getCredentialsOptions(String name)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
Single<JsonObject> |
WebAuthn.rxCreateCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Single<JsonObject> |
WebAuthn.rxGetCredentialsOptions(String name)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
Modifier and Type | Method and Description |
---|---|
MetaDataService |
MetaDataService.addStatement(JsonObject statement)
Manually feed a Meta Data Statement to the service.
|
Single<JsonObject> |
WebAuthn.createCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Single<JsonObject> |
WebAuthn.rxCreateCredentialsOptions(JsonObject user)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
BaseBridgeEvent.getRawMessage()
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
BaseBridgeEvent |
BaseBridgeEvent.setRawMessage(JsonObject message)
Override the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
ConsulClient.agentInfo()
Returns the configuration and member information of the local agent
|
Single<JsonObject> |
ConsulClient.rxAgentInfo()
Returns the configuration and member information of the local agent
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot(Measured measured)
Will return the metrics that correspond with the
measured object, null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available.
Note: in the case of scaled servers, the JsonObject returns an aggregation of the metrics as the
dropwizard backend reports to a single server. |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Get the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
HealthChecks.invoke(String name)
Invokes the registered procedure with the given name and sub-procedures.
|
Single<JsonObject> |
HealthChecks.rxInvoke(String name)
Invokes the registered procedure with the given name and sub-procedures.
|
Modifier and Type | Method and Description |
---|---|
HealthChecks |
HealthChecks.invoke(Handler<JsonObject> resultHandler)
Invokes the registered procedures and computes the outcome.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
MailAttachment.toJson()
convert this object to JSON representation
|
Modifier and Type | Method and Description |
---|---|
static MailAttachment |
MailAttachment.create(JsonObject json)
create a MailAttachment object from a JsonObject representation
|
Modifier and Type | Method and Description |
---|---|
ReadStream<JsonObject> |
MongoClient.aggregate(String collection,
JsonArray pipeline)
Run aggregate MongoDB command with default
AggregateOptions . |
ReadStream<JsonObject> |
MongoClient.aggregateWithOptions(String collection,
JsonArray pipeline,
AggregateOptions options)
Run aggregate MongoDB command.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatch(String collection,
String fieldName,
String resultClassname,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<List<JsonObject>> |
MongoClient.find(String collection,
JsonObject query)
Find matching documents in the specified collection
|
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Maybe<JsonObject> |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Maybe<JsonObject> |
MongoClient.findOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Maybe<JsonObject> |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Maybe<JsonObject> |
MongoClient.runCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
Single<List<JsonObject>> |
MongoClient.rxFind(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Maybe<JsonObject> |
MongoClient.rxFindOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.rxFindWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Maybe<JsonObject> |
MongoClient.rxRunCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
ReadStream<com.mongodb.client.model.changestream.ChangeStreamDocument<JsonObject>> |
MongoClient.watch(String collection,
JsonArray pipeline,
boolean withUpdatedDoc,
int batchSize)
Watch the collection change.
|
Modifier and Type | Method and Description |
---|---|
Single<Long> |
MongoClient.count(String collection,
JsonObject query)
Count matching documents in a collection.
|
Single<Long> |
MongoClient.countWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
static MongoClient |
MongoClient.create(Vertx vertx,
JsonObject config)
Create a Mongo client which maintains its own data source.
|
Completable |
MongoClient.createIndex(String collection,
JsonObject key)
Creates an index.
|
Completable |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config)
Like
MongoClient.createShared(io.vertx.rxjava3.core.Vertx, io.vertx.core.json.JsonObject, java.lang.String) but with the default data source name |
static MongoClient |
MongoClient.createShared(Vertx vertx,
JsonObject config,
String dataSourceName)
Create a Mongo client which shares its data source with any other Mongo clients created with the same
data source name
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize)
Gets the distinct values of the specified field name filtered by specified query.
|
ReadStream<JsonObject> |
MongoClient.distinctBatchWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
int batchSize,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<List<JsonObject>> |
MongoClient.find(String collection,
JsonObject query)
Find matching documents in the specified collection
|
ReadStream<JsonObject> |
MongoClient.findBatch(String collection,
JsonObject query)
Find matching documents in the specified collection.
|
ReadStream<JsonObject> |
MongoClient.findBatchWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options.
|
Single<List<String>> |
MongoGridFsClient.findIds(JsonObject query)
Finds all file ids that match a query.
|
Maybe<JsonObject> |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Maybe<JsonObject> |
MongoClient.findOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Maybe<JsonObject> |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Maybe<String> |
MongoClient.insert(String collection,
JsonObject document)
Insert a document in the specified collection
|
Maybe<String> |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
Maybe<MongoClientDeleteResult> |
MongoClient.removeDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.removeDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<JsonObject> |
MongoClient.runCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
Single<Long> |
MongoClient.rxCount(String collection,
JsonObject query)
Count matching documents in a collection.
|
Single<Long> |
MongoClient.rxCountWithOptions(String collection,
JsonObject query,
CountOptions countOptions)
Count matching documents in a collection.
|
Completable |
MongoClient.rxCreateIndex(String collection,
JsonObject key)
Creates an index.
|
Completable |
MongoClient.rxCreateIndexWithOptions(String collection,
JsonObject key,
IndexOptions options)
Creates an index.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<JsonArray> |
MongoClient.rxDistinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
DistinctOptions distinctOptions)
Gets the distinct values of the specified field name filtered by specified query.
|
Single<List<JsonObject>> |
MongoClient.rxFind(String collection,
JsonObject query)
Find matching documents in the specified collection
|
Single<List<String>> |
MongoGridFsClient.rxFindIds(JsonObject query)
Finds all file ids that match a query.
|
Maybe<JsonObject> |
MongoClient.rxFindOne(String collection,
JsonObject query,
JsonObject fields)
Find a single matching document in the specified collection
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDelete(String collection,
JsonObject query)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions)
Find a single matching document in the specified collection and delete it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplace(String collection,
JsonObject query,
JsonObject replace)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and replace it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdate(String collection,
JsonObject query,
JsonObject update)
Find a single matching document in the specified collection and update it.
|
Maybe<JsonObject> |
MongoClient.rxFindOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions)
Find a single matching document in the specified collection and update it.
|
Single<List<JsonObject>> |
MongoClient.rxFindWithOptions(String collection,
JsonObject query,
FindOptions options)
Find matching documents in the specified collection, specifying options
|
Maybe<String> |
MongoClient.rxInsert(String collection,
JsonObject document)
Insert a document in the specified collection
|
Maybe<String> |
MongoClient.rxInsertWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Insert a document in the specified collection with the specified write option
|
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocument(String collection,
JsonObject query)
Remove a single matching document from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocuments(String collection,
JsonObject query)
Remove matching documents from a collection and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove matching documents from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientDeleteResult> |
MongoClient.rxRemoveDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption)
Remove a single matching document from a collection with the specified write option and return the handler with
MongoClientDeleteResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxReplaceDocuments(String collection,
JsonObject query,
JsonObject replace)
Replace matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxReplaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options)
Replace matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<JsonObject> |
MongoClient.rxRunCommand(String commandName,
JsonObject command)
Run an arbitrary MongoDB command.
|
Maybe<String> |
MongoClient.rxSave(String collection,
JsonObject document)
Save a document in the specified collection
|
Maybe<String> |
MongoClient.rxSaveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.rxUpdateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<String> |
MongoClient.save(String collection,
JsonObject document)
Save a document in the specified collection
|
Maybe<String> |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption)
Save a document in the specified collection with the specified write option
|
Maybe<MongoClientUpdateResult> |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonArray update)
Use an aggregation pipeline to update documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update)
Update matching documents in the specified collection and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonArray update,
UpdateOptions options)
Use an aggregation pipeline to update documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Maybe<MongoClientUpdateResult> |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options)
Update matching documents in the specified collection, specifying options and return the handler with
MongoClientUpdateResult result |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestBody.asJsonObject() |
JsonObject |
RequestBody.asJsonObject(int maxAllowedLength)
Gets the current body buffer as a .
|
JsonObject |
RoutingContext.getBodyAsJson()
Deprecated.
|
JsonObject |
RoutingContext.getBodyAsJson(int maxAllowedLength)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestParameter.getJsonObject()
Deprecated.
|
JsonObject |
RequestParameters.toJson()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
RouterFactory |
RouterFactory.setExtraOperationContextPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Single<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
static Single<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.rxCreate(Vertx vertx,
String url,
List<JsonObject> auth)
Deprecated.
|
RouterFactory |
OpenAPI3RouterFactory.setExtraOperationContextPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
HttpResponse.bodyAsJsonObject() |
Modifier and Type | Method and Description |
---|---|
Single<HttpResponse<T>> |
HttpRequest.rxSendJsonObject(JsonObject body)
Like
HttpRequest.send() but with an HTTP request body object encoded as json and the content type
set to application/json . |
Single<HttpResponse<T>> |
HttpRequest.sendJsonObject(JsonObject body)
Like
HttpRequest.send() but with an HTTP request body object encoded as json and the content type
set to application/json . |
Modifier and Type | Method and Description |
---|---|
static BodyCodec<JsonObject> |
BodyCodec.jsonObject() |
Modifier and Type | Method and Description |
---|---|
Single<Buffer> |
TemplateEngine.render(JsonObject context,
String templateFileName)
Render the template.
|
Single<Buffer> |
TemplateEngine.rxRender(JsonObject context,
String templateFileName)
Render the template.
|
Modifier and Type | Method and Description |
---|---|
OAuth2AuthHandler |
OAuth2AuthHandler.extraParams(JsonObject extraParams)
Extra parameters needed to be passed while requesting a token.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
ApolloWSMessage.content()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
Message.message() |
Modifier and Type | Method and Description |
---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Set the raw JSON message for the event.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIHolder.getCached(JsonPointer pointer)
Get cached object using
pointer |
JsonObject |
OpenAPIHolder.getOpenAPI() |
JsonObject |
Operation.getOperationModel() |
JsonObject |
OpenAPIHolder.solveIfNeeded(JsonObject obj)
if
obj contains $ref , it tries to solve it and return the resolved object, otherwise it returns obj |
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIHolder.solveIfNeeded(JsonObject obj)
if
obj contains $ref , it tries to solve it and return the resolved object, otherwise it returns obj |
Modifier and Type | Method and Description |
---|---|
Future<RouterBuilder> |
SecurityScheme.bind(java.util.function.Function<JsonObject,Single<AuthenticationHandler>> factory) |
RouterBuilder |
SecurityScheme.bindBlocking(java.util.function.Function<JsonObject,AuthenticationHandler> factory) |
RouterBuilder |
RouterBuilder.serviceExtraPayloadMapper(java.util.function.Function<RoutingContext,JsonObject> serviceExtraPayloadMapper)
When set, this function is called while creating the payload of
|
Modifier and Type | Method and Description |
---|---|
static SessionStore |
SessionStore.create(Vertx vertx,
JsonObject options)
Create a Session store given a backend and configuration JSON.
|
SessionStore |
SessionStore.init(Vertx vertx,
JsonObject options)
Initialize this store.
|
Modifier and Type | Method and Description |
---|---|
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options)
Create a new
InfinispanSessionStore for the given configuration. |
static InfinispanSessionStore |
InfinispanSessionStore.create(Vertx vertx,
JsonObject options,
org.infinispan.client.hotrod.RemoteCacheManager remoteCacheManager)
Like
InfinispanSessionStore.create(io.vertx.rxjava3.core.Vertx, io.vertx.core.json.JsonObject) but with a pre-configured Infinispan Client. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
RequestParameter.getJsonObject()
Returns null if value is not a , otherwise it returns value
|
JsonObject |
RequestParameters.toJson()
This method converts RequestParameters in an unique JsonObject with 6 fields: cookie, path, query, header, form, body
cookie, path, query, header, form are JsonObject where keys are param names and values are param values, while body depends on body's shape and may not exist |
Modifier and Type | Method and Description |
---|---|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
DataSource dataSource,
JsonObject config)
Deprecated.
|
static JDBCPool |
JDBCPool.pool(Vertx vertx,
JsonObject config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
JsonSchema.resolve()
Tries to resolve all internal references.
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonSchema schema)
Tries to resolve all internal and repository local references.
|
JsonObject |
SchemaRepository.resolve(String ref)
Tries to resolve all internal and repository local references.
|
Modifier and Type | Method and Description |
---|---|
SchemaRouter |
SchemaRouter.addJson(String uri,
JsonObject object)
Deprecated.
|
SchemaRouter |
SchemaRouter.addJson(URI uri,
JsonObject object)
Deprecated.
|
static JsonSchema |
JsonSchema.of(JsonObject json)
Factory method to create a
JsonSchema from a . |
static JsonSchema |
JsonSchema.of(String id,
JsonObject json)
Factory method to create a
JsonSchema from a . |
Schema |
SchemaParser.parse(JsonObject jsonSchema)
Deprecated.
|
Schema |
SchemaParser.parse(JsonObject jsonSchema,
JsonPointer schemaPointer)
Deprecated.
|
static JsonObject |
Ref.resolve(JsonObject json)
Resolve all
$ref in the given . |
JsonObject |
SchemaRepository.resolve(JsonObject schema)
Resolve all
$ref in the given . |
Modifier and Type | Method and Description |
---|---|
JsonObject |
MetricsService.getMetricsSnapshot()
Will return the metrics that correspond with the
measured object, null if no metrics is available. |
JsonObject |
MetricsService.getMetricsSnapshot(String baseName)
Will return the metrics that begins with the
baseName , null if no metrics is available. |
Modifier and Type | Method and Description |
---|---|
JsonObject |
OpenAPIContract.getRawContract() |
Modifier and Type | Method and Description |
---|---|
static Single<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Single<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Single<OpenAPIContract> |
OpenAPIContract.rxFrom(Vertx vertx,
JsonObject unresolvedContract)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Single<OpenAPIContract> |
OpenAPIContract.rxFrom(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
Modifier and Type | Method and Description |
---|---|
static Single<OpenAPIContract> |
OpenAPIContract.from(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
static Single<OpenAPIContract> |
OpenAPIContract.rxFrom(Vertx vertx,
JsonObject unresolvedContract,
Map<String,JsonObject> additionalContractFiles)
Resolves / dereferences the passed contract and creates an
OpenAPIContract instance. |
Modifier and Type | Method and Description |
---|---|
Single<JsonObject> |
RabbitMQClient.queueDeclareAuto()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Single<JsonObject> |
RabbitMQClient.rxQueueDeclareAuto()
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
Modifier and Type | Method and Description |
---|---|
Completable |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config)
Declare a queue with config options
|
Completable |
RabbitMQClient.rxExchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
Single<com.rabbitmq.client.AMQP.Queue.DeclareOk> |
RabbitMQClient.rxQueueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config)
Declare a queue with config options
|
Modifier and Type | Method and Description |
---|---|
Request |
Request.arg(JsonObject arg)
Adds a JsonObject argument, the encoding will serialize the json as key0, value0, key1, value1, ...
|
Modifier and Type | Method and Description |
---|---|
Maybe<Record> |
ServiceDiscovery.getRecord(JsonObject filter)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.getRecords(JsonObject filter)
Lookups for a set of records.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
Completable |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
Completable |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
Maybe<Record> |
ServiceDiscovery.rxGetRecord(JsonObject filter)
Lookups for a single record.
|
Single<List<Record>> |
ServiceDiscovery.rxGetRecords(JsonObject filter)
Lookups for a set of records.
|
Completable |
ServiceDiscovery.rxRegisterServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Registers a discovery bridge.
|
Completable |
ServiceDiscovery.rxRegisterServiceImporter(ServiceImporter importer,
JsonObject configuration)
Registers a discovery service importer.
|
Modifier and Type | Method and Description |
---|---|
void |
ServiceExporter.init(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the importer.
|
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(java.lang.String, java.lang.String, int, java.lang.String, io.vertx.core.json.JsonObject) but let you configure whether or not the
service is using https . |
static Record |
MongoDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Mongo data source.
|
static Record |
RedisDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Redis data source.
|
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
static Single<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static Single<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static Single<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<HttpClient> |
HttpEndpoint.rxGetClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static <T> Single<MessageConsumer<T>> |
MessageSource.rxGetConsumer(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a message source and provides the configured .
|
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<MongoClient> |
MongoDataSource.rxGetMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<Redis> |
RedisDataSource.rxGetRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
JsonObject filter)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Single<WebClient> |
HttpEndpoint.rxGetWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
Modifier and Type | Method and Description |
---|---|
JsonObject[] |
Tuple.getArrayOfJsonObjects(int pos)
Get an array of value at
pos . |
JsonObject[] |
Row.getArrayOfJsonObjects(String column)
Get an array of value for the given
column . |
JsonObject |
Tuple.getJsonObject(int pos)
Get a value at
pos . |
JsonObject |
Row.getJsonObject(String column)
Get a value for the given
column . |
JsonObject |
Row.toJson()
Return a JSON object representation of the row.
|
Modifier and Type | Method and Description |
---|---|
Tuple |
Tuple.addArrayOfJsonObject(JsonObject[] value)
Add an array of value at the end of the tuple.
|
Tuple |
Tuple.addJsonObject(JsonObject value)
Add a value at the end of the tuple.
|
Modifier and Type | Method and Description |
---|---|
static TupleMapper<JsonObject> |
TupleMapper.jsonObject()
Map a to a .
|
Modifier and Type | Method and Description |
---|---|
Variables |
Variables.addAll(JsonObject json)
Populates with a JSON object:
null are conserved
JsonArray is converted to List
JsonObject is converted to Map
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
Variables |
Variables.setAll(JsonObject json)
Like
Variables.addAll(io.vertx.core.json.JsonObject) but overwrites previous variables. |
static Variables |
Variables.variables(JsonObject json)
Create an instance populated from a JSON object:
null are conserved
JsonArray is converted to List
JsonObject is converted to Map
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ServiceDiscoveryOptions.getBackendConfiguration() |
JsonObject |
Record.getLocation() |
JsonObject |
Record.getMetadata()
Gets the metadata attached to the record.
|
JsonObject |
ServiceDiscoveryOptions.toJson()
Builds the JSON representation for the current
ServiceDiscoveryOptions . |
JsonObject |
Record.toJson() |
Modifier and Type | Method and Description |
---|---|
Future<Record> |
ServiceDiscovery.getRecord(JsonObject filter)
Like
ServiceDiscovery.getRecord(JsonObject, Handler) but returns a Future of the asynchronous result |
void |
ServiceDiscovery.getRecord(JsonObject filter,
Handler<AsyncResult<Record>> resultHandler)
Lookups for a single record.
|
Future<List<Record>> |
ServiceDiscovery.getRecords(JsonObject filter)
Like
ServiceDiscovery.getRecords(JsonObject, Handler) but returns a Future of the asynchronous result |
void |
ServiceDiscovery.getRecords(JsonObject filter,
Handler<AsyncResult<List<Record>>> resultHandler)
Lookups for a set of records.
|
ServiceReference |
ServiceDiscovery.getReferenceWithConfiguration(Record record,
JsonObject configuration)
Gets a service reference from the given record, the reference is configured with the given json object.
|
boolean |
Record.match(JsonObject filter)
Checks whether or not the current
Record matches the filter. |
Future<Void> |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration)
Like
ServiceDiscovery.registerServiceExporter(ServiceExporter, JsonObject, Handler) but returns a Future of the asynchronous result |
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery bridge.
|
Future<Void> |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration)
Like
ServiceDiscovery.registerServiceImporter(ServiceImporter, JsonObject, Handler) but returns a Future of the asynchronous result |
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery service importer.
|
ServiceDiscoveryOptions |
ServiceDiscoveryOptions.setBackendConfiguration(JsonObject backendConfiguration)
Sets the configuration passed to the
ServiceDiscoveryBackend . |
Record |
Record.setLocation(JsonObject location)
Sets the json object describing the location of the service.
|
Record |
Record.setMetadata(JsonObject metadata) |
Constructor and Description |
---|
Record(JsonObject json)
Creates a new
Record from its json representation. |
ServiceDiscoveryOptions(JsonObject json)
Creates a new instance of
ServiceDiscoveryOptions from its JSON representation. |
Modifier and Type | Method and Description |
---|---|
void |
RedisBackendService.init(Vertx vertx,
JsonObject configuration) |
Modifier and Type | Method and Description |
---|---|
void |
ConsulServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> completion) |
Modifier and Type | Method and Description |
---|---|
void |
DockerLinksServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> completion) |
Modifier and Type | Method and Description |
---|---|
void |
KubernetesServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> completion) |
Modifier and Type | Method and Description |
---|---|
ServiceReference |
ServiceType.get(Vertx vertx,
ServiceDiscovery discovery,
Record record,
JsonObject configuration)
Gets the `service` for the given record.
|
void |
ServiceDiscoveryBackend.init(Vertx vertx,
JsonObject config)
Initializes the backend.
|
void |
ServiceExporter.init(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the exporter.
|
void |
ServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future)
Starts the importer.
|
Modifier and Type | Method and Description |
---|---|
JsonObject |
HttpLocation.toJson() |
Modifier and Type | Method and Description |
---|---|
static Record |
HttpEndpoint.createRecord(String name,
boolean ssl,
String host,
int port,
String root,
JsonObject metadata)
Same as
HttpEndpoint.createRecord(String, String, int, String, JsonObject) but let you configure whether or not the
service is using https . |
static Record |
MongoDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Mongo data source.
|
static Record |
RedisDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata)
Convenient method to create a record for a Redis data source.
|
static Record |
JDBCDataSource.createRecord(String name,
JsonObject location,
JsonObject metadata) |
static Record |
EventBusService.createRecord(String name,
String address,
Class itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
Class type,
JsonObject metadata)
Create a record representing a data producer.
|
static Record |
HttpEndpoint.createRecord(String name,
String host,
int port,
String root,
JsonObject metadata)
Convenient method to create a record for a HTTP endpoint.
|
static Record |
EventBusService.createRecord(String name,
String address,
String itf,
JsonObject metadata)
Sugar method to creates a record for this type.
|
static Record |
MessageSource.createRecord(String name,
String address,
String type,
JsonObject metadata)
Create a record representing a data producer.
|
static Future<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Like
HttpEndpoint.getClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
HttpClient . |
static Future<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter)
Like
HttpEndpoint.getClient(ServiceDiscovery, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
HttpClient . |
static Future<HttpClient> |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Like
HttpEndpoint.getClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf,
Handler<AsyncResult<HttpClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
HttpClient . |
static <T> Future<MessageConsumer<T>> |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter)
Like
MessageSource.getConsumer(ServiceDiscovery, JsonObject, Handler) but returns a future of the result |
static <T> void |
MessageSource.getConsumer(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MessageConsumer<T>>> resultHandler)
Convenient method that looks for a message source and provides the configured
MessageConsumer . |
static Future<JDBCClient> |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Like
JDBCDataSource.getJDBCClient(ServiceDiscovery, Function, JsonObject, Handler) but returns a future of the result |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Future<JDBCClient> |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter)
Like
JDBCDataSource.getJDBCClient(ServiceDiscovery, JsonObject, Handler) but returns a future of the result |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Future<JDBCClient> |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Like
JDBCDataSource.getJDBCClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
JDBCDataSource.getJDBCClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<JDBCClient>> resultHandler)
Convenient method that looks for a JDBC datasource source and provides the configured
JDBCClient . |
static Future<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter)
Like
MongoDataSource.getMongoClient(ServiceDiscovery, JsonObject, Handler) but returns a future of the result |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static Future<MongoClient> |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Like
MongoDataSource.getMongoClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
MongoDataSource.getMongoClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<MongoClient>> resultHandler)
Convenient method that looks for a Mongo datasource source and provides the configured
MongoClient . |
static <T> T |
EventBusService.getProxy(ServiceDiscovery discovery,
Class<T> itf,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static Future<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration)
Like
RedisDataSource.getRedisClient(ServiceDiscovery, Function, JsonObject, Handler) but returns a future of the result |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Future<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter)
Like
RedisDataSource.getRedisClient(ServiceDiscovery, JsonObject, Handler) but returns a future of the result |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static Future<Redis> |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration)
Like
RedisDataSource.getRedisClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
RedisDataSource.getRedisClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject consumerConfiguration,
Handler<AsyncResult<Redis>> resultHandler)
Convenient method that looks for a Redis data source and provides the configured
Redis . |
static <T> T |
EventBusService.getServiceProxy(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static <T> T |
EventBusService.getServiceProxyWithJsonFilter(ServiceDiscovery discovery,
JsonObject filter,
Class<T> clientClass,
JsonObject conf,
Handler<AsyncResult<T>> resultHandler)
Lookup for a service record and if found, retrieve it and return the service object (used to consume the service).
|
static Future<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf)
Like
HttpEndpoint.getWebClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
java.util.function.Function<Record,Boolean> filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
WebClient . |
static Future<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter)
Like
HttpEndpoint.getWebClient(ServiceDiscovery, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured .
|
static Future<WebClient> |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf)
Like
HttpEndpoint.getWebClient(ServiceDiscovery, JsonObject, JsonObject, Handler) but returns a future of the result |
static void |
HttpEndpoint.getWebClient(ServiceDiscovery discovery,
JsonObject filter,
JsonObject conf,
Handler<AsyncResult<WebClient>> resultHandler)
Convenient method that looks for a HTTP endpoint and provides the configured
WebClient . |
Constructor and Description |
---|
HttpLocation(JsonObject json)
Creates a new
HttpLocation from the given json object |
Modifier and Type | Method and Description |
---|---|
org.apache.curator.x.discovery.ServiceInstance<JsonObject> |
JsonObjectSerializer.deserialize(byte[] bytes) |
Modifier and Type | Method and Description |
---|---|
void |
ZookeeperServiceImporter.start(Vertx vertx,
ServicePublisher publisher,
JsonObject configuration,
Promise<Void> future) |
Modifier and Type | Method and Description |
---|---|
byte[] |
JsonObjectSerializer.serialize(org.apache.curator.x.discovery.ServiceInstance<JsonObject> instance) |
Modifier and Type | Field and Description |
---|---|
protected MessageConsumer<JsonObject> |
ProxyHandler.consumer |
Modifier and Type | Method and Description |
---|---|
static JsonObject |
HelperUtils.generateDebugInfo(Throwable cause) |
JsonObject |
ServiceException.getDebugInfo()
Get the Debugging information provided to this ServiceException
|
Modifier and Type | Method and Description |
---|---|
Future<Message<JsonObject>> |
ServiceJWTInterceptor.apply(Message<JsonObject> msg)
Deprecated.
|
Future<Message<JsonObject>> |
ServiceAuthInterceptor.apply(Message<JsonObject> msg)
Deprecated.
|
Future<Message<JsonObject>> |
ServiceInterceptor.intercept(Vertx vertx,
Map<String,Object> interceptorContext,
Message<JsonObject> body)
Perform the interceptor handling
|
<T> MessageConsumer<JsonObject> |
ServiceBinder.register(Class<T> clazz,
T service)
Registers a service on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.register(EventBus eventBus,
String address)
Register the proxy handle on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.register(Vertx vertx,
String address,
List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders)
Register the proxy handle on the event bus.
|
<T> MessageConsumer<JsonObject> |
ServiceBinder.registerLocal(Class<T> clazz,
T service)
Registers a local service on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.registerLocal(EventBus eventBus,
String address)
Register the local proxy handle on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.registerLocal(Vertx vertx,
String address,
List<io.vertx.serviceproxy.impl.InterceptorHolder> interceptorHolders)
Register the local proxy handle on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
Registers a local service on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerLocalService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address)
Deprecated.
Registers a service on the event bus.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
boolean topLevel,
long timeoutSeconds)
Deprecated.
|
static <T> MessageConsumer<JsonObject> |
ProxyHelper.registerService(Class<T> clazz,
Vertx vertx,
T service,
String address,
long timeoutSeconds)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,Character> |
ProxyUtils.convertToMapChar(JsonObject obj) |
static <T> AsyncResult<T> |
ServiceException.fail(int failureCode,
String message,
JsonObject debugInfo)
Create a failed Future containing a ServiceException.
|
Modifier and Type | Method and Description |
---|---|
ServiceBinder |
ServiceBinder.addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.
|
ServiceBinder |
ServiceBinder.addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.
|
ServiceBinder |
ServiceBinder.addInterceptor(String action,
java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.
|
ServiceBinder |
ServiceBinder.addInterceptor(String action,
java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor)
Deprecated.
|
Future<Message<JsonObject>> |
ServiceJWTInterceptor.apply(Message<JsonObject> msg)
Deprecated.
|
Future<Message<JsonObject>> |
ServiceAuthInterceptor.apply(Message<JsonObject> msg)
Deprecated.
|
Future<Message<JsonObject>> |
ServiceInterceptor.intercept(Vertx vertx,
Map<String,Object> interceptorContext,
Message<JsonObject> body)
Perform the interceptor handling
|
void |
ServiceBinder.unregister(MessageConsumer<JsonObject> consumer)
Unregisters a published service.
|
static void |
ProxyHelper.unregisterService(MessageConsumer<JsonObject> consumer)
Deprecated.
Unregisters a published service.
|
Constructor and Description |
---|
ServiceException(int failureCode,
String message,
JsonObject debugInfo) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
IgniteCacheOptions.getExpiryPolicy()
Gets cache expiry policy object.
|
JsonObject |
IgniteDiscoveryOptions.getProperties()
Get the discovery implementation properties.
|
JsonObject |
IgniteOptions.toJson()
Convert to JSON
|
JsonObject |
IgniteCacheOptions.toJson()
Convert to JSON
|
JsonObject |
IgniteSslOptions.toJson()
Convert to JSON
|
JsonObject |
IgniteMetricExporterOptions.toJson()
Convert to JSON
|
JsonObject |
IgniteDiscoveryOptions.toJson()
Convert to JSON
|
Modifier and Type | Method and Description |
---|---|
IgniteCacheOptions |
IgniteCacheOptions.setExpiryPolicy(JsonObject expiryPolicy)
Sets cache expiry policy object.
|
IgniteDiscoveryOptions |
IgniteDiscoveryOptions.setProperties(JsonObject properties)
Sets the properties used to configure the discovery implementation.
|
Constructor and Description |
---|
IgniteCacheOptions(JsonObject options)
Constructor from JSON
|
IgniteClusterManager(JsonObject jsonConfig)
Creates cluster manager instance with given JSON configuration.
|
IgniteDiscoveryOptions(JsonObject options)
Constructor from JSON
|
IgniteMetricExporterOptions(JsonObject options)
Constructor from JSON
|
IgniteOptions(JsonObject options)
Constructor from JSON
|
IgniteSslOptions(JsonObject options)
Constructor from JSON
|
Modifier and Type | Method and Description |
---|---|
static JsonObject |
ConfigHelper.lookupJsonConfiguration(Class<?> clazz,
String... files) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ZookeeperClusterManager.getConfig() |
Modifier and Type | Method and Description |
---|---|
void |
ZookeeperClusterManager.setConfig(JsonObject conf) |
Constructor and Description |
---|
ZookeeperClusterManager(JsonObject config) |
Modifier and Type | Method and Description |
---|---|
default JsonObject[] |
Tuple.getArrayOfJsonObjects(int pos)
Get an array of
JsonObject value at pos . |
default JsonObject[] |
Row.getArrayOfJsonObjects(String column)
Get an array of
JsonObject value for the given column . |
default JsonObject |
Tuple.getJsonObject(int pos)
Get a
JsonObject value at pos . |
default JsonObject |
Row.getJsonObject(String column)
Get a
JsonObject value for the given column . |
default JsonObject |
Row.toJson()
Return a JSON object representation of the row.
|
JsonObject |
PrepareOptions.toJson() |
JsonObject |
PoolOptions.toJson() |
JsonObject |
SqlConnectOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
default Tuple |
Tuple.addArrayOfJsonObject(JsonObject[] value)
Add an array of
JsonObject value at the end of the tuple. |
default Tuple |
Tuple.addJsonObject(JsonObject value)
Add a
JsonObject value at the end of the tuple. |
SqlConnectOptions |
SqlConnectOptions.merge(JsonObject other)
Returns new options created after this object and merged with the
other json config. |
Constructor and Description |
---|
PoolOptions(JsonObject json) |
PrepareOptions(JsonObject json) |
SqlConnectOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
static TupleMapper<JsonObject> |
TupleMapper.jsonObject()
Map a
JsonObject to a Tuple . |
Modifier and Type | Method and Description |
---|---|
TracingOptions |
OpenTelemetryTracingFactory.newOptions(JsonObject jsonObject) |
Constructor and Description |
---|
OpenTelemetryOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
OpenTracingOptions |
OpenTracingTracerFactory.newOptions(JsonObject jsonObject) |
Constructor and Description |
---|
OpenTracingOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ZipkinTracingOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
TracingOptions |
ZipkinTracerFactory.newOptions(JsonObject jsonObject) |
Constructor and Description |
---|
HttpSenderOptions(JsonObject json) |
ZipkinTracingOptions(JsonObject json) |
Modifier and Type | Method and Description |
---|---|
JsonObject |
ExpandOptions.toJson() |
Modifier and Type | Method and Description |
---|---|
Variables |
Variables.addAll(JsonObject json)
Populates with a JSON object:
null are conserved
JsonArray is converted to List<String>
JsonObject is converted to Map<String, String>
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
default Variables |
Variables.setAll(JsonObject json)
Like
Variables.addAll(JsonObject) but overwrites previous variables. |
static Variables |
Variables.variables(JsonObject json)
Create an instance populated from a JSON object:
null are conserved
JsonArray is converted to List<String>
JsonObject is converted to Map<String, String>
any other value is converted to a string
Note that nested JSON elements are converted to a string, so { "user": { "first_name": "John", "last_name": "Doe", "address" : { "city": "Paris", etc... |
Constructor and Description |
---|
ExpandOptions(JsonObject json) |
Copyright © 2024 Eclipse. All rights reserved.