Skip to content

Commit

Permalink
Merge pull request #1848 from mboersma/sync-linters
Browse files Browse the repository at this point in the history
Replace and remove deprecated linters
  • Loading branch information
k8s-ci-robot authored Nov 17, 2021
2 parents 45519b1 + e666293 commit 8be8e43
Show file tree
Hide file tree
Showing 4 changed files with 22 additions and 23 deletions.
3 changes: 1 addition & 2 deletions .golangci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,15 +16,14 @@ linters:
- godot
- gofmt
- goimports
- golint
- gosec
- gosimple
- govet
- ineffassign
- interfacer
- misspell
- nakedret
- prealloc
- revive
- staticcheck
- structcheck
- unconvert
Expand Down
4 changes: 2 additions & 2 deletions azure/services/managedclusters/managedclusters.go
Original file line number Diff line number Diff line change
Expand Up @@ -37,8 +37,8 @@ import (
)

var (
defaultUser string = "azureuser"
managedIdentity string = "msi"
defaultUser = "azureuser"
managedIdentity = "msi"
)

// ManagedClusterScope defines the scope interface for a managed cluster.
Expand Down
14 changes: 7 additions & 7 deletions exp/controllers/helpers.go
Original file line number Diff line number Diff line change
Expand Up @@ -477,19 +477,19 @@ func MachinePoolToInfrastructureMapFunc(gvk schema.GroupVersionKind, log logr.Lo

// AzureClusterToAzureMachinePoolsFunc is a handler.MapFunc to be used to enqueue
// requests for reconciliation of AzureMachinePools.
func AzureClusterToAzureMachinePoolsFunc(ctx context.Context, kClient client.Client, log logr.Logger) handler.MapFunc {
func AzureClusterToAzureMachinePoolsFunc(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc {
return func(o client.Object) []reconcile.Request {
ctx, cancel := context.WithTimeout(ctx, reconciler.DefaultMappingTimeout)
defer cancel()

c, ok := o.(*infrav1.AzureCluster)
ac, ok := o.(*infrav1.AzureCluster)
if !ok {
log.Error(errors.Errorf("expected a AzureCluster but got a %T", o), "failed to get AzureCluster")
return nil
}
logWithValues := log.WithValues("AzureCluster", c.Name, "Namespace", c.Namespace)
logWithValues := log.WithValues("AzureCluster", ac.Name, "Namespace", ac.Namespace)

cluster, err := util.GetOwnerCluster(ctx, kClient, c.ObjectMeta)
cluster, err := util.GetOwnerCluster(ctx, c, ac.ObjectMeta)
switch {
case apierrors.IsNotFound(err) || cluster == nil:
logWithValues.V(4).Info("owning cluster not found")
Expand All @@ -501,7 +501,7 @@ func AzureClusterToAzureMachinePoolsFunc(ctx context.Context, kClient client.Cli

labels := map[string]string{clusterv1.ClusterLabelName: cluster.Name}
ampl := &infrav1exp.AzureMachinePoolList{}
if err := kClient.List(ctx, ampl, client.InNamespace(c.Namespace), client.MatchingLabels(labels)); err != nil {
if err := c.List(ctx, ampl, client.InNamespace(ac.Namespace), client.MatchingLabels(labels)); err != nil {
logWithValues.Error(err, "failed to list AzureMachinePools")
return nil
}
Expand All @@ -522,7 +522,7 @@ func AzureClusterToAzureMachinePoolsFunc(ctx context.Context, kClient client.Cli

// AzureMachinePoolToAzureMachinePoolMachines maps an AzureMachinePool to its child AzureMachinePoolMachines through
// Cluster and MachinePool labels.
func AzureMachinePoolToAzureMachinePoolMachines(ctx context.Context, kClient client.Client, log logr.Logger) handler.MapFunc {
func AzureMachinePoolToAzureMachinePoolMachines(ctx context.Context, c client.Client, log logr.Logger) handler.MapFunc {
return func(o client.Object) []reconcile.Request {
ctx, cancel := context.WithTimeout(ctx, reconciler.DefaultMappingTimeout)
defer cancel()
Expand All @@ -539,7 +539,7 @@ func AzureMachinePoolToAzureMachinePoolMachines(ctx context.Context, kClient cli
infrav1exp.MachinePoolNameLabel: amp.Name,
}
ampml := &infrav1exp.AzureMachinePoolMachineList{}
if err := kClient.List(ctx, ampml, client.InNamespace(amp.Namespace), client.MatchingLabels(labels)); err != nil {
if err := c.List(ctx, ampml, client.InNamespace(amp.Namespace), client.MatchingLabels(labels)); err != nil {
logWithValues.Error(err, "failed to list AzureMachinePoolMachines")
return nil
}
Expand Down
24 changes: 12 additions & 12 deletions exp/controllers/helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -566,10 +566,10 @@ func Test_azureClusterToAzureMachinePoolsFunc(t *testing.T) {
Setup: func(g *GomegaWithT, t *testing.T) (*mock_log.MockLogger, *gomock.Controller, client.Client) {
mockCtrl := gomock.NewController(t)
log := mock_log.NewMockLogger(mockCtrl)
kClient := fake.NewClientBuilder().WithScheme(newScheme(g)).Build()
fakeClient := fake.NewClientBuilder().WithScheme(newScheme(g)).Build()
log.EXPECT().Error(gomockinternal.ErrStrEq("expected a AzureCluster but got a *v1beta1.MachinePool"), "failed to get AzureCluster")

return log, mockCtrl, kClient
return log, mockCtrl, fakeClient
},
Expect: func(g *GomegaWithT, reqs []reconcile.Request) {
g.Expect(reqs).To(HaveLen(0))
Expand All @@ -583,11 +583,11 @@ func Test_azureClusterToAzureMachinePoolsFunc(t *testing.T) {
Setup: func(g *GomegaWithT, t *testing.T) (*mock_log.MockLogger, *gomock.Controller, client.Client) {
mockCtrl := gomock.NewController(t)
log := mock_log.NewMockLogger(mockCtrl)
kClient := fake.NewClientBuilder().WithScheme(newScheme(g)).Build()
fakeClient := fake.NewClientBuilder().WithScheme(newScheme(g)).Build()
log.EXPECT().WithValues("AzureCluster", "azurefoo", "Namespace", "default").Return(log)
log.EXPECT().V(4).Return(log)
log.EXPECT().Info("owning cluster not found")
return log, mockCtrl, kClient
return log, mockCtrl, fakeClient
},
Expect: func(g *GomegaWithT, reqs []reconcile.Request) {
g.Expect(reqs).To(HaveLen(0))
Expand All @@ -607,9 +607,9 @@ func Test_azureClusterToAzureMachinePoolsFunc(t *testing.T) {
newCluster(clusterName),
newAzureCluster(clusterName),
}
kClient := fake.NewClientBuilder().WithScheme(newScheme(g)).WithRuntimeObjects(initObj...).Build()
fakeClient := fake.NewClientBuilder().WithScheme(newScheme(g)).WithRuntimeObjects(initObj...).Build()
log.EXPECT().WithValues("AzureCluster", "azurefoo", "Namespace", "default").Return(logWithValues)
return log, mockCtrl, kClient
return log, mockCtrl, fakeClient
},
Expect: func(g *GomegaWithT, reqs []reconcile.Request) {
g.Expect(reqs).To(HaveLen(0))
Expand All @@ -631,9 +631,9 @@ func Test_azureClusterToAzureMachinePoolsFunc(t *testing.T) {
newMachinePool(clusterName, "pool1"),
newMachinePool(clusterName, "pool2"),
}
kClient := fake.NewClientBuilder().WithScheme(newScheme(g)).WithRuntimeObjects(initObj...).Build()
fakeClient := fake.NewClientBuilder().WithScheme(newScheme(g)).WithRuntimeObjects(initObj...).Build()
log.EXPECT().WithValues("AzureCluster", "azurefoo", "Namespace", "default").Return(logWithValues)
return log, mockCtrl, kClient
return log, mockCtrl, fakeClient
},
Expect: func(g *GomegaWithT, reqs []reconcile.Request) {
g.Expect(reqs).To(HaveLen(0))
Expand All @@ -656,9 +656,9 @@ func Test_azureClusterToAzureMachinePoolsFunc(t *testing.T) {
newAzureMachinePool(clusterName, "azurepool2"),
newMachinePoolWithInfrastructureRef(clusterName, "pool2"),
}
kClient := fake.NewClientBuilder().WithScheme(newScheme(g)).WithRuntimeObjects(initObj...).Build()
fakeClient := fake.NewClientBuilder().WithScheme(newScheme(g)).WithRuntimeObjects(initObj...).Build()
log.EXPECT().WithValues("AzureCluster", "azurefoo", "Namespace", "default").Return(logWithValues)
return log, mockCtrl, kClient
return log, mockCtrl, fakeClient
},
Expect: func(g *GomegaWithT, reqs []reconcile.Request) {
g.Expect(reqs).To(HaveLen(1))
Expand All @@ -677,10 +677,10 @@ func Test_azureClusterToAzureMachinePoolsFunc(t *testing.T) {
t.Run(c.Name, func(t *testing.T) {
t.Parallel()
g := NewGomegaWithT(t)
log, mockctrl, kClient := c.Setup(g, t)
log, mockctrl, fakeClient := c.Setup(g, t)
defer mockctrl.Finish()

f := AzureClusterToAzureMachinePoolsFunc(context.Background(), kClient, log)
f := AzureClusterToAzureMachinePoolsFunc(context.Background(), fakeClient, log)
reqs := f(c.MapObjectFactory(g))
c.Expect(g, reqs)
})
Expand Down

0 comments on commit 8be8e43

Please sign in to comment.