Check service status via deployments
After migration on Deployments we can use deployment objects for checking service status. Change-Id: I78b85a1de787a38d100c6f8dd4972c626fc4c188
This commit is contained in:
parent
b9ca170d44
commit
e78d1e3b06
@ -49,14 +49,12 @@ def get_pod_states(components=None):
|
||||
ext_ip = CONF.configs.get("k8s_external_ip", "")
|
||||
|
||||
states = {}
|
||||
for pod in kubernetes.list_cluster_pods():
|
||||
app_name = pod.obj["metadata"]["labels"].get("app")
|
||||
if not app_name:
|
||||
continue
|
||||
states.setdefault(app_name, copy.deepcopy(STATE_TEMPLATE))
|
||||
states[app_name]["pod_total"] += 1
|
||||
if pod.ready:
|
||||
states[app_name]["pod_running"] += 1
|
||||
for dp in kubernetes.list_cluster_deployments():
|
||||
states.setdefault(dp.name, copy.deepcopy(STATE_TEMPLATE))
|
||||
dp_st = dp.obj["status"]
|
||||
states[dp.name]["pod_total"] = dp_st["replicas"]
|
||||
states[dp.name]["pod_running"] = min(
|
||||
dp_st.get("availableReplicas", 0), dp_st["updatedReplicas"])
|
||||
|
||||
for job in kubernetes.list_cluster_jobs():
|
||||
app_name = job.obj["metadata"]["labels"].get("app")
|
||||
|
Loading…
Reference in New Issue
Block a user