INNER CODE UNIT · Go

createK8sClient

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

func createK8sClient(qps float32) (kubernetes.Interface, error) {
	k8sConfig := k8sutils.GenerateK8sConfig()

	k8sClient, err := k8sutils.GenerateK8sClient(k8sConfig, qps)
	if err != nil {
		setupLog.Error(err, "unable to create k8s client")
		return nil, err
	}

	return k8sClient, nil
}

// setupControllers sets up all controllers
func setupControllers(mgr ctrl.Manager, k8sClient kubernetes.Interface, maxConcurrentReconciles int) error {
	// Get max concurrent reconciles from environment
	maxConcurrentReconciles = envs.GetMaxConcurrentReconciles(maxConcurrentReconciles)

	healer := redis.NewHealer(k8sClient)

View source record →