Update dbapi type TerminationPolicy -> DeletionPolicy

Signed-off-by: Neaj Morshad <neaj@appscode.com>
kubedb · Nov 11, 2024 · 469497e · 469497e
1 parent 7aba590
commit 469497e
Show file tree

Hide file tree

Showing 60 changed files with 91 additions and 105 deletions.
diff --git a/apis/kubedb/v1alpha1/conversion.go b/apis/kubedb/v1alpha1/conversion.go
@@ -134,7 +134,7 @@ func Convert_v1alpha1_ElasticsearchSpec_To_v1alpha2_ElasticsearchSpec(in *Elasti
 	}
 	out.MaxUnavailable = (*intstr.IntOrString)(unsafe.Pointer(in.MaxUnavailable))
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -280,7 +280,7 @@ func Convert_v1alpha1_EtcdSpec_To_v1alpha2_EtcdSpec(in *EtcdSpec, out *v1alpha2.
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.DeletionPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.DeletionPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -365,7 +365,7 @@ func Convert_v1alpha1_MariaDBSpec_To_v1alpha2_MariaDBSpec(in *MariaDBSpec, out *
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -434,7 +434,7 @@ func Convert_v1alpha1_MemcachedSpec_To_v1alpha2_MemcachedSpec(in *MemcachedSpec,
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -537,7 +537,7 @@ func Convert_v1alpha1_MongoDBSpec_To_v1alpha2_MongoDBSpec(in *MongoDBSpec, out *
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -722,7 +722,7 @@ func Convert_v1alpha1_MySQLSpec_To_v1alpha2_MySQLSpec(in *MySQLSpec, out *v1alph
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -834,7 +834,7 @@ func Convert_v1alpha1_PerconaXtraDBSpec_To_v1alpha2_PerconaXtraDBSpec(in *Percon
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -932,7 +932,7 @@ func Convert_v1alpha1_PostgresSpec_To_v1alpha2_PostgresSpec(in *PostgresSpec, ou
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 
@@ -1005,7 +1005,7 @@ func Convert_v1alpha1_RedisSpec_To_v1alpha2_RedisSpec(in *RedisSpec, out *v1alph
 		})
 	}
 	// WARNING: in.UpdateStrategy requires manual conversion: does not exist in peer-type
-	out.TerminationPolicy = v1alpha2.TerminationPolicy(in.TerminationPolicy)
+	out.TerminationPolicy = v1alpha2.DeletionPolicy(in.TerminationPolicy)
 	return nil
 }
 

diff --git a/apis/kubedb/v1alpha2/cassandra_helpers.go b/apis/kubedb/v1alpha2/cassandra_helpers.go
@@ -269,7 +269,7 @@ func (r *Cassandra) ResourceSingular() string {
 
 func (r *Cassandra) SetDefaults() {
 	if r.Spec.DeletionPolicy == "" {
-		r.Spec.DeletionPolicy = TerminationPolicyDelete
+		r.Spec.DeletionPolicy = DeletionPolicyDelete
 	}
 
 	var casVersion catalog.CassandraVersion

diff --git a/apis/kubedb/v1alpha2/cassandra_types.go b/apis/kubedb/v1alpha2/cassandra_types.go
@@ -97,7 +97,7 @@ type CassandraSpec struct {
 
 	// DeletionPolicy controls the delete operation for database
 	// +optional
-	DeletionPolicy TerminationPolicy `json:"deletionPolicy,omitempty"`
+	DeletionPolicy DeletionPolicy `json:"deletionPolicy,omitempty"`
 
 	// HealthChecker defines attributes of the health checker
 	// +optional

diff --git a/apis/kubedb/v1alpha2/cassandra_webhook.go b/apis/kubedb/v1alpha2/cassandra_webhook.go
@@ -69,7 +69,7 @@ func (r *Cassandra) ValidateDelete() (admission.Warnings, error) {
 	cassandralog.Info("validate delete", "name", r.Name)
 
 	var allErr field.ErrorList
-	if r.Spec.DeletionPolicy == TerminationPolicyDoNotTerminate {
+	if r.Spec.DeletionPolicy == DeletionPolicyDoNotTerminate {
 		allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("deletionPolicy"),
 			r.Name,
 			"Can not delete as terminationPolicy is set to \"DoNotTerminate\""))

diff --git a/apis/kubedb/v1alpha2/clickhouse_helpers.go b/apis/kubedb/v1alpha2/clickhouse_helpers.go
@@ -370,7 +370,7 @@ func (c *ClickHouse) SetDefaults() {
 			c.Spec.Replicas = pointer.Int32P(1)
 		}
 		if c.Spec.DeletionPolicy == "" {
-			c.Spec.DeletionPolicy = TerminationPolicyDelete
+			c.Spec.DeletionPolicy = DeletionPolicyDelete
 		}
 		if c.Spec.StorageType == "" {
 			c.Spec.StorageType = StorageTypeDurable

diff --git a/apis/kubedb/v1alpha2/clickhouse_types.go b/apis/kubedb/v1alpha2/clickhouse_types.go
@@ -101,7 +101,7 @@ type ClickHouseSpec struct {
 
 	// DeletionPolicy controls the delete operation for database
 	// +optional
-	DeletionPolicy TerminationPolicy `json:"deletionPolicy,omitempty"`
+	DeletionPolicy DeletionPolicy `json:"deletionPolicy,omitempty"`
 
 	// HealthChecker defines attributes of the health checker
 	// +optional

diff --git a/apis/kubedb/v1alpha2/clickhouse_webhook.go b/apis/kubedb/v1alpha2/clickhouse_webhook.go
@@ -69,7 +69,7 @@ func (c *ClickHouse) ValidateDelete() (admission.Warnings, error) {
 	clickhouselog.Info("validate delete", "name", c.Name)
 
 	var allErr field.ErrorList
-	if c.Spec.DeletionPolicy == TerminationPolicyDoNotTerminate {
+	if c.Spec.DeletionPolicy == DeletionPolicyDoNotTerminate {
 		allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("teminationPolicy"),
 			c.Name,
 			"Can not delete as terminationPolicy is set to \"DoNotTerminate\""))

diff --git a/apis/kubedb/v1alpha2/conversion.go b/apis/kubedb/v1alpha2/conversion.go
@@ -183,7 +183,7 @@ func Convert_v1_MariaDBSpec_To_v1alpha2_MariaDBSpec(in *v1.MariaDBSpec, out *Mar
 	out.RequireSSL = in.RequireSSL
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.AllowedSchemas = (*AllowedConsumers)(unsafe.Pointer(in.AllowedSchemas))
 	out.HealthChecker = in.HealthChecker
 	out.Archiver = (*Archiver)(unsafe.Pointer(in.Archiver))
@@ -264,7 +264,7 @@ func Convert_v1_PostgresSpec_To_v1alpha2_PostgresSpec(in *v1.PostgresSpec, out *
 	out.ServiceTemplates = *(*[]NamedServiceTemplateSpec)(unsafe.Pointer(&in.ServiceTemplates))
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.EnforceFsGroup = in.EnforceFsGroup
 	out.AllowedSchemas = (*AllowedConsumers)(unsafe.Pointer(in.AllowedSchemas))
 	out.HealthChecker = in.HealthChecker
@@ -369,7 +369,7 @@ func Convert_v1_MySQLSpec_To_v1alpha2_MySQLSpec(in *v1.MySQLSpec, out *MySQLSpec
 	out.RequireSSL = in.RequireSSL
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.UseAddressType = AddressType(in.UseAddressType)
 	out.AllowedSchemas = (*AllowedConsumers)(unsafe.Pointer(in.AllowedSchemas))
 	out.AllowedReadReplicas = (*AllowedConsumers)(unsafe.Pointer(in.AllowedReadReplicas))
@@ -611,7 +611,7 @@ func Convert_v1_MongoDBSpec_To_v1alpha2_MongoDBSpec(in *v1.MongoDBSpec, out *Mon
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
 	out.KeyFileSecret = (*corev1.LocalObjectReference)(unsafe.Pointer(in.KeyFileSecret))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.StorageEngine = StorageEngine(in.StorageEngine)
 	out.AllowedSchemas = (*AllowedConsumers)(unsafe.Pointer(in.AllowedSchemas))
 	if in.Arbiter != nil {
@@ -761,7 +761,7 @@ func Convert_v1_RedisSpec_To_v1alpha2_RedisSpec(in *v1.RedisSpec, out *RedisSpec
 	out.ServiceTemplates = *(*[]NamedServiceTemplateSpec)(unsafe.Pointer(&in.ServiceTemplates))
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.AllowedSchemas = (*AllowedConsumers)(unsafe.Pointer(in.AllowedSchemas))
 	out.HealthChecker = in.HealthChecker
 	return nil
@@ -829,7 +829,7 @@ func Convert_v1_PerconaXtraDBSpec_To_v1alpha2_PerconaXtraDBSpec(in *v1.PerconaXt
 	out.RequireSSL = in.RequireSSL
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.AllowedSchemas = (*AllowedConsumers)(unsafe.Pointer(in.AllowedSchemas))
 	out.HealthChecker = in.HealthChecker
 	out.SystemUserSecrets = (*SystemUserSecretsSpec)(unsafe.Pointer(in.SystemUserSecrets))
@@ -958,7 +958,7 @@ func Convert_v1_ElasticsearchSpec_To_v1alpha2_ElasticsearchSpec(in *v1.Elasticse
 	out.InternalUsers = *(*map[string]ElasticsearchUserSpec)(unsafe.Pointer(&in.InternalUsers))
 	out.RolesMapping = *(*map[string]ElasticsearchRoleMapSpec)(unsafe.Pointer(&in.RolesMapping))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.KernelSettings = (*KernelSettings)(unsafe.Pointer(in.KernelSettings))
 	out.HeapSizePercentage = (*int32)(unsafe.Pointer(in.HeapSizePercentage))
 	out.HealthChecker = in.HealthChecker
@@ -977,7 +977,7 @@ func Convert_v1_MemcachedSpec_To_v1alpha2_MemcachedSpec(in *v1.MemcachedSpec, ou
 	out.ServiceTemplates = *(*[]NamedServiceTemplateSpec)(unsafe.Pointer(&in.ServiceTemplates))
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
 	out.Halted = in.Halted
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.HealthChecker = in.HealthChecker
 	return nil
 }
@@ -1025,7 +1025,7 @@ func Convert_v1_PgBouncerSpec_To_v1alpha2_PgBouncerSpec(in *v1.PgBouncerSpec, ou
 	out.Monitor = (*monitoringagentapiapiv1.AgentSpec)(unsafe.Pointer(in.Monitor))
 	out.SSLMode = PgBouncerSSLMode(in.SSLMode)
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
-	out.TerminationPolicy = PgBouncerTerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.HealthChecker = in.HealthChecker
 	return nil
 }
@@ -1069,7 +1069,7 @@ func Convert_v1_ProxySQLSpec_To_v1alpha2_ProxySQLSpec(in *v1.ProxySQLSpec, out *
 	}
 	out.ServiceTemplates = *(*[]NamedServiceTemplateSpec)(unsafe.Pointer(&in.ServiceTemplates))
 	out.TLS = (*clientgoapiv1.TLSConfig)(unsafe.Pointer(in.TLS))
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.HealthChecker = in.HealthChecker
 	return nil
 }
@@ -1113,7 +1113,7 @@ func Convert_v1_RedisSentinelSpec_To_v1alpha2_RedisSentinelSpec(in *v1.RedisSent
 	out.DisableAuth = in.DisableAuth
 	out.Halted = in.Halted
 	out.Monitor = (*monitoringagentapiapiv1.AgentSpec)(unsafe.Pointer(in.Monitor))
-	out.TerminationPolicy = TerminationPolicy(in.DeletionPolicy)
+	out.TerminationPolicy = DeletionPolicy(in.DeletionPolicy)
 	out.HealthChecker = in.HealthChecker
 	return nil
 }

diff --git a/apis/kubedb/v1alpha2/druid_helpers.go b/apis/kubedb/v1alpha2/druid_helpers.go
@@ -431,7 +431,7 @@ func (d *Druid) GetCertSecretName(alias DruidCertificateAlias) string {
 
 func (d *Druid) SetDefaults() {
 	if d.Spec.DeletionPolicy == "" {
-		d.Spec.DeletionPolicy = TerminationPolicyDelete
+		d.Spec.DeletionPolicy = DeletionPolicyDelete
 	}
 
 	if d.Spec.EnableSSL {

diff --git a/apis/kubedb/v1alpha2/druid_types.go b/apis/kubedb/v1alpha2/druid_types.go
@@ -115,7 +115,7 @@ type DruidSpec struct {
 
 	// DeletionPolicy controls the delete operation for database
 	// +optional
-	DeletionPolicy TerminationPolicy `json:"deletionPolicy,omitempty"`
+	DeletionPolicy DeletionPolicy `json:"deletionPolicy,omitempty"`
 
 	// HealthChecker defines attributes of the health checker
 	// +optional

diff --git a/apis/kubedb/v1alpha2/elasticsearch_helpers.go b/apis/kubedb/v1alpha2/elasticsearch_helpers.go
@@ -436,7 +436,7 @@ func (e *Elasticsearch) SetDefaults(esVersion *catalog.ElasticsearchVersion, top
 	}
 
 	if e.Spec.TerminationPolicy == "" {
-		e.Spec.TerminationPolicy = TerminationPolicyDelete
+		e.Spec.TerminationPolicy = DeletionPolicyDelete
 	}
 
 	if e.Spec.PodTemplate.Spec.ServiceAccountName == "" {

diff --git a/apis/kubedb/v1alpha2/elasticsearch_types.go b/apis/kubedb/v1alpha2/elasticsearch_types.go
@@ -156,7 +156,7 @@ type ElasticsearchSpec struct {
 
 	// TerminationPolicy controls the delete operation for database
 	// +optional
-	TerminationPolicy TerminationPolicy `json:"terminationPolicy,omitempty"`
+	TerminationPolicy DeletionPolicy `json:"terminationPolicy,omitempty"`
 
 	// KernelSettings contains the additional kernel settings.
 	// +optional

diff --git a/apis/kubedb/v1alpha2/etcd_helpers.go b/apis/kubedb/v1alpha2/etcd_helpers.go
@@ -182,7 +182,7 @@ func (e *Etcd) SetDefaults() {
 		e.Spec.StorageType = StorageTypeDurable
 	}
 	if e.Spec.DeletionPolicy == "" {
-		e.Spec.DeletionPolicy = TerminationPolicyDelete
+		e.Spec.DeletionPolicy = DeletionPolicyDelete
 	}
 
 	e.Spec.Monitor.SetDefaults()

diff --git a/apis/kubedb/v1alpha2/etcd_types.go b/apis/kubedb/v1alpha2/etcd_types.go
@@ -92,7 +92,7 @@ type EtcdSpec struct {
 
 	// DeletionPolicy controls the delete operation for database
 	// +optional
-	DeletionPolicy TerminationPolicy `json:"deletionPolicy,omitempty"`
+	DeletionPolicy DeletionPolicy `json:"deletionPolicy,omitempty"`
 }
 
 type TLSPolicy struct {

diff --git a/apis/kubedb/v1alpha2/ferretdb_helpers.go b/apis/kubedb/v1alpha2/ferretdb_helpers.go
@@ -181,7 +181,7 @@ func (f *FerretDB) SetDefaults() {
 	}
 
 	if f.Spec.DeletionPolicy == "" {
-		f.Spec.DeletionPolicy = TerminationPolicyWipeOut
+		f.Spec.DeletionPolicy = DeletionPolicyWipeOut
 	}
 
 	if f.Spec.SSLMode == "" {

diff --git a/apis/kubedb/v1alpha2/ferretdb_types.go b/apis/kubedb/v1alpha2/ferretdb_types.go
@@ -92,7 +92,7 @@ type FerretDBSpec struct {
 
 	// DeletionPolicy controls the delete operation for database
 	// +optional
-	DeletionPolicy TerminationPolicy `json:"deletionPolicy,omitempty"`
+	DeletionPolicy DeletionPolicy `json:"deletionPolicy,omitempty"`
 
 	// HealthChecker defines attributes of the health checker
 	// +optional

diff --git a/apis/kubedb/v1alpha2/ferretdb_webhook.go b/apis/kubedb/v1alpha2/ferretdb_webhook.go
@@ -92,7 +92,7 @@ func (f *FerretDB) ValidateDelete() (admission.Warnings, error) {
 	ferretdblog.Info("validate delete", "name", f.Name)
 
 	var allErr field.ErrorList
-	if f.Spec.DeletionPolicy == TerminationPolicyDoNotTerminate {
+	if f.Spec.DeletionPolicy == DeletionPolicyDoNotTerminate {
 		allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("terminationPolicy"),
 			f.Name,
 			"Can not delete as terminationPolicy is set to \"DoNotTerminate\""))
@@ -154,7 +154,7 @@ func (f *FerretDB) ValidateCreateOrUpdate() field.ErrorList {
 	}
 
 	// Termination policy related
-	if f.Spec.DeletionPolicy == TerminationPolicyHalt {
+	if f.Spec.DeletionPolicy == DeletionPolicyHalt {
 		allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("terminationPolicy"),
 			f.Name,
 			`'spec.terminationPolicy' value 'Halt' is not supported yet for FerretDB`))

diff --git a/apis/kubedb/v1alpha2/kafka_helpers.go b/apis/kubedb/v1alpha2/kafka_helpers.go
@@ -300,15 +300,15 @@ func (k *Kafka) SetHealthCheckerDefaults() {
 
 func (k *Kafka) SetDefaults() {
 	if k.Spec.Halted {
-		if k.Spec.DeletionPolicy == TerminationPolicyDoNotTerminate {
+		if k.Spec.DeletionPolicy == DeletionPolicyDoNotTerminate {
 			klog.Errorf(`Can't halt, since deletion policy is 'DoNotTerminate'`)
 			return
 		}
-		k.Spec.DeletionPolicy = TerminationPolicyHalt
+		k.Spec.DeletionPolicy = DeletionPolicyHalt
 	}
 
 	if k.Spec.DeletionPolicy == "" {
-		k.Spec.DeletionPolicy = TerminationPolicyDelete
+		k.Spec.DeletionPolicy = DeletionPolicyDelete
 	}
 
 	if k.Spec.StorageType == "" {

diff --git a/apis/kubedb/v1alpha2/kafka_types.go b/apis/kubedb/v1alpha2/kafka_types.go
@@ -110,7 +110,7 @@ type KafkaSpec struct {
 
 	// DeletionPolicy controls the delete operation for database
 	// +optional
-	DeletionPolicy TerminationPolicy `json:"deletionPolicy,omitempty"`
+	DeletionPolicy DeletionPolicy `json:"deletionPolicy,omitempty"`
 
 	// HealthChecker defines attributes of the health checker
 	// +optional

diff --git a/apis/kubedb/v1alpha2/kafka_webhook.go b/apis/kubedb/v1alpha2/kafka_webhook.go
@@ -81,7 +81,7 @@ func (k *Kafka) ValidateDelete() (admission.Warnings, error) {
 
 	// TODO(user): fill in your validation logic upon object deletion.
 	var allErr field.ErrorList
-	if k.Spec.DeletionPolicy == TerminationPolicyDoNotTerminate {
+	if k.Spec.DeletionPolicy == DeletionPolicyDoNotTerminate {
 		allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("teminationPolicy"),
 			k.Name,
 			"Can not delete as terminationPolicy is set to \"DoNotTerminate\""))
@@ -170,7 +170,7 @@ func (k *Kafka) ValidateCreateOrUpdate() error {
 		}
 	}
 
-	if k.Spec.Halted && k.Spec.DeletionPolicy == TerminationPolicyDoNotTerminate {
+	if k.Spec.Halted && k.Spec.DeletionPolicy == DeletionPolicyDoNotTerminate {
 		allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("halted"),
 			k.Name,
 			`can't halt if deletionPolicy is set to "DoNotTerminate"`))
@@ -207,7 +207,7 @@ func (k *Kafka) ValidateCreateOrUpdate() error {
 				k.Name,
 				"StorageType should be either durable or ephemeral"))
 		}
-		if k.Spec.StorageType == StorageTypeEphemeral && k.Spec.DeletionPolicy == TerminationPolicyHalt {
+		if k.Spec.StorageType == StorageTypeEphemeral && k.Spec.DeletionPolicy == DeletionPolicyHalt {
 			allErr = append(allErr, field.Invalid(field.NewPath("spec").Child("deletionPolicy"),
 				k.Name,
 				`'spec.deletionPolicy: Halt' can not be used for 'Ephemeral' storage`))

diff --git a/apis/kubedb/v1alpha2/mariadb_helpers.go b/apis/kubedb/v1alpha2/mariadb_helpers.go
@@ -210,7 +210,7 @@ func (m *MariaDB) SetDefaults(mdVersion *v1alpha1.MariaDBVersion, topology *core
 		m.Spec.StorageType = StorageTypeDurable
 	}
 	if m.Spec.TerminationPolicy == "" {
-		m.Spec.TerminationPolicy = TerminationPolicyDelete
+		m.Spec.TerminationPolicy = DeletionPolicyDelete
 	}
 
 	if m.Spec.PodTemplate.Spec.ServiceAccountName == "" {

diff --git a/apis/kubedb/v1alpha2/mariadb_types.go b/apis/kubedb/v1alpha2/mariadb_types.go
@@ -111,7 +111,7 @@ type MariaDBSpec struct {
 
 	// TerminationPolicy controls the delete operation for database
 	// +optional
-	TerminationPolicy TerminationPolicy `json:"terminationPolicy,omitempty"`
+	TerminationPolicy DeletionPolicy `json:"terminationPolicy,omitempty"`
 
 	// Coordinator defines attributes of the coordinator container
 	// +optional