INNER CODE UNIT · Go

runManager

OT-CONTAINER-KIT/redis-operator · internal/cmd/manager/cmd.go:124

func runManager(opts *managerOptions) error {
	// Setup logging
	ctrl.SetLogger(zap.New(zap.UseFlagOptions(&opts.zapOptions)))

	monitoring.RegisterRedisReplicationMetrics()
	monitoring.RegisterRedisClusterMetrics()

	setupLog.Info("setting up v1beta2 scheme")
	scheme.SetupV1beta2Scheme()

	if err := setupFeatureGates(opts.featureGatesString); err != nil {
		return err
	}

	// Config to talk to k8s api server
	cfg := ctrl.GetConfigOrDie()

	configuredQPS := float32(viper.GetFloat64(operator.KubeClientQPSMGRFlag))

View source record →