controllers

func MigrateAllSubscriptionsOrDie ¶

func MigrateAllSubscriptionsOrDie(ctx context.Context, resourcesDBClient database.ResourcesDBClient, kubeApplierDBClients database.KubeApplierDBClients)

MigrateAllSubscriptionsOrDie runs the Cosmos migration once across every subscription currently in the Resources container and panics on the first unrecoverable error. It is intended for integration-test setup where the long-running subscription-watching controller is not wired in; production migration runs as the controller returned by NewCosmosMigrationController.

func NewCleanOrphanedClusterManagedResourceGroupController ¶

func NewCleanOrphanedClusterManagedResourceGroupController(
	location string,
	activeOperationLister listers.ActiveOperationLister,
	resourcesDBClient database.ResourcesDBClient,
	azureFPAClientBuilder azureclient.FirstPartyApplicationClientBuilder,
	backendInformers informers.BackendInformers,
) controllerutils.Controller

NewCleanOrphanedClusterManagedResourceGroupController periodically looks for managed resource groups that are not referenced by any HCPOpenShiftCluster in the database and cleans them up.

func NewCosmosMigrationController ¶

func NewCosmosMigrationController(
	resourcesDBClient database.ResourcesDBClient,
	kubeApplierDBClients database.KubeApplierDBClients,
	backendInformers informers.BackendInformers,
	resyncDuration time.Duration,
) controllerutils.Controller

NewCosmosMigrationController creates a subscription-watching controller that iterates depth-first through every named document type in the Resources container and the per-management-cluster kube-applier containers, performing a read/write cycle to force Cosmos DB re-serialization.

func NewCreateClusterScopedReadDesiresController ¶

func NewCreateClusterScopedReadDesiresController(
	activeOperationLister listers.ActiveOperationLister,
	resourcesDBClient database.ResourcesDBClient,
	kubeApplierDBClients database.KubeApplierDBClients,
	informers informers.BackendInformers,
	hostedClusterNamespaceEnvIdentifier string,
) controllerutils.Controller

NewCreateClusterScopedReadDesiresController wires the per-cluster ReadDesire creator. It reuses NewClusterWatchingController so the cadence (informer relist + cooldown) matches the rest of the cluster-scoped pipeline.

func NewCreateNodePoolScopedReadDesiresController ¶

func NewCreateNodePoolScopedReadDesiresController(
	activeOperationLister listers.ActiveOperationLister,
	resourcesDBClient database.ResourcesDBClient,
	kubeApplierDBClients database.KubeApplierDBClients,
	informers informers.BackendInformers,
	hostedClusterNamespaceEnvIdentifier string,
) controllerutils.Controller

func NewDoNothingExampleController ¶

func NewDoNothingExampleController(resourcesDBClient database.ResourcesDBClient, subscriptionLister listers.SubscriptionLister) controllerutils.Controller

NewDoNothingExampleController periodically lists all clusters and for each out when the cluster was created and its state.