io.fabric8.kubernetes.api.KubernetesHelper.getSelectedPodMap()方法的使用及代码示例

本文整理了Java中io.fabric8.kubernetes.api.KubernetesHelper.getSelectedPodMap()方法的一些代码示例，展示了KubernetesHelper.getSelectedPodMap()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。KubernetesHelper.getSelectedPodMap()方法的具体详情如下：
包路径：io.fabric8.kubernetes.api.KubernetesHelper
类名称：KubernetesHelper
方法名：getSelectedPodMap

KubernetesHelper.getSelectedPodMap介绍

暂无

代码示例

代码示例来源：origin: io.fabric8.jube.images.fabric8/fabric8-mq

public void pollBrokers() {
try {
Map podMap = KubernetesHelper.getSelectedPodMap(kubernetes, getBrokerSelector());
Collection pods = podMap.values();
LOG.info("Checking " + getBrokerSelector() + ": groupSize = " + pods.size());
for (Pod pod : pods) {
String host = KubernetesHelper.getHost(pod);
List cOntainers= KubernetesHelper.getContainers(pod);
for (Container container : containers) {
try {
LOG.info("Checking pod " + getName(pod) + " container: " + container.getName() + " image: " + container.getImage());
J4pClient client = clients.clientForContainer(host, container, pod);
populateBrokerStatistics(pod, client);
} catch (Throwable e) {
LOG.error("Failed to get broker statistics for pod: " + getName(pod));
}
}
}
} catch (Throwable e) {
LOG.error("Failed to pollBrokers ", e);
}
}

代码示例来源：origin: io.fabric8.ipaas.apps/fabric8mq

public void pollBrokers() {
try {
Map podMap = KubernetesHelper.getSelectedPodMap(kubernetes,namespace, getBrokerSelector());
Collection pods = podMap.values();
LOG.debug("Checking " + getBrokerSelector() + ": groupSize = " + pods.size());
for (Pod pod : pods) {
if (KubernetesHelper.isPodRunning(pod)) {
String host = KubernetesHelper.getHost(pod);
List cOntainers= KubernetesHelper.getContainers(pod);
for (Container container : containers) {
try {
LOG.debug("Checking pod " + getName(pod) + " container: " + container.getName() + " image: " + container.getImage());
J4pClient client = clients.clientForContainer(host, container, pod);
populateBrokerStatistics(pod, container, client);
} catch (Throwable e) {
LOG.error("Failed to get broker statistics for pod: " + getName(pod));
}
}
}
}
} catch (Throwable e) {
LOG.error("Failed to pollBrokers ", e);
}
}