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.22'
     steps:
       - checkout:
           path: ~/core

Dockerfile

@@ -1,9 +1,9 @@
-FROM golang:1.18-bullseye
+FROM golang:1.22-bullseye
 
 RUN apt-get update && apt-get upgrade -y && apt-get install -y unzip
 
 ARG protoc_version=3.19.4
-ARG protoc_arch=x86_64
+ARG protoc_arch=aarch_64
 ARG protoc_release=https://github.com/protocolbuffers/protobuf/releases/download/v${protoc_version}/protoc-${protoc_version}-linux-${protoc_arch}.zip
 
 ADD $protoc_release /opt/protoc.zip

v2/check.go

@@ -131,6 +131,7 @@ func NewCheck(c *CheckConfig) *Check {
 		MaxOutputSize:          c.MaxOutputSize,
 		Scheduler:              c.Scheduler,
 		Pipelines:              c.Pipelines,
+		FallbackPipelines:      c.FallbackPipelines,
 	}
 	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.FallbackPipelines == nil {
+		c.FallbackPipelines = []*ResourceReference{}
+	}
 
 	type Clone Check
 	clone := &Clone{}

v2/check.proto

@@ -171,6 +171,9 @@ message CheckConfig {
   repeated MetricThreshold output_metric_thresholds = 33 [ (gogoproto.jsontag) = "output_metric_thresholds,omitempty", (gogoproto.moretags) = "yaml: \"output_metric_thresholds,omitempty\"" ];
 
   repeated TimeWindowRepeated subdues = 34  [ (gogoproto.jsontag) = "subdues,omitempty" ];
+
+  //added fallback pieplines details in order of execution
+  repeated ResourceReference fallback_pipelines = 35 [ (gogoproto.jsontag) = "fallback_pipelines" ,(gogoproto.moretags) = "yaml: \"fallback_pipelines,omitempty\"" ];
 }
 
 // A Check is a check specification and optionally the results of the check's
@@ -334,6 +337,9 @@ message Check {
 
   repeated TimeWindowRepeated subdues = 48  [ (gogoproto.jsontag) = "subdues,omitempty" ];
 
+  //fallback pieplines details in order of execution
+  repeated ResourceReference fallback_pipelines = 49 [ (gogoproto.jsontag) = "fallback_pipelines" ,(gogoproto.moretags) = "yaml: \"fallback_pipelines,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 _, fallpipelines := range e.FallbackPipelines {
+		if err := e.validateFallbackPipelineReference(fallpipelines); 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 pipelines
+  repeated ResourceReference fallback_pipelines = 9 [ (gogoproto.jsontag) = "fallback_pipelines" ];
 }