Add SystemReplication Spec

Signed-off-by: ZobayerAbedin <[email protected]>

Author: ZobayerAbedin

apis/catalog/v1alpha1/hanadb_version_helpers.go

@@ -26,7 +26,7 @@ import (
 	"kmodules.xyz/client-go/apiextensions"
 )
 
-func (_ HanaDBVersion) CustomResourceDefinition() *apiextensions.CustomResourceDefinition {
+func (HanaDBVersion) CustomResourceDefinition() *apiextensions.CustomResourceDefinition {
 	return crds.MustCustomResourceDefinition(SchemeGroupVersion.WithResource(ResourcePluralHanaDBVersion))
 }
 

apis/kubedb/constants.go

@@ -2285,79 +2285,3 @@ const (
 	// TenantDatabaseName is the name of the KubeDB managed tenant database
 	KubeDBTenantDatabaseName = "KUBEDB_HEALTH_CHECK"
 )
-
-// =========================== Qdrant Constants ============================
-const (
-	QdrantContainerName = "qdrant"
-
-	QdrantHTTPPortName = "http"
-	QdrantHTTPPort     = 6333
-	QdrantGRPCPortName = "grpc"
-	QdrantGRPCPort     = 6334
-	QdrantP2PPortName  = "p2p"
-	QdrantP2PPort      = 6335
-
-	QdrantDataVolName   = "data"
-	QdrantDataDir       = "/qdrant/storage"
-	QdrantConfigVolName = "qdrant-config"
-	QdrantConfigDir     = "/qdrant/config"
-
-	QdrantConfigFileName = "config.yaml"
-
-	QdrantAPIKey         = "api-key"
-	QdrantReadOnlyAPIKey = "read-only-api-key"
-)
-
-// =========================== HanaDB Constants ============================
-const (
-	HanaDBVolumeScripts = "hanadb-scripts"
-
-	HanaDBVolumeMountScripts = "/scripts"
-
-	// Container names
-	HanaDBContainerName            = "hanadb"
-	HanaDBCoordinatorContainerName = "hanadb-coordinator"
-
-	// Mount paths
-	HanaDBDataDir         = "/hana/mounts"
-	HanaDBSecretMountPath = "/etc/hana-secrets"
-
-	// Volume names
-	HanaDBDataVolume           = "data"
-	HanaDBVolumePasswordSecret = "password-secret"
-
-	// User and Group IDs
-	HanaDBUserID  = 12000 // hxeadm UID
-	HanaDBGroupID = 79    // hxeadm GID
-
-	// Health check schema and table
-	HanaDBHealthCheckSchemaName = "KUBEDB_SYSTEM"
-	HanaDBHealthCheckTableName  = "KUBEDB_WRITE_CHECK"
-
-	// Auth secret
-	HanaDBSystemUser        = "SYSTEM"
-	HanaDBPasswordFileKey   = "password.json"
-	HanaDBMasterPasswordKey = "master_password"
-
-	// Main SYSTEMDB SQL connection port, Used by health checks and administrative operations
-	HanaDBSystemDBSQLPortName = "systemdb-sql"
-	HanaDBSystemDBSQLPort     = 39017
-
-	// Nameserver port for internal communication and system replication
-	HanaDBNameServerPortName = "nameserver"
-	HanaDBNameServerPort     = 39001
-
-	// SYSTEMDB SQL mapping port - used internally for routing
-	HanaDBSystemDBMappingPortName = "systemdb-map"
-	HanaDBSystemDBMappingPort     = 39013
-
-	HanaDBPrimaryServicePortName = "primary"
-
-	HanaDBCoordinatorPort           = 2380
-	HanaDBCoordinatorClientPort     = 2379
-	HanaDBCoordinatorPortName       = "coordinator"
-	HanaDBCoordinatorClientPortName = "coordinator-client"
-
-	// TenantDatabaseName is the name of the KubeDB managed tenant database
-	KubeDBTenantDatabaseName = "KUBEDB_HEALTH_CHECK"
-)

apis/kubedb/v1alpha2/hanadb_helpers.go

@@ -36,16 +36,14 @@ import (
 	coreutil "kmodules.xyz/client-go/core/v1"
 	metautil "kmodules.xyz/client-go/meta"
 	"kmodules.xyz/client-go/policy/secomp"
-	_ "kmodules.xyz/custom-resources/apis/appcatalog/v1alpha1"
 	appcat "kmodules.xyz/custom-resources/apis/appcatalog/v1alpha1"
 	mona "kmodules.xyz/monitoring-agent-api/api/v1"
 	ofst "kmodules.xyz/offshoot-api/api/v2"
 	pslister "kubeops.dev/petset/client/listers/apps/v1"
 	"sigs.k8s.io/controller-runtime/pkg/client"
-	_ "sigs.k8s.io/controller-runtime/pkg/client"
 )
 
-func (_ HanaDB) CustomResourceDefinition() *apiextensions.CustomResourceDefinition {
+func (HanaDB) CustomResourceDefinition() *apiextensions.CustomResourceDefinition {
 	return crds.MustCustomResourceDefinition(SchemeGroupVersion.WithResource(ResourcePluralHanaDB))
 }
 
@@ -274,6 +272,16 @@ 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)
 

apis/kubedb/v1alpha2/hanadb_types.go

@@ -134,6 +134,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.