Skip to content

Commit 92fee33

Browse files
authored
Merge pull request #181 from chaosi-zju/staticcheck4
chore: format code about misspell,staticcheck,govet
2 parents a7c02b5 + 22e6528 commit 92fee33

File tree

10 files changed

+9
-50
lines changed

10 files changed

+9
-50
lines changed

cmd/api/app/routes/cluster/handler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -205,7 +205,7 @@ func handleDeleteCluster(c *gin.Context) {
205205
}
206206

207207
// make sure the given cluster object has been deleted
208-
err = wait.Poll(1*time.Second, waitDuration, func() (done bool, err error) {
208+
err = wait.PollUntilContextTimeout(ctx, 1*time.Second, waitDuration, true, func(ctx context.Context) (done bool, err error) {
209209
_, err = karmadaClient.ClusterV1alpha1().Clusters().Get(ctx, clusterName, metav1.GetOptions{})
210210
if apierrors.IsNotFound(err) {
211211
return true, nil

cmd/api/app/routes/clusteroverridepolicy/handler.go

Lines changed: 0 additions & 39 deletions
Original file line numberDiff line numberDiff line change
@@ -22,15 +22,13 @@ import (
2222
"github.com/gin-gonic/gin"
2323
"github.com/karmada-io/karmada/pkg/apis/policy/v1alpha1"
2424
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
25-
"k8s.io/client-go/util/retry"
2625
"k8s.io/klog/v2"
2726
"sigs.k8s.io/yaml"
2827

2928
"github.com/karmada-io/dashboard/cmd/api/app/router"
3029
v1 "github.com/karmada-io/dashboard/cmd/api/app/types/api/v1"
3130
"github.com/karmada-io/dashboard/cmd/api/app/types/common"
3231
"github.com/karmada-io/dashboard/pkg/client"
33-
"github.com/karmada-io/dashboard/pkg/common/errors"
3432
"github.com/karmada-io/dashboard/pkg/resource/clusteroverridepolicy"
3533
)
3634

@@ -135,43 +133,6 @@ func handlePutClusterOverridePolicy(c *gin.Context) {
135133
common.Success(c, "ok")
136134
}
137135

138-
func handleDeleteClusterOverridePolicy(c *gin.Context) {
139-
ctx := context.Context(c)
140-
overridepolicyRequest := new(v1.DeleteOverridePolicyRequest)
141-
if err := c.ShouldBind(&overridepolicyRequest); err != nil {
142-
common.Fail(c, err)
143-
return
144-
}
145-
var err error
146-
karmadaClient := client.InClusterKarmadaClient()
147-
if overridepolicyRequest.IsClusterScope {
148-
err = karmadaClient.PolicyV1alpha1().ClusterOverridePolicies().Delete(ctx, overridepolicyRequest.Name, metav1.DeleteOptions{})
149-
if err != nil {
150-
klog.ErrorS(err, "Failed to delete ClusterOverridePolicy")
151-
common.Fail(c, err)
152-
return
153-
}
154-
} else {
155-
err = karmadaClient.PolicyV1alpha1().OverridePolicies(overridepolicyRequest.Namespace).Delete(ctx, overridepolicyRequest.Name, metav1.DeleteOptions{})
156-
if err != nil {
157-
klog.ErrorS(err, "Failed to delete OverridePolicy")
158-
common.Fail(c, err)
159-
return
160-
}
161-
err = retry.OnError(
162-
retry.DefaultRetry,
163-
func(err error) bool {
164-
return errors.IsNotFound(err)
165-
},
166-
func() error {
167-
_, getErr := karmadaClient.PolicyV1alpha1().OverridePolicies(overridepolicyRequest.Namespace).Get(ctx, overridepolicyRequest.Name, metav1.GetOptions{})
168-
return getErr
169-
})
170-
}
171-
172-
common.Success(c, "ok")
173-
}
174-
175136
func init() {
176137
r := router.V1()
177138
r.GET("/clusteroverridepolicy", handleGetClusterOverridePolicyList)

cmd/api/app/routes/clusterpropagationpolicy/handler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,7 @@ func handleDeleteClusterPropagationPolicy(c *gin.Context) {
157157
common.Fail(c, err)
158158
return
159159
}
160-
err = retry.OnError(
160+
_ = retry.OnError(
161161
retry.DefaultRetry,
162162
func(err error) bool {
163163
return errors.IsNotFound(err)

cmd/api/app/routes/overridepolicy/handler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ func handleDeleteOverridePolicy(c *gin.Context) {
161161
common.Fail(c, err)
162162
return
163163
}
164-
err = retry.OnError(
164+
_ = retry.OnError(
165165
retry.DefaultRetry,
166166
func(err error) bool {
167167
return errors.IsNotFound(err)

cmd/api/app/routes/overview/misc.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,7 +80,7 @@ func GetControllerManagerVersionInfo() (*version.Info, error) {
8080
return nil, err
8181
}
8282
var stdout, stderr bytes.Buffer
83-
err = executor.Stream(remotecommand.StreamOptions{
83+
err = executor.StreamWithContext(context.TODO(), remotecommand.StreamOptions{
8484
Stdout: &stdout,
8585
Stderr: &stderr,
8686
Tty: false,

cmd/api/app/routes/propagationpolicy/handler.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -161,7 +161,7 @@ func handleDeletePropagationPolicy(c *gin.Context) {
161161
common.Fail(c, err)
162162
return
163163
}
164-
err = retry.OnError(
164+
_ = retry.OnError(
165165
retry.DefaultRetry,
166166
func(err error) bool {
167167
return errors.IsNotFound(err)

hack/verify-staticcheck.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ else
3232
curl -sSfL https://raw.githubusercontent.com/golangci/golangci-lint/master/install.sh | sh -s -- -b $(go env GOPATH)/bin ${GOLANGCI_LINT_VER}
3333
fi
3434

35-
if golangci-lint run --enable-only goimports,gci,whitespace; then
35+
if golangci-lint run --enable-only goimports,gci,whitespace,misspell,staticcheck,govet; then
3636
echo 'Congratulations! All Go source files have passed staticcheck.'
3737
else
3838
echo # print one empty line, separate from warning messages.

pkg/client/init.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -129,7 +129,7 @@ func isKubeInitialized() bool {
129129

130130
func InitKubeConfig(options ...Option) {
131131
builder := newConfigBuilder(options...)
132-
// prefer InClusterConfig, if something wrong, use explict kubeconfig path
132+
// prefer InClusterConfig, if something wrong, use explicit kubeconfig path
133133
restConfig, err := rest.InClusterConfig()
134134
if err == nil {
135135
klog.Infof("InitKubeConfig by InClusterConfig method")
@@ -141,7 +141,7 @@ func InitKubeConfig(options ...Option) {
141141
kubernetesApiConfig = apiConfig
142142
} else {
143143
klog.Infof("InClusterConfig error: %+v", err)
144-
klog.Infof("InitKubeConfig by explict kubeconfig path")
144+
klog.Infof("InitKubeConfig by explicit kubeconfig path")
145145
restConfig, err = builder.buildRestConfig()
146146
if err != nil {
147147
klog.Errorf("Could not init client config: %s", err)

pkg/config/config.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ func InitDashboardConfig(k8sClient kubernetes.Interface, stopper <-chan struct{}
7979
}
8080
onUpdate := func(oldObj, newObj interface{}) {
8181
newConfigMap := newObj.(*v1.ConfigMap)
82-
klog.V(2).Info("ConfigMap %s Updated\n", newConfigMap.Name)
82+
klog.V(2).Infof("ConfigMap %s Updated", newConfigMap.Name)
8383
var tmpConfig DashboardConfig
8484
if err := yaml.Unmarshal([]byte(newConfigMap.Data[GetConfigKey()]), &tmpConfig); err != nil {
8585
klog.Errorf("Failed to unmarshal ConfigMap %s: %v", newConfigMap.Name, err)

pkg/resource/cronjob/jobs.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -154,8 +154,6 @@ func filterJobsByState(active bool, jobs []batch.Job) (matchingJobs []batch.Job)
154154
matchingJobs = append(matchingJobs, j)
155155
} else if !active && j.Status.Active == 0 {
156156
matchingJobs = append(matchingJobs, j)
157-
} else {
158-
//sup
159157
}
160158
}
161159
return

0 commit comments

Comments
 (0)