Function main

main.go:77–219

()

}

func main() {
	var metricsAddr string
	var enableLeaderElection bool
	var probeAddr string
	var interval time.Duration

	flag.StringVar(&metricsAddr, "metrics-bind-address", ":8080", "The address the metric endpoint binds to.")
	flag.StringVar(&probeAddr, "health-probe-bind-address", ":8081", "The address the probe endpoint binds to.")
	flag.BoolVar(&enableLeaderElection, "leader-elect", false,
		"Enable leader election for controller manager. "+
			"Enabling this will ensure there is only one active controller manager.")
	flag.DurationVar(&interval, "builder-check-interval", time.Minute, "The interval used to check the expired builder")

	// Use `--zap-log-level=debug` to enable debug log.
	opts := zap.Options{
		Development:     true,
		StacktraceLevel: zapcore.PanicLevel,
		TimeEncoder:     zapcore.RFC3339TimeEncoder,
	}
	opts.BindFlags(flag.CommandLine)
	flag.Parse()

	ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts)))

	mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
		Scheme:                 scheme,
		MetricsBindAddress:     metricsAddr,
		Port:                   9443,
		HealthProbeBindAddress: probeAddr,
		LeaderElection:         enableLeaderElection,
		LeaderElectionID:       "79f0111e.openfunction.io",
	})
	if err != nil {
		setupLog.Error(err, "unable to start manager")
		os.Exit(1)
	}

	eventsV1Client, err := typedeventsv1.NewForConfig(ctrl.GetConfigOrDie())
	if err != nil {
		setupLog.Error(err, "unable to get events client")
		os.Exit(1)
	}
	eventBroadcaster := events.NewBroadcaster(&events.EventSinkImpl{Interface: eventsV1Client})
	termCh := make(chan os.Signal, 1)
	signal.Notify(termCh, os.Interrupt, syscall.SIGTERM)
	stopCh := make(chan struct{}, 1)
	go func() {
		for {
			select {
			case <-termCh:
				stopCh <- struct{}{}
				return
			}
		}
	}()
	eventBroadcaster.StartRecordingToSink(stopCh)
	eventRecorder := eventBroadcaster.NewRecorder(mgr.GetScheme(), "openfunction")