-
Notifications
You must be signed in to change notification settings - Fork 19
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add ManagedClusterView controller and create or update ClientInfo
- Added initialization for ManagedClusterViewReconciler in manager.go to setup the ManagedClusterView controller. - Creates or updates configMap odf-client-info which maps client to it provider cluster - Created comprehensive unit tests to cover the creation and update scenarios of the ConfigMap. Signed-off-by: vbadrina <[email protected]>
- Loading branch information
Showing
7 changed files
with
406 additions
and
11 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,199 @@ | ||
| package controllers | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "fmt" | ||
| "log/slog" | ||
| "os" | ||
|
|
||
| ocsv1alpha1 "github.com/red-hat-storage/ocs-operator/api/v4/v1alpha1" | ||
| "github.com/red-hat-storage/odf-multicluster-orchestrator/controllers/utils" | ||
| viewv1beta1 "github.com/stolostron/multicloud-operators-foundation/pkg/apis/view/v1beta1" | ||
| corev1 "k8s.io/api/core/v1" | ||
| "k8s.io/apimachinery/pkg/api/errors" | ||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| "k8s.io/apimachinery/pkg/types" | ||
| ctrl "sigs.k8s.io/controller-runtime" | ||
| "sigs.k8s.io/controller-runtime/pkg/builder" | ||
| "sigs.k8s.io/controller-runtime/pkg/client" | ||
| "sigs.k8s.io/controller-runtime/pkg/controller/controllerutil" | ||
| "sigs.k8s.io/controller-runtime/pkg/event" | ||
| "sigs.k8s.io/controller-runtime/pkg/predicate" | ||
| "sigs.k8s.io/controller-runtime/pkg/reconcile" | ||
| "sigs.k8s.io/yaml" | ||
| ) | ||
|
|
||
| type ManagedClusterViewReconciler struct { | ||
| Client client.Client | ||
| Logger *slog.Logger | ||
| } | ||
|
|
||
| const ( | ||
| ODFInfoConfigMapName = "odf-info" | ||
| ConfigMapResourceType = "ConfigMap" | ||
| ClientInfoConfigMapName = "odf-client-info" | ||
| ) | ||
|
|
||
| type ProviderInfo struct { | ||
| Version string `json:"version"` | ||
| DeploymentType string `json:"deploymentType"` | ||
| StorageSystemName string `json:"storageSystemName"` | ||
| ProviderManagedClusterName string `json:"providerManagedClusterName"` | ||
| NamespacedName types.NamespacedName `json:"namespacedName"` | ||
| StorageProviderEndpoint string `json:"storageProviderEndpoint"` | ||
| CephClusterFSID string `json:"cephClusterFSID"` | ||
| } | ||
|
|
||
| type ClientInfo struct { | ||
| ClusterID string `json:"clusterId"` | ||
| Name string `json:"name"` | ||
| ProviderInfo ProviderInfo `json:"providerInfo,omitempty"` | ||
| ClientManagedClusterName string `json:"clientManagedClusterName,omitempty"` | ||
| } | ||
|
|
||
| func (r *ManagedClusterViewReconciler) SetupWithManager(mgr ctrl.Manager) error { | ||
| r.Logger.Info("Setting up ManagedClusterViewReconciler with manager") | ||
| managedClusterViewPredicate := predicate.Funcs{ | ||
| UpdateFunc: func(e event.UpdateEvent) bool { | ||
| obj, ok := e.ObjectNew.(*viewv1beta1.ManagedClusterView) | ||
| if !ok { | ||
| return false | ||
| } | ||
| return hasODFInfoInScope(obj) | ||
| }, | ||
| CreateFunc: func(e event.CreateEvent) bool { | ||
| obj, ok := e.Object.(*viewv1beta1.ManagedClusterView) | ||
| if !ok { | ||
| return false | ||
| } | ||
| return hasODFInfoInScope(obj) | ||
| }, | ||
| } | ||
|
|
||
| return ctrl.NewControllerManagedBy(mgr). | ||
| For(&viewv1beta1.ManagedClusterView{}, builder.WithPredicates(managedClusterViewPredicate, predicate.ResourceVersionChangedPredicate{})). | ||
| Complete(r) | ||
| } | ||
|
|
||
| func hasODFInfoInScope(mc *viewv1beta1.ManagedClusterView) bool { | ||
| if mc.Spec.Scope.Name == ODFInfoConfigMapName && mc.Spec.Scope.Kind == ConfigMapResourceType { | ||
| return true | ||
| } | ||
| return false | ||
| } | ||
|
|
||
| func (r *ManagedClusterViewReconciler) Reconcile(ctx context.Context, req reconcile.Request) (reconcile.Result, error) { | ||
| logger := r.Logger.With("ManagedClusterView", req.NamespacedName) | ||
| logger.Info("Reconciling ManagedClusterView") | ||
|
|
||
| var managedClusterView viewv1beta1.ManagedClusterView | ||
| if err := r.Client.Get(ctx, req.NamespacedName, &managedClusterView); err != nil { | ||
| if client.IgnoreNotFound(err) != nil { | ||
| logger.Error("Failed to get ManagedClusterView", "error", err) | ||
| } | ||
| return ctrl.Result{}, client.IgnoreNotFound(err) | ||
| } | ||
|
|
||
| if err := createOrUpdateConfigMap(ctx, r.Client, managedClusterView, r.Logger); err != nil { | ||
| logger.Error("Failed to create or update ConfigMap for ManagedClusterView", "error", err) | ||
| return ctrl.Result{}, err | ||
| } | ||
|
|
||
| logger.Info("Successfully reconciled ManagedClusterView") | ||
|
|
||
| return ctrl.Result{}, nil | ||
| } | ||
|
|
||
| func createOrUpdateConfigMap(ctx context.Context, c client.Client, managedClusterView viewv1beta1.ManagedClusterView, logger *slog.Logger) error { | ||
| logger = logger.With("ManagedClusterView", managedClusterView.Name, "Namespace", managedClusterView.Namespace) | ||
|
|
||
| var resultData map[string]string | ||
| err := json.Unmarshal(managedClusterView.Status.Result.Raw, &resultData) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to unmarshal result data. %w", err) | ||
| } | ||
|
|
||
| clientInfoMap := make(map[string]ClientInfo) | ||
|
|
||
| for _, value := range resultData { | ||
| var odfInfo ocsv1alpha1.OdfInfoData | ||
| err := yaml.Unmarshal([]byte(value), &odfInfo) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to unmarshal ODF info data. %w", err) | ||
| } | ||
|
|
||
| providerInfo := ProviderInfo{ | ||
| Version: odfInfo.Version, | ||
| DeploymentType: odfInfo.DeploymentType, | ||
| CephClusterFSID: odfInfo.StorageCluster.CephClusterFSID, | ||
| StorageProviderEndpoint: odfInfo.StorageCluster.StorageProviderEndpoint, | ||
| NamespacedName: odfInfo.StorageCluster.NamespacedName, | ||
| StorageSystemName: odfInfo.StorageSystemName, | ||
| ProviderManagedClusterName: managedClusterView.Namespace, | ||
| } | ||
|
|
||
| for _, client := range odfInfo.Clients { | ||
| managedCluster, err := utils.GetManagedClusterById(ctx, c, client.ClusterID) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| clientInfo := ClientInfo{ | ||
| ClusterID: client.ClusterID, | ||
| Name: client.Name, | ||
| ProviderInfo: providerInfo, | ||
| ClientManagedClusterName: managedCluster.Name, | ||
| } | ||
| clientInfoMap[fmt.Sprintf("%s/%s", managedCluster.Name, client.Name)] = clientInfo | ||
| } | ||
| } | ||
|
|
||
| operatorNamespace := os.Getenv("POD_NAMESPACE") | ||
| configMap := &corev1.ConfigMap{ | ||
| ObjectMeta: metav1.ObjectMeta{ | ||
| Name: ClientInfoConfigMapName, | ||
| Namespace: operatorNamespace, | ||
| }, | ||
| } | ||
| err = c.Get(ctx, types.NamespacedName{Name: ClientInfoConfigMapName, Namespace: operatorNamespace}, configMap) | ||
| if err != nil && !errors.IsNotFound(err) { | ||
| return fmt.Errorf("failed to get ConfigMap. %w", err) | ||
| } | ||
|
|
||
| if configMap.Data == nil { | ||
| configMap.Data = make(map[string]string) | ||
| } | ||
|
|
||
| op, err := controllerutil.CreateOrUpdate(ctx, c, configMap, func() error { | ||
| for clientKey, clientInfo := range clientInfoMap { | ||
| clientInfoJSON, err := json.Marshal(clientInfo) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to marshal client info. %w", err) | ||
| } | ||
| configMap.Data[clientKey] = string(clientInfoJSON) | ||
| } | ||
|
|
||
| mcvOwnerRefs := managedClusterView.GetOwnerReferences() | ||
| for _, mcvOwnerRef := range mcvOwnerRefs { | ||
| exists := false | ||
| for _, existingOwnerRef := range configMap.OwnerReferences { | ||
| if existingOwnerRef.UID == mcvOwnerRef.UID { | ||
| exists = true | ||
| break | ||
| } | ||
| } | ||
| if !exists { | ||
| configMap.OwnerReferences = append(configMap.OwnerReferences, mcvOwnerRef) | ||
| } | ||
| } | ||
| return nil | ||
| }) | ||
|
|
||
| if err != nil { | ||
| return fmt.Errorf("failed to create or update ConfigMap. %w", err) | ||
| } | ||
|
|
||
| logger.Info(fmt.Sprintf("ConfigMap %s in namespace %s has been %s", ClientInfoConfigMapName, operatorNamespace, op)) | ||
|
|
||
| return nil | ||
| } |
Oops, something went wrong.