// Path: common/src/main/java/org/openshift/ping/common/stream/StreamProvider.java
// public interface StreamProvider {
// 
//     public InputStream openStream(String url, Map<String, String> headers, int connectTimeout, int readTimeout) throws IOException;
// 
// }


import static org.openshift.ping.common.Utils.openStream;
import static org.openshift.ping.common.Utils.urlencode;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.jboss.dmr.ModelNode;
import org.openshift.ping.common.stream.StreamProvider;
            if (!conditionsNode.isDefined()) {
                continue;
            }
            boolean ready = false;
            List<ModelNode> conditions = conditionsNode.asList();
            for (ModelNode condition : conditions) {
                ModelNode conditionTypeNode = condition.get("type");
                ModelNode conditionStatusNode = condition.get("status");
                if (conditionTypeNode.isDefined() && "Ready".equals(conditionTypeNode.asString()) &&
                        conditionStatusNode.isDefined() && "True".equals(conditionStatusNode.asString())) {
                    ready = true;
                    break;
                }
            }
            if (!ready) {
                continue;
            }
            */
            //String hostIP = statusNode.get("hostIP").asString(); // 10.34.75.250
            ModelNode podIPNode = statusNode.get("podIP");
            if (!podIPNode.isDefined()) {
                continue;
            }
            String podIP = podIPNode.asString(); // 10.1.0.169
            Pod pod = new Pod(podIP);
            ModelNode containersNode = specNode.get("containers");
            if (!containersNode.isDefined()) {
                continue;
            }
            List<ModelNode> containerNodes = containersNode.asList();
// Path: common/src/main/java/org/openshift/ping/common/stream/StreamProvider.java
// public interface StreamProvider {
// 
//     public InputStream openStream(String url, Map<String, String> headers, int connectTimeout, int readTimeout) throws IOException;
// 
// }


// Path: kube/src/main/java/org/openshift/ping/kube/Client.java
import static org.openshift.ping.common.Utils.openStream;
import static org.openshift.ping.common.Utils.urlencode;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.jboss.dmr.ModelNode;
import org.openshift.ping.common.stream.StreamProvider;

            if (!conditionsNode.isDefined()) {
                continue;
            }
            boolean ready = false;
            List<ModelNode> conditions = conditionsNode.asList();
            for (ModelNode condition : conditions) {
                ModelNode conditionTypeNode = condition.get("type");
                ModelNode conditionStatusNode = condition.get("status");
                if (conditionTypeNode.isDefined() && "Ready".equals(conditionTypeNode.asString()) &&
                        conditionStatusNode.isDefined() && "True".equals(conditionStatusNode.asString())) {
                    ready = true;
                    break;
                }
            }
            if (!ready) {
                continue;
            }
            */
            //String hostIP = statusNode.get("hostIP").asString(); // 10.34.75.250
            ModelNode podIPNode = statusNode.get("podIP");
            if (!podIPNode.isDefined()) {
                continue;
            }
            String podIP = podIPNode.asString(); // 10.1.0.169
            Pod pod = new Pod(podIP);
            ModelNode containersNode = specNode.get("containers");
            if (!containersNode.isDefined()) {
                continue;
            }
            List<ModelNode> containerNodes = containersNode.asList();
            for (ModelNode containerNode : containerNodes) {