main.go

package main

import (
	"flag"
	"os"
	"path"
	"time"

	log "github.com/lijiansgit/go/libs/log4go"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
)

var (
	clientset  *kubernetes.Clientset
	kubeConf   string
	consulPath string
	verbose    bool
	config     *Config
)

func init() {
	defaultKubeConf := path.Join(os.Getenv("HOME"), ".kube/config")
	flag.StringVar(&kubeConf, "c", defaultKubeConf, "kubernetes client config file path")
	flag.StringVar(&consulPath, "cp", defaultConsulPath, "kubernetes base config consul path")
	flag.BoolVar(&verbose, "v", false, "log verbose")
}

func main() {
	flag.Parse()

	startTime := time.Now()

	if verbose == true {
		log.AddFilter("stdout", log.DEBUG, log.NewConsoleLogWriter())
	} else {
		log.AddFilter("stdout", log.INFO, log.NewConsoleLogWriter())
	}
	defer log.Close()

	var err error
	config, err = NewConfig()
	if err != nil {
		panic(err)
	}

	kconf, err := clientcmd.BuildConfigFromFlags("", kubeConf)
	if err != nil {
		panic(err)
	}

	clientset, err = kubernetes.NewForConfig(kconf)
	if err != nil {
		panic(err)
	}

	log.Debug("Connect Kubernets: %s OK", kconf.Host)

	release()

	log.Debug("Connect Kubernets: %s END", kconf.Host)
	log.Info("Run Time: %v", time.Since(startTime))
}