managers

Documentation

Index

• Constants
• Variables
• func GetManagers(namespace string, currentSystems map[string]*rest.FSRestClient) (map[string]*rest.FSRestClient, error)

Constants

const (
	SecretUsernameKey = "username"
	SecretPasswordKey = "password"
	SecretMgmtKey     = "management_address"
)

Variables

var CheckRestClientState = func(restClient *rest.FSRestClient, mgr drivermanager.DriverManager, err error) error {
	if err != nil {
		var _ = mgr.UpdateCondition(operatorapi.ExporterReady, false, drivermanager.AuthFailure, drivermanager.AuthFailureMessage)
		log.Errorf("Fail to initialize rest client for %s, error: %s", mgr.GetSubsystemName(), err)
		return err
	}

	var valid bool
	valid, err = restClient.CheckVersion()
	if err != nil {
		log.Errorf("Flash system version check hit error: %s", err)
		var _ = mgr.UpdateCondition(operatorapi.ExporterReady, false, drivermanager.RestFailure, drivermanager.RestErrorMessage)
		return err
	} else if !valid {
		log.Error("Flash system version invalid")
		var _ = mgr.UpdateCondition(operatorapi.ExporterReady, false, drivermanager.VersionCheckFailed, drivermanager.VersionCheckErrMessage)
		return fmt.Errorf("flash system version invalid")
	}

	valid, err = restClient.CheckUserRole()
	if err != nil {
		log.Errorf("Flash system user role check hit errors: %s", err)
		var _ = mgr.UpdateCondition(operatorapi.ExporterReady, false, drivermanager.RestFailure, drivermanager.RestErrorMessage)
		return err
	} else if !valid {
		log.Error("Flash system user role invalid")
		var _ = mgr.UpdateCondition(operatorapi.ExporterReady, false, drivermanager.RoleCheckFailed, drivermanager.RoleCheckErrMessage)
		return fmt.Errorf("flash system user role invalid")
	}

	{
		var _ = mgr.UpdateCondition(operatorapi.ExporterReady, true, "", "")
		var _ = mgr.UpdateCondition(operatorapi.StorageClusterReady, true, "", "")
		log.Info("Exporter check done, ready to serve")
		return nil
	}
}

var GetFscMap = func() (map[string]operutil.FlashSystemClusterMapContent, error) {
	return operutil.ReadPoolConfigMapFile()
}

var GetStorageCredentials = func(d *drivermanager.DriverManager) (rest.Config, error) {
	secret := &corev1.Secret{}
	err := d.Client.Get(context.TODO(),
		types.NamespacedName{
			Namespace: d.GetNamespaceName(),
			Name:      d.GetSecretName()},
		secret)
	if err != nil {
		return rest.Config{}, err
	}

	restConfig := rest.Config{
		Host:     string(secret.Data[SecretMgmtKey]),
		Username: string(secret.Data[SecretUsernameKey]),
		Password: string(secret.Data[SecretPasswordKey]),
	}

	return restConfig, nil
}

var Scheme = runtime.NewScheme()

Functions

func GetManagers

func GetManagers(namespace string, currentSystems map[string]*rest.FSRestClient) (map[string]*rest.FSRestClient, error)