feat(bmc): add redfish support

Signed-off-by: Sunil Thaha <sthaha@redhat.com>

Author: sthaha

cmd/kepler/main.go

@@ -11,13 +11,16 @@ import (
 	"syscall"
 
 	"github.com/alecthomas/kingpin/v2"
+	"k8s.io/utils/ptr"
+
 	"github.com/sustainable-computing-io/kepler/config"
 	"github.com/sustainable-computing-io/kepler/internal/device"
 	"github.com/sustainable-computing-io/kepler/internal/exporter/prometheus"
 	"github.com/sustainable-computing-io/kepler/internal/exporter/stdout"
 	"github.com/sustainable-computing-io/kepler/internal/k8s/pod"
 	"github.com/sustainable-computing-io/kepler/internal/logger"
 	"github.com/sustainable-computing-io/kepler/internal/monitor"
+	"github.com/sustainable-computing-io/kepler/internal/platform/redfish"
 	"github.com/sustainable-computing-io/kepler/internal/resource"
 	"github.com/sustainable-computing-io/kepler/internal/server"
 	"github.com/sustainable-computing-io/kepler/internal/service"
@@ -157,6 +160,20 @@ func createServices(logger *slog.Logger, cfg *config.Config) ([]service.Service,
 		monitor.WithMinTerminatedEnergyThreshold(monitor.Energy(cfg.Monitor.MinTerminatedEnergyThreshold)*monitor.Joule),
 	)
 
+	// Create Redfish service if enabled
+	var redfishService *redfish.Service
+	if ptr.Deref(cfg.Platform.Redfish.Enabled, false) {
+		var err error
+		redfishService, err = redfish.NewService(
+			cfg.Platform.Redfish.ConfigFile,
+			cfg.Platform.NodeID,
+			logger,
+		)
+		if err != nil {
+			return nil, fmt.Errorf("failed to create Redfish service: %w", err)
+		}
+	}
+
 	apiServer := server.NewAPIServer(
 		server.WithLogger(logger),
 		server.WithListenAddress(cfg.Web.ListenAddresses),
@@ -170,9 +187,14 @@ func createServices(logger *slog.Logger, cfg *config.Config) ([]service.Service,
 		pm,
 	)
 
+	// Add Redfish service if enabled
+	if redfishService != nil {
+		services = append(services, redfishService)
+	}
+
 	// Add Prometheus exporter if enabled
 	if *cfg.Exporter.Prometheus.Enabled {
-		promExporter, err := createPrometheusExporter(logger, cfg, apiServer, pm)
+		promExporter, err := createPrometheusExporter(logger, cfg, apiServer, pm, redfishService)
 		if err != nil {
 			return nil, fmt.Errorf("failed to create Prometheus exporter: %w", err)
 		}
@@ -194,19 +216,26 @@ func createServices(logger *slog.Logger, cfg *config.Config) ([]service.Service,
 	return services, nil
 }
 
-func createPrometheusExporter(logger *slog.Logger, cfg *config.Config, apiServer *server.APIServer, pm *monitor.PowerMonitor) (*prometheus.Exporter, error) {
+func createPrometheusExporter(logger *slog.Logger, cfg *config.Config, apiServer *server.APIServer, pm *monitor.PowerMonitor, redfishService *redfish.Service) (*prometheus.Exporter, error) {
 	logger.Debug("Creating Prometheus exporter")
 
 	// Use metrics level from configuration (already parsed)
 	metricsLevel := cfg.Exporter.Prometheus.MetricsLevel
 
-	collectors, err := prometheus.CreateCollectors(
-		pm,
+	var collectorOpts []prometheus.OptionFn
+	collectorOpts = append(collectorOpts,
 		prometheus.WithLogger(logger),
 		prometheus.WithProcFSPath(cfg.Host.ProcFS),
 		prometheus.WithNodeName(cfg.Kube.Node),
 		prometheus.WithMetricsLevel(metricsLevel),
 	)
+
+	// Add platform data provider if Redfish service is available
+	if redfishService != nil {
+		collectorOpts = append(collectorOpts, prometheus.WithPlatformDataProvider(redfishService))
+	}
+
+	collectors, err := prometheus.CreateCollectors(pm, collectorOpts...)
 	if err != nil {
 		return nil, fmt.Errorf("failed to create Prometheus collectors: %w", err)
 	}

config/config.go

@@ -93,6 +93,18 @@ type (
 		Node    string `yaml:"nodeName"`
 	}
 
+	// Platform contains settings for platform power monitoring
+	Platform struct {
+		NodeID  string  `yaml:"nodeID"` // High-level node identifier
+		Redfish Redfish `yaml:"redfish"`
+	}
+
+	// Redfish contains settings for Redfish BMC power monitoring
+	Redfish struct {
+		Enabled    *bool  `yaml:"enabled"`
+		ConfigFile string `yaml:"configFile"`
+	}
+
 	Config struct {
 		Log      Log      `yaml:"log"`
 		Host     Host     `yaml:"host"`
@@ -103,7 +115,8 @@ type (
 		Debug    Debug    `yaml:"debug"`
 		Dev      Dev      `yaml:"dev"` // WARN: do not expose dev settings as flags
 
-		Kube Kube `yaml:"kube"`
+		Platform Platform `yaml:"platform"`
+		Kube     Kube     `yaml:"kube"`
 	}
 )
 
@@ -186,6 +199,11 @@ const (
 	KubeConfigFlag   = "kube.config"
 	KubeNodeNameFlag = "kube.node-name"
 
+	// Platform flags
+	PlatformNodeIDFlag         = "platform.node-id"
+	PlatformRedfishEnabledFlag = "platform.redfish.enabled"
+	PlatformRedfishConfigFlag  = "platform.redfish.config"
+
 // WARN:  dev settings shouldn't be exposed as flags as flags are intended for end users
 )
 
@@ -228,6 +246,13 @@ func DefaultConfig() *Config {
 		Web: Web{
 			ListenAddresses: []string{":28282"},
 		},
+		Platform: Platform{
+			NodeID: "",
+			Redfish: Redfish{
+				Enabled:    ptr.To(false),
+				ConfigFile: "",
+			},
+		},
 		Kube: Kube{
 			Enabled: ptr.To(false),
 		},
@@ -327,6 +352,11 @@ func RegisterFlags(app *kingpin.Application) ConfigUpdaterFn {
 	kubeconfig := app.Flag(KubeConfigFlag, "Path to a kubeconfig. Only required if out-of-cluster.").ExistingFile()
 	nodeName := app.Flag(KubeNodeNameFlag, "Name of kubernetes node on which kepler is running.").String()
 
+	// platform
+	platformNodeID := app.Flag(PlatformNodeIDFlag, "Node identifier for platform power monitoring").String()
+	platformRedfishEnabled := app.Flag(PlatformRedfishEnabledFlag, "Enable Redfish BMC power monitoring").Default("false").Bool()
+	platformRedfishConfig := app.Flag(PlatformRedfishConfigFlag, "Path to Redfish BMC configuration file").String()
+
 	return func(cfg *Config) error {
 		// Logging settings
 		if flagsSet[LogLevelFlag] {
@@ -389,6 +419,19 @@ func RegisterFlags(app *kingpin.Application) ConfigUpdaterFn {
 			cfg.Kube.Node = *nodeName
 		}
 
+		// platform settings
+		if flagsSet[PlatformNodeIDFlag] {
+			cfg.Platform.NodeID = *platformNodeID
+		}
+
+		if flagsSet[PlatformRedfishEnabledFlag] {
+			cfg.Platform.Redfish.Enabled = platformRedfishEnabled
+		}
+
+		if flagsSet[PlatformRedfishConfigFlag] {
+			cfg.Platform.Redfish.ConfigFile = *platformRedfishConfig
+		}
+
 		cfg.sanitize()
 		return cfg.Validate()
 	}
@@ -412,6 +455,8 @@ func (c *Config) sanitize() {
 		c.Exporter.Prometheus.DebugCollectors[i] = strings.TrimSpace(c.Exporter.Prometheus.DebugCollectors[i])
 	}
 	c.Kube.Config = strings.TrimSpace(c.Kube.Config)
+	c.Platform.NodeID = strings.TrimSpace(c.Platform.NodeID)
+	c.Platform.Redfish.ConfigFile = strings.TrimSpace(c.Platform.Redfish.ConfigFile)
 }
 
 // Validate checks for configuration errors
@@ -500,6 +545,17 @@ func (c *Config) Validate(skips ...SkipValidation) error {
 			}
 		}
 	}
+	{ // Platform
+		if ptr.Deref(c.Platform.Redfish.Enabled, false) {
+			if c.Platform.Redfish.ConfigFile == "" {
+				errs = append(errs, fmt.Sprintf("%s not supplied but %s set to true", PlatformRedfishConfigFlag, PlatformRedfishEnabledFlag))
+			} else {
+				if err := canReadFile(c.Platform.Redfish.ConfigFile); err != nil {
+					errs = append(errs, fmt.Sprintf("unreadable Redfish config file: %s: %s", c.Platform.Redfish.ConfigFile, err.Error()))
+				}
+			}
+		}
+	}
 
 	if len(errs) > 0 {
 		return fmt.Errorf("invalid configuration: %s", strings.Join(errs, ", "))

go.mod

@@ -14,6 +14,7 @@ require (
 	github.com/prometheus/client_model v0.6.1
 	github.com/prometheus/exporter-toolkit v0.14.0
 	github.com/prometheus/procfs v0.15.1
+	github.com/stmcginnis/gofish v0.15.0
 	github.com/stretchr/testify v1.10.0
 	go.uber.org/zap v1.26.0
 	golang.org/x/sync v0.12.0

go.sum

@@ -135,6 +135,8 @@ github.com/rogpeppe/go-internal v1.12.0 h1:exVL4IDcn6na9z1rAb56Vxr+CgyK3nn3O+epU
 github.com/rogpeppe/go-internal v1.12.0/go.mod h1:E+RYuTGaKKdloAfM02xzb0FW3Paa99yedzYV+kq4uf4=
 github.com/spf13/pflag v1.0.5 h1:iy+VFUOCP1a+8yFto/drg2CJ5u0yRoB7fZw3DKv/JXA=
 github.com/spf13/pflag v1.0.5/go.mod h1:McXfInJRrz4CZXVZOBLb0bTZqETkiAhM9Iw0y3An2Bg=
+github.com/stmcginnis/gofish v0.15.0 h1:8TG41+lvJk/0Nf8CIIYErxbMlQUy80W0JFRZP3Ld82A=
+github.com/stmcginnis/gofish v0.15.0/go.mod h1:BLDSFTp8pDlf/xDbLZa+F7f7eW0E/CHCboggsu8CznI=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=