feat: add configurable check interval, default is 1 minute

README.md

@@ -28,6 +28,7 @@ metadata:
     uptime.pdok.nl/name: "Logical name of the check"
     uptime.pdok.nl/url: "https://site.example/service/wms/v1_0"
     uptime.pdok.nl/tags: "metadata,separated,by,commas"
+    uptime.pdok.nl/interval-in-minutes: "5"
     uptime.pdok.nl/request-headers: "Accept: application/json, Accept-Language: en"
     uptime.pdok.nl/response-check-for-string-contains: "It works!"
     uptime.pdok.nl/response-check-for-string-not-contains: "NullPointerException"

internal/controller/ingressroute_controller_test.go

@@ -127,10 +127,11 @@ var _ = Describe("IngressRoute Controller", func() {
 			_, err = controllerReconciler.Reconcile(ctx, reconcile.Request{NamespacedName: typeNamespacedName})
 			Expect(err).NotTo(HaveOccurred())
 			Expect(testProvider.checks).To(ContainElement(m.UptimeCheck{
-				ID:   "y45735y375",
-				URL:  "https://test.example",
-				Name: "Test uptime check",
-				Tags: []string{"managed-by-uptime-operator"},
+				ID:       "y45735y375",
+				URL:      "https://test.example",
+				Name:     "Test uptime check",
+				Tags:     []string{"managed-by-uptime-operator"},
+				Interval: 1,
 			}))
 
 			By("Fetching and updating IngressRoute (adding extra uptime annotation)")
@@ -151,6 +152,7 @@ var _ = Describe("IngressRoute Controller", func() {
 				Name:           "Test uptime check",
 				Tags:           []string{"managed-by-uptime-operator"},
 				StringContains: "OK",
+				Interval:       1,
 			}))
 
 			By("Reconciling the IngressRoute again to make sure it doesn't cause any side effects")
@@ -176,6 +178,7 @@ var _ = Describe("IngressRoute Controller", func() {
 				Name:           "Test uptime check",
 				Tags:           []string{"managed-by-uptime-operator"},
 				StringContains: "OK",
+				Interval:       1,
 			}))
 
 			By("Delete IngressRoute")

internal/model/check.go

@@ -3,6 +3,7 @@ package model
 import (
 	"fmt"
 	"slices"
+	"strconv"
 	"strings"
 )
 
@@ -17,6 +18,7 @@ const (
 	AnnotationName              = AnnotationBase + "/name"
 	AnnotationURL               = AnnotationBase + "/url"
 	AnnotationTags              = AnnotationBase + "/tags"
+	AnnotationInterval          = AnnotationBase + "/interval-in-minutes"
 	AnnotationRequestHeaders    = AnnotationBase + "/request-headers"
 	AnnotationStringContains    = AnnotationBase + "/response-check-for-string-contains"
 	AnnotationStringNotContains = AnnotationBase + "/response-check-for-string-not-contains"
@@ -29,6 +31,7 @@ type UptimeCheck struct {
 	Name              string            `json:"name"`
 	URL               string            `json:"url"`
 	Tags              []string          `json:"tags"`
+	Interval          int               `json:"resolution"`
 	RequestHeaders    map[string]string `json:"request_headers"`     //nolint:tagliatelle // grandfathered in
 	StringContains    string            `json:"string_contains"`     //nolint:tagliatelle // grandfathered in
 	StringNotContains string            `json:"string_not_contains"` //nolint:tagliatelle // grandfathered in
@@ -47,11 +50,16 @@ func NewUptimeCheck(ingressName string, annotations map[string]string) (*UptimeC
 	if !ok {
 		return nil, fmt.Errorf("%s annotation not found on ingress route %s", AnnotationURL, ingressName)
 	}
+	interval, err := getInterval(annotations)
+	if err != nil {
+		return nil, err
+	}
 	check := &UptimeCheck{
 		ID:                id,
 		Name:              name,
 		URL:               url,
 		Tags:              stringToSlice(annotations[AnnotationTags]),
+		Interval:          interval,
 		RequestHeaders:    kvStringToMap(annotations[AnnotationRequestHeaders]),
 		StringContains:    annotations[AnnotationStringContains],
 		StringNotContains: annotations[AnnotationStringNotContains],
@@ -62,6 +70,17 @@ func NewUptimeCheck(ingressName string, annotations map[string]string) (*UptimeC
 	return check, nil
 }
 
+func getInterval(annotations map[string]string) (int, error) {
+	if _, ok := annotations[AnnotationInterval]; ok {
+		interval, err := strconv.Atoi(annotations[AnnotationInterval])
+		if err != nil {
+			return 1, fmt.Errorf("%s annotation should contain integer value: %w", AnnotationInterval, err)
+		}
+		return interval, nil
+	}
+	return 1, nil
+}
+
 func kvStringToMap(s string) map[string]string {
 	if s == "" {
 		return nil

internal/service/providers/pingdom.go

@@ -213,7 +213,7 @@ func (m *PingdomUptimeProvider) checkToJSON(check model.UptimeCheck, includeType
 		"url":        relativeURL,
 		"encryption": true, // assume all checks run over HTTPS
 		"port":       port,
-		"resolution": 1,
+		"resolution": check.Interval,
 		"tags":       check.Tags,
 	}
 	if includeType {