home/kt-connect
2
0
Fork 0
mirror of https://github.com/wahyd4/kt-connect.git synced 2026-08-09 05:16:02 +10:00
Code Issues Packages Projects Releases Wiki Activity

improve: use log with level relace printf

Browse Source
This commit is contained in:
yunlzheng
2020-03-07 19:55:27 +08:00
parent 44730d4e70
commit bb2e24fd36
5 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/kt/cluster/helper.go
+2 -2
View File
@@ -33,7 +33,7 @@ func getPodCirds(clientset *kubernetes.Clientset, podCIDR string) (cidrs []strin
nodeList, err := clientset.CoreV1().Nodes().List(metav1.ListOptions{})
if err != nil {
log.Printf("Fails to get node info of cluster")
log.Error().Msgf("Fails to get node info of cluster")
return nil, err
}
@@ -61,7 +61,7 @@ func getPodCirdByInstance(clientset *kubernetes.Clientset) (samples mapset.Set,
log.Info().Msgf("Fail to get pod cidr from node.Spec.PODCIDR, try to get with pod sample")
podList, err := clientset.CoreV1().Pods("").List(metav1.ListOptions{})
if err != nil {
log.Printf("Fails to get service info of cluster")
log.Error().Msg("Fails to get service info of cluster")
return
}
pkg/kt/cluster/kubernetes.go
+3 -3
View File
@@ -18,16 +18,16 @@ import (
// Scale scale deployment to
func (k *Kubernetes) Scale(deployment *appV1.Deployment, replicas *int32) (err error) {
log.Printf("scale deployment %s to %d\n", deployment.GetObjectMeta().GetName(), *replicas)
log.Info().Msgf("scale deployment %s to %d\n", deployment.GetObjectMeta().GetName(), *replicas)
client := k.Clientset.AppsV1().Deployments(deployment.GetObjectMeta().GetNamespace())
deployment.Spec.Replicas = replicas
d, err := client.Update(deployment)
if err != nil {
log.Printf("%s Fails scale deployment %s to %d\n", err.Error(), deployment.GetObjectMeta().GetName(), *replicas)
log.Error().Msgf("%s Fails scale deployment %s to %d\n", err.Error(), deployment.GetObjectMeta().GetName(), *replicas)
return
}
log.Printf(" * %s (%d replicas) success", d.Name, *d.Spec.Replicas)
log.Info().Msgf(" * %s (%d replicas) success", d.Name, *d.Spec.Replicas)
return
}
pkg/kt/connect/inbound.go
+1 -1
View File
@@ -33,7 +33,7 @@ func (s *Shadow) Inbound(exposePort, podName, remoteIP string) (err error) {
if err != nil {
return
}
log.Printf("SSH Remote port-forward POD %s 22 to 127.0.0.1:%d starting\n", remoteIP, localSSHPort)
log.Info().Msgf("SSH Remote port-forward POD %s 22 to 127.0.0.1:%d starting\n", remoteIP, localSSHPort)
localPort := exposePort
remotePort := exposePort
ports := strings.SplitN(exposePort, ":", 2)
pkg/kt/exec/run.go
+2 -2
View File
@@ -22,7 +22,7 @@ func BackgroundRun(cmd *exec.Cmd, name string, debug bool) (err error) {
runCmd(cmd, name, debug)
go func() {
err = cmd.Wait()
log.Printf("%s finished", name)
log.Info().Msgf("%s finished", name)
}()
return
}
@@ -52,6 +52,6 @@ func runCmd(cmd *exec.Cmd, name string, debug bool) (err error) {
time.Sleep(time.Duration(2) * time.Second)
pid := cmd.Process.Pid
log.Printf("%s start at pid: %d", name, pid)
log.Info().Msgf("%s start at pid: %d", name, pid)
return
}
pkg/kt/util/system.go
+1 -1
View File
@@ -51,7 +51,7 @@ func init() {
func PrepareSSHPrivateKey() (err error) {
err = ioutil.WriteFile(PrivateKeyPath(), pk, 400)
if err != nil {
log.Printf("Fails create temp ssh private key")
log.Error().Msgf("Fails create temp ssh private key")
}
return
}