Format code (#109)

* Format code

* Fix gosec issue

api/v1/webhook_suite_test.go

@@ -43,10 +43,12 @@ import (
 // http://onsi.github.io/ginkgo/ to learn more about Ginkgo.
 
 // var cfg *rest.Config
-var k8sClient client.Client
-var testEnv *envtest.Environment
-var ctx context.Context
-var cancel context.CancelFunc
+var (
+	k8sClient client.Client
+	testEnv   *envtest.Environment
+	ctx       context.Context
+	cancel    context.CancelFunc
+)
 
 func TestAPIs(t *testing.T) {
 	RegisterFailHandler(Fail)
@@ -124,7 +126,6 @@ var _ = BeforeSuite(func() {
 		conn.Close()
 		return nil
 	}).Should(Succeed())
-
 }, 60)
 
 var _ = AfterSuite(func() {

controllers/suite_test.go

@@ -37,8 +37,10 @@ import (
 // http://onsi.github.io/ginkgo/ to learn more about Ginkgo.
 
 // var cfg *rest.Config
-var k8sClient client.Client
-var testEnv *envtest.Environment
+var (
+	k8sClient client.Client
+	testEnv   *envtest.Environment
+)
 
 func TestAPIs(t *testing.T) {
 	RegisterFailHandler(Fail)
@@ -69,7 +71,6 @@ var _ = BeforeSuite(func() {
 	k8sClient, err = client.New(cfg, client.Options{Scheme: scheme.Scheme})
 	Expect(err).NotTo(HaveOccurred())
 	Expect(k8sClient).NotTo(BeNil())
-
 }, 60)
 
 var _ = AfterSuite(func() {

pkg/diskinfo/frpc.go

@@ -40,7 +40,11 @@ func getProxy(name, namespace string) (string, error) {
 						proxyPollLog.Error(err, "failed to call dashboard")
 						return
 					}
-					defer resp.Body.Close()
+					defer func() {
+						if err := resp.Body.Close(); err != nil {
+							proxyPollLog.Error(err, "failed to close body")
+						}
+					}()
 
 					content, err := io.ReadAll(resp.Body)
 					if err != nil {

pkg/utils/semaphore.go

@@ -11,7 +11,7 @@ type Semaphore func() (bool, func())
 
 // CreateSemaphore creates a new semaphore to limit concurrency
 func CreateSemaphore(concurrency int, wait time.Duration) Semaphore {
-	var lock = make(chan bool, concurrency)
+	lock := make(chan bool, concurrency)
 
 	return func() (bool, func()) {
 		timer := time.NewTimer(wait)