Skip to content

Commit

Permalink
Drop completed TODO (gardener#10136)
Browse files Browse the repository at this point in the history
  • Loading branch information
shafeeqes authored Jul 16, 2024
1 parent ac06e06 commit 76a84d6
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 52 deletions.
2 changes: 1 addition & 1 deletion cmd/gardenlet/app/app.go
Original file line number Diff line number Diff line change
Expand Up @@ -359,7 +359,7 @@ func (g *garden) Start(ctx context.Context) error {
return err
}

if err := g.runMigrations(ctx, log, gardenCluster, g.config.SeedConfig.Name); err != nil {
if err := g.runMigrations(ctx, log); err != nil {
return err
}

Expand Down
48 changes: 1 addition & 47 deletions cmd/gardenlet/app/migration.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,26 +11,18 @@ import (
"github.com/Masterminds/semver/v3"
"github.com/go-logr/logr"
corev1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/types"
"k8s.io/client-go/discovery"
"k8s.io/client-go/rest"
"sigs.k8s.io/controller-runtime/pkg/client"
"sigs.k8s.io/controller-runtime/pkg/cluster"

"github.com/gardener/gardener/pkg/apis/core"
gardencorev1beta1 "github.com/gardener/gardener/pkg/apis/core/v1beta1"
v1beta1constants "github.com/gardener/gardener/pkg/apis/core/v1beta1/constants"
v1beta1helper "github.com/gardener/gardener/pkg/apis/core/v1beta1/helper"
"github.com/gardener/gardener/pkg/component/extensions/operatingsystemconfig"
"github.com/gardener/gardener/pkg/component/nodemanagement/dependencywatchdog"
"github.com/gardener/gardener/pkg/utils/flow"
kubernetesutils "github.com/gardener/gardener/pkg/utils/kubernetes"
"github.com/gardener/gardener/pkg/utils/managedresources"
versionutils "github.com/gardener/gardener/pkg/utils/version"
)

func (g *garden) runMigrations(ctx context.Context, log logr.Logger, gardenCluster cluster.Cluster, seedName string) error {
func (g *garden) runMigrations(ctx context.Context, log logr.Logger) error {
log.Info("Migrating deprecated failure-domain.beta.kubernetes.io labels to topology.kubernetes.io")
if err := migrateDeprecatedTopologyLabels(ctx, log, g.mgr.GetClient(), g.mgr.GetConfig()); err != nil {
return err
Expand All @@ -41,11 +33,6 @@ func (g *garden) runMigrations(ctx context.Context, log logr.Logger, gardenClust
return err
}

log.Info("Cleaning up DWD access for workerless shoots")
if err := cleanupDWDAccess(ctx, gardenCluster.GetClient(), g.mgr.GetClient(), seedName); err != nil {
return err
}

return nil
}

Expand Down Expand Up @@ -162,36 +149,3 @@ func createOSCHashMigrationSecret(ctx context.Context, seedClient client.Client)
}
return flow.Parallel(tasks...)(ctx)
}

// TODO (shafeeqes): Remove this function in gardener v1.100
func cleanupDWDAccess(ctx context.Context, gardenClient client.Client, seedClient client.Client, seedName string) error {
shootList := &gardencorev1beta1.ShootList{}
if err := gardenClient.List(ctx, shootList, client.MatchingFields{core.ShootSeedName: seedName}); err != nil {
return err
}

var taskFns []flow.TaskFn

for _, shoot := range shootList.Items {
if !v1beta1helper.IsWorkerless(&shoot) || shoot.DeletionTimestamp != nil || shoot.Status.TechnicalID == "" {
continue
}

namespace := shoot.Status.TechnicalID
taskFns = append(taskFns, func(ctx context.Context) error {
if err := kubernetesutils.DeleteObjects(ctx, seedClient,
&corev1.Secret{ObjectMeta: metav1.ObjectMeta{Name: dependencywatchdog.KubeConfigSecretName, Namespace: namespace}},
); err != nil {
return fmt.Errorf("failed to delete DWD access secret for namespace %q: %w", namespace, err)
}

if err := managedresources.DeleteForShoot(ctx, seedClient, namespace, dependencywatchdog.ManagedResourceName); err != nil {
return fmt.Errorf("failed to delete DWD managed resource for namespace %q: %w", namespace, err)
}

return nil
})
}

return flow.Parallel(taskFns...)(ctx)
}
8 changes: 4 additions & 4 deletions pkg/component/nodemanagement/dependencywatchdog/access.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,8 +33,8 @@ const (
DefaultWatchDuration = 5 * time.Minute
// KubeConfigSecretName is the name of the kubecfg secret with internal DNS for external access.
KubeConfigSecretName = gardenerutils.SecretNamePrefixShootAccess + "dependency-watchdog-probe"
// ManagedResourceName is the name of the managed resource created for DWD.
ManagedResourceName = "shoot-core-dependency-watchdog"
// managedResourceName is the name of the managed resource created for DWD.
managedResourceName = "shoot-core-dependency-watchdog"
)

// NewAccess creates a new instance of the deployer for shoot cluster access for the dependency-watchdog.
Expand Down Expand Up @@ -163,11 +163,11 @@ func (d *dependencyWatchdogAccess) createManagedResource(ctx context.Context) er
return err
}

return managedresources.CreateForShoot(ctx, d.client, d.namespace, ManagedResourceName, managedresources.LabelValueGardener, false, resources)
return managedresources.CreateForShoot(ctx, d.client, d.namespace, managedResourceName, managedresources.LabelValueGardener, false, resources)
}

func (d *dependencyWatchdogAccess) Destroy(ctx context.Context) error {
if err := managedresources.DeleteForShoot(ctx, d.client, d.namespace, ManagedResourceName); err != nil {
if err := managedresources.DeleteForShoot(ctx, d.client, d.namespace, managedResourceName); err != nil {
return err
}
return kubernetesutils.DeleteObjects(ctx, d.client,
Expand Down

0 comments on commit 76a84d6

Please sign in to comment.