Adding statefulsets to ccp status

Change-Id: I993f174109f3d02aa2c5243dce2b82615983876d
This commit is contained in:
Andrey Pavlov 2017-03-16 17:05:39 +04:00
parent f83c2f1aa7
commit b5b0196ee6
2 changed files with 13 additions and 2 deletions

View File

@ -207,11 +207,14 @@ def list_cluster_ingress():
namespace=CONF.kubernetes.namespace)
def list_cluster_statefulsets():
def list_cluster_statefulsets(selector=None):
ccp_selector = "ccp=true"
if selector:
ccp_selector += ',' + selector
client = get_client()
return pykube.StatefulSet.objects(client).filter(
namespace=CONF.kubernetes.namespace,
selector="ccp=true")
selector=ccp_selector)
def get_object_names(items):

View File

@ -64,6 +64,14 @@ def get_pod_states(components=None):
states[app_name]["job_completed"] += (
job.obj["status"].get("succeeded", 0))
for ss in kubernetes.list_cluster_statefulsets(selector):
states.setdefault(ss.name, copy.deepcopy(STATE_TEMPLATE))
states[ss.name]["pod_total"] = ss.obj["spec"]["replicas"]
for pod in kubernetes.list_cluster_pods(ss.name):
if all((cont["ready"] for cont in
pod.obj["status"]["containerStatuses"])):
states[ss.name]["pod_running"] += 1
if CONF.configs.ingress.enabled:
url_template = "https://%s"
if CONF.configs.ingress.get("port"):