Function main

cmd/postgres-operator/main.go:179–274

()

}

func main() {
	running, stopRunning := context.WithCancel(context.Background())
	defer stopRunning()

	initVersion()
	initLogging()
	log := logging.FromContext(running)
	log.V(1).Info("debug flag set to true")

	// Start a goroutine that waits for SIGINT or SIGTERM.
	{
		signals := []os.Signal{os.Interrupt, syscall.SIGTERM}
		receive := make(chan os.Signal, len(signals))
		signal.Notify(receive, signals...)
		go func() {
			// Wait for a signal then immediately restore the default signal handlers.
			// After this, a SIGHUP, SIGINT, or SIGTERM causes the program to exit.
			// - https://pkg.go.dev/os/signal#hdr-Default_behavior_of_signals_in_Go_programs
			s := <-receive
			signal.Stop(receive)

			log.Info("received signal from OS", "signal", s.String())
			stopRunning()
		}()
	}

	features := feature.NewGate()
	must(features.Set(os.Getenv("PGO_FEATURE_GATES")))

	running = feature.NewContext(running, features)
	log.Info("feature gates",
		// These are set by the user
		"PGO_FEATURE_GATES", feature.ShowAssigned(running),
		// These are enabled, including features that are on by default
		"enabled", feature.ShowEnabled(running))

	// Initialize OpenTelemetry and flush data when there is a panic.
	otelFinish := need(initOpenTelemetry(running))
	defer func(ctx context.Context) { _ = otelFinish(ctx) }(running)

	tracing.SetDefaultTracer(tracing.New("github.com/CrunchyData/postgres-operator"))

	// Load Kubernetes client configuration and ensure it works.
	config := need(initClient())
	k8s := need(kubernetes.NewDiscoveryRunner(config))
	must(k8s.Read(running))
	log.Info("connected to Kubernetes", "api", k8s.Version().String(), "openshift", k8s.IsOpenShift())

	options := need(initManager(running))

	// Add to the Context that Manager passes to Reconciler.Start, Runnable.Start,
	// and eventually Reconciler.Reconcile.
	options.BaseContext = func() context.Context {
		ctx := context.Background()
		ctx = feature.NewContext(ctx, features)
		ctx = kubernetes.NewAPIContext(ctx, k8s)
		return ctx
	}