未验证 提交 4d386501 编写于 作者: M Medya Ghazizadeh 提交者: GitHub

Merge pull request #10955 from azhao155/yzhao/feature/replaceGlogWithKlog

Replace glog with klog
...@@ -27,8 +27,7 @@ import ( ...@@ -27,8 +27,7 @@ import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/client-go/kubernetes" "k8s.io/client-go/kubernetes"
"k8s.io/client-go/rest" "k8s.io/client-go/rest"
"k8s.io/klog/v2"
"github.com/golang/glog"
) )
var ( var (
...@@ -41,11 +40,11 @@ var ( ...@@ -41,11 +40,11 @@ var (
func client() *kubernetes.Clientset { func client() *kubernetes.Clientset {
config, err := rest.InClusterConfig() config, err := rest.InClusterConfig()
if err != nil { if err != nil {
glog.Fatal(err) klog.Fatal(err)
} }
clientset, err := kubernetes.NewForConfig(config) clientset, err := kubernetes.NewForConfig(config)
if err != nil { if err != nil {
glog.Fatal(err) klog.Fatal(err)
} }
return clientset return clientset
} }
...@@ -55,14 +54,14 @@ func client() *kubernetes.Clientset { ...@@ -55,14 +54,14 @@ func client() *kubernetes.Clientset {
func apiServerCert(clientset *kubernetes.Clientset) []byte { func apiServerCert(clientset *kubernetes.Clientset) []byte {
c, err := clientset.CoreV1().ConfigMaps("kube-system").Get(context.TODO(), "extension-apiserver-authentication", metav1.GetOptions{}) c, err := clientset.CoreV1().ConfigMaps("kube-system").Get(context.TODO(), "extension-apiserver-authentication", metav1.GetOptions{})
if err != nil { if err != nil {
glog.Fatal(err) klog.Fatal(err)
} }
pem, ok := c.Data["requestheader-client-ca-file"] pem, ok := c.Data["requestheader-client-ca-file"]
if !ok { if !ok {
glog.Fatalf(fmt.Sprintf("cannot find the ca.crt in the configmap, configMap.Data is %#v", c.Data)) klog.Fatalf(fmt.Sprintf("cannot find the ca.crt in the configmap, configMap.Data is %#v", c.Data))
} }
glog.Info("client-ca-file=", pem) klog.Info("client-ca-file=", pem)
return []byte(pem) return []byte(pem)
} }
...@@ -73,7 +72,7 @@ func configTLS(clientset *kubernetes.Clientset, serverCert []byte, serverKey []b ...@@ -73,7 +72,7 @@ func configTLS(clientset *kubernetes.Clientset, serverCert []byte, serverKey []b
sCert, err := tls.X509KeyPair(serverCert, serverKey) sCert, err := tls.X509KeyPair(serverCert, serverKey)
if err != nil { if err != nil {
glog.Fatal(err) klog.Fatal(err)
} }
return &tls.Config{ return &tls.Config{
Certificates: []tls.Certificate{sCert}, Certificates: []tls.Certificate{sCert},
...@@ -89,7 +88,7 @@ func selfRegistration(clientset *kubernetes.Clientset, caCert []byte) { ...@@ -89,7 +88,7 @@ func selfRegistration(clientset *kubernetes.Clientset, caCert []byte) {
_, err := client.Get(context.TODO(), webhookName, metav1.GetOptions{}) _, err := client.Get(context.TODO(), webhookName, metav1.GetOptions{})
if err == nil { if err == nil {
if err2 := client.Delete(context.TODO(), webhookName, metav1.DeleteOptions{}); err2 != nil { if err2 := client.Delete(context.TODO(), webhookName, metav1.DeleteOptions{}); err2 != nil {
glog.Fatal(err2) klog.Fatal(err2)
} }
} }
var failurePolicy v1.FailurePolicyType = v1.Fail var failurePolicy v1.FailurePolicyType = v1.Fail
...@@ -142,7 +141,7 @@ func selfRegistration(clientset *kubernetes.Clientset, caCert []byte) { ...@@ -142,7 +141,7 @@ func selfRegistration(clientset *kubernetes.Clientset, caCert []byte) {
}, },
} }
if _, err := client.Create(context.TODO(), webhookConfig, metav1.CreateOptions{}); err != nil { if _, err := client.Create(context.TODO(), webhookConfig, metav1.CreateOptions{}); err != nil {
glog.Fatalf("Client creation failed with %s", err) klog.Fatalf("Client creation failed with %s", err)
} }
log.Println("CLIENT CREATED") log.Println("CLIENT CREATED")
} }
...@@ -25,7 +25,6 @@ import ( ...@@ -25,7 +25,6 @@ import (
"net/http" "net/http"
"strconv" "strconv"
"github.com/golang/glog"
"github.com/mattbaird/jsonpatch" "github.com/mattbaird/jsonpatch"
v1 "k8s.io/api/admission/v1" v1 "k8s.io/api/admission/v1"
...@@ -33,6 +32,7 @@ import ( ...@@ -33,6 +32,7 @@ import (
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime"
"k8s.io/apimachinery/pkg/runtime/serializer" "k8s.io/apimachinery/pkg/runtime/serializer"
"k8s.io/klog/v2"
"k8s.io/minikube/pkg/minikube/constants" "k8s.io/minikube/pkg/minikube/constants"
) )
...@@ -171,6 +171,6 @@ func main() { ...@@ -171,6 +171,6 @@ func main() {
go selfRegistration(clientset, cacert) go selfRegistration(clientset, cacert)
err := server.ListenAndServeTLS("", "") err := server.ListenAndServeTLS("", "")
if err != nil { if err != nil {
glog.Fatalf("Start https server failed with %s", err) klog.Fatalf("Start https server failed with %s", err)
} }
} }
...@@ -27,7 +27,6 @@ require ( ...@@ -27,7 +27,6 @@ require (
github.com/elazarl/goproxy v0.0.0-20190421051319-9d40249d3c2f github.com/elazarl/goproxy v0.0.0-20190421051319-9d40249d3c2f
github.com/elazarl/goproxy/ext v0.0.0-20190421051319-9d40249d3c2f // indirect github.com/elazarl/goproxy/ext v0.0.0-20190421051319-9d40249d3c2f // indirect
github.com/golang-collections/collections v0.0.0-20130729185459-604e922904d3 github.com/golang-collections/collections v0.0.0-20130729185459-604e922904d3
github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b // indirect
github.com/google/go-cmp v0.5.5 github.com/google/go-cmp v0.5.5
github.com/google/go-containerregistry v0.4.1 github.com/google/go-containerregistry v0.4.1
github.com/google/go-github v17.0.0+incompatible github.com/google/go-github v17.0.0+incompatible
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册