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 completeServiceOptionsConsulClient maintenanceService(MaintenanceOptions maintenanceOptions, Handler<AsyncResult<Void>> resultHandler)
maintenanceOptions - the maintenance optionsresultHandler - will be called when completeMaintenanceOptionsConsulClient 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 completeCheckStatusConsulClient 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 completeCheckStatusConsulClient warnCheck(String checkId, Handler<AsyncResult<Void>> resultHandler)
checkId - the ID of checkresultHandler - will be called when completeCheckStatusConsulClient 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 completeCheckStatusConsulClient failCheck(String checkId, Handler<AsyncResult<Void>> resultHandler)
checkId - the ID of checkresultHandler - will be called when completeCheckStatusConsulClient 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 completeCheckStatusConsulClient 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.