main.go

package main

import (
	"flag"
	nodeporthandler "github.com/crc-org/routes-controller/pkg/node-port-handler"
	routeshandler "github.com/crc-org/routes-controller/pkg/routes-handler"
	routeclientset "github.com/openshift/client-go/route/clientset/versioned"
	log "github.com/sirupsen/logrus"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/clientcmd"
	"os"
	"os/signal"
	"syscall"
)

var (
	master     string
	kubeconfig string
	debug      bool
)

func main() {
	// setup args
	flag.BoolVar(&debug, "debug", false, "Print debug info")
	flag.StringVar(&master, "master", "", "master url")
	flag.StringVar(&kubeconfig, "kubeconfig", "", "absolute path to the kubeconfig file")
	flag.Parse()

	// setup logging
	if debug {
		log.SetLevel(log.DebugLevel)
	}

	// build config
	config, err := clientcmd.BuildConfigFromFlags(master, kubeconfig)
	if err != nil {
		log.Fatal(err)
		return
	}

	// setup informer stop channel
	stop := make(chan struct{})
	defer close(stop)

	// run node port handler
	nodePortClientSet, err := kubernetes.NewForConfig(config)
	if err != nil {
		log.Fatal(err)
		return
	}
	nodePortHandler := nodeporthandler.NodePortHandler(nodePortClientSet)
	go func() {
		nodePortHandler.Run(stop)
	}()

	// run routes handler
	routesClientSet, err := routeclientset.NewForConfig(config)
	if err != nil {
		log.Fatal(err)
		return
	}
	routePortHandler := routeshandler.RoutesHandler(routesClientSet)
	go func() {
		routePortHandler.Run(stop)
	}()

	// block until sigterm
	signalCh := make(chan os.Signal, 1)
	signal.Notify(signalCh, syscall.SIGTERM)
	select {
	case <-signalCh:
		return
	}
}