async function aggregateMetrics()

in src/poller/poller-core/index.js [536:555]


async function aggregateMetrics(clusters) {
  const aggregatedMetrics = [];
  for (const cluster of clusters) {
    try {
      cluster.metrics = await getMetrics(cluster);
      aggregatedMetrics.push(cluster);
      await Counters.incPollingSuccessCounter(cluster);
    } catch (err) {
      logger.error({
        message: `Unable to retrieve metrics for ${cluster.projectId}/${cluster.regionId}/${cluster.clusterId}: ${err}`,
        projectId: cluster.projectId,
        instanceId: cluster.clusterId,
        cluster: cluster,
        err: err,
      });
      await Counters.incPollingFailedCounter(cluster);
    }
  }
  return aggregatedMetrics;
}