qbit/consul-client/src/main/java/io/advantageous/consul/endpoints/CatalogEndpoint.java
public ConsulResponse<Map<String, List<String>>> getServices(
            @SuppressWarnings("SameParameterValue") final String datacenter, @SuppressWarnings("SameParameterValue") final String tag,
            final RequestOptions requestOptions) {


        final URI uri = createURI("/services");


        final HttpRequestBuilder httpRequestBuilder = RequestUtils.getHttpRequestBuilder(datacenter, tag, requestOptions, "/");


        HTTP.Response httpResponse = HTTP.getResponse(uri.toString() + "?" + httpRequestBuilder.paramString());

        if (httpResponse.code() != 200) {
            die("Unable to retrieve the datacenters", uri, httpResponse.code(), httpResponse.body());
        }

        //noinspection unchecked
        return (ConsulResponse<Map<String, List<String>>>) (Object) RequestUtils.consulResponse(Map.class, httpResponse);

    }
public ConsulResponse<Map<String, List<String>>> getServices(
            @SuppressWarnings("SameParameterValue") final String datacenter, @SuppressWarnings("SameParameterValue") final String tag,
            final RequestOptions requestOptions) {


        final URI uri = createURI("/services");


        final HttpRequestBuilder httpRequestBuilder = RequestUtils.getHttpRequestBuilder(datacenter, tag, requestOptions, "/");


        HTTP.Response httpResponse = HTTP.getResponse(uri.toString() + "?" + httpRequestBuilder.paramString());

        if (httpResponse.code() != 200) {
            die("Unable to retrieve the datacenters", uri, httpResponse.code(), httpResponse.body());
        }

        //noinspection unchecked
        return (ConsulResponse<Map<String, List<String>>>) (Object) RequestUtils.consulResponse(Map.class, httpResponse);

    }
public ConsulResponse < Map < String , List < String > > > getServices ( @ SuppressWarnings ( "SameParameterValue" ) final String datacenter , @ SuppressWarnings ( "SameParameterValue" ) final String tag , final RequestOptions requestOptions ) { final URI uri = createURI ( "/services" ) ; final HttpRequestBuilder httpRequestBuilder = RequestUtils . getHttpRequestBuilder ( datacenter , tag , requestOptions , "/" ) ; HTTP . Response httpResponse = HTTP . getResponse ( uri . toString ( ) + "?" + httpRequestBuilder . paramString ( ) ) ; if ( httpResponse . code ( ) != 200 ) { die ( "Unable to retrieve the datacenters" , uri , httpResponse . code ( ) , httpResponse . body ( ) ) ; } //noinspection unchecked return ( ConsulResponse < Map < String , List < String > > > ) ( Object ) RequestUtils . consulResponse ( Map . class , httpResponse ) ; }
Retrieves all services for a given datacenter with {@link io.advantageous.consul.domain.option.RequestOptions}.
<p>
GET /v1/catalog/services?dc={datacenter}

@param datacenter     datacenter
@param tag            tag
@param requestOptions The Query Options to use.
@return A {@link io.advantageous.consul.domain.ConsulResponse} containing a map of service name to list of tags.
Retrieves all services for a given datacenter with { @link io . advantageous . consul . domain . option . RequestOptions } . <p > GET / v1 / catalog / services?dc = { datacenter }