Fallback Pipeline addition in core/v2

.circleci/config.yml

@@ -11,7 +11,7 @@ jobs:
     working_directory: ~/core/<< parameters.module>>
     executor:
       name: go/default
-      tag: '1.18'
+      tag: '1.19'
     steps:
       - checkout:
           path: ~/core

v2/check.go

@@ -131,6 +131,7 @@ func NewCheck(c *CheckConfig) *Check {
 		MaxOutputSize:          c.MaxOutputSize,
 		Scheduler:              c.Scheduler,
 		Pipelines:              c.Pipelines,
+		FallbackPipeline:       c.FallbackPipeline,
 	}
 	if check.Labels == nil {
 		check.Labels = make(map[string]string)
@@ -268,6 +269,9 @@ func (c *Check) MarshalJSON() ([]byte, error) {
 	if c.Pipelines == nil {
 		c.Pipelines = []*ResourceReference{}
 	}
+	if c.FallbackPipeline == nil {
+		c.FallbackPipeline = []*ResourceReference{}
+	}
 
 	type Clone Check
 	clone := &Clone{}

v2/check.proto

@@ -168,9 +168,13 @@ message CheckConfig {
   // Pipelines are the pipelines this check will use to process its events.
   repeated ResourceReference pipelines = 32 [ (gogoproto.jsontag) = "pipelines" ];
 
-  repeated MetricThreshold output_metric_thresholds = 33 [ (gogoproto.jsontag) = "output_metric_thresholds,omitempty", (gogoproto.moretags) = "yaml: \"output_metric_thresholds,omitempty\"" ];
+  //added fallback pieplines detials in order of execution
+  repeated ResourceReference fallback_pipeline = 33 [ (gogoproto.jsontag) = "fallback_pipeline" ,(gogoproto.moretags) = "yaml: \"fallback_pipeline,omitempty\"" ];
 
-  repeated TimeWindowRepeated subdues = 34  [ (gogoproto.jsontag) = "subdues,omitempty" ];
+
+  repeated MetricThreshold output_metric_thresholds = 34 [ (gogoproto.jsontag) = "output_metric_thresholds,omitempty", (gogoproto.moretags) = "yaml: \"output_metric_thresholds,omitempty\"" ];
+
+  repeated TimeWindowRepeated subdues = 35  [ (gogoproto.jsontag) = "subdues,omitempty" ];
 }
 
 // A Check is a check specification and optionally the results of the check's
@@ -328,11 +332,14 @@ message Check {
   // Pipelines are the pipelines this check will use to process its events.
   repeated ResourceReference pipelines = 46 [ (gogoproto.jsontag) = "pipelines" ];
 
+  //fallback pieplines detials in order of execution
+  repeated ResourceReference fallback_pipeline = 47 [ (gogoproto.jsontag) = "fallback_pipeline" ,(gogoproto.moretags) = "yaml: \"fallback_pipeline,omitempty\"" ];
+
   // MetricThresholds are a list of thresholds to apply to metrics in order to determine
   // the check status.
-  repeated MetricThreshold output_metric_thresholds = 47 [ (gogoproto.jsontag) = "output_metric_thresholds,omitempty", (gogoproto.moretags) = "yaml: \"output_metric_thresholds,omitempty\"" ];
+  repeated MetricThreshold output_metric_thresholds = 48 [ (gogoproto.jsontag) = "output_metric_thresholds,omitempty", (gogoproto.moretags) = "yaml: \"output_metric_thresholds,omitempty\"" ];
 
-  repeated TimeWindowRepeated subdues = 48  [ (gogoproto.jsontag) = "subdues,omitempty" ];
+  repeated TimeWindowRepeated subdues = 49  [ (gogoproto.jsontag) = "subdues,omitempty" ];
 
   // ExtendedAttributes store serialized arbitrary JSON-encoded data
   bytes ExtendedAttributes = 99 [ (gogoproto.jsontag) = "-" ];

v2/event.go

@@ -76,6 +76,12 @@ func (e *Event) Validate() error {
 		}
 	}
 
+	for _, fallpipeline := range e.FallbackPipeline {
+		if err := e.validateFallbackPipelineReference(fallpipeline); err != nil {
+			return errors.New("Fallback-pipeline reference is invalid: " + err.Error())
+		}
+	}
+
 	if e.Name != "" {
 		return errors.New("events cannot be named")
 	}
@@ -205,6 +211,19 @@ func (e *Event) validatePipelineReference(ref *ResourceReference) error {
 	return fmt.Errorf("resource type not capable of acting as a pipeline: %s.%s", ref.APIVersion, ref.Type)
 }
 
+// validateFallbackPipelineReference validates that a resource reference is capable of
+// acting as a pipeline.
+func (e *Event) validateFallbackPipelineReference(ref *ResourceReference) error {
+	switch ref.APIVersion {
+	case "core/v2":
+		switch ref.Type {
+		case "LegacyPipeline":
+			return nil
+		}
+	}
+	return fmt.Errorf("resource type not capable of acting as a fallbackpipeline: %s.%s", ref.APIVersion, ref.Type)
+}
+
 // FixtureEvent returns a testing fixture for an Event object.
 func FixtureEvent(entityName, checkID string) *Event {
 	id := uuid.New()

v2/event.proto

@@ -50,4 +50,6 @@ message Event {
   // APIVersion should default to "core/v2" and Type should default to
   // "Pipeline".
   repeated ResourceReference pipelines = 8 [ (gogoproto.jsontag) = "pipelines" ];
+  //fallback pipeline
+  repeated ResourceReference fallback_pipeline = 9 [ (gogoproto.jsontag) = "fallback_pipeline" ];
 }