alert-mgmt-01: k8s foundation and server bootstrap for alert management API

\nSigned-off-by: avlitman <alitman@redhat.com>\nSigned-off-by: Shirly Radco <sradco@redhat.com>\nSigned-off-by: machadovilaca <machadovilaca@gmail.com>\nCo-authored-by: Cursor AI Agent <cursor-ai@users.noreply.github.com>\n

Made-with: Cursor

Author: sradco

cmd/plugin-backend.go

@@ -8,15 +8,16 @@ import (
 	"strconv"
 	"strings"
 
-	server "github.com/openshift/monitoring-plugin/pkg"
 	"github.com/sirupsen/logrus"
+
+	server "github.com/openshift/monitoring-plugin/pkg"
 )
 
 var (
 	portArg             = flag.Int("port", 0, "server port to listen on (default: 9443)\nports 9444 and 9445 reserved for other use")
 	certArg             = flag.String("cert", "", "cert file path to enable TLS (disabled by default)")
 	keyArg              = flag.String("key", "", "private key file path to enable TLS (disabled by default)")
-	featuresArg         = flag.String("features", "", "enabled features, comma separated.\noptions: ['acm-alerting', 'incidents', 'dev-config', 'perses-dashboards']")
+	featuresArg         = flag.String("features", "", "enabled features, comma separated.\noptions: ['acm-alerting', 'incidents', 'dev-config', 'perses-dashboards', 'alert-management-api']")
 	staticPathArg       = flag.String("static-path", "", "static files path to serve frontend (default: './web/dist')")
 	configPathArg       = flag.String("config-path", "", "config files path (default: './config')")
 	pluginConfigArg     = flag.String("plugin-config-path", "", "plugin yaml configuration")

pkg/k8s/namespace.go

@@ -90,7 +90,11 @@ func (nm *namespaceManager) updateMonitoringNamespace(ns *corev1.Namespace) {
 	nm.mu.Lock()
 	defer nm.mu.Unlock()
 
-	nm.monitoringNamespaces[ns.Name] = true
+	if ns.Labels != nil && ns.Labels[ClusterMonitoringLabel] == "true" {
+		nm.monitoringNamespaces[ns.Name] = true
+	} else {
+		delete(nm.monitoringNamespaces, ns.Name)
+	}
 }
 
 func (nm *namespaceManager) removeMonitoringNamespace(name string) {

pkg/server.go

@@ -12,7 +12,6 @@ import (
 
 	"github.com/gorilla/handlers"
 	"github.com/gorilla/mux"
-	"github.com/openshift/monitoring-plugin/pkg/proxy"
 	"github.com/sirupsen/logrus"
 	"gopkg.in/yaml.v2"
 	v1 "k8s.io/api/core/v1"
@@ -21,6 +20,8 @@ import (
 	"k8s.io/client-go/kubernetes/scheme"
 	"k8s.io/client-go/rest"
 	"k8s.io/client-go/tools/record"
+
+	"github.com/openshift/monitoring-plugin/pkg/proxy"
 )
 
 var log = logrus.WithField("module", "server")
@@ -56,10 +57,11 @@ type PluginConfig struct {
 type Feature string
 
 const (
-	AcmAlerting      Feature = "acm-alerting"
-	Incidents        Feature = "incidents"
-	DevConfig        Feature = "dev-config"
-	PersesDashboards Feature = "perses-dashboards"
+	AcmAlerting        Feature = "acm-alerting"
+	Incidents          Feature = "incidents"
+	DevConfig          Feature = "dev-config"
+	PersesDashboards   Feature = "perses-dashboards"
+	AlertManagementAPI Feature = "alert-management-api"
 )
 
 func (pluginConfig *PluginConfig) MarshalJSON() ([]byte, error) {
@@ -103,6 +105,8 @@ func (s *PluginServer) Shutdown(ctx context.Context) error {
 
 func createHTTPServer(ctx context.Context, cfg *Config) (*http.Server, error) {
 	acmMode := cfg.Features[AcmAlerting]
+	alertManagementAPIMode := cfg.Features[AlertManagementAPI]
+
 	acmLocationsLength := len(cfg.AlertmanagerUrl) + len(cfg.ThanosQuerierUrl)
 
 	if acmLocationsLength > 0 && !acmMode {
@@ -116,15 +120,19 @@ func createHTTPServer(ctx context.Context, cfg *Config) (*http.Server, error) {
 		return nil, fmt.Errorf("cannot set default port to reserved port %d", cfg.Port)
 	}
 
+	var k8sconfig *rest.Config
+	var err error
+
 	// Uncomment the following line for local development:
-	// k8sconfig, err := clientcmd.BuildConfigFromFlags("", "$HOME/.kube/config")
+	// k8sconfig, err = clientcmd.BuildConfigFromFlags("", os.Getenv("KUBECONFIG"))
+	// if err != nil {
+	// 	return nil, fmt.Errorf("cannot get kubeconfig from file: %w", err)
+	// }
 
 	// Comment the following line for local development:
 	var k8sclient *dynamic.DynamicClient
-	if acmMode {
-
-		k8sconfig, err := rest.InClusterConfig()
-
+	if acmMode || alertManagementAPIMode {
+		k8sconfig, err = rest.InClusterConfig()
 		if err != nil {
 			return nil, fmt.Errorf("cannot get in cluster config: %w", err)
 		}