8603508478

Committed 08 Apr 2024 04:26PM UTC coverage: 74.428%. Remained the same

Build # 8603508478

Build Type

Pull #1339

github

Committed by

web-flow

Commit Message

chore(deps): bump golang.org/x/net from 0.22.0 to 0.24.0

Bumps [golang.org/x/net](https://github.com/golang/net) from 0.22.0 to 0.24.0.
- [Commits](https://github.com/golang/net/compare/v0.22.0...v0.24.0)

---
updated-dependencies:
- dependency-name: golang.org/x/net
  dependency-type: direct:production
  update-type: version-update:semver-minor
...

Signed-off-by: dependabot[bot] <support@github.com>

Pull Request Pull Request #1339: chore(deps): bump golang.org/x/net from 0.22.0 to 0.24.0

Run Details

2212 of 2972 relevant lines covered (74.43%)

7.21 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/pkg/blobplugin/main.go

/*
Copyright 2017 The Kubernetes Authors.

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

    http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package main

import (
        "context"
        "flag"
        "fmt"
        "net"
        "net/http"
        "os"
        "strings"

        "sigs.k8s.io/blob-csi-driver/pkg/blob"
        "sigs.k8s.io/blob-csi-driver/pkg/util"

        "k8s.io/component-base/metrics/legacyregistry"
        "k8s.io/klog/v2"
)

var driverOptions blob.DriverOptions
var (
        metricsAddress             = flag.String("metrics-address", "", "export the metrics")
        version                    = flag.Bool("version", false, "Print the version and exit.")
        endpoint                   = flag.String("endpoint", "unix://tmp/csi.sock", "CSI endpoint")
        kubeconfig                 = flag.String("kubeconfig", "", "Absolute path to the kubeconfig file. Required only when running out of cluster.")
        cloudConfigSecretName      = flag.String("cloud-config-secret-name", "azure-cloud-provider", "secret name of cloud config")
        cloudConfigSecretNamespace = flag.String("cloud-config-secret-namespace", "kube-system", "secret namespace of cloud config")
        customUserAgent            = flag.String("custom-user-agent", "", "custom userAgent")
        userAgentSuffix            = flag.String("user-agent-suffix", "", "userAgent suffix")
        allowEmptyCloudConfig      = flag.Bool("allow-empty-cloud-config", true, "allow running driver without cloud config")
        kubeAPIQPS                 = flag.Float64("kube-api-qps", 25.0, "QPS to use while communicating with the kubernetes apiserver.")
        kubeAPIBurst               = flag.Int("kube-api-burst", 50, "Burst to use while communicating with the kubernetes apiserver.")
)

func init() {
        driverOptions.AddFlags()
}

func main() {
        klog.InitFlags(nil)
        _ = flag.Set("logtostderr", "true")
        flag.Parse()
        if *version {
                info, err := blob.GetVersionYAML(driverOptions.DriverName)
                if err != nil {
                        klog.Fatalln(err)
                }
                fmt.Println(info) // nolint
                os.Exit(0)
        }

        exportMetrics()
        handle()
        os.Exit(0)
}

func handle() {
        userAgent := blob.GetUserAgent(driverOptions.DriverName, *customUserAgent, *userAgentSuffix)
        klog.V(2).Infof("driver userAgent: %s", userAgent)

        kubeClient, err := util.GetKubeClient(*kubeconfig, *kubeAPIQPS, *kubeAPIBurst, userAgent)
        if err != nil {
                klog.Warningf("failed to get kubeClient, error: %v", err)
        }

        cloud, err := blob.GetCloudProvider(context.Background(), kubeClient, driverOptions.NodeID, *cloudConfigSecretName, *cloudConfigSecretNamespace, userAgent, *allowEmptyCloudConfig)
        if err != nil {
                klog.Fatalf("failed to get Azure Cloud Provider, error: %v", err)
        }
        klog.V(2).Infof("cloud: %s, location: %s, rg: %s, VnetName: %s, VnetResourceGroup: %s, SubnetName: %s", cloud.Cloud, cloud.Location, cloud.ResourceGroup, cloud.VnetName, cloud.VnetResourceGroup, cloud.SubnetName)

        driver := blob.NewDriver(&driverOptions, kubeClient, cloud)
        if driver == nil {
                klog.Fatalln("Failed to initialize Azure Blob Storage CSI driver")
        }
        if err := driver.Run(context.Background(), *endpoint); err != nil {
                klog.Fatalf("Failed to run Azure Blob Storage CSI driver: %v", err)
        }
}

func exportMetrics() {
        if *metricsAddress == "" {
                return
        }
        l, err := net.Listen("tcp", *metricsAddress)
        if err != nil {
                klog.Warningf("failed to get listener for metrics endpoint: %v", err)
                return
        }
        serve(context.Background(), l, serveMetrics)
}

func serve(_ context.Context, l net.Listener, serveFunc func(net.Listener) error) {
        path := l.Addr().String()
        klog.V(2).Infof("set up prometheus server on %v", path)
        go func() {
                defer l.Close()
                if err := serveFunc(l); err != nil {
                        klog.Fatalf("serve failure(%v), address(%v)", err, path)
                }
        }()
}

func serveMetrics(l net.Listener) error {
        m := http.NewServeMux()
        m.Handle("/metrics", legacyregistry.Handler()) //nolint, because azure cloud provider uses legacyregistry currently
        return trapClosedConnErr(http.Serve(l, m))
}

func trapClosedConnErr(err error) error {
        if err == nil {
                return nil
        }
        if strings.Contains(err.Error(), "use of closed network connection") {
                return nil
        }
        return err
}

1	/*
2	Copyright 2017 The Kubernetes Authors.
3
4	Licensed under the Apache License, Version 2.0 (the "License");
5	you may not use this file except in compliance with the License.
6	You may obtain a copy of the License at
7
8	http://www.apache.org/licenses/LICENSE-2.0
9
10	Unless required by applicable law or agreed to in writing, software
11	distributed under the License is distributed on an "AS IS" BASIS,
12	WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13	See the License for the specific language governing permissions and
14	limitations under the License.
15	*/
16
17	package main
18
19	import (
20	"context"
21	"flag"
22	"fmt"
23	"net"
24	"net/http"
25	"os"
26	"strings"
27
28	"sigs.k8s.io/blob-csi-driver/pkg/blob"
29	"sigs.k8s.io/blob-csi-driver/pkg/util"
30
31	"k8s.io/component-base/metrics/legacyregistry"
32	"k8s.io/klog/v2"
33	)
34
35	var driverOptions blob.DriverOptions
36	var (
37	metricsAddress = flag.String("metrics-address", "", "export the metrics")
38	version = flag.Bool("version", false, "Print the version and exit.")
39	endpoint = flag.String("endpoint", "unix://tmp/csi.sock", "CSI endpoint")
40	kubeconfig = flag.String("kubeconfig", "", "Absolute path to the kubeconfig file. Required only when running out of cluster.")
41	cloudConfigSecretName = flag.String("cloud-config-secret-name", "azure-cloud-provider", "secret name of cloud config")
42	cloudConfigSecretNamespace = flag.String("cloud-config-secret-namespace", "kube-system", "secret namespace of cloud config")
43	customUserAgent = flag.String("custom-user-agent", "", "custom userAgent")
44	userAgentSuffix = flag.String("user-agent-suffix", "", "userAgent suffix")
45	allowEmptyCloudConfig = flag.Bool("allow-empty-cloud-config", true, "allow running driver without cloud config")
46	kubeAPIQPS = flag.Float64("kube-api-qps", 25.0, "QPS to use while communicating with the kubernetes apiserver.")
47	kubeAPIBurst = flag.Int("kube-api-burst", 50, "Burst to use while communicating with the kubernetes apiserver.")
48	)
49
50	func init() {	×
51	driverOptions.AddFlags()	×
52	}	×
53
54	func main() {	×
55	klog.InitFlags(nil)	×
56	_ = flag.Set("logtostderr", "true")	×
57	flag.Parse()	×
58	if *version {	×
59	info, err := blob.GetVersionYAML(driverOptions.DriverName)	×
60	if err != nil {	×
61	klog.Fatalln(err)	×
62	}	×
63	fmt.Println(info) // nolint	×
64	os.Exit(0)	×
65	}
66
67	exportMetrics()	×
68	handle()	×
69	os.Exit(0)	×
70	}
71
72	func handle() {	×
73	userAgent := blob.GetUserAgent(driverOptions.DriverName, customUserAgent, userAgentSuffix)	×
74	klog.V(2).Infof("driver userAgent: %s", userAgent)	×
75		×
76	kubeClient, err := util.GetKubeClient(kubeconfig, kubeAPIQPS, *kubeAPIBurst, userAgent)	×
77	if err != nil {	×
78	klog.Warningf("failed to get kubeClient, error: %v", err)	×
79	}	×
80
81	cloud, err := blob.GetCloudProvider(context.Background(), kubeClient, driverOptions.NodeID, cloudConfigSecretName, cloudConfigSecretNamespace, userAgent, *allowEmptyCloudConfig)	×
82	if err != nil {	×
83	klog.Fatalf("failed to get Azure Cloud Provider, error: %v", err)	×
84	}	×
85	klog.V(2).Infof("cloud: %s, location: %s, rg: %s, VnetName: %s, VnetResourceGroup: %s, SubnetName: %s", cloud.Cloud, cloud.Location, cloud.ResourceGroup, cloud.VnetName, cloud.VnetResourceGroup, cloud.SubnetName)	×
86		×
87	driver := blob.NewDriver(&driverOptions, kubeClient, cloud)	×
88	if driver == nil {	×
89	klog.Fatalln("Failed to initialize Azure Blob Storage CSI driver")	×
90	}	×
91	if err := driver.Run(context.Background(), *endpoint); err != nil {	×
92	klog.Fatalf("Failed to run Azure Blob Storage CSI driver: %v", err)	×
93	}	×
94	}
95
96	func exportMetrics() {	×
97	if *metricsAddress == "" {	×
98	return	×
99	}	×
100	l, err := net.Listen("tcp", *metricsAddress)	×
101	if err != nil {	×
102	klog.Warningf("failed to get listener for metrics endpoint: %v", err)	×
103	return	×
104	}	×
105	serve(context.Background(), l, serveMetrics)	×
106	}
107
108	func serve(_ context.Context, l net.Listener, serveFunc func(net.Listener) error) {	×
109	path := l.Addr().String()	×
110	klog.V(2).Infof("set up prometheus server on %v", path)	×
111	go func() {	×
112	defer l.Close()	×
113	if err := serveFunc(l); err != nil {	×
114	klog.Fatalf("serve failure(%v), address(%v)", err, path)	×
115	}	×
116	}()
117	}
118
119	func serveMetrics(l net.Listener) error {	×
120	m := http.NewServeMux()	×
121	m.Handle("/metrics", legacyregistry.Handler()) //nolint, because azure cloud provider uses legacyregistry currently	×
122	return trapClosedConnErr(http.Serve(l, m))	×
123	}	×
124
125	func trapClosedConnErr(err error) error {	×
126	if err == nil {	×
127	return nil	×
128	}	×
129	if strings.Contains(err.Error(), "use of closed network connection") {	×
130	return nil	×
131	}	×
132	return err	×
133	}

kubernetes-sigs / blob-csi-driver / 8603508478

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous