update api version & glog -> klog

Author: wlan0

cmd/controller-manager/controller-manager.go

@@ -14,7 +14,7 @@ import (
 	"github.com/kubernetes-sigs/container-object-storage-interface-controller/pkg/bucketrequest"
 	bucketcontroller "sigs.k8s.io/container-object-storage-interface-api/controller"
 
-	"github.com/golang/glog"
+	"k8s.io/klog/v2"
 )
 
 var cmd = &cobra.Command{
@@ -29,34 +29,20 @@ var cmd = &cobra.Command{
 }
 
 var kubeConfig string
+var verbosity int
 
 func init() {
 	viper.AutomaticEnv()
 
-	cmd.PersistentFlags().AddGoFlagSet(flag.CommandLine)
-	flag.Set("logtostderr", "true")
-
-	strFlag := func(c *cobra.Command, ptr *string, name string, short string, dfault string, desc string) {
-		c.PersistentFlags().
-			StringVarP(ptr, name, short, dfault, desc)
-	}
-	strFlag(cmd, &kubeConfig, "kubeconfig", "", kubeConfig, "path to kubeconfig file")
-
-	hideFlag := func(name string) {
-		cmd.PersistentFlags().MarkHidden(name)
-	}
-	hideFlag("alsologtostderr")
-	hideFlag("log_backtrace_at")
-	hideFlag("log_dir")
-	hideFlag("logtostderr")
-	hideFlag("master")
-	hideFlag("stderrthreshold")
-	hideFlag("vmodule")
-
-	// suppress the incorrect prefix in glog output
-	flag.CommandLine.Parse([]string{})
+	flag.Set("alsologtostderr", "true")
+	kflags := flag.NewFlagSet("klog", flag.ExitOnError)
+	klog.InitFlags(kflags)
+	
+	cmd.PersistentFlags().AddGoFlagSet(kflags)
+	cmd.PersistentFlags().StringVarP(&kubeConfig, "kubeconfig", "", kubeConfig, "path to kubeconfig file")
+	
+	//flag.CommandLine.Parse([]string{})
 	viper.BindPFlags(cmd.PersistentFlags())
-
 }
 
 func main() {
@@ -72,16 +58,16 @@ func main() {
 	}()
 
 	if err := cmd.ExecuteContext(ctx); err != nil {
-		glog.Fatal(err.Error())
+		klog.Error(err)
 	}
 }
 
 func run(ctx context.Context, args []string) error {
-	ctrl, err := bucketcontroller.NewDefaultObjectStorageController("controller-manager", "leader-lock", 40)
+	ctrl, err := bucketcontroller.NewDefaultObjectStorageController("cosi-controller-manager", "leader-lock", 40)
 	if err != nil {
 		return err
 	}
-	ctrl.AddBucketRequestListener(bucketrequest.NewListener())
+	ctrl.AddBucketRequestListener(bucketrequest.NewBucketRequestListener())
 	ctrl.AddBucketAccessRequestListener(bucketaccessrequest.NewListener())
 	return ctrl.Run(ctx)
 }

go.mod

@@ -3,10 +3,7 @@ module github.com/kubernetes-sigs/container-object-storage-interface-controller
 go 1.15
 
 require (
-	github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b
-	github.com/golang/protobuf v1.4.3 // indirect
 	github.com/google/go-cmp v0.5.2 // indirect
-	github.com/google/uuid v1.1.2 // indirect
 	github.com/gopherjs/gopherjs v0.0.0-20190328170749-bb2674552d8f // indirect
 	github.com/kr/text v0.2.0 // indirect
 	github.com/mailru/easyjson v0.7.6 // indirect
@@ -29,8 +26,8 @@ require (
 	k8s.io/apiextensions-apiserver v0.19.4
 	k8s.io/apimachinery v0.19.4
 	k8s.io/client-go v0.19.4
-	k8s.io/klog/v2 v2.4.0 // indirect
+	k8s.io/klog/v2 v2.4.0
 	k8s.io/kube-openapi v0.0.0-20201113171705-d219536bb9fd // indirect
-	sigs.k8s.io/container-object-storage-interface-api v0.0.0-20210225042325-7c26b4fc1ed9
+	sigs.k8s.io/container-object-storage-interface-api v0.0.0-20210315005104-5e1814a6aedd
 	sigs.k8s.io/controller-tools v0.4.1
 )