feat: notification silence CRD

models/canary.go

@@ -8,6 +8,8 @@ import (
 	"github.com/samber/lo"
 	"gorm.io/gorm"
 	"gorm.io/gorm/clause"
+	"k8s.io/apimachinery/pkg/fields"
+	"k8s.io/apimachinery/pkg/labels"
 )
 
 type Canary struct {
@@ -79,6 +81,34 @@ func (c Canary) AsMap(removeFields ...string) map[string]any {
 	return asMap(c, removeFields...)
 }
 
+func (c Canary) GetID() string {
+	return c.ID.String()
+}
+
+func (c Canary) GetName() string {
+	return c.Name
+}
+
+func (c Canary) GetNamespace() string {
+	return c.Namespace
+}
+
+func (c Canary) GetType() string {
+	return ""
+}
+
+func (c Canary) GetStatus() (string, error) {
+	return "", nil
+}
+
+func (c Canary) GetLabelsMatcher() labels.Labels {
+	return canaryLabels{c}
+}
+
+func (c Canary) GetFieldsMatcher() fields.Fields {
+	return noopMatcher{}
+}
+
 func DeleteChecksForCanary(db *gorm.DB, id string) ([]string, error) {
 	var checkIDs []string
 	var checks []Check
@@ -98,3 +128,35 @@ func DeleteChecksForCanary(db *gorm.DB, id string) ([]string, error) {
 func DeleteCheckComponentRelationshipsForCanary(db *gorm.DB, id string) error {
 	return db.Table("check_component_relationships").Where("canary_id = ?", id).UpdateColumn("deleted_at", Now()).Error
 }
+
+type noopMatcher struct {
+}
+
+func (t noopMatcher) Has(field string) (exists bool) {
+	return false
+}
+
+func (t noopMatcher) Get(field string) (value string) {
+	return ""
+}
+
+type canaryLabels struct {
+	Canary
+}
+
+func (t canaryLabels) Has(field string) (exists bool) {
+	if len(t.Labels) == 0 {
+		return false
+	}
+
+	_, ok := (t.Labels)[field]
+	return ok
+}
+
+func (t canaryLabels) Get(key string) (value string) {
+	if len(t.Labels) == 0 {
+		return ""
+	}
+
+	return (t.Labels)[key]
+}

models/checks.go

@@ -129,7 +129,7 @@ func (c Check) GetLabelsMatcher() labels.Labels {
 }
 
 func (c Check) GetFieldsMatcher() fields.Fields {
-	return checkFieldsProvider{c}
+	return noopMatcher{}
 }
 
 type checkLabelsProvider struct {
@@ -145,18 +145,6 @@ func (c checkLabelsProvider) Has(key string) bool {
 	return ok
 }
 
-type checkFieldsProvider struct {
-	Check
-}
-
-func (c checkFieldsProvider) Get(key string) string {
-	return ""
-}
-
-func (c checkFieldsProvider) Has(key string) bool {
-	return false // field selector not applicalbe for checks
-}
-
 type Checks []*Check
 
 func (c Checks) Len() int {

models/notifications.go

@@ -183,6 +183,7 @@ type NotificationSilence struct {
 
 	ID          uuid.UUID           `json:"id"  gorm:"default:generate_ulid()"`
 	Namespace   string              `json:"namespace,omitempty"`
+	Name        string              `json:"name,omitempty"`
 	Filter      types.CelExpression `json:"filter,omitempty"`
 	From        time.Time           `json:"from"`
 	Until       time.Time           `json:"until"`
@@ -194,6 +195,8 @@ type NotificationSilence struct {
 	UpdatedAt   time.Time           `json:"updated_at" time_format:"postgres_timestamp" gorm:"<-:false"`
 	DeletedAt   *time.Time          `json:"deleted_at,omitempty"`
 
+	Selectors types.JSON `json:"selectors,omitempty"`
+
 	// Error contains cel expression error in the filter
 	Error *string `json:"error,omitempty"`
 }

schema/notifications.hcl

@@ -233,6 +233,11 @@ table "notification_silences" {
     null = false
     type = text
   }
+  column "name" {
+    null    = false
+    type    = text
+    default = sql("generate_ulid()") # temporary default value to make the migration possible. we can remove this later.
+  }
   column "description" {
     null = true
     type = text
@@ -241,6 +246,11 @@ table "notification_silences" {
     null = true
     type = text
   }
+  column "selectors" {
+    null = true
+    type = jsonb
+    comment = "list of resource selectors"
+  }
   column "error" {
     null = true
     type = text