Package | Description |
---|---|
io.vertx.rxjava.ext.consul |
Modifier and Type | Field and Description |
---|---|
static TypeArg<ConsulClient> |
ConsulClient.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
ConsulClient |
ConsulClient.agentInfo(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.core.json.JsonObject>> resultHandler)
Returns the configuration and member information of the local agent
|
ConsulClient |
ConsulClient.catalogDatacenters(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<String>>> resultHandler)
Return all the datacenters that are known by the Consul server
|
ConsulClient |
ConsulClient.catalogNodes(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.NodeList>> resultHandler)
Returns the nodes registered in a datacenter
|
ConsulClient |
ConsulClient.catalogNodeServices(String node,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>> resultHandler)
Returns the node's registered services
|
ConsulClient |
ConsulClient.catalogNodeServicesWithOptions(String node,
io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>> resultHandler)
Returns the node's registered services
This is blocking query unlike
catalogNodeServices(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>>) |
ConsulClient |
ConsulClient.catalogNodesWithOptions(io.vertx.ext.consul.NodeQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.NodeList>> resultHandler)
Returns the nodes registered in a datacenter
|
ConsulClient |
ConsulClient.catalogServiceNodes(String service,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>> resultHandler)
Returns the nodes providing a service
|
ConsulClient |
ConsulClient.catalogServiceNodesWithOptions(String service,
io.vertx.ext.consul.ServiceQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>> resultHandler)
Returns the nodes providing a service
|
ConsulClient |
ConsulClient.catalogServices(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>> resultHandler)
Returns the services registered in a datacenter
|
ConsulClient |
ConsulClient.catalogServicesWithOptions(io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>> resultHandler)
Returns the services registered in a datacenter
This is blocking query unlike
catalogServices(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>>) |
ConsulClient |
ConsulClient.cloneAclToken(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<String>> idHandler)
Clone Acl token
|
ConsulClient |
ConsulClient.coordinateDatacenters(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<io.vertx.ext.consul.DcCoordinates>>> resultHandler)
Returns the WAN network coordinates for all Consul servers, organized by DCs
|
ConsulClient |
ConsulClient.coordinateNodes(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.CoordinateList>> resultHandler)
Returns the LAN network coordinates for all nodes in a given DC
|
ConsulClient |
ConsulClient.coordinateNodesWithOptions(io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.CoordinateList>> resultHandler)
Returns the LAN network coordinates for all nodes in a given DC
This is blocking query unlike
coordinateNodes(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.CoordinateList>>) |
static ConsulClient |
ConsulClient.create(Vertx vertx)
Create a Consul client with default options.
|
static ConsulClient |
ConsulClient.create(Vertx vertx,
io.vertx.ext.consul.ConsulClientOptions options)
Create a Consul client.
|
ConsulClient |
ConsulClient.createAclToken(io.vertx.ext.consul.AclToken token,
io.vertx.core.Handler<io.vertx.core.AsyncResult<String>> idHandler)
Create new Acl token
|
ConsulClient |
ConsulClient.createPreparedQuery(io.vertx.ext.consul.PreparedQueryDefinition definition,
io.vertx.core.Handler<io.vertx.core.AsyncResult<String>> resultHandler) |
ConsulClient |
ConsulClient.createSession(io.vertx.core.Handler<io.vertx.core.AsyncResult<String>> idHandler)
Initialize a new session
|
ConsulClient |
ConsulClient.createSessionWithOptions(io.vertx.ext.consul.SessionOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<String>> idHandler)
Initialize a new session
|
ConsulClient |
ConsulClient.deletePreparedQuery(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Deletes an existing prepared query
|
ConsulClient |
ConsulClient.deleteValue(String key,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Remove the key/value pair that corresponding to the specified key
|
ConsulClient |
ConsulClient.deleteValues(String keyPrefix,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Removes all the key/value pair that corresponding to the specified key prefix
|
ConsulClient |
ConsulClient.deregisterCheck(String checkId,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Remove a check from the local agent.
|
ConsulClient |
ConsulClient.deregisterService(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Remove a service from the local agent.
|
ConsulClient |
ConsulClient.destroyAclToken(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Destroy Acl token
|
ConsulClient |
ConsulClient.destroySession(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Destroys the given session
|
ConsulClient |
ConsulClient.executePreparedQuery(String query,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.PreparedQueryExecuteResponse>> resultHandler)
Executes an existing prepared query.
|
ConsulClient |
ConsulClient.executePreparedQueryWithOptions(String query,
io.vertx.ext.consul.PreparedQueryExecuteOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.PreparedQueryExecuteResponse>> resultHandler)
Executes an existing prepared query.
|
ConsulClient |
ConsulClient.failCheck(String checkId,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to "critical".
|
ConsulClient |
ConsulClient.failCheckWithNote(String checkId,
String note,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to "critical".
|
ConsulClient |
ConsulClient.fireEvent(String name,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.Event>> resultHandler)
Fires a new user event
|
ConsulClient |
ConsulClient.fireEventWithOptions(String name,
io.vertx.ext.consul.EventOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.Event>> resultHandler)
Fires a new user event
|
ConsulClient |
ConsulClient.getAllPreparedQueries(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<io.vertx.ext.consul.PreparedQueryDefinition>>> resultHandler)
Returns a list of all prepared queries.
|
ConsulClient |
ConsulClient.getKeys(String keyPrefix,
io.vertx.core.Handler<io.vertx.core.AsyncResult<List<String>>> resultHandler)
Returns the list of keys that corresponding to the specified key prefix.
|
ConsulClient |
ConsulClient.getKeysWithOptions(String keyPrefix,
io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<List<String>>> resultHandler)
Returns the list of keys that corresponding to the specified key prefix.
|
ConsulClient |
ConsulClient.getPreparedQuery(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.PreparedQueryDefinition>> resultHandler)
Returns an existing prepared query
|
ConsulClient |
ConsulClient.getValue(String key,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.KeyValue>> resultHandler)
Returns key/value pair that corresponding to the specified key.
|
ConsulClient |
ConsulClient.getValues(String keyPrefix,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.KeyValueList>> resultHandler)
Returns the list of key/value pairs that corresponding to the specified key prefix.
|
ConsulClient |
ConsulClient.getValuesWithOptions(String keyPrefix,
io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.KeyValueList>> resultHandler)
Returns the list of key/value pairs that corresponding to the specified key prefix.
|
ConsulClient |
ConsulClient.getValueWithOptions(String key,
io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.KeyValue>> resultHandler)
Returns key/value pair that corresponding to the specified key.
|
ConsulClient |
ConsulClient.healthChecks(String service,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.CheckList>> resultHandler)
Returns the checks associated with the service
|
ConsulClient |
ConsulClient.healthChecksWithOptions(String service,
io.vertx.ext.consul.CheckQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.CheckList>> resultHandler)
Returns the checks associated with the service
|
ConsulClient |
ConsulClient.healthServiceNodes(String service,
boolean passing,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceEntryList>> resultHandler)
Returns the nodes providing the service.
|
ConsulClient |
ConsulClient.healthServiceNodesWithOptions(String service,
boolean passing,
io.vertx.ext.consul.ServiceQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceEntryList>> resultHandler)
Returns the nodes providing the service.
|
ConsulClient |
ConsulClient.healthState(io.vertx.ext.consul.HealthState healthState,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.CheckList>> resultHandler)
Returns the checks in the specified status
|
ConsulClient |
ConsulClient.healthStateWithOptions(io.vertx.ext.consul.HealthState healthState,
io.vertx.ext.consul.CheckQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.CheckList>> resultHandler)
Returns the checks in the specified status
|
ConsulClient |
ConsulClient.infoAclToken(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.AclToken>> tokenHandler)
Get info of Acl token
|
ConsulClient |
ConsulClient.infoSession(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.Session>> resultHandler)
Returns the requested session information
|
ConsulClient |
ConsulClient.infoSessionWithOptions(String id,
io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.Session>> resultHandler)
Returns the requested session information
This is blocking query unlike
infoSession(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.Session>>) |
ConsulClient |
ConsulClient.leaderStatus(io.vertx.core.Handler<io.vertx.core.AsyncResult<String>> resultHandler)
Get the Raft leader for the datacenter in which the agent is running.
|
ConsulClient |
ConsulClient.listAclTokens(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<io.vertx.ext.consul.AclToken>>> resultHandler)
Get list of Acl token
|
ConsulClient |
ConsulClient.listEvents(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.EventList>> resultHandler)
Returns the most recent events known by the agent
|
ConsulClient |
ConsulClient.listEventsWithOptions(io.vertx.ext.consul.EventListOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.EventList>> resultHandler)
Returns the most recent events known by the agent.
|
ConsulClient |
ConsulClient.listNodeSessions(String nodeId,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.SessionList>> resultHandler)
Returns the active sessions for a given node
|
ConsulClient |
ConsulClient.listNodeSessionsWithOptions(String nodeId,
io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.SessionList>> resultHandler)
Returns the active sessions for a given node
This is blocking query unlike
listNodeSessions(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.SessionList>>) |
ConsulClient |
ConsulClient.listSessions(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.SessionList>> resultHandler)
Returns the active sessions
|
ConsulClient |
ConsulClient.listSessionsWithOptions(io.vertx.ext.consul.BlockingQueryOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.SessionList>> resultHandler)
Returns the active sessions
This is blocking query unlike
listSessions(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.SessionList>>) |
ConsulClient |
ConsulClient.localChecks(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<io.vertx.ext.consul.Check>>> resultHandler)
Return all the checks that are registered with the local agent.
|
ConsulClient |
ConsulClient.localServices(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<io.vertx.ext.consul.Service>>> resultHandler)
Returns list of services registered with the local agent.
|
ConsulClient |
ConsulClient.maintenanceService(io.vertx.ext.consul.MaintenanceOptions maintenanceOptions,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Places a given service into "maintenance mode"
|
static ConsulClient |
ConsulClient.newInstance(io.vertx.ext.consul.ConsulClient arg) |
ConsulClient |
ConsulClient.passCheck(String checkId,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to "passing".
|
ConsulClient |
ConsulClient.passCheckWithNote(String checkId,
String note,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to "passing".
|
ConsulClient |
ConsulClient.peersStatus(io.vertx.core.Handler<io.vertx.core.AsyncResult<List<String>>> resultHandler)
Retrieves the Raft peers for the datacenter in which the the agent is running.
|
ConsulClient |
ConsulClient.putValue(String key,
String value,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Boolean>> resultHandler)
Adds specified key/value pair
|
ConsulClient |
ConsulClient.putValueWithOptions(String key,
String value,
io.vertx.ext.consul.KeyValueOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Boolean>> resultHandler) |
ConsulClient |
ConsulClient.registerCheck(io.vertx.ext.consul.CheckOptions checkOptions,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Add a new check to the local agent.
|
ConsulClient |
ConsulClient.registerService(io.vertx.ext.consul.ServiceOptions serviceOptions,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Adds a new service, with an optional health check, to the local agent.
|
ConsulClient |
ConsulClient.renewSession(String id,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.Session>> resultHandler)
Renews the given session.
|
ConsulClient |
ConsulClient.transaction(io.vertx.ext.consul.TxnRequest request,
io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.TxnResponse>> resultHandler)
Manages multiple operations inside a single, atomic transaction.
|
ConsulClient |
ConsulClient.updateAclToken(io.vertx.ext.consul.AclToken token,
io.vertx.core.Handler<io.vertx.core.AsyncResult<String>> idHandler)
Update Acl token
|
ConsulClient |
ConsulClient.updateCheck(String checkId,
io.vertx.ext.consul.CheckStatus status,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to given status.
|
ConsulClient |
ConsulClient.updateCheckWithNote(String checkId,
io.vertx.ext.consul.CheckStatus status,
String note,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to given status.
|
ConsulClient |
ConsulClient.updatePreparedQuery(io.vertx.ext.consul.PreparedQueryDefinition definition,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.warnCheck(String checkId,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to "warning".
|
ConsulClient |
ConsulClient.warnCheckWithNote(String checkId,
String note,
io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> resultHandler)
Set status of the check to "warning".
|
Copyright © 2019 Eclipse. All rights reserved.