public MetricStoreImpl()

in service/src/main/java/org/apache/griffin/core/metric/MetricStoreImpl.java [70:98]
29 lines of code
3 McCabe index (conditional complexity)

    public MetricStoreImpl(@Value("${elasticsearch.host}") String host,
                           @Value("${elasticsearch.port}") int port,
                           @Value("${elasticsearch.scheme:http}") String scheme,
                           @Value("${elasticsearch.user:}") String user,
                           @Value("${elasticsearch.password:}") String password) {
        HttpHost httpHost = new HttpHost(host, port, scheme);
        RestClientBuilder builder = RestClient.builder(httpHost);
        if (!user.isEmpty() && !password.isEmpty()) {
            String encodedAuth = buildBasicAuthString(user, password);
            Header[] requestHeaders = new Header[]{
                new BasicHeader(org.apache.http.HttpHeaders.AUTHORIZATION,
                    encodedAuth)};
            builder.setDefaultHeaders(requestHeaders);
        }
        this.client = builder.build();
        HttpHeaders responseHeaders = new HttpHeaders();
        responseHeaders.setContentType(MediaType.APPLICATION_JSON);
        this.responseHeaders = responseHeaders;
        String urlBase = String.format("/%s/%s", INDEX, TYPE);
        this.urlGet = urlBase.concat("/_search?filter_path=hits.hits._source");
        this.urlPost = urlBase.concat("/_bulk");
        this.urlDelete = urlBase.concat("/_delete_by_query");
        this.indexMetaData = String.format(
            "{ \"index\" : { \"_index\" : " +
                "\"%s\",\"_type\" : \"%s\" } }%n",
            INDEX,
            TYPE);
        this.mapper = new ObjectMapper();
    }