Add HanaDB monitoring

Makefile

@@ -439,4 +439,4 @@ ci: verify check-license lint build unit-tests #cover
 
 .PHONY: clean
 clean:
-	rm -rf .go bin
+	rm -rf .go bin

apis/catalog/v1alpha1/hanadb_version_helpers.go

@@ -18,7 +18,6 @@ package v1alpha1
 
 import (
 	"fmt"
-	"strings"
 
 	"kubedb.dev/apimachinery/apis"
 	"kubedb.dev/apimachinery/apis/catalog"
@@ -56,11 +55,9 @@ func (h HanaDBVersion) ResourcePlural() string {
 func (h HanaDBVersion) ValidateSpecs() error {
 	if h.Spec.Version == "" ||
 		h.Spec.DB.Image == "" {
-		fields := []string{
-			"spec.version",
-			"spec.db.image",
-		}
-		return fmt.Errorf("atleast one of the following specs is not set for HanaDBVersion %q: %s", h.Name, strings.Join(fields, ", "))
+		return fmt.Errorf(`atleast one of the following specs is not set for HanaDBVersion "%v":
+spec.version,
+spec.db.image,`, h.Name)
 	}
 	return nil
 }

apis/catalog/v1alpha1/hanadb_version_types.go

@@ -49,13 +49,13 @@ type HanaDBVersion struct {
 type HanaDBVersionSpec struct {
 	// Version
 	Version string `json:"version"`
-
-	// EndOfLife refers if this version reached into its end of the life or not, based on https://endoflife.date/
-	// +optional
-	EndOfLife bool `json:"endOfLife"`
-
 	// Database Image
 	DB HanaDatabase `json:"db"`
+	// Coordinator Image
+	// +optional
+	Coordinator HanaDBCoordinator `json:"coordinator,omitempty"`
+	// Exporter Image
+	Exporter HanaDBVersionExporter `json:"exporter"`
 	// Deprecated versions usable but considered as obsolete and best avoided typically superseded
 	Deprecated bool `json:"deprecated,omitempty"`
 	// SecurityContext is for the additional config for the DB container
@@ -78,6 +78,16 @@ type HanaDatabase struct {
 	Image string `json:"image"`
 }
 
+// HanaDBCoordinator is the HanaDB coordinator Container image
+type HanaDBCoordinator struct {
+	Image string `json:"image"`
+}
+
+// HanaDBVersionExporter is the image for the HanaDB exporter
+type HanaDBVersionExporter struct {
+	Image string `json:"image"`
+}
+
 // +k8s:deepcopy-gen:interfaces=k8s.io/apimachinery/pkg/runtime.Object
 
 // HanaDBVersionList is a list of HanaDBVersions

apis/kubedb/constants.go

@@ -2277,6 +2277,9 @@ const (
 	HanaDBSystemDBSQLPortName = "systemdb-sql"
 	HanaDBSystemDBSQLPort     = 39017
 
+	// Metrics exporter port
+	HanaDBExporterPort = 9668
+
 	// Nameserver port for internal communication and system replication
 	HanaDBNameServerPortName = "nameserver"
 	HanaDBNameServerPort     = 39001

apis/kubedb/v1alpha2/hanadb_helpers.go

@@ -274,12 +274,38 @@ func (h *HanaDB) SetDefaults(kc client.Client) {
 			h.Spec.Replicas = pointer.Int32P(1)
 		}
 	}
+	if h.Spec.Topology != nil && h.Spec.Topology.Mode != nil &&
+		*h.Spec.Topology.Mode == HanaDBModeSystemReplication &&
+		h.Spec.Topology.SystemReplication != nil {
+		if h.Spec.Topology.SystemReplication.ReplicationMode == "" {
+			h.Spec.Topology.SystemReplication.ReplicationMode = ReplicationModeSync
+		}
+		if h.Spec.Topology.SystemReplication.OperationMode == "" {
+			h.Spec.Topology.SystemReplication.OperationMode = OperationModeLogReplay
+		}
+	}
 
 	h.setDefaultContainerSecurityContext(&hanadbVersion, h.Spec.PodTemplate)
 
 	h.SetHealthCheckerDefaults()
 
 	h.setDefaultContainerResourceLimits(h.Spec.PodTemplate)
+
+	if h.Spec.Monitor != nil {
+		if h.Spec.Monitor.Prometheus == nil {
+			h.Spec.Monitor.Prometheus = &mona.PrometheusSpec{}
+		}
+		if h.Spec.Monitor.Prometheus.Exporter.Port == 0 {
+			h.Spec.Monitor.Prometheus.Exporter.Port = kubedb.HanaDBExporterPort
+		}
+		h.Spec.Monitor.SetDefaults()
+		if h.Spec.Monitor.Prometheus.Exporter.SecurityContext.RunAsUser == nil {
+			h.Spec.Monitor.Prometheus.Exporter.SecurityContext.RunAsUser = hanadbVersion.Spec.SecurityContext.RunAsUser
+		}
+		if h.Spec.Monitor.Prometheus.Exporter.SecurityContext.RunAsGroup == nil {
+			h.Spec.Monitor.Prometheus.Exporter.SecurityContext.RunAsGroup = hanadbVersion.Spec.SecurityContext.RunAsGroup
+		}
+	}
 }
 
 func (h *HanaDB) setDefaultContainerSecurityContext(hanadbVersion *catalog.HanaDBVersion, podTemplate *ofst.PodTemplateSpec) {

apis/kubedb/v1alpha2/hanadb_types.go

@@ -20,6 +20,7 @@ import (
 	core "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	kmapi "kmodules.xyz/client-go/api/v1"
+	mona "kmodules.xyz/monitoring-agent-api/api/v1"
 	ofst "kmodules.xyz/offshoot-api/api/v2"
 )
 
@@ -30,6 +31,24 @@ const (
 	ResourcePluralHanaDB   = "hanadbs"
 )
 
+// +kubebuilder:validation:Enum=sync;syncmem;async
+type ReplicationMode string
+
+const (
+	ReplicationModeSync    ReplicationMode = "sync"
+	ReplicationModeSyncMem ReplicationMode = "syncmem"
+	ReplicationModeAsync   ReplicationMode = "async"
+)
+
+// +kubebuilder:validation:Enum=logreplay;delta_datashipping;logreplay_readaccess
+type OperationMode string
+
+const (
+	OperationModeLogReplay           OperationMode = "logreplay"
+	OperationModeDeltaDataShipping   OperationMode = "delta_datashipping"
+	OperationModeLogReplayReadAccess OperationMode = "logreplay_readaccess"
+)
+
 // +kubebuilder:validation:Enum=Standalone;SystemReplication
 type HanaDBMode string
 
@@ -92,6 +111,10 @@ type HanaDBSpec struct {
 	// +optional
 	Configuration *ConfigurationSpec `json:"configuration,omitempty"`
 
+	// Monitor is used monitor database instance
+	// +optional
+	Monitor *mona.AgentSpec `json:"monitor,omitempty"`
+
 	// PodTemplate is an optional configuration for pods used to expose database
 	// +optional
 	PodTemplate *ofst.PodTemplateSpec `json:"podTemplate,omitempty"`
@@ -115,6 +138,23 @@ type HanaDBTopology struct {
 	// Mode specifies the deployment mode.
 	// +optional
 	Mode *HanaDBMode `json:"mode,omitempty"`
+
+	// SystemReplication defines configuration for SAP HANA system replication.
+	// +optional
+	SystemReplication *HanaDBSystemReplicationSpec `json:"systemReplication,omitempty"`
+}
+
+// HanaDBSystemReplicationSpec defines system replication configuration.
+type HanaDBSystemReplicationSpec struct {
+	// ReplicationMode controls when transactions are committed relative to log shipping.
+	// +optional
+	// +kubebuilder:default=sync
+	ReplicationMode ReplicationMode `json:"replicationMode,omitempty"`
+
+	// OperationMode controls the log shipping/replay strategy on the secondary.
+	// +optional
+	// +kubebuilder:default=logreplay
+	OperationMode OperationMode `json:"operationMode,omitempty"`
 }
 
 // HanaDBStatus defines the observed state of HanaDB.