builder.field(STATUS, response.getStatus().name().toLowerCase(Locale.ROOT));
            }
            if (fieldSet.contains(TIMED_OUT)) {
                builder.field(TIMED_OUT, response.isTimedOut());
            }
            if (fieldSet.contains(NUMBER_OF_NODES)) {
                builder.field(NUMBER_OF_NODES, response.getNumberOfNodes());
            }
            if (fieldSet.contains(NUMBER_OF_DATA_NODES)) {

            }

            @Override
            public ClusterHealthStatus getStatus() {
                return status;
            }

            @Override
            public boolean isTimedOut() {
                return false;
            }

            @Override
            public int getNumberOfNodes() {
                return 3;
            }

            @Override

        final ClusterHealthResponse healthResponse =
                get(c -> c.admin().cluster().prepareHealth(targetIndices).setWaitForYellowStatus().execute());
        if (!healthResponse.isTimedOut()) {
            onConnectListenerList.forEach(l -> {
                try {
                    l.onConnect();
                } catch (final Exception e) {
                    logger.warn("Failed to invoke " + l, e);