Implement platform_load metric.
This metric shows the number of waiting and running jobs for each worker platform.
diff --git a/metrics/main.go b/metrics/main.go
index c3d5982..cb97b62 100644
--- a/metrics/main.go
+++ b/metrics/main.go
@@ -37,18 +37,18 @@
log.Fatalf("No pipelines were specified.")
}
+ bk, err := clients.CreateBuildkiteClient(settings.BuildkiteOrg, settings.BuildkiteApiToken, settings.BuildkiteDebug)
+ if err != nil {
+ log.Fatalf("Cannot create Buildkite client: %v", err)
+ }
+
/*
- bk, err := clients.CreateBuildkiteClient(settings.BuildkiteOrg, settings.BuildkiteApiToken, settings.BuildkiteDebug)
+ gcs, err := clients.CreateGcsClient()
if err != nil {
- log.Fatalf("Cannot create Buildkite client: %v", err)
+ log.Fatalf("Cannot create GCS client: %v", err)
}
*/
- gcs, err := clients.CreateGcsClient()
- if err != nil {
- log.Fatalf("Cannot create GCS client: %v", err)
- }
-
/*
cloudSql, err := publishers.CreateCloudSqlPublisher(settings.CloudSqlUser, settings.CloudSqlPassword, settings.CloudSqlInstance, settings.CloudSqlDatabase, settings.CloudSqlLocalPort)
if err != nil {
@@ -60,10 +60,8 @@
srv := service.CreateService(handleError)
- // TODO(fweikert): use real settings instead of hardcoded values
- flakiness := metrics.CreateFlakiness(gcs, "bazel-buildkite-stats", "flaky-tests-bep", "google-bazel-presubmit") // TODO: settings.BuildkitePipelines...)
- srv.AddMetric(flakiness, 60, stdout)
-
+ platformLoad := metrics.CreatePlatformLoad(bk, 100)
+ srv.AddMetric(platformLoad, 60, stdout)
/*
buildsPerChange := metrics.CreateBuildsPerChange(bk, 500, settings.BuildkitePipelines...)
srv.AddMetric(buildsPerChange, 60, stdout)
@@ -71,6 +69,10 @@
buildSuccess := metrics.CreateBuildSuccess(bk, 200, settings.BuildkitePipelines...)
srv.AddMetric(buildSuccess, 60, stdout)
+ // TODO(fweikert): use real settings instead of hardcoded values
+ flakiness := metrics.CreateFlakiness(gcs, "bazel-buildkite-stats", "flaky-tests-bep", "google-bazel-presubmit") // TODO: settings.BuildkitePipelines...)
+ srv.AddMetric(flakiness, 60, stdout)
+
macPerformance := metrics.CreateMacPerformance(bk, 20, "google-bazel-presubmit") // TODO: settings.BuildkitePipelines...)
srv.AddMetric(macPerformance, 60, stdout)