driver

Documentation

Index

• Constants
• Variables
• type DriverManager
  • func NewManager(scheme *runtime.Scheme, namespace string, fscName string, ...) (DriverManager, error)
  • func (d *DriverManager) GetClient() client.Client
  • func (d *DriverManager) GetFlashSystemClusterCR() (*operatorapi.FlashSystemCluster, error)
  • func (d *DriverManager) GetNamespaceName() string
  • func (d *DriverManager) GetPoolNames() map[string]int
  • func (d *DriverManager) GetSCNameByPoolName(poolName string) []string
  • func (d *DriverManager) GetSecretName() string
  • func (d *DriverManager) GetSubsystemName() string
  • func (d *DriverManager) Ready()
  • func (d *DriverManager) SendK8sEvent(eventtype, reason, message string) error
  • func (d *DriverManager) UpdateCondition(conditionType operatorapi.ConditionType, ready bool, reason string, ...) error
  • func (d *DriverManager) UpdatePoolMap(scPool map[string]string)

Constants

const (
	AuthFailure        = "AuthFailure"
	AuthSuccess        = "AuthSuccess"
	VersionCheckFailed = "VersionCheckFailed"
	RoleCheckFailed    = "RoleCheckFailed"
	RestFailure        = "RestFailure"
	ClusterNotOnline   = "ClusterNotOnline"
)

Reason

const (
	AuthFailureMessage     = "Authentication to flash system rest server failed"
	AuthSuccessMessage     = "Authentication to flash system rest server succeed"
	VersionCheckErrMessage = "Flash system code level too low, need >= 8.3.1"
	RoleCheckErrMessage    = "User role need to be Administrator, SecurityAdmin or RestrictedAdmin"
	RestErrorMessage       = "Rest server hit unexpected error"
	ClusterErrMessage      = "Flash system cluster is not online"
	ExporterReadyMessage   = "Flash system exporter is ready"
)

Message

const INIT_POOL_ID = -1

Variables

var K8SClient client.Client = nil

Types

type DriverManager

type DriverManager struct {
	client.Client

	SystemName string
	// contains filtered or unexported fields
}

func NewManager

func NewManager(scheme *runtime.Scheme, namespace string, fscName string, fscScSecretMap operutil.FlashSystemClusterMapContent) (DriverManager, error)

func (*DriverManager) GetClient

func (d *DriverManager) GetClient() client.Client

func (*DriverManager) GetFlashSystemClusterCR

func (d *DriverManager) GetFlashSystemClusterCR() (*operatorapi.FlashSystemCluster, error)

func (*DriverManager) GetNamespaceName

func (d *DriverManager) GetNamespaceName() string

func (*DriverManager) GetPoolNames

func (d *DriverManager) GetPoolNames() map[string]int

func (*DriverManager) GetSCNameByPoolName

func (d *DriverManager) GetSCNameByPoolName(poolName string) []string

func (*DriverManager) GetSecretName

func (d *DriverManager) GetSecretName() string

func (*DriverManager) GetSubsystemName

func (d *DriverManager) GetSubsystemName() string

func (*DriverManager) Ready

func (d *DriverManager) Ready()

Add helper function to expose the state for mockup

func (*DriverManager) SendK8sEvent

func (d *DriverManager) SendK8sEvent(eventtype, reason, message string) error

func (*DriverManager) UpdateCondition

func (d *DriverManager) UpdateCondition(conditionType operatorapi.ConditionType, ready bool, reason string, message string) error

func (*DriverManager) UpdatePoolMap

func (d *DriverManager) UpdatePoolMap(scPool map[string]string)