我正在使用 kubernetes-client/java api,我想以编程方式获取所有命名空间中所有 pod 的 pod 状态。我的代码基于这个 Kubernetes java 库的示例。
这是我的代码片段:
Watch<V1Pod> watch = Watch.createWatch(
client,
api.listPodForAllNamespacesCall(
null, null, null, null, limit,
null, null, null, watchTrue,
null, null),
new TypeToken<Watch.Response<V1Pod>>() {}.getType());
for (Watch.Response<V1Pod> item : watch) {
V1PodStatus podStatus = item.object.getStatus();
String name = item.object.getMetadata().getName();
String status = podStatus.getPhase();
String kind = item.object.getKind();
String details = podStatus.toString();
System.out.printf("NAME: %s | KIND: %s | STATUS: %s | DETAILS: %n%s%n====================%n", name, kind, status, details);
}
我的问题是这样的:
Watch
相当于事件处理程序吗?此代码向我显示了 Pod 的所有状态的列表,但它会在实时发生时自动“推送”更多 Pod 状态事件吗?还是只触发一次?
Watch 旨在发送持续更新。如果您运行程序一段时间并启动/停止某些操作,您将看到新的更新即将到来。
我不确定将其称为事件处理程序是否正确。这是一种不同的模式。
现在有一个更简单的解决方案来监视 Kubernetes 资源: