repartition command: metrics

littlehorse-enterprises · Feb 14, 2025 · f64f85f · f64f85f
1 parent 509fb40
commit f64f85f
Show file tree

Hide file tree

Showing 41 changed files with 3,000 additions and 711 deletions.
diff --git a/schemas/internal/command.proto b/schemas/internal/command.proto
@@ -14,7 +14,6 @@ import "variable.proto";
 import "storage.proto";
 import "acls.proto";
 import "job.proto";
-import "metrics.proto";
 
 
 // This is the schema of everything that flows through the Central Command topic.

diff --git a/schemas/internal/storage.proto b/schemas/internal/storage.proto
@@ -50,6 +50,7 @@ enum GetableClassEnum {
     SCHEDULED_WF_RUN = 17;
     METRIC = 18;
     PARTITION_METRIC = 19;
+    METRIC_RUN = 20;
 }
 
 message AttributePb {

diff --git a/schemas/littlehorse/common_enums.proto b/schemas/littlehorse/common_enums.proto
@@ -139,4 +139,15 @@ enum LHErrorType {
 
   // An unexpected LittleHorse Internal error occurred. This is not expected to happen.
   INTERNAL_ERROR = 8;
+}
+
+enum MeasurableObject {
+  WORKFLOW = 0;
+  TASK = 1;
+}
+
+enum MetricType {
+  COUNT = 0;
+  AVG = 1;
+  RATIO = 2;
 }
diff --git a/schemas/littlehorse/metrics.proto b/schemas/littlehorse/metrics.proto
@@ -18,22 +18,6 @@ message Metric {
   google.protobuf.Duration window_length = 3;
 }
 
-message MetricId {
-  MeasurableObject measurable = 1;
-  MetricType type = 2;
-}
-
-enum MeasurableObject {
-  WORKFLOW = 0;
-  TASK = 1;
-}
-
-enum MetricType {
-  COUNT = 0;
-  AVG = 1;
-  RATIO = 2;
-}
-
 message PartitionMetric {
   PartitionMetricId id = 1;
   google.protobuf.Timestamp created_at = 2;
@@ -49,4 +33,10 @@ message PartitionWindowedMetric {
 message PartitionMetricId {
    MetricId id = 1;
    TenantId tenant_id = 2;
+}
+
+message MetricRun {
+  MetricRunId id = 1;
+  double value = 2;
+  google.protobuf.Timestamp created_at = 4;
 }
diff --git a/schemas/littlehorse/object_id.proto b/schemas/littlehorse/object_id.proto
@@ -192,4 +192,14 @@ message TenantId {
 // ID for a ScheduledWfRun
 message ScheduledWfRunId {
   string id = 1;
+}
+
+message MetricId {
+  MeasurableObject measurable = 1;
+  MetricType type = 2;
+}
+
+message MetricRunId {
+  MetricId metric_id = 1;
+  google.protobuf.Timestamp window_start = 2;
 }
diff --git a/sdk-go/lhproto/common_enums.pb.go b/sdk-go/lhproto/common_enums.pb.go