api: add v1beta1 conversion and types for operatorconfig

Signed-off-by: Niraj Yadav <niryadav@redhat.com>

Author: black-dragon74

PROJECT

@@ -104,4 +104,17 @@ resources:
     spoke:
     - v1alpha1
     webhookVersion: v1
+- api:
+    crdVersion: v1
+    namespaced: true
+  domain: ceph.io
+  group: csi
+  kind: OperatorConfig
+  path: github.com/ceph/ceph-csi-operator/api/csi/v1beta1
+  version: v1beta1
+  webhooks:
+    conversion: true
+    spoke:
+    - v1alpha1
+    webhookVersion: v1
 version: "3"

api/csi/v1alpha1/operatorconfig_conversion.go

@@ -0,0 +1,65 @@
+/*
+Copyright 2024.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1alpha1
+
+import (
+	"errors"
+	"log"
+
+	"sigs.k8s.io/controller-runtime/pkg/conversion"
+
+	csiv1beta1 "github.com/ceph/ceph-csi-operator/api/csi/v1beta1"
+)
+
+// ConvertTo converts this OperatorConfig (v1alpha1) to the Hub version (v1beta1).
+func (src *OperatorConfig) ConvertTo(dstRaw conversion.Hub) error {
+	dst, ok := dstRaw.(*csiv1beta1.OperatorConfig)
+	if !ok {
+		return errors.New("convertto: failed to cast to v1beta1 OperatorConfig")
+	}
+
+	log.Printf("ConvertTo: Converting OperatorConfig from Spoke version v1alpha1 to Hub version v1beta1;"+
+		"source: %s/%s, target: %s/%s", src.Namespace, src.Name, dst.Namespace, dst.Name)
+
+	dst.ObjectMeta = src.ObjectMeta
+
+	if src.Spec.DriverSpecDefaults != nil {
+		cSpec := ConvertAlphaDriverToBeta(*src.Spec.DriverSpecDefaults)
+		dst.Spec.DriverSpecDefaults = &cSpec
+	}
+
+	return nil
+}
+
+// ConvertFrom converts the Hub version (v1beta1) to this OperatorConfig (v1alpha1).
+func (dst *OperatorConfig) ConvertFrom(srcRaw conversion.Hub) error {
+	src, ok := srcRaw.(*csiv1beta1.OperatorConfig)
+	if !ok {
+		return errors.New("convertto: failed to cast to v1beta1 OperatorConfig")
+	}
+
+	log.Printf("ConvertFrom: Converting OperatorConfig from Hub version v1beta1 to Spoke version v1alpha1;"+
+		"source: %s/%s, target: %s/%s", src.Namespace, src.Name, dst.Namespace, dst.Name)
+
+	dst.ObjectMeta = src.ObjectMeta
+
+	if src.Spec.DriverSpecDefaults != nil {
+		cSpec := ConvertBetaDriverToAlpha(*src.Spec.DriverSpecDefaults)
+		dst.Spec.DriverSpecDefaults = &cSpec
+	}
+	return nil
+}

api/csi/v1beta1/groupversion_info.go

@@ -44,6 +44,7 @@ func addKnownTypes(scheme *runtime.Scheme) error {
 		&ClientProfile{}, &ClientProfileList{},
 		&ClientProfileMapping{}, &ClientProfileMappingList{},
 		&Driver{}, &DriverList{},
+		&OperatorConfig{}, &OperatorConfigList{},
 	)
 	metav1.AddToGroupVersion(scheme, GroupVersion)
 	return nil

api/csi/v1beta1/operatorconfig_conversion.go

@@ -0,0 +1,22 @@
+/*
+Copyright 2024.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1beta1
+
+// EDIT THIS FILE!  THIS IS SCAFFOLDING FOR YOU TO OWN!
+
+// Hub marks this type as a conversion hub.
+func (*OperatorConfig) Hub() {}

api/csi/v1beta1/operatorconfig_types.go

@@ -0,0 +1,67 @@
+/*
+Copyright 2024.
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.
+*/
+
+package v1beta1
+
+import (
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+// OperatorLogSpec provide log related settings for the operator
+type OperatorLogSpec struct {
+	// Operator's log level
+	// +kubebuilder:validation:Optional
+	// +kubebuilder:validation:Minimum=0
+	// +kubebuilder:validation:Maximum=3
+	Verbosity int `json:"verbosity,omitempty"`
+}
+
+// OperatorConfigSpec defines the desired state of OperatorConfig
+type OperatorConfigSpec struct {
+	// +kubebuilder:validation:Optional
+	Log *OperatorLogSpec `json:"log,omitempty"`
+
+	// Allow overwrite of hardcoded defaults for any driver managed by this operator
+	// +kubebuilder:validation:Optional
+	DriverSpecDefaults *DriverSpec `json:"driverSpecDefaults,omitempty"`
+}
+
+// OperatorConfigStatus defines the observed state of OperatorConfig
+type OperatorConfigStatus struct {
+}
+
+// +kubebuilder:object:root=true
+// +kubebuilder:storageversion
+// +kubebuilder:conversion:hub
+// +kubebuilder:subresource:status
+
+// OperatorConfig is the Schema for the operatorconfigs API
+type OperatorConfig struct {
+	metav1.TypeMeta   `json:",inline"`
+	metav1.ObjectMeta `json:"metadata,omitempty"`
+
+	Spec   OperatorConfigSpec   `json:"spec,omitempty"`
+	Status OperatorConfigStatus `json:"status,omitempty"`
+}
+
+// +kubebuilder:object:root=true
+
+// OperatorConfigList contains a list of OperatorConfig
+type OperatorConfigList struct {
+	metav1.TypeMeta `json:",inline"`
+	metav1.ListMeta `json:"metadata,omitempty"`
+	Items           []OperatorConfig `json:"items"`
+}

api/csi/v1beta1/zz_generated.deepcopy.go

@@ -274,6 +274,13 @@ func main() {
 			os.Exit(1)
 		}
 	}
+	// nolint:goconst
+	if os.Getenv("ENABLE_WEBHOOKS") != "false" {
+		if err = webhookcsiv1beta1.SetupOperatorConfigWebhookWithManager(mgr); err != nil {
+			setupLog.Error(err, "unable to create webhook", "webhook", "OperatorConfig")
+			os.Exit(1)
+		}
+	}
 	//+kubebuilder:scaffold:builder
 
 	if metricsCertWatcher != nil {