smoke: support node image

.github/workflows/benchmark.yml

@@ -73,6 +73,8 @@ jobs:
         include:
           - image: wordpress
             tag: 6.1.1
+          - image: node
+            tag: 19.8
     steps:
     - name: Checkout
       uses: actions/checkout@v3
@@ -109,6 +111,8 @@ jobs:
         include:
           - image: wordpress
             tag: 6.1.1
+          - image: node
+            tag: 19.8
     steps:
     - name: Checkout
       uses: actions/checkout@v3
@@ -145,6 +149,8 @@ jobs:
         include:
           - image: wordpress
             tag: 6.1.1
+          - image: node
+            tag: 19.8
     steps:
     - name: Checkout
       uses: actions/checkout@v3
@@ -181,6 +187,8 @@ jobs:
         include:
           - image: wordpress
             tag: 6.1.1
+          - image: node
+            tag: 19.8
     steps:
     - name: Checkout
       uses: actions/checkout@v3
@@ -208,6 +216,9 @@ jobs:
           "wordpress")
               echo "### workload: wait the 80 port response" > $GITHUB_STEP_SUMMARY
             ;;
+            "node")
+              echo "### workload: node index.js; wait the 80 port response" > $GITHUB_STEP_SUMMARY
+            ;;
         esac
         cd benchmark-result
         metric_files=(

smoke/tests/texture/node/index.js

@@ -0,0 +1,10 @@
+// Load the http module to create an http server.
+var http = require('http');
+
+// Configure our HTTP server to respond with Hello World to all requests.
+var server = http.createServer(function (request, response) {
+  response.writeHead(200, {"Content-Type": "text/plain"});
+  response.end("hello\n");
+});
+
+server.listen(80);

smoke/tests/tool/container.go

@@ -13,7 +13,6 @@ import (
 	"net/http"
 	"os"
 	"path/filepath"
-	"strings"
 	"testing"
 	"time"
 
@@ -29,10 +28,17 @@ type ContainerMetrics struct {
 
 type RunArgs struct {
 	WaitURL            string
+	Arg                string
+	Mount              mountPath
 	BaselineReadCount  map[string]uint64
 	BaselineReadAmount map[string]uint64
 }
 
+type mountPath struct {
+	source string
+	target string
+}
+
 var URL_WAIT = map[string]RunArgs{
 	"wordpress": {
 		WaitURL: "http://localhost:80",
@@ -47,27 +53,33 @@ var URL_WAIT = map[string]RunArgs{
 			"zran":         79836339,
 		},
 	},
+	"node": {
+		WaitURL: "http://localhost:80",
+		Arg:     "node /src/index.js",
+		Mount: mountPath{
+			source: "tests/texture/node",
+			target: "/src",
+		},
+	},
 }
 
-var supportContainerImages = []string{"wordpress"}
-
 // SupportContainerImage help to check if we support the image or not
 func SupportContainerImage(image string) bool {
-	return contains(supportContainerImages, image)
-}
-
-func contains(slice []string, value string) bool {
-	for _, v := range slice {
-		if strings.Contains(v, value) {
-			return true
-		}
-	}
-	return false
+	_, ok := URL_WAIT[image]
+	return ok
 }
 
 // runUrlWaitContainer run Contaienr util geting http response from WaitUrl
 func runUrlWaitContainer(t *testing.T, image string, containerName string, runArgs RunArgs) {
-	cmd := fmt.Sprintf("sudo nerdctl --insecure-registry --snapshotter nydus run -d --net=host --name=%s %s", containerName, image)
+	cmd := "sudo nerdctl --insecure-registry --snapshotter nydus run -d --net=host"
+	if runArgs.Mount.source != "" {
+		currentDir, err := os.Getwd()
+		if err != nil {
+			t.Fatalf("can't get rooted path name")
+		}
+		cmd += fmt.Sprintf(" --volume %s:%s", filepath.Join(currentDir, runArgs.Mount.source), runArgs.Mount.target)
+	}
+	cmd += fmt.Sprintf(" --name=%s %s %s", containerName, image, runArgs.Arg)
 	RunWithoutOutput(t, cmd)
 	for {
 		resp, err := http.Get(runArgs.WaitURL)
@@ -103,14 +115,16 @@ func RunContainerWithBaseline(t *testing.T, image string, containerName string,
 // RunContainer and return container metric
 func RunContainer(t *testing.T, image string, containerName string) *ContainerMetrics {
 	var containerMetic ContainerMetrics
+	startTime := time.Now()
+
+	// runContainer
 	args, ok := URL_WAIT[ImageRepo(t, image)]
 	if ok {
-		startTime := time.Now()
 		runUrlWaitContainer(t, image, containerName, args)
-		endTime := time.Now()
-		containerMetic.E2ETime = endTime.Sub(startTime)
 		defer clearContainer(t, image, containerName)
 	}
+
+	containerMetic.E2ETime = time.Since(startTime)
 	backendMetrics, err := getContainerBackendMetrics(t)
 	if err != nil {
 		t.Logf(err.Error())