Make the metric interval optional

- set default value to 1m

artifacts/flagger/crd.yaml

@@ -91,7 +91,7 @@ spec:
                   properties:
                     items:
                       type: object
-                      required: ['name', 'interval', 'threshold']
+                      required: ['name', 'threshold']
                       properties:
                         name:
                           type: string

charts/flagger/templates/crd.yaml

@@ -92,7 +92,7 @@ spec:
                   properties:
                     items:
                       type: object
-                      required: ['name', 'interval', 'threshold']
+                      required: ['name', 'threshold']
                       properties:
                         name:
                           type: string

pkg/apis/flagger/v1alpha3/types.go

@@ -27,6 +27,7 @@ const (
 	CanaryKind              = "Canary"
 	ProgressDeadlineSeconds = 600
 	AnalysisInterval        = 60 * time.Second
+	MetricInterval          = "1m"
 )
 
 // +genclient
@@ -128,7 +129,7 @@ type CanaryAnalysis struct {
 // CanaryMetric holds the reference to Istio metrics used for canary analysis
 type CanaryMetric struct {
 	Name      string  `json:"name"`
-	Interval  string  `json:"interval"`
+	Interval  string  `json:"interval,omitempty"`
 	Threshold float64 `json:"threshold"`
 	// +optional
 	Query string `json:"query,omitempty"`
@@ -172,3 +173,8 @@ func (c *Canary) GetAnalysisInterval() time.Duration {
 
 	return interval
 }
+
+// GetMetricInterval returns the metric interval default value (1m)
+func (c *Canary) GetMetricInterval() string {
+	return MetricInterval
+}

pkg/controller/observer.go

@@ -80,8 +80,8 @@ func (c *CanaryObserver) GetScalar(query string) (float64, error) {
 		return 100, nil
 	}
 
-	query = strings.Replace(query, "\n","",-1)
-	query = strings.Replace(query, " ","",-1)
+	query = strings.Replace(query, "\n", "", -1)
+	query = strings.Replace(query, " ", "", -1)
 
 	var value *float64
 	result, err := c.queryMetric(query)

pkg/controller/scheduler.go

@@ -405,6 +405,10 @@ func (c *Controller) analyseCanary(r *flaggerv1.Canary) bool {
 
 	// run metrics checks
 	for _, metric := range r.Spec.CanaryAnalysis.Metrics {
+		if metric.Interval == "" {
+			metric.Interval = r.GetMetricInterval()
+		}
+
 		if metric.Name == "istio_requests_total" {
 			val, err := c.observer.GetDeploymentCounter(r.Spec.TargetRef.Name, r.Namespace, metric.Name, metric.Interval)
 			if err != nil {