Added deployment of predeployment commands for vSwarm benchmarks

Signed-off-by: aryans1204 <arshar1204@gmail.com>

Author: aryans1204

data/traces/example/mapper_output.json

@@ -1,14 +1,14 @@
 {
     "c13acdc7567b225971cef2416a3a2b03c8a4d8d154df48afe75834e2f5c59ddf": {
-        "proxy-function": "video-processing-python-10"
+        "proxy-function": "cartservice"
     },
     "a2faad786b3c813b12ce57d349d5e62f6d0f22ceecfa86cd72a962853383b600": {
         "proxy-function": "image-rotate-go-11"
     },
     "7dc5aeabc131669912e8c793c8925cc9928321f45f13a4af031592b4611630d7": {
-        "proxy-function": "video-processing-python-100"
+        "proxy-function": "video-processing-python-10"
     },
     "ae8a1640fa932024f59b38a0b001808b5c64612bd60c6f3eb80ba9461ba2d091": {
-        "proxy-function": "video-processing-python-10"
+        "proxy-function": "video-processing-python-100"
     }
 }

pkg/common/trace_types.go

@@ -99,11 +99,12 @@ type Function struct {
 
 	ColdStartBusyLoopMs int
 
-	CPURequestsMilli  int
-	MemoryRequestsMiB int
-	CPULimitsMilli    int
-	YAMLPath          string
-	Specification     *FunctionSpecification
+	CPURequestsMilli      int
+	MemoryRequestsMiB     int
+	CPULimitsMilli        int
+	YAMLPath              string
+	PredeploymentCommands []string
+	Specification         *FunctionSpecification
 }
 
 type Node struct {

pkg/driver/deployment/knative.go

@@ -3,15 +3,16 @@ package deployment
 import (
 	"bytes"
 	"fmt"
-	log "github.com/sirupsen/logrus"
-	"github.com/vhive-serverless/loader/pkg/common"
-	"github.com/vhive-serverless/loader/pkg/config"
 	"math"
 	"os/exec"
 	"regexp"
 	"runtime"
 	"strconv"
 	"sync"
+
+	log "github.com/sirupsen/logrus"
+	"github.com/vhive-serverless/loader/pkg/common"
+	"github.com/vhive-serverless/loader/pkg/config"
 )
 
 const (
@@ -94,7 +95,11 @@ func knativeDeploySingleFunction(function *common.Function, yamlPath string, isP
 		// for rps mode use the average runtime in milliseconds to determine how many requests a pod can process per
 		// second, then round to an integer as that is what the knative config expects
 	}
-
+	for _, command := range function.PredeploymentCommands {
+		_ = exec.Command(
+			command,
+		)
+	}
 	cmd := exec.Command(
 		"bash",
 		"./pkg/driver/deployment/knative.sh",

pkg/trace/mapper_trace_parser.go

@@ -48,14 +48,15 @@ func (p *MapperTraceParser) extractFunctions(mapperOutput map[string]map[string]
 		hashFunction := invocationStats.HashFunction
 		proxyFunction := mapperOutput[hashFunction]["proxy-function"]
 		yamlPath := deploymentInfo[proxyFunction].YamlLocation
-
+		predeploymentCommands := deploymentInfo[proxyFunction].PredeploymentCommands
 		function := &common.Function{
 			Name: fmt.Sprintf("%s-%d-%d", proxyFunction, i, p.functionNameGenerator.Uint64()),
 
-			InvocationStats: &invocationStats,
-			RuntimeStats:    runtimeByHashFunction[hashFunction],
-			MemoryStats:     memoryByHashFunction[hashFunction],
-			YAMLPath:        yamlPath,
+			InvocationStats:       &invocationStats,
+			RuntimeStats:          runtimeByHashFunction[hashFunction],
+			MemoryStats:           memoryByHashFunction[hashFunction],
+			YAMLPath:              yamlPath,
+			PredeploymentCommands: predeploymentCommands,
 		}
 
 		result = append(result, function)

pkg/trace/mapper_trace_parser_test.go

@@ -14,7 +14,9 @@ func TestMapperParserWrapper(t *testing.T) {
 	}
 	if !strings.HasPrefix(functions[0].Name, "cartservice") ||
 		functions[0].InvocationStats == nil ||
-		functions[0].YAMLPath != "workloads/container/yamls/online-shop/kn-cartservice.yaml" {
+		functions[0].YAMLPath != "workloads/container/yamls/online-shop/kn-cartservice.yaml" ||
+		len(functions[0].PredeploymentCommands) != 1 ||
+		functions[0].PredeploymentCommands[0] != "kubectl apply -f workloads/container/yamls/online-shop/database.yaml" {
 		t.Error("Unexpected results.")
 	}
 }

workloads/container/yamls.tar.gz

@@ -1,3 +1,3 @@
 version https://git-lfs.github.com/spec/v1
-oid sha256:f9668c376425a77a640153d8a0b164fc123b90c22d65cc5b382e4c3f529ec125
-size 24156
+oid sha256:abf8c5e3bc3ba592fb429a4ecbe89a53c235fa51015455d4669568fc9eecbe97
+size 24189