Add dalec integration testing

go.mod

@@ -1,6 +1,6 @@
 module sigs.k8s.io/azurelustre-csi-driver
 
-go 1.23.6
+go 1.23.8
 
 require (
 	github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.8.2

test/integration_dalec/integration_dalec_aks.yaml.template

@@ -0,0 +1,26 @@
+---
+apiVersion: v1
+kind: Pod
+metadata:
+  name: azurelustre-integration-dalec
+spec:
+  containers:
+    - name: integration-dalec
+      image: ${IMAGE_NAME}
+      imagePullPolicy: Always
+      command: ["bash", "/test/run_integration_test.sh"]
+      env:
+        - name: MSFT_GOLANG_PKG_VER
+          value: "${MSFT_GOLANG_PKG_VER}"
+      volumeMounts:
+        - name: script-volume
+          mountPath: /test/run_integration_test.sh
+          subPath: run_integration_test.sh
+          readOnly: true
+  volumes:
+    - name: script-volume
+      configMap:
+        name: integration-dalec-script
+  restartPolicy: Never
+  nodeSelector:
+    kubernetes.io/os: linux

test/integration_dalec/run_integration_test.sh

@@ -0,0 +1,105 @@
+#!/bin/bash
+
+# Copyright 2025 The Kubernetes Authors.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#     http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+set -o xtrace
+set -o errexit
+set -o pipefail
+set -o nounset
+
+readonly volname="citest-$(date +%s)"
+readonly volsize="2147483648"
+readonly endpoint="unix:///csi/csi.sock"
+readonly target_path="/tmp/target_path"
+readonly lustre_fs_ip=1.2.3.4
+
+mkdir -p $target_path
+
+apt-get update
+apt-get install -y --no-install-recommends kmod wget git ca-certificates lsb-release gpg curl
+update-ca-certificates
+
+curl -sL https://packages.microsoft.com/keys/microsoft.asc | gpg --dearmor | tee /etc/apt/trusted.gpg.d/microsoft.gpg > /dev/null
+echo "deb [arch=amd64,arm64,armhf] https://packages.microsoft.com/ubuntu/22.04/prod jammy main" | tee /etc/apt/sources.list.d/amlfs.list
+apt-get update
+
+# This should match the version of Go that is used to build the CSI driver
+apt install -y msft-golang=${MSFT_GOLANG_PKG_VER}
+
+go version
+
+lctl network up || true
+echo "$(date -u) Enabled Lustre client kernel modules."
+
+echo "$(date -u) Entering Lustre CSI driver"
+
+echo "$(date -u) install csc"
+go install github.com/dell/gocsi/csc@latest
+export PATH=$PATH:/root/go/bin # add csc to path
+
+mkdir /csi
+echo "$(date -u) Exiting Lustre CSI driver"
+nohup 2>&1 /app/azurelustreplugin --v=5 \
+              --endpoint=${endpoint} \
+              --enable-azurelustre-mock-mount \
+	      --nodeid=integrationtestnode >csi.log &
+
+sleep 5
+
+echo "====: $(date -u) Exiting integration test"
+export X_CSI_DEBUG=true
+echo "====: $(date -u) Create volume test:"
+value="$(csc controller new --endpoint "${endpoint}" \
+                            --cap MULTI_NODE_MULTI_WRITER,mount,,, \
+                            "${volname}" \
+                            --req-bytes "${volsize}" \
+                            --params fs-name=lustrefs,mgs-ip-address="${lustre_fs_ip}")"
+sleep 5
+
+volumeid="$(echo "$value" | awk '{print $1}' | sed 's/"//g')"
+echo "====: $(date -u) Volume ID is $volumeid"
+
+echo "====: $(date -u) Validate volume capabilities test:"
+csc controller validate-volume-capabilities --endpoint "${endpoint}" \
+                                            --cap MULTI_NODE_MULTI_WRITER,mount,,, \
+                                            "$volumeid"
+
+echo "====: $(date -u) stats test:"
+csc node stats --endpoint "${endpoint}" "${volumeid}:${target_path}"
+sleep 2
+
+echo "====: $(date -u) Node publish volume test:"  # Requires routng to amlfs
+csc node publish --endpoint "${endpoint}" \
+                 --cap MULTI_NODE_MULTI_WRITER,mount,,, \
+                 --target-path "${target_path}" \
+                 --vol-context "fs-name=lustrefs,mgs-ip-address=${lustre_fs_ip}" \
+                 "${volumeid}"
+sleep 3
+
+echo "====: $(date -u) Node unpublish volume test:"  # Requires routng to amlfs
+csc node unpublish --endpoint "${endpoint}" \
+                   --target-path "$target_path" \
+                   "$volumeid"
+
+echo "====: $(date -u) Delete volume test:"
+csc controller del --endpoint "${endpoint}" "$volumeid"
+
+echo "====: $(date -u) Identity test:"
+csc identity plugin-info --endpoint "${endpoint}"
+
+echo "====: $(date -u) Node get info test:"
+csc node get-info --endpoint "${endpoint}"
+
+echo "$(date -u) Integration test on aks is completed."

test/integration_dalec/setup_integration_test_dalec.sh

@@ -0,0 +1,31 @@
+#!/bin/bash
+
+set -euox pipefail
+
+# Ensure required variables are set
+: "${IMAGE_NAME:?Required variable IMAGE_NAME is not set}" # Ex: upstream.azurecr.io/oss/v2/kubernetes-csi/azurelustre-csi:v0.2.0
+: "${MSFT_GOLANG_PKG_VER:?Required variable MSFT_GOLANG_PKG_VER is not set}" # Ex: 1.23.7-ubuntu22.04u1
+
+echo "IMAGE_NAME: ${IMAGE_NAME}"
+echo "MSFT_GOLANG_PKG_VER: ${MSFT_GOLANG_PKG_VER}"
+
+# Create a configmap for the integration test script
+kubectl delete configmap integration-dalec-script --ignore-not-found
+kubectl create configmap integration-dalec-script --from-file=run_integration_test.sh
+
+# Show the filled in template
+envsubst < integration_dalec_aks.yaml.template
+
+# Make sure to delete any previous instances of the pod
+envsubst < integration_dalec_aks.yaml.template | kubectl delete -f - --ignore-not-found
+envsubst < integration_dalec_aks.yaml.template | kubectl apply -f -
+
+# Now running - wait for completion!
+pod=azurelustre-integration-dalec
+kubectl wait --for=condition=Ready pod/${pod} --timeout=300s
+kubectl wait --for=condition=Ready=false pod/${pod} --timeout=300s
+# Grab Result.
+result=$(kubectl get pod ${pod} -o=jsonpath='{.status.containerStatuses[*].state.*.exitCode}')
+kubectl logs ${pod}
+echo "Result: ${result}"
+exit ${result}