INNER CODE UNIT · Go

getK8sClient

mariadb-operator/mariadb-operator · cmd/init/main.go:56

func getK8sClient() (client.Client, error) {
	restConfig, err := ctrl.GetConfig()
	if err != nil {
		return nil, fmt.Errorf("error getting REST config: %v", err)
	}
	k8sClient, err := client.New(restConfig, client.Options{Scheme: scheme})
	if err != nil {
		return nil, fmt.Errorf("error creating Kubernetes client: %v", err)
	}
	return k8sClient, nil
}

func cleanupStateFile(fm *filemanager.FileManager, file string) error {
	exists, err := fm.StateFileExists(file)
	if err != nil {
		return fmt.Errorf("error checking if %s file exists: %v", file, err)
	}
	if exists {

View source record →