Changes to beforeserve to pick up storage array labels and parameters if provided

service/service.go

@@ -147,6 +147,13 @@ type Opts struct {
 	PodmonPort                 string // to indicates the port to be used for exposing podmon API health
 	PodmonPollingFreq          string // indicates the polling frequency to check array connectivity
 	TLSCertDir                 string
+	StorageArrays              []StorageArrayConfig
+}
+
+// StorageArrayConfig represents the configuration of a storage array in the config file
+type StorageArrayConfig struct {
+	Labels     map[string]interface{} `yaml:"labels,omitempty"`
+	Parameters map[string]interface{} `yaml:"parameters,omitempty"`
 }
 
 // NodeConfig defines rules for given node
@@ -430,6 +437,29 @@ func (s *service) BeforeServe(
 		} else {
 			log.Println("No management servers found.")
 		}
+
+		// Access the storagearrays key (which is a slice of maps)
+		storageArrays := secretParams.Get("storagearrays").([]interface{})
+		// Ensure there's at least one server and extract labels and parameters if any
+		if len(storageArrays) == 0 {
+			log.Println("No storage arrays found.")
+		} else {
+			// cycle through each storage array and extract Labels and Parameters maps
+			for _, storageArray := range storageArrays {
+				storageArrayMap := storageArray.(map[string]interface{})
+				if storageArrayMap["labels"] == nil {
+					storageArrayMap["labels"] = make(map[string]interface{})
+				}
+				if storageArrayMap["parameters"] == nil {
+					storageArrayMap["parameters"] = make(map[string]interface{})
+				}
+				storageArrayConfig := StorageArrayConfig{
+					Labels:     storageArrayMap["labels"].(map[string]interface{}),
+					Parameters: storageArrayMap["parameters"].(map[string]interface{}),
+				}
+				opts.StorageArrays = append(opts.StorageArrays, storageArrayConfig)
+			}
+		}
 	}
 
 	if chapuser, ok := csictx.LookupEnv(ctx, EnvISCSICHAPUserName); ok {