• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

kubernetes-sigs / blob-csi-driver / 12793063300

15 Jan 2025 04:48PM UTC coverage: 77.35%. Remained the same
12793063300

Pull #1795

github

web-flow
chore(deps): bump google.golang.org/protobuf from 1.36.2 to 1.36.3

Bumps google.golang.org/protobuf from 1.36.2 to 1.36.3.

---
updated-dependencies:
- dependency-name: google.golang.org/protobuf
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>
Pull Request #1795: chore(deps): bump google.golang.org/protobuf from 1.36.2 to 1.36.3

2271 of 2936 relevant lines covered (77.35%)

7.44 hits per line

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

0.0
/pkg/blobfuse-proxy/main.go
1
/*
2
Copyright 2021 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
        "flag"
21
        "net"
22
        "os"
23

24
        "k8s.io/klog/v2"
25

26
        "sigs.k8s.io/blob-csi-driver/pkg/blobfuse-proxy/server"
27
        csicommon "sigs.k8s.io/blob-csi-driver/pkg/csi-common"
28
)
29

30
var (
31
        blobfuseProxyEndpoint = flag.String("blobfuse-proxy-endpoint", "unix://tmp/blobfuse-proxy.sock", "blobfuse-proxy endpoint")
32
)
33

34
func main() {
×
35
        klog.InitFlags(nil)
×
36
        _ = flag.Set("logtostderr", "true")
×
37
        flag.Parse()
×
38
        proto, addr, err := csicommon.ParseEndpoint(*blobfuseProxyEndpoint)
×
39
        if err != nil {
×
40
                klog.Fatalf("failed to  parse endpoint %v", err.Error())
×
41
        }
×
42

43
        if proto == "unix" {
×
44
                addr = "/" + addr
×
45
                if err := os.Remove(addr); err != nil && !os.IsNotExist(err) {
×
46
                        klog.Fatalf("Failed to remove %s, error: %s", addr, err.Error())
×
47
                }
×
48
        }
49

50
        listener, err := net.Listen(proto, addr)
×
51
        if err != nil {
×
52
                klog.Fatal("cannot start server:", err)
×
53
        }
×
54

55
        mountServer := server.NewMountServiceServer()
×
56

×
57
        klog.V(2).Infof("Listening for connections on address: %v\n", listener.Addr())
×
58
        if err = server.RunGRPCServer(mountServer, false, listener); err != nil {
×
59
                klog.Fatalf("Error running grpc server %v. Error: %v", listener.Addr(), err)
×
60
        }
×
61
}
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc