Skip to content

Commit

Permalink
Remove dead code
Browse files Browse the repository at this point in the history
  • Loading branch information
adejanovski committed Jun 20, 2023
1 parent 719129f commit d3a50fc
Showing 1 changed file with 0 additions and 30 deletions.
30 changes: 0 additions & 30 deletions pkg/k8ssandra/util.go
Original file line number Diff line number Diff line change
@@ -1,14 +1,8 @@
package k8ssandra

import (
"context"

"github.com/go-logr/logr"
cassdcapi "github.com/k8ssandra/cass-operator/apis/cassandra/v1beta1"
api "github.com/k8ssandra/k8ssandra-operator/apis/k8ssandra/v1alpha1"
"k8s.io/apimachinery/pkg/types"
"k8s.io/utils/strings/slices"
"sigs.k8s.io/controller-runtime/pkg/client"
)

func GetDatacenterForDecommission(kc *api.K8ssandraCluster) string {
Expand All @@ -35,27 +29,3 @@ func GetDatacenterForDecommission(kc *api.K8ssandraCluster) string {

return ""
}

func GetK8ssandraClusterFromCassDc(ctx context.Context, cassdc *cassdcapi.CassandraDatacenter, client client.Client, logger logr.Logger) *api.K8ssandraCluster {
kcName := cassdc.Spec.ClusterName
if kcName == "" {
logger.Info("CassandraDatacenter %s/%s does not have a cluster name", cassdc.Namespace, cassdc.Name)
return nil
}

kcNamespace := cassdc.Labels[api.K8ssandraClusterNamespaceLabel]
if kcNamespace == "" {
logger.Info("CassandraDatacenter %s/%s does not have a k8ssandra cluster namespace label", cassdc.Namespace, cassdc.Name)
return nil
}

// Read the K8ssandraCluster object from the API server
kc := &api.K8ssandraCluster{}
err := client.Get(ctx, types.NamespacedName{Namespace: kcNamespace, Name: kcName}, kc)
if err != nil {
logger.Error(err, "Failed to get K8ssandraCluster")
return nil
}

return kc
}

0 comments on commit d3a50fc

Please sign in to comment.