controllers

func (*DiscoveredClusterReconciler) CreateAutoImportSecret ¶

func (r *DiscoveredClusterReconciler) CreateAutoImportSecret(nn types.NamespacedName, clusterID, apiToken string,
) *corev1.Secret

CreateAutoImportSecret creates an auto-import secret for the given NamespacedName and DiscoveryConfig. It constructs a Secret object with the specified name, namespace, and credential from the DiscoveryConfig. Other fields like api_url, token_url, and cluster_id are left empty. It sets the retry_times field to a default value of "2". The secret type is set to "auto-import/rosa".

func (*DiscoveredClusterReconciler) CreateKlusterletAddonConfig ¶

func (r *DiscoveredClusterReconciler) CreateKlusterletAddonConfig(nn types.NamespacedName,
) *agentv1.KlusterletAddonConfig

createKlusterletAddonConfig creates a KlusterletAddonConfig object with the specified NamespacedName. It sets the basic configuration for the KlusterletAddonConfig, including metadata and spec fields. It also initializes the ClusterLabels with default values and enables various addon configurations.

func (*DiscoveredClusterReconciler) CreateManagedCluster ¶

func (r *DiscoveredClusterReconciler) CreateManagedCluster(nn types.NamespacedName) *clusterapiv1.ManagedCluster

CreateManagedCluster creates a ManagedCluster object with the specified NamespacedName. It sets default labels and annotations for the ManagedCluster. It also adds a finalizer for cleanup.

func (*DiscoveredClusterReconciler) CreateNamespaceForDiscoveredCluster ¶

func (r *DiscoveredClusterReconciler) CreateNamespaceForDiscoveredCluster(dc discovery.DiscoveredCluster,
) *corev1.Namespace

CreateNamespaceForDiscoveredCluster creates a Namespace object for the specified DiscoveredCluster. It sets the Namespace's metadata including Name and Labels. The Namespace is labeled for cluster monitoring with a label indicating its purpose.

func (*DiscoveredClusterReconciler) EnsureAutoImportSecret ¶

func (r *DiscoveredClusterReconciler) EnsureAutoImportSecret(ctx context.Context, dc discovery.DiscoveredCluster) (
	ctrl.Result, error)

EnsureAutoImportSecret ensures the existence of an auto-import secret for the given DiscoveredCluster and DiscoveryConfig. It checks if an auto-import secret with the specified name and namespace exists. If not found, it creates a new auto-import secret with the name "auto-import-secret" and the DiscoveredCluster's namespace. It sets a controller reference to the DiscoveredCluster for ownership management. If creation fails, it logs an error and returns with a requeue signal. If the auto-import secret already exists or if an error occurs during retrieval, it logs an error and returns with a requeue signal.

func (*DiscoveredClusterReconciler) EnsureCRDExist ¶

func (r *DiscoveredClusterReconciler) EnsureCRDExist(ctx context.Context, crdName string) (ctrl.Result, error)

EnsureCRDExist checks if a Custom Resource Definition (CRD) with the specified name exists in the cluster. If the CRD exists, it returns indicating that the reconciliation should continue without requeueing. If the CRD doesn't exist, it logs a message indicating that the CRD was not found and returns. If an error occurs while getting the CRD (other than IsNotFound), it logs an error message and returns an error.

func (*DiscoveredClusterReconciler) EnsureDiscoveredClusterCredentialExists ¶

func (r *DiscoveredClusterReconciler) EnsureDiscoveredClusterCredentialExists(
	ctx context.Context, dc discovery.DiscoveredCluster) (ctrl.Result, error)

EnsureDiscoveredClusterCredentialExists ...

func (*DiscoveredClusterReconciler) EnsureKlusterletAddonConfig ¶

func (r *DiscoveredClusterReconciler) EnsureKlusterletAddonConfig(ctx context.Context, dc discovery.DiscoveredCluster) (
	ctrl.Result, error)

EnsureKlusterletAddonConfig ensures the existence of a KlusterletAddonConfig resource for the given DiscoveredCluster. It checks if a KlusterletAddonConfig with the specified display name exists. If not found, it creates a new KlusterletAddonConfig with the display name and default configurations. It sets a controller reference to the DiscoveredCluster for ownership management. If creation fails, it logs an error and returns with a requeue signal. If the KlusterletAddonConfig already exists or if an error occurs during retrieval, it logs an error and returns with a requeue signal.

func (*DiscoveredClusterReconciler) EnsureManagedCluster ¶

func (r *DiscoveredClusterReconciler) EnsureManagedCluster(ctx context.Context, dc discovery.DiscoveredCluster) (
	ctrl.Result, error)

EnsureManagedCluster ensures the existence of a ManagedCluster resource for the given DiscoveredCluster. It checks if a ManagedCluster with the specified display name exists. If not found, it creates a new ManagedCluster with the display name and default configurations. It sets a controller reference to the DiscoveredCluster for ownership management. If creation fails, it logs an error and returns with a requeue signal. If the ManagedCluster already exists or if an error occurs during retrieval, it logs an error and returns with a requeue signal.

func (*DiscoveredClusterReconciler) EnsureNamespaceForDiscoveredCluster ¶

func (r *DiscoveredClusterReconciler) EnsureNamespaceForDiscoveredCluster(ctx context.Context,
	dc discovery.DiscoveredCluster) (ctrl.Result, error)

EnsureNamespaceForDiscoveredCluster ensures the existence of a Namespace for the given DiscoveredCluster. It checks if a Namespace with the specified display name exists. If not found, it creates a new Namespace with the display name. It sets a controller reference to the DiscoveredCluster for ownership management. If creation fails, it returns with a requeue signal. If an error occurs during retrieval or creation, it logs an error and returns with a requeue signal.

func (*DiscoveredClusterReconciler) Reconcile ¶

func (r *DiscoveredClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the DiscoveredCluster object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.14.4/pkg/reconcile

func (*DiscoveredClusterReconciler) SetupWithManager ¶

func (r *DiscoveredClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager ...

func (*DiscoveredClusterReconciler) ShouldReconcile ¶

func (r *DiscoveredClusterReconciler) ShouldReconcile(obj metav1.Object) bool

ShouldReconcile ...

func (*DiscoveryConfigReconciler) Reconcile ¶

func (r *DiscoveryConfigReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*DiscoveryConfigReconciler) SetupWithManager ¶

func (r *DiscoveryConfigReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager ...

func (*ManagedClusterReconciler) Reconcile ¶

func (r *ManagedClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

func (*ManagedClusterReconciler) SetupWithManager ¶

func (r *ManagedClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager ...