[core] Pass any var ddsched_<varname> to DD scheduler as param <varname>

Author: teo

core/integration/ddsched/plugin.go

@@ -33,6 +33,7 @@ import (
 	"fmt"
 	"net/url"
 	"strconv"
+	"strings"
 	"time"
 
 	"github.com/AliceO2Group/Control/common/utils/uid"
@@ -199,13 +200,24 @@ func (p *Plugin) ObjectStack(data interface{}) (stack map[string]interface{}) {
 			}
 		})
 
+		partitionParams := make(map[string]string)
+
+		// FIXME: this only copies over vars prefixed with "ddsched_"
+		// Figure out a better way!
+		for k, v := range varStack {
+			if strings.HasPrefix(k, "ddsched_") && k != "ddsched_enabled" {
+				partitionParams[strings.TrimPrefix(k, "ddsched_")] = v
+			}
+		}
+
 		in := ddpb.PartitionInitRequest{
 			PartitionInfo: &ddpb.PartitionInfo{
 				EnvironmentId: envId,
 				PartitionId:   envId,
 			},
 			StfbHostIdMap: p.stfbHostIdMap,
 			StfsHostIdMap: p.stfsHostIdMap,
+			PartitionParams: partitionParams,
 		}
 		if p.ddSchedClient == nil {
 			log.WithError(fmt.Errorf("DD scheduler plugin not initialized")).

core/integration/ddsched/protos/ddsched.pb.go

@@ -80,6 +80,9 @@ message PartitionInitRequest {
   //        4. discovery-ids are used for debugging purposes. It would be helpful if the values assigned by AliECS
   //           provided human-readable information. E.g. an id for the first StfSender on flp009 could be:
   //           "stfs-flp009#0-<short_partition_id>".
+
+  // [optional] parameters passed from AliECS to TfScheduler
+  map<string, string> partition_params = 4;
 }
 
 // Request for partition to be terminated.