Source code for opium.business
from opium.okd import get_pod_proxy
[docs]def gen_metrics_jobs(settings, session, dc_pods):
return (
get_annotated_pod_metrics(
session, settings.okd.base_url, settings.project, pod=pod
)
for dc in settings.deployment_configs
for pod in dc_pods[dc]
)
[docs]async def get_annotated_pod_metrics(*args, pod, **kwargs):
resp = await get_pod_proxy(*args, **kwargs, name=pod, path="/metrics")
return f"# metrics for {pod}\n{resp}"