feat: add network performance benchmark

.gitignore

@@ -13,7 +13,7 @@ harness
 
 # linux image
 
-images/fio-urunc/bzImage
+images/*-urunc/bzImage
 
 
 # python cache

experiment.yml

@@ -53,3 +53,10 @@ experiments:
         runtime: urunc
         snapshotter: overlayfs
 
+  network:
+    workloads:
+      default:
+        image: networkstatic/iperf3:latest
+      other:
+      - image: docker.io/jimjuniorb/iperf3-urunc:0.3
+        runtime: urunc

images/iperf3-urunc/bunnyfile

@@ -0,0 +1,22 @@
+#syntax=harbor.nbfc.io/nubificus/bunny:latest
+version: v0.1
+
+platforms:
+  framework: linux
+  monitor: qemu
+  architecture: x86
+
+rootfs:
+  from: networkstatic/iperf3:latest
+  type: raw
+  include:
+    - from: harbor.nbfc.io/nubificus/urunit:latest
+      source: /urunit
+      destination: /urunit
+
+kernel:
+  from: local
+  path: bzImage
+
+
+entrypoint: ["/urunit", "/usr/bin/iperf3"]

internal/cli/run.go

@@ -18,6 +18,7 @@ import (
 	harnessruntime "github.com/urunc-dev/evaluation_suite/internal/runtime"
 	runtimeHTTPReadiness "github.com/urunc-dev/evaluation_suite/internal/runtime/httpreadiness"
 	runtimeLifecycle "github.com/urunc-dev/evaluation_suite/internal/runtime/lifecycle"
+	runtimeNetwork "github.com/urunc-dev/evaluation_suite/internal/runtime/network"
 	runtimeStorage "github.com/urunc-dev/evaluation_suite/internal/runtime/storage"
 )
 
@@ -62,6 +63,8 @@ func NewRunCommand() *cobra.Command {
 				return err
 			}
 
+			var adapterFactories []orchestrator.AdapterFactory
+
 			containerdClient, err := containerd.New("/run/containerd/containerd.sock")
 			if err != nil {
 				return err
@@ -70,27 +73,28 @@ func NewRunCommand() *cobra.Command {
 
 			containerdNamespace := namespaces.WithNamespace(cmd.Context(), "default")
 
-			lifecycleAdapterFactory := func(trial plan.Trial) (harnessruntime.Adapter, error) {
-				return runtimeLifecycle.NewAdapter(containerdClient, &containerdNamespace), nil
-			}
-
-			storageAdapterFactory := func(trial plan.Trial) (harnessruntime.Adapter, error) {
-				return runtimeStorage.NewAdapter(containerdClient, &containerdNamespace), nil
-			}
-
-			httpReadinessAdapterFactory := func(trial plan.Trial) (harnessruntime.Adapter, error) {
-				return runtimeHTTPReadiness.NewAdapter(), nil
-			}
-
-			orch := orchestrator.New(
-				lifecycleAdapterFactory,
-				storageAdapterFactory,
-				httpReadinessAdapterFactory,
+			// append the adapters for different experiments
+			adapterFactories = append(adapterFactories,
+				func(trial plan.Trial) (harnessruntime.Adapter, error) {
+					return runtimeLifecycle.NewAdapter(containerdClient, &containerdNamespace), nil
+				},
+				func(trial plan.Trial) (harnessruntime.Adapter, error) {
+					return runtimeStorage.NewAdapter(containerdClient, &containerdNamespace), nil
+				},
+				func(trial plan.Trial) (harnessruntime.Adapter, error) {
+					return runtimeNetwork.NewAdapter(), nil
+				},
+				func(trial plan.Trial) (harnessruntime.Adapter, error) {
+					return runtimeHTTPReadiness.NewAdapter(), nil
+				},
 			)
 
+			orch := orchestrator.New(adapterFactories...)
+
 			result, err := orch.Run(cmd.Context(), p, orchestrator.Options{
 				RunID: runID,
 			})
+
 			if err != nil {
 				return err
 			}
@@ -157,3 +161,12 @@ func NewRunCommand() *cobra.Command {
 
 	return cmd
 }
+
+func planHasExperiment(p *plan.Plan, name string) bool {
+	for _, trial := range p.Trials {
+		if trial.ExperimentName == name {
+			return true
+		}
+	}
+	return false
+}

internal/doctor/checks.go

@@ -38,13 +38,22 @@ func Run(
 		)
 	}
 
+	if hasNetworkExperiment(m) {
+		checkTool(report, "nerdctl", true)
+	}
+
 	checkHostPorts(report, m)
 	checkHostPathVolumes(report, m)
 	checkEnvironmentVisibility(ctx, report)
 
 	return report, nil
 }
 
+func hasNetworkExperiment(m *manifest.Manifest) bool {
+	_, ok := m.Experiments["network"]
+	return ok
+}
+
 func checkManifest(report *Report, m *manifest.Manifest) {
 	if err := manifest.Validate(m); err != nil {
 		report.Add(StatusFail, "manifest", err.Error())