package io.vertx.ext.consul.impl;

import io.vertx.core.AsyncResult;
import io.vertx.core.Handler;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.consul.*;

import java.util.List;

Author:Ruslan Sennov
/** * @author <a href="mailto:ruslan.sennov@gmail.com">Ruslan Sennov</a> */
public class ConsulServiceImpl implements ConsulService { private final ConsulClient consulClient; public ConsulServiceImpl(ConsulClient consulClient) { this.consulClient = consulClient; } @Override public ConsulService agentInfo(Handler<AsyncResult<JsonObject>> resultHandler) { consulClient.agentInfo(resultHandler); return this; } @Override public ConsulService coordinateNodes(Handler<AsyncResult<CoordinateList>> resultHandler) { consulClient.coordinateNodes(resultHandler); return this; } @Override public ConsulService coordinateNodesWithOptions(BlockingQueryOptions options, Handler<AsyncResult<CoordinateList>> resultHandler) { consulClient.coordinateNodesWithOptions(options, resultHandler); return this; } @Override public ConsulService coordinateDatacenters(Handler<AsyncResult<List<DcCoordinates>>> resultHandler) { consulClient.coordinateDatacenters(resultHandler); return this; } @Override public ConsulService getKeys(String keyPrefix, Handler<AsyncResult<List<String>>> resultHandler) { consulClient.getKeys(keyPrefix, resultHandler); return this; } @Override public ConsulService getKeysWithOptions(String keyPrefix, BlockingQueryOptions options, Handler<AsyncResult<List<String>>> resultHandler) { consulClient.getKeysWithOptions(keyPrefix, options, resultHandler); return this; } @Override public ConsulService getValue(String key, Handler<AsyncResult<KeyValue>> resultHandler) { consulClient.getValue(key, resultHandler); return this; } @Override public ConsulService getValueWithOptions(String key, BlockingQueryOptions options, Handler<AsyncResult<KeyValue>> resultHandler) { consulClient.getValueWithOptions(key, options, resultHandler); return this; } @Override public ConsulService deleteValue(String key, Handler<AsyncResult<Void>> resultHandler) { consulClient.deleteValue(key, resultHandler); return this; } @Override public ConsulService getValues(String keyPrefix, Handler<AsyncResult<KeyValueList>> resultHandler) { consulClient.getValues(keyPrefix, resultHandler); return this; } @Override public ConsulService getValuesWithOptions(String keyPrefix, BlockingQueryOptions options, Handler<AsyncResult<KeyValueList>> resultHandler) { consulClient.getValuesWithOptions(keyPrefix, options, resultHandler); return this; } @Override public ConsulService deleteValues(String keyPrefix, Handler<AsyncResult<Void>> resultHandler) { consulClient.deleteValues(keyPrefix, resultHandler); return this; } @Override public ConsulService putValue(String key, String value, Handler<AsyncResult<Boolean>> resultHandler) { consulClient.putValue(key, value, resultHandler); return this; } @Override public ConsulService putValueWithOptions(String key, String value, KeyValueOptions options, Handler<AsyncResult<Boolean>> resultHandler) { consulClient.putValueWithOptions(key, value, options, resultHandler); return this; } @Override public ConsulService transaction(TxnRequest request, Handler<AsyncResult<TxnResponse>> resultHandler) { consulClient.transaction(request, resultHandler); return this; } @Override public ConsulService createAclToken(AclToken aclToken, Handler<AsyncResult<String>> idHandler) { consulClient.createAclToken(aclToken, idHandler); return this; } @Override public ConsulService updateAclToken(AclToken token, Handler<AsyncResult<String>> idHandler) { consulClient.updateAclToken(token, idHandler); return this; } @Override public ConsulService cloneAclToken(String id, Handler<AsyncResult<String>> idHandler) { consulClient.cloneAclToken(id, idHandler); return this; } @Override public ConsulService listAclTokens(Handler<AsyncResult<List<AclToken>>> resultHandler) { consulClient.listAclTokens(resultHandler); return this; } @Override public ConsulService infoAclToken(String id, Handler<AsyncResult<AclToken>> tokenHandler) { consulClient.infoAclToken(id, tokenHandler); return this; } @Override public ConsulService destroyAclToken(String id, Handler<AsyncResult<Void>> resultHandler) { consulClient.destroyAclToken(id, resultHandler); return this; } @Override public ConsulService fireEvent(String name, Handler<AsyncResult<Event>> resultHandler) { consulClient.fireEvent(name, resultHandler); return this; } @Override public ConsulService fireEventWithOptions(String name, EventOptions options, Handler<AsyncResult<Event>> resultHandler) { consulClient.fireEventWithOptions(name, options, resultHandler); return this; } @Override public ConsulService listEvents(Handler<AsyncResult<EventList>> resultHandler) { consulClient.listEvents(resultHandler); return this; } @Override public ConsulService listEventsWithOptions(EventListOptions options, Handler<AsyncResult<EventList>> resultHandler) { consulClient.listEventsWithOptions(options, resultHandler); return this; } @Override public ConsulService registerService(ServiceOptions serviceOptions, Handler<AsyncResult<Void>> resultHandler) { consulClient.registerService(serviceOptions, resultHandler); return this; } @Override public ConsulService maintenanceService(MaintenanceOptions maintenanceOptions, Handler<AsyncResult<Void>> resultHandler) { consulClient.maintenanceService(maintenanceOptions, resultHandler); return this; } @Override public ConsulService deregisterService(String id, Handler<AsyncResult<Void>> resultHandler) { consulClient.deregisterService(id, resultHandler); return this; } @Override public ConsulService healthChecks(String service, Handler<AsyncResult<CheckList>> resultHandler) { consulClient.healthChecks(service, resultHandler); return this; } @Override public ConsulService healthChecksWithOptions(String service, CheckQueryOptions options, Handler<AsyncResult<CheckList>> resultHandler) { consulClient.healthChecksWithOptions(service, options, resultHandler); return this; } @Override public ConsulService healthState(HealthState healthState, Handler<AsyncResult<CheckList>> handler) { consulClient.healthState(healthState, handler); return this; } @Override public ConsulService healthStateWithOptions(HealthState healthState, CheckQueryOptions checkQueryOptions, Handler<AsyncResult<CheckList>> handler) { consulClient.healthStateWithOptions(healthState, checkQueryOptions, handler); return this; } @Override public ConsulService healthServiceNodes(String service, boolean passing, Handler<AsyncResult<ServiceEntryList>> resultHandler) { consulClient.healthServiceNodes(service, passing, resultHandler); return this; } @Override public ConsulService healthServiceNodesWithOptions(String service, boolean passing, ServiceQueryOptions options, Handler<AsyncResult<ServiceEntryList>> resultHandler) { consulClient.healthServiceNodesWithOptions(service, passing, options, resultHandler); return this; } @Override public ConsulService catalogServiceNodes(String service, Handler<AsyncResult<ServiceList>> resultHandler) { consulClient.catalogServiceNodes(service, resultHandler); return this; } @Override public ConsulService catalogServiceNodesWithOptions(String service, ServiceQueryOptions options, Handler<AsyncResult<ServiceList>> resultHandler) { consulClient.catalogServiceNodesWithOptions(service, options, resultHandler); return this; } @Override public ConsulService catalogDatacenters(Handler<AsyncResult<List<String>>> resultHandler) { consulClient.catalogDatacenters(resultHandler); return this; } @Override public ConsulService catalogNodes(Handler<AsyncResult<NodeList>> resultHandler) { consulClient.catalogNodes(resultHandler); return this; } @Override public ConsulService catalogNodesWithOptions(NodeQueryOptions options, Handler<AsyncResult<NodeList>> resultHandler) { consulClient.catalogNodesWithOptions(options, resultHandler); return this; } @Override public ConsulService catalogServices(Handler<AsyncResult<ServiceList>> resultHandler) { consulClient.catalogServices(resultHandler); return this; } @Override public ConsulService catalogServicesWithOptions(BlockingQueryOptions options, Handler<AsyncResult<ServiceList>> resultHandler) { consulClient.catalogServicesWithOptions(options, resultHandler); return this; } @Override public ConsulService localChecks(Handler<AsyncResult<List<Check>>> resultHandler) { consulClient.localChecks(resultHandler); return this; } @Override public ConsulService registerCheck(CheckOptions checkOptions, Handler<AsyncResult<Void>> resultHandler) { consulClient.registerCheck(checkOptions, resultHandler); return this; } @Override public ConsulService deregisterCheck(String checkId, Handler<AsyncResult<Void>> resultHandler) { consulClient.deregisterCheck(checkId, resultHandler); return this; } @Override public ConsulService passCheck(String checkId, Handler<AsyncResult<Void>> resultHandler) { consulClient.passCheck(checkId, resultHandler); return this; } @Override public ConsulService passCheckWithNote(String checkId, String note, Handler<AsyncResult<Void>> resultHandler) { consulClient.passCheckWithNote(checkId, note, resultHandler); return this; } @Override public ConsulService warnCheck(String checkId, Handler<AsyncResult<Void>> resultHandler) { consulClient.warnCheck(checkId, resultHandler); return this; } @Override public ConsulService warnCheckWithNote(String checkId, String note, Handler<AsyncResult<Void>> resultHandler) { consulClient.warnCheckWithNote(checkId, note, resultHandler); return this; } @Override public ConsulService failCheck(String checkId, Handler<AsyncResult<Void>> resultHandler) { consulClient.failCheck(checkId, resultHandler); return this; } @Override public ConsulService failCheckWithNote(String checkId, String note, Handler<AsyncResult<Void>> resultHandler) { consulClient.failCheckWithNote(checkId, note, resultHandler); return this; } @Override public ConsulService updateCheck(String checkId, CheckStatus status, Handler<AsyncResult<Void>> resultHandler) { consulClient.updateCheck(checkId, status, resultHandler); return this; } @Override public ConsulService updateCheckWithNote(String checkId, CheckStatus status, String note, Handler<AsyncResult<Void>> resultHandler) { consulClient.updateCheckWithNote(checkId, status, note, resultHandler); return this; } @Override public ConsulService leaderStatus(Handler<AsyncResult<String>> resultHandler) { consulClient.leaderStatus(resultHandler); return this; } @Override public ConsulService peersStatus(Handler<AsyncResult<List<String>>> resultHandler) { consulClient.peersStatus(resultHandler); return this; } @Override public ConsulService createSession(Handler<AsyncResult<String>> idHandler) { consulClient.createSession(idHandler); return this; } @Override public ConsulService createSessionWithOptions(SessionOptions options, Handler<AsyncResult<String>> idHandler) { consulClient.createSessionWithOptions(options, idHandler); return this; } @Override public ConsulService infoSession(String id, Handler<AsyncResult<Session>> resultHandler) { consulClient.infoSession(id, resultHandler); return this; } @Override public ConsulService infoSessionWithOptions(String id, BlockingQueryOptions options, Handler<AsyncResult<Session>> resultHandler) { consulClient.infoSessionWithOptions(id, options, resultHandler); return this; } @Override public ConsulService renewSession(String id, Handler<AsyncResult<Session>> resultHandler) { consulClient.renewSession(id, resultHandler); return this; } @Override public ConsulService listSessions(Handler<AsyncResult<SessionList>> resultHandler) { consulClient.listSessions(resultHandler); return this; } @Override public ConsulService listSessionsWithOptions(BlockingQueryOptions options, Handler<AsyncResult<SessionList>> resultHandler) { consulClient.listSessionsWithOptions(options, resultHandler); return this; } @Override public ConsulService listNodeSessions(String nodeId, Handler<AsyncResult<SessionList>> resultHandler) { consulClient.listNodeSessions(nodeId, resultHandler); return this; } @Override public ConsulService listNodeSessionsWithOptions(String nodeId, BlockingQueryOptions options, Handler<AsyncResult<SessionList>> resultHandler) { consulClient.listNodeSessionsWithOptions(nodeId, options, resultHandler); return this; } @Override public ConsulService destroySession(String id, Handler<AsyncResult<Void>> resultHandler) { consulClient.destroySession(id, resultHandler); return this; } @Override public ConsulService createPreparedQuery(PreparedQueryDefinition definition, Handler<AsyncResult<String>> resultHandler) { consulClient.createPreparedQuery(definition, resultHandler); return this; } @Override public ConsulService getPreparedQuery(String id, Handler<AsyncResult<PreparedQueryDefinition>> resultHandler) { consulClient.getPreparedQuery(id, resultHandler); return this; } @Override public ConsulService getAllPreparedQueries(Handler<AsyncResult<List<PreparedQueryDefinition>>> resultHandler) { consulClient.getAllPreparedQueries(resultHandler); return this; } @Override public ConsulService updatePreparedQuery(PreparedQueryDefinition definition, Handler<AsyncResult<Void>> resultHandler) { consulClient.updatePreparedQuery(definition, resultHandler); return this; } @Override public ConsulService deletePreparedQuery(String id, Handler<AsyncResult<Void>> resultHandler) { consulClient.deletePreparedQuery(id, resultHandler); return this; } @Override public ConsulService executePreparedQuery(String query, Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler) { consulClient.executePreparedQuery(query, resultHandler); return this; } @Override public ConsulService executePreparedQueryWithOptions(String query, PreparedQueryExecuteOptions options, Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler) { consulClient.executePreparedQueryWithOptions(query, options, resultHandler); return this; } @Override public ConsulService localServices(Handler<AsyncResult<List<Service>>> resultHandler) { consulClient.localServices(resultHandler); return this; } @Override public ConsulService catalogNodeServices(String node, Handler<AsyncResult<ServiceList>> resultHandler) { consulClient.catalogNodeServices(node, resultHandler); return this; } @Override public ConsulService catalogNodeServicesWithOptions(String node, BlockingQueryOptions options, Handler<AsyncResult<ServiceList>> resultHandler) { consulClient.catalogNodeServicesWithOptions(node, options, resultHandler); return this; } @Override public void close() { consulClient.close(); } }