Fix lint errors

Signed-off-by: Yevhen Vydolob <[email protected]>
containers · Mar 6, 2024 · 0837f7f · 0837f7f
1 parent c33a46e
commit 0837f7f
Show file tree

Hide file tree

Showing 10 changed files with 21 additions and 21 deletions.
diff --git a/cmd/test-companion/main.go b/cmd/test-companion/main.go
@@ -39,7 +39,7 @@ func main() {
 	}()
 
 	mux := http.NewServeMux()
-	mux.HandleFunc("/", func(writer http.ResponseWriter, request *http.Request) {
+	mux.HandleFunc("/", func(writer http.ResponseWriter, _ *http.Request) {
 		_, _ = writer.Write([]byte(`Hello world!`))
 	})
 

diff --git a/pkg/services/dhcp/dhcp.go b/pkg/services/dhcp/dhcp.go
@@ -120,7 +120,7 @@ func (s *Server) Serve() error {
 
 func (s *Server) Mux() http.Handler {
 	mux := http.NewServeMux()
-	mux.HandleFunc("/leases", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc("/leases", func(w http.ResponseWriter, _ *http.Request) {
 		_ = json.NewEncoder(w).Encode(s.IPPool.Leases())
 	})
 	return mux

diff --git a/pkg/services/dns/dns.go b/pkg/services/dns/dns.go
@@ -231,7 +231,7 @@ func (s *Server) ServeTCP() error {
 
 func (s *Server) Mux() http.Handler {
 	mux := http.NewServeMux()
-	mux.HandleFunc("/all", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc("/all", func(w http.ResponseWriter, _ *http.Request) {
 		s.handler.zonesLock.RLock()
 		_ = json.NewEncoder(w).Encode(s.handler.zones)
 		s.handler.zonesLock.RUnlock()

diff --git a/pkg/services/forwarder/ports.go b/pkg/services/forwarder/ports.go
@@ -117,7 +117,7 @@ func (f *PortsForwarder) Expose(protocol types.TransportProtocol, local, remote
 			var sshForward *sshclient.SSHForward
 			var connLock sync.Mutex
 
-			dialFn = func(ctx context.Context, network, addr string) (net.Conn, error) {
+			dialFn = func(ctx context.Context, _, _ string) (net.Conn, error) {
 				connLock.Lock()
 				defer connLock.Unlock()
 
@@ -232,7 +232,7 @@ func (f *PortsForwarder) Expose(protocol types.TransportProtocol, local, remote
 		var p tcpproxy.Proxy
 		p.AddRoute(local, &tcpproxy.DialProxy{
 			Addr: remote,
-			DialContext: func(ctx context.Context, network, addr string) (conn net.Conn, e error) {
+			DialContext: func(ctx context.Context, _, _ string) (conn net.Conn, e error) {
 				return gonet.DialContextTCP(ctx, f.stack, address, ipv4.ProtocolNumber)
 			},
 		})
@@ -273,7 +273,7 @@ func (f *PortsForwarder) Unexpose(protocol types.TransportProtocol, local string
 
 func (f *PortsForwarder) Mux() http.Handler {
 	mux := http.NewServeMux()
-	mux.HandleFunc("/all", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc("/all", func(w http.ResponseWriter, _ *http.Request) {
 		f.proxiesLock.Lock()
 		defer f.proxiesLock.Unlock()
 		ret := make([]proxy, 0)

diff --git a/pkg/services/forwarder/tcp.go b/pkg/services/forwarder/tcp.go
@@ -47,7 +47,7 @@ func TCP(s *stack.Stack, nat map[tcpip.Address]tcpip.Address, natLock *sync.Mute
 		}
 
 		remote := tcpproxy.DialProxy{
-			DialContext: func(ctx context.Context, network, address string) (net.Conn, error) {
+			DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
 				return outbound, nil
 			},
 		}

diff --git a/pkg/sshclient/bastion.go b/pkg/sshclient/bastion.go
@@ -138,7 +138,7 @@ func CreateBastion(_url *url.URL, passPhrase string, identity string, initial ne
 	}
 
 	if connect == nil {
-		connect = func(ctx context.Context, bastion *Bastion) (net.Conn, error) {
+		connect = func(_ context.Context, bastion *Bastion) (net.Conn, error) {
 			conn, err := net.DialTimeout("tcp",
 				net.JoinHostPort(bastion.Host, bastion.Port),
 				bastion.Config.Timeout,

diff --git a/pkg/transport/dial_darwin.go b/pkg/transport/dial_darwin.go
@@ -6,6 +6,6 @@ import (
 	"github.com/pkg/errors"
 )
 
-func Dial(endpoint string) (net.Conn, string, error) {
+func Dial(_ string) (net.Conn, string, error) {
 	return nil, "", errors.New("unsupported")
 }
diff --git a/pkg/virtualnetwork/mux.go b/pkg/virtualnetwork/mux.go
@@ -18,16 +18,16 @@ import (
 func (n *VirtualNetwork) Mux() *http.ServeMux {
 	mux := http.NewServeMux()
 	mux.Handle("/services/", http.StripPrefix("/services", n.servicesMux))
-	mux.HandleFunc("/stats", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc("/stats", func(w http.ResponseWriter, _ *http.Request) {
 		_ = json.NewEncoder(w).Encode(statsAsJSON(n.networkSwitch.Sent, n.networkSwitch.Received, n.stack.Stats()))
 	})
-	mux.HandleFunc("/cam", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc("/cam", func(w http.ResponseWriter, _ *http.Request) {
 		_ = json.NewEncoder(w).Encode(n.networkSwitch.CAM())
 	})
-	mux.HandleFunc("/leases", func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc("/leases", func(w http.ResponseWriter, _ *http.Request) {
 		_ = json.NewEncoder(w).Encode(n.ipPool.Leases())
 	})
-	mux.HandleFunc(types.ConnectPath, func(w http.ResponseWriter, r *http.Request) {
+	mux.HandleFunc(types.ConnectPath, func(w http.ResponseWriter, _ *http.Request) {
 		hj, ok := w.(http.Hijacker)
 		if !ok {
 			http.Error(w, "webserver doesn't support hijacking", http.StatusInternalServerError)
@@ -83,14 +83,14 @@ func (n *VirtualNetwork) Mux() *http.ServeMux {
 		}
 
 		remote := tcpproxy.DialProxy{
-			DialContext: func(ctx context.Context, network, address string) (net.Conn, error) {
+			DialContext: func(ctx context.Context, _, _ string) (net.Conn, error) {
 				return gonet.DialContextTCP(ctx, n.stack, tcpip.FullAddress{
 					NIC:  1,
 					Addr: tcpip.AddrFrom4Slice(net.ParseIP(ip).To4()),
 					Port: uint16(port),
 				}, ipv4.ProtocolNumber)
 			},
-			OnDialError: func(src net.Conn, dstDialErr error) {
+			OnDialError: func(_ net.Conn, dstDialErr error) {
 				log.Errorf("cannot dial: %v", dstDialErr)
 			},
 		}

diff --git a/test/basic_test.go b/test/basic_test.go
@@ -95,7 +95,7 @@ var _ = ginkgo.Describe("dns", func() {
 	ginkgo.It("should resolve dynamically added dns entry test.dynamic.internal", func() {
 		client := gvproxyclient.New(&http.Client{
 			Transport: &http.Transport{
-				DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
+				DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
 					return net.Dial("unix", sock)
 				},
 			},
@@ -120,7 +120,7 @@ var _ = ginkgo.Describe("dns", func() {
 	ginkgo.It("should resolve recently added dns entry test.dynamic.internal", func() {
 		client := gvproxyclient.New(&http.Client{
 			Transport: &http.Transport{
-				DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
+				DialContext: func(_ context.Context, _, _ string) (net.Conn, error) {
 					return net.Dial("unix", sock)
 				},
 			},
@@ -156,7 +156,7 @@ var _ = ginkgo.Describe("dns", func() {
 	ginkgo.It("should retain order of existing zone", func() {
 		client := gvproxyclient.New(&http.Client{
 			Transport: &http.Transport{
-				DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
+				DialContext: func(_ context.Context, network, addr string) (net.Conn, error) {
 					return net.Dial("unix", sock)
 				},
 			},

diff --git a/test/port_forwarding_test.go b/test/port_forwarding_test.go
@@ -23,7 +23,7 @@ import (
 var _ = ginkgo.Describe("port forwarding", func() {
 	client := gvproxyclient.New(&http.Client{
 		Transport: &http.Transport{
-			DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
+			DialContext: func(ctx context.Context, _, _ string) (net.Conn, error) {
 				return net.Dial("unix", sock)
 			},
 		},
@@ -35,7 +35,7 @@ var _ = ginkgo.Describe("port forwarding", func() {
 		defer ln.Close()
 
 		mux := http.NewServeMux()
-		mux.HandleFunc("/", func(writer http.ResponseWriter, request *http.Request) {
+		mux.HandleFunc("/", func(writer http.ResponseWriter, _ *http.Request) {
 			_, _ = writer.Write([]byte("Hello from the host"))
 		})
 		go func() {
@@ -109,7 +109,7 @@ var _ = ginkgo.Describe("port forwarding", func() {
 	ginkgo.It("should reach a http server in the VM using the tunneling of the daemon", func() {
 		httpClient := &http.Client{
 			Transport: &http.Transport{
-				DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
+				DialContext: func(ctx context.Context, _, _ string) (net.Conn, error) {
 					conn, err := net.Dial("unix", sock)
 					if err != nil {
 						return nil, err