public interface ConsulClient
Modifier and Type | Method and Description |
---|---|
ConsulClient |
agentInfo(Handler<AsyncResult<JsonObject>> resultHandler)
Returns the configuration and member information of the local agent
|
ConsulClient |
catalogDatacenters(Handler<AsyncResult<List<String>>> resultHandler)
Return all the datacenters that are known by the Consul server
|
ConsulClient |
catalogNodes(Handler<AsyncResult<NodeList>> resultHandler)
Returns the nodes registered in a datacenter
|
ConsulClient |
catalogNodeServices(String node,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the node's registered services
|
ConsulClient |
catalogNodeServicesWithOptions(String node,
BlockingQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the node's registered services
This is blocking query unlike
catalogNodeServices(String, Handler) |
ConsulClient |
catalogNodesWithOptions(NodeQueryOptions options,
Handler<AsyncResult<NodeList>> resultHandler)
Returns the nodes registered in a datacenter
|
ConsulClient |
catalogServiceNodes(String service,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the nodes providing a service
|
ConsulClient |
catalogServiceNodesWithOptions(String service,
ServiceQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the nodes providing a service
|
ConsulClient |
catalogServices(Handler<AsyncResult<ServiceList>> resultHandler)
Returns the services registered in a datacenter
|
ConsulClient |
catalogServicesWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the services registered in a datacenter
This is blocking query unlike
catalogServices(Handler) |
ConsulClient |
cloneAclToken(String id,
Handler<AsyncResult<String>> idHandler)
Clone Acl token
|
void |
close()
Close the client and release its resources
|
ConsulClient |
coordinateDatacenters(Handler<AsyncResult<List<DcCoordinates>>> resultHandler)
Returns the WAN network coordinates for all Consul servers, organized by DCs
|
ConsulClient |
coordinateNodes(Handler<AsyncResult<CoordinateList>> resultHandler)
Returns the LAN network coordinates for all nodes in a given DC
|
ConsulClient |
coordinateNodesWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<CoordinateList>> resultHandler)
Returns the LAN network coordinates for all nodes in a given DC
This is blocking query unlike
coordinateNodes(Handler) |
static ConsulClient |
create(Vertx vertx)
Create a Consul client with default options.
|
static ConsulClient |
create(Vertx vertx,
ConsulClientOptions options)
Create a Consul client.
|
ConsulClient |
createAclToken(AclToken token,
Handler<AsyncResult<String>> idHandler)
Create new Acl token
|
ConsulClient |
createPreparedQuery(PreparedQueryDefinition definition,
Handler<AsyncResult<String>> resultHandler) |
ConsulClient |
createSession(Handler<AsyncResult<String>> idHandler)
Initialize a new session
|
ConsulClient |
createSessionWithOptions(SessionOptions options,
Handler<AsyncResult<String>> idHandler)
Initialize a new session
|
ConsulClient |
deletePreparedQuery(String id,
Handler<AsyncResult<Void>> resultHandler)
Deletes an existing prepared query
|
ConsulClient |
deleteValue(String key,
Handler<AsyncResult<Void>> resultHandler)
Remove the key/value pair that corresponding to the specified key
|
ConsulClient |
deleteValues(String keyPrefix,
Handler<AsyncResult<Void>> resultHandler)
Removes all the key/value pair that corresponding to the specified key prefix
|
ConsulClient |
deregisterCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Remove a check from the local agent.
|
ConsulClient |
deregisterService(String id,
Handler<AsyncResult<Void>> resultHandler)
Remove a service from the local agent.
|
ConsulClient |
destroyAclToken(String id,
Handler<AsyncResult<Void>> resultHandler)
Destroy Acl token
|
ConsulClient |
destroySession(String id,
Handler<AsyncResult<Void>> resultHandler)
Destroys the given session
|
ConsulClient |
executePreparedQuery(String query,
Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler)
Executes an existing prepared query.
|
ConsulClient |
executePreparedQueryWithOptions(String query,
PreparedQueryExecuteOptions options,
Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler)
Executes an existing prepared query.
|
ConsulClient |
failCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "critical".
|
ConsulClient |
failCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "critical".
|
ConsulClient |
fireEvent(String name,
Handler<AsyncResult<Event>> resultHandler)
Fires a new user event
|
ConsulClient |
fireEventWithOptions(String name,
EventOptions options,
Handler<AsyncResult<Event>> resultHandler)
Fires a new user event
|
ConsulClient |
getAllPreparedQueries(Handler<AsyncResult<List<PreparedQueryDefinition>>> resultHandler)
Returns a list of all prepared queries.
|
ConsulClient |
getKeys(String keyPrefix,
Handler<AsyncResult<List<String>>> resultHandler)
Returns the list of keys that corresponding to the specified key prefix.
|
ConsulClient |
getKeysWithOptions(String keyPrefix,
BlockingQueryOptions options,
Handler<AsyncResult<List<String>>> resultHandler)
Returns the list of keys that corresponding to the specified key prefix.
|
ConsulClient |
getPreparedQuery(String id,
Handler<AsyncResult<PreparedQueryDefinition>> resultHandler)
Returns an existing prepared query
|
ConsulClient |
getValue(String key,
Handler<AsyncResult<KeyValue>> resultHandler)
Returns key/value pair that corresponding to the specified key.
|
ConsulClient |
getValues(String keyPrefix,
Handler<AsyncResult<KeyValueList>> resultHandler)
Returns the list of key/value pairs that corresponding to the specified key prefix.
|
ConsulClient |
getValuesWithOptions(String keyPrefix,
BlockingQueryOptions options,
Handler<AsyncResult<KeyValueList>> resultHandler)
Returns the list of key/value pairs that corresponding to the specified key prefix.
|
ConsulClient |
getValueWithOptions(String key,
BlockingQueryOptions options,
Handler<AsyncResult<KeyValue>> resultHandler)
Returns key/value pair that corresponding to the specified key.
|
ConsulClient |
healthChecks(String service,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks associated with the service
|
ConsulClient |
healthChecksWithOptions(String service,
CheckQueryOptions options,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks associated with the service
|
ConsulClient |
healthServiceNodes(String service,
boolean passing,
Handler<AsyncResult<ServiceEntryList>> resultHandler)
Returns the nodes providing the service.
|
ConsulClient |
healthServiceNodesWithOptions(String service,
boolean passing,
ServiceQueryOptions options,
Handler<AsyncResult<ServiceEntryList>> resultHandler)
Returns the nodes providing the service.
|
ConsulClient |
healthState(HealthState healthState,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks in the specified status
|
ConsulClient |
healthStateWithOptions(HealthState healthState,
CheckQueryOptions options,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks in the specified status
|
ConsulClient |
infoAclToken(String id,
Handler<AsyncResult<AclToken>> tokenHandler)
Get info of Acl token
|
ConsulClient |
infoSession(String id,
Handler<AsyncResult<Session>> resultHandler)
Returns the requested session information
|
ConsulClient |
infoSessionWithOptions(String id,
BlockingQueryOptions options,
Handler<AsyncResult<Session>> resultHandler)
Returns the requested session information
This is blocking query unlike
infoSession(String, Handler) |
ConsulClient |
leaderStatus(Handler<AsyncResult<String>> resultHandler)
Get the Raft leader for the datacenter in which the agent is running.
|
ConsulClient |
listAclTokens(Handler<AsyncResult<List<AclToken>>> resultHandler)
Get list of Acl token
|
ConsulClient |
listEvents(Handler<AsyncResult<EventList>> resultHandler)
Returns the most recent events known by the agent
|
ConsulClient |
listEventsWithOptions(EventListOptions options,
Handler<AsyncResult<EventList>> resultHandler)
Returns the most recent events known by the agent.
|
ConsulClient |
listNodeSessions(String nodeId,
Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions for a given node
|
ConsulClient |
listNodeSessionsWithOptions(String nodeId,
BlockingQueryOptions options,
Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions for a given node
This is blocking query unlike
listNodeSessions(String, Handler) |
ConsulClient |
listSessions(Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions
|
ConsulClient |
listSessionsWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions
This is blocking query unlike
listSessions(Handler) |
ConsulClient |
localChecks(Handler<AsyncResult<List<Check>>> resultHandler)
Return all the checks that are registered with the local agent.
|
ConsulClient |
localServices(Handler<AsyncResult<List<Service>>> resultHandler)
Returns list of services registered with the local agent.
|
ConsulClient |
maintenanceService(MaintenanceOptions maintenanceOptions,
Handler<AsyncResult<Void>> resultHandler)
Places a given service into "maintenance mode"
|
ConsulClient |
passCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "passing".
|
ConsulClient |
passCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "passing".
|
ConsulClient |
peersStatus(Handler<AsyncResult<List<String>>> resultHandler)
Retrieves the Raft peers for the datacenter in which the the agent is running.
|
ConsulClient |
putValue(String key,
String value,
Handler<AsyncResult<Boolean>> resultHandler)
Adds specified key/value pair
|
ConsulClient |
putValueWithOptions(String key,
String value,
KeyValueOptions options,
Handler<AsyncResult<Boolean>> resultHandler) |
ConsulClient |
registerCheck(CheckOptions checkOptions,
Handler<AsyncResult<Void>> resultHandler)
Add a new check to the local agent.
|
ConsulClient |
registerService(ServiceOptions serviceOptions,
Handler<AsyncResult<Void>> resultHandler)
Adds a new service, with an optional health check, to the local agent.
|
ConsulClient |
renewSession(String id,
Handler<AsyncResult<Session>> resultHandler)
Renews the given session.
|
ConsulClient |
transaction(TxnRequest request,
Handler<AsyncResult<TxnResponse>> resultHandler)
Manages multiple operations inside a single, atomic transaction.
|
ConsulClient |
updateAclToken(AclToken token,
Handler<AsyncResult<String>> idHandler)
Update Acl token
|
ConsulClient |
updateCheck(String checkId,
CheckStatus status,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to given status.
|
ConsulClient |
updateCheckWithNote(String checkId,
CheckStatus status,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to given status.
|
ConsulClient |
updatePreparedQuery(PreparedQueryDefinition definition,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
warnCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "warning".
|
ConsulClient |
warnCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "warning".
|
static ConsulClient create(Vertx vertx)
vertx
- the Vert.x instancestatic ConsulClient create(Vertx vertx, ConsulClientOptions options)
vertx
- the Vert.x instanceoptions
- the optionsConsulClient agentInfo(Handler<AsyncResult<JsonObject>> resultHandler)
resultHandler
- will be provided with the configuration and member information of the local agentConsulClient coordinateNodes(Handler<AsyncResult<CoordinateList>> resultHandler)
resultHandler
- will be provided with network coordinates of nodes in datacenterConsulClient coordinateNodesWithOptions(BlockingQueryOptions options, Handler<AsyncResult<CoordinateList>> resultHandler)
coordinateNodes(Handler)
options
- the blocking optionsresultHandler
- will be provided with network coordinates of nodes in datacenterConsulClient coordinateDatacenters(Handler<AsyncResult<List<DcCoordinates>>> resultHandler)
resultHandler
- will be provided with network coordinates for all Consul serversConsulClient getKeys(String keyPrefix, Handler<AsyncResult<List<String>>> resultHandler)
keyPrefix
- the prefixresultHandler
- will be provided with keys listConsulClient getKeysWithOptions(String keyPrefix, BlockingQueryOptions options, Handler<AsyncResult<List<String>>> resultHandler)
keyPrefix
- the prefixoptions
- the blocking optionsresultHandler
- will be provided with keys listConsulClient getValue(String key, Handler<AsyncResult<KeyValue>> resultHandler)
KeyValue
object will be returned if no such key is found.key
- the keyresultHandler
- will be provided with key/value pairConsulClient getValueWithOptions(String key, BlockingQueryOptions options, Handler<AsyncResult<KeyValue>> resultHandler)
KeyValue
object will be returned if no such key is found.
This is blocking query unlike getValue(String, Handler)
key
- the keyoptions
- the blocking optionsresultHandler
- will be provided with key/value pairConsulClient deleteValue(String key, Handler<AsyncResult<Void>> resultHandler)
key
- the keyresultHandler
- will be called on completeConsulClient getValues(String keyPrefix, Handler<AsyncResult<KeyValueList>> resultHandler)
KeyValueList
object will be returned if no such key prefix is found.keyPrefix
- the prefixresultHandler
- will be provided with list of key/value pairsConsulClient getValuesWithOptions(String keyPrefix, BlockingQueryOptions options, Handler<AsyncResult<KeyValueList>> resultHandler)
KeyValueList
object will be returned if no such key prefix is found.
This is blocking query unlike getValues(String, Handler)
keyPrefix
- the prefixoptions
- the blocking optionsresultHandler
- will be provided with list of key/value pairsConsulClient deleteValues(String keyPrefix, Handler<AsyncResult<Void>> resultHandler)
keyPrefix
- the prefixresultHandler
- will be called on completeConsulClient putValue(String key, String value, Handler<AsyncResult<Boolean>> resultHandler)
key
- the keyvalue
- the valueresultHandler
- will be provided with success of operationConsulClient putValueWithOptions(String key, String value, KeyValueOptions options, Handler<AsyncResult<Boolean>> resultHandler)
key
- the keyvalue
- the valueoptions
- options used to push pairresultHandler
- will be provided with success of operationConsulClient transaction(TxnRequest request, Handler<AsyncResult<TxnResponse>> resultHandler)
request
- transaction requestresultHandler
- will be provided with result of transactionConsulClient createAclToken(AclToken token, Handler<AsyncResult<String>> idHandler)
token
- properties of the tokenidHandler
- will be provided with ID of created tokenConsulClient updateAclToken(AclToken token, Handler<AsyncResult<String>> idHandler)
token
- properties of the token to be updatedidHandler
- will be provided with ID of updatedConsulClient cloneAclToken(String id, Handler<AsyncResult<String>> idHandler)
id
- the ID of token to be clonedidHandler
- will be provided with ID of cloned tokenConsulClient listAclTokens(Handler<AsyncResult<List<AclToken>>> resultHandler)
resultHandler
- will be provided with list of tokensConsulClient infoAclToken(String id, Handler<AsyncResult<AclToken>> tokenHandler)
id
- the ID of tokentokenHandler
- will be provided with tokenConsulClient destroyAclToken(String id, Handler<AsyncResult<Void>> resultHandler)
id
- the ID of tokenresultHandler
- will be called on completeConsulClient fireEvent(String name, Handler<AsyncResult<Event>> resultHandler)
name
- name of eventresultHandler
- will be provided with properties of eventConsulClient fireEventWithOptions(String name, EventOptions options, Handler<AsyncResult<Event>> resultHandler)
name
- name of eventoptions
- options used to create eventresultHandler
- will be provided with properties of eventConsulClient listEvents(Handler<AsyncResult<EventList>> resultHandler)
resultHandler
- will be provided with list of eventsConsulClient listEventsWithOptions(EventListOptions options, Handler<AsyncResult<EventList>> resultHandler)
listEvents(Handler)
. However, the semantics of this endpoint
are slightly different. Most blocking queries provide a monotonic index and block until a newer index is available.
This can be supported as a consequence of the total ordering of the consensus protocol. With gossip,
there is no ordering, and instead X-Consul-Index
maps to the newest event that matches the query.
In practice, this means the index is only useful when used against a single agent and has no meaning globally. Because Consul defines the index as being opaque, clients should not be expecting a natural ordering either.
resultHandler
- will be provided with list of eventsoptions
- the blocking optionsConsulClient registerService(ServiceOptions serviceOptions, Handler<AsyncResult<Void>> resultHandler)
serviceOptions
- the options of new serviceresultHandler
- will be called when completeServiceOptions
ConsulClient maintenanceService(MaintenanceOptions maintenanceOptions, Handler<AsyncResult<Void>> resultHandler)
maintenanceOptions
- the maintenance optionsresultHandler
- will be called when completeMaintenanceOptions
ConsulClient deregisterService(String id, Handler<AsyncResult<Void>> resultHandler)
id
- the ID of serviceresultHandler
- will be called when completeConsulClient catalogServiceNodes(String service, Handler<AsyncResult<ServiceList>> resultHandler)
service
- name of serviceresultHandler
- will be provided with list of nodes providing given serviceConsulClient catalogServiceNodesWithOptions(String service, ServiceQueryOptions options, Handler<AsyncResult<ServiceList>> resultHandler)
service
- name of serviceoptions
- options used to request servicesresultHandler
- will be provided with list of nodes providing given serviceConsulClient catalogDatacenters(Handler<AsyncResult<List<String>>> resultHandler)
resultHandler
- will be provided with list of datacentersConsulClient catalogNodes(Handler<AsyncResult<NodeList>> resultHandler)
resultHandler
- will be provided with list of nodesConsulClient catalogNodesWithOptions(NodeQueryOptions options, Handler<AsyncResult<NodeList>> resultHandler)
resultHandler
- will be provided with list of nodesoptions
- options used to request nodesConsulClient healthChecks(String service, Handler<AsyncResult<CheckList>> resultHandler)
service
- the service nameresultHandler
- will be provided with list of checksConsulClient healthChecksWithOptions(String service, CheckQueryOptions options, Handler<AsyncResult<CheckList>> resultHandler)
service
- the service nameoptions
- options used to request checksresultHandler
- will be provided with list of checksConsulClient healthState(HealthState healthState, Handler<AsyncResult<CheckList>> resultHandler)
healthState
- the health stateresultHandler
- will be provided with list of checksConsulClient healthStateWithOptions(HealthState healthState, CheckQueryOptions options, Handler<AsyncResult<CheckList>> resultHandler)
healthState
- the health stateoptions
- options used to request checksresultHandler
- will be provided with list of checksConsulClient healthServiceNodes(String service, boolean passing, Handler<AsyncResult<ServiceEntryList>> resultHandler)
catalogServiceNodes(java.lang.String, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>>)
endpoint;
however, this endpoint automatically returns the status of the associated health check as well as any system level health checks.service
- the service namepassing
- if true, filter results to only nodes with all checks in the passing stateresultHandler
- will be provided with list of servicesConsulClient healthServiceNodesWithOptions(String service, boolean passing, ServiceQueryOptions options, Handler<AsyncResult<ServiceEntryList>> resultHandler)
catalogServiceNodesWithOptions(java.lang.String, io.vertx.ext.consul.ServiceQueryOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.ext.consul.ServiceList>>)
endpoint;
however, this endpoint automatically returns the status of the associated health check as well as any system level health checks.service
- the service namepassing
- if true, filter results to only nodes with all checks in the passing stateoptions
- options used to request servicesresultHandler
- will be provided with list of servicesConsulClient catalogServices(Handler<AsyncResult<ServiceList>> resultHandler)
resultHandler
- will be provided with list of servicesConsulClient catalogServicesWithOptions(BlockingQueryOptions options, Handler<AsyncResult<ServiceList>> resultHandler)
catalogServices(Handler)
resultHandler
- will be provided with list of servicesoptions
- the blocking optionsConsulClient catalogNodeServices(String node, Handler<AsyncResult<ServiceList>> resultHandler)
node
- node nameresultHandler
- will be provided with list of servicesConsulClient catalogNodeServicesWithOptions(String node, BlockingQueryOptions options, Handler<AsyncResult<ServiceList>> resultHandler)
catalogNodeServices(String, Handler)
node
- node nameoptions
- the blocking optionsresultHandler
- will be provided with list of servicesConsulClient localServices(Handler<AsyncResult<List<Service>>> resultHandler)
resultHandler
- will be provided with list of servicesConsulClient localChecks(Handler<AsyncResult<List<Check>>> resultHandler)
resultHandler
- will be provided with list of checksConsulClient registerCheck(CheckOptions checkOptions, Handler<AsyncResult<Void>> resultHandler)
checkOptions
- options used to register new checkresultHandler
- will be called when completeConsulClient deregisterCheck(String checkId, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checkresultHandler
- will be called when completeConsulClient passCheck(String checkId, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checkresultHandler
- will be called when completeCheckStatus
ConsulClient passCheckWithNote(String checkId, String note, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checknote
- specifies a human-readable message. This will be passed through to the check's Output
field.resultHandler
- will be called when completeCheckStatus
ConsulClient warnCheck(String checkId, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checkresultHandler
- will be called when completeCheckStatus
ConsulClient warnCheckWithNote(String checkId, String note, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checknote
- specifies a human-readable message. This will be passed through to the check's Output
field.resultHandler
- will be called when completeCheckStatus
ConsulClient failCheck(String checkId, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checkresultHandler
- will be called when completeCheckStatus
ConsulClient failCheckWithNote(String checkId, String note, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checknote
- specifies a human-readable message. This will be passed through to the check's Output
field.resultHandler
- will be called when completeCheckStatus
ConsulClient updateCheck(String checkId, CheckStatus status, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checkstatus
- new status of checkresultHandler
- will be called when completeConsulClient updateCheckWithNote(String checkId, CheckStatus status, String note, Handler<AsyncResult<Void>> resultHandler)
checkId
- the ID of checkstatus
- new status of checknote
- specifies a human-readable message. This will be passed through to the check's Output
field.resultHandler
- will be called when completeConsulClient leaderStatus(Handler<AsyncResult<String>> resultHandler)
10.1.10.12:8300
"resultHandler
- will be provided with address of cluster leaderConsulClient peersStatus(Handler<AsyncResult<List<String>>> resultHandler)
10.1.10.12:8300
", "10.1.10.13:8300
"resultHandler
- will be provided with list of peersConsulClient createSession(Handler<AsyncResult<String>> idHandler)
idHandler
- will be provided with ID of new sessionConsulClient createSessionWithOptions(SessionOptions options, Handler<AsyncResult<String>> idHandler)
options
- options used to create sessionidHandler
- will be provided with ID of new sessionConsulClient infoSession(String id, Handler<AsyncResult<Session>> resultHandler)
id
- the ID of requested sessionresultHandler
- will be provided with info of requested sessionConsulClient infoSessionWithOptions(String id, BlockingQueryOptions options, Handler<AsyncResult<Session>> resultHandler)
infoSession(String, Handler)
id
- the ID of requested sessionoptions
- the blocking optionsresultHandler
- will be provided with info of requested sessionConsulClient renewSession(String id, Handler<AsyncResult<Session>> resultHandler)
id
- the ID of session that should be renewedresultHandler
- will be provided with info of renewed sessionConsulClient listSessions(Handler<AsyncResult<SessionList>> resultHandler)
resultHandler
- will be provided with list of sessionsConsulClient listSessionsWithOptions(BlockingQueryOptions options, Handler<AsyncResult<SessionList>> resultHandler)
listSessions(Handler)
options
- the blocking optionsresultHandler
- will be provided with list of sessionsConsulClient listNodeSessions(String nodeId, Handler<AsyncResult<SessionList>> resultHandler)
nodeId
- the ID of noderesultHandler
- will be provided with list of sessionsConsulClient listNodeSessionsWithOptions(String nodeId, BlockingQueryOptions options, Handler<AsyncResult<SessionList>> resultHandler)
listNodeSessions(String, Handler)
nodeId
- the ID of nodeoptions
- the blocking optionsresultHandler
- will be provided with list of sessionsConsulClient destroySession(String id, Handler<AsyncResult<Void>> resultHandler)
id
- the ID of sessionresultHandler
- will be called when completeConsulClient createPreparedQuery(PreparedQueryDefinition definition, Handler<AsyncResult<String>> resultHandler)
definition
- definition of the prepare queryresultHandler
- will be provided with id of created prepare queryConsulClient getPreparedQuery(String id, Handler<AsyncResult<PreparedQueryDefinition>> resultHandler)
id
- the id of the query to readresultHandler
- will be provided with definition of the prepare queryConsulClient getAllPreparedQueries(Handler<AsyncResult<List<PreparedQueryDefinition>>> resultHandler)
resultHandler
- will be provided with list of definitions of the all prepare queriesConsulClient updatePreparedQuery(PreparedQueryDefinition definition, Handler<AsyncResult<Void>> resultHandler)
definition
- definition of the prepare queryresultHandler
- will be called when completeConsulClient deletePreparedQuery(String id, Handler<AsyncResult<Void>> resultHandler)
id
- the id of the query to deleteresultHandler
- will be called when completeConsulClient executePreparedQuery(String query, Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler)
query
- the ID of the query to execute. This can also be the name of an existing prepared query,
or a name that matches a prefix name for a prepared query template.resultHandler
- will be provided with responseConsulClient executePreparedQueryWithOptions(String query, PreparedQueryExecuteOptions options, Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler)
query
- the ID of the query to execute. This can also be the name of an existing prepared query,
or a name that matches a prefix name for a prepared query template.options
- the options used to execute prepared queryresultHandler
- will be provided with responsevoid close()
Copyright © 2023 Eclipse. All rights reserved.