Uses of Class io.vertx.reactivex.ext.consul.ConsulClient (Vert.x Stack

Packages that use ConsulClient
Package Description

io.vertx.reactivex.ext.consul

Packages that use ConsulClient
Package	Description
io.vertx.reactivex.ext.consul

Uses of ConsulClient in io.vertx.reactivex.ext.consul

Fields in io.vertx.reactivex.ext.consul with type parameters of type ConsulClient
Modifier and Type	Field and Description
`static io.vertx.lang.rx.TypeArg<ConsulClient>`	ConsulClient.`__TYPE_ARG`

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

Uses of Classio.vertx.reactivex.ext.consul.ConsulClient

Uses of ConsulClient in io.vertx.reactivex.ext.consul

Uses of Class
io.vertx.reactivex.ext.consul.ConsulClient