diff --git a/.github/workflows/metrics.yaml b/.github/workflows/metrics.yaml
new file mode 100644
index 00000000..f5000526
--- /dev/null
+++ b/.github/workflows/metrics.yaml
@@ -0,0 +1,37 @@
+name: test-metrics-5m
+on:
+  push:
+    branches: [master]
+  pull_request:
+    branches: [master]
+  workflow_dispatch:
+jobs:
+  integration:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v2
+      - name: Start a kind cluster with containerd
+        uses: helm/kind-action@v1.4.0
+        with:
+          cluster_name: kind-${{ github.run_id }}
+          kubectl_version: "v1.25.2"
+          config: ./hack/ci/containerd-cluster-conf.yaml
+      - name: Build image
+        run: ./hack/ci/build.sh
+      - name: Set image version
+        run: |
+          echo "VALUE_FILE=charts/warm-metal-csi-driver/values.yaml" >> "$GITHUB_ENV"
+          echo "IMAGE_TAG=$(git rev-parse --short HEAD)" >> "$GITHUB_ENV"
+          echo "HELM_NAME=wm-csi-integration-tests" >> "$GITHUB_ENV"
+      - name: Install the CSI Driver
+        run: |
+          trap "kubectl -n kube-system describe po" ERR
+          helm install ${HELM_NAME} charts/warm-metal-csi-driver -n kube-system \
+            -f ${VALUE_FILE} \
+            --set csiPlugin.image.tag=${IMAGE_TAG} \
+            --wait \
+            --debug
+      - name: Test metrics
+        run: ./test/integration/test-metrics.sh
+      - name: Uninstall the CSI Driver
+        run: helm uninstall -n kube-system ${HELM_NAME} --wait
\ No newline at end of file
diff --git a/Makefile b/Makefile
index d6ada2e7..0d868df6 100644
--- a/Makefile
+++ b/Makefile
@@ -1,4 +1,4 @@
-VERSION ?= v0.8.2
+VERSION ?= v0.9.0
 
 IMAGE_BUILDER ?= docker
 IMAGE_BUILD_CMD ?= buildx
diff --git a/charts/warm-metal-csi-driver/Chart.yaml b/charts/warm-metal-csi-driver/Chart.yaml
index 88430946..3d26c907 100644
--- a/charts/warm-metal-csi-driver/Chart.yaml
+++ b/charts/warm-metal-csi-driver/Chart.yaml
@@ -15,9 +15,9 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.8.2
+version: 0.9.0
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
 # follow Semantic Versioning. They should reflect the version the application is using.
-appVersion: v0.8.2
+appVersion: v0.9.0
diff --git a/charts/warm-metal-csi-driver/templates/nodeplugin.yaml b/charts/warm-metal-csi-driver/templates/nodeplugin.yaml
index c7f8d9da..d125159f 100644
--- a/charts/warm-metal-csi-driver/templates/nodeplugin.yaml
+++ b/charts/warm-metal-csi-driver/templates/nodeplugin.yaml
@@ -95,6 +95,9 @@ spec:
             - containerPort: 9809
               name: metrics
               protocol: TCP
+            - containerPort: 8080
+              name: metrics2
+              protocol: TCP
           livenessProbe:
             {{- toYaml .Values.csiPlugin.livenessProbe | nindent 12}}
           securityContext:
diff --git a/charts/warm-metal-csi-driver/templates/podmonitor.yaml b/charts/warm-metal-csi-driver/templates/podmonitor.yaml
index 9a29a464..15081591 100644
--- a/charts/warm-metal-csi-driver/templates/podmonitor.yaml
+++ b/charts/warm-metal-csi-driver/templates/podmonitor.yaml
@@ -15,6 +15,15 @@ spec:
       {{- if .Values.podMonitor.timeout }}
       scrapeTimeout: {{ .Values.podMonitor.timeout }}
         {{- end }}
+    - path: /metrics
+      port: metrics2
+      scheme: http
+      {{- if .Values.podMonitor.interval }}
+      interval: {{ .Values.podMonitor.interval }}
+      {{- end }}
+      {{- if .Values.podMonitor.timeout }}
+      scrapeTimeout: {{ .Values.podMonitor.timeout }}
+        {{- end }}
   jobLabel: {{ include "warm-metal-csi-driver.fullname" . }}
   namespaceSelector:
     matchNames:
diff --git a/cmd/plugin/main.go b/cmd/plugin/main.go
index 550b889f..4dbbdd37 100644
--- a/cmd/plugin/main.go
+++ b/cmd/plugin/main.go
@@ -12,6 +12,7 @@ import (
 	"github.com/warm-metal/csi-driver-image/pkg/backend/containerd"
 	"github.com/warm-metal/csi-driver-image/pkg/backend/crio"
 	"github.com/warm-metal/csi-driver-image/pkg/cri"
+	"github.com/warm-metal/csi-driver-image/pkg/metrics"
 	"github.com/warm-metal/csi-driver-image/pkg/secret"
 	"github.com/warm-metal/csi-driver-image/pkg/watcher"
 	csicommon "github.com/warm-metal/csi-drivers/pkg/csi-common"
@@ -145,5 +146,6 @@ func main() {
 		)
 	}
 
+	metrics.StartMetricsServer(metrics.RegisterMetrics())
 	server.Wait()
 }
diff --git a/cmd/plugin/node_server.go b/cmd/plugin/node_server.go
index a3f3f7f0..621fee15 100644
--- a/cmd/plugin/node_server.go
+++ b/cmd/plugin/node_server.go
@@ -8,6 +8,7 @@ import (
 	"github.com/container-storage-interface/spec/lib/go/csi"
 	"github.com/containerd/containerd/reference/docker"
 	"github.com/warm-metal/csi-driver-image/pkg/backend"
+	"github.com/warm-metal/csi-driver-image/pkg/metrics"
 	"github.com/warm-metal/csi-driver-image/pkg/mountexecutor"
 	"github.com/warm-metal/csi-driver-image/pkg/mountstatus"
 	"github.com/warm-metal/csi-driver-image/pkg/pullexecutor"
@@ -189,6 +190,8 @@ func (n NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpubl
 	}
 
 	if err = n.mounter.Unmount(ctx, req.VolumeId, backend.MountTarget(req.TargetPath)); err != nil {
+		// TODO(vadasambar): move this to mountexecutor once mountexecutor has `StartUnmounting` function
+		metrics.OperationErrorsCount.WithLabelValues("StartUnmounting").Inc()
 		err = status.Error(codes.Internal, err.Error())
 		return
 	}
diff --git a/cmd/plugin/node_server_test.go b/cmd/plugin/node_server_test.go
index 12ae09d6..3ada9613 100644
--- a/cmd/plugin/node_server_test.go
+++ b/cmd/plugin/node_server_test.go
@@ -3,7 +3,9 @@ package main
 import (
 	"context"
 	"fmt"
+	"io"
 	"net"
+	"net/http"
 	"net/url"
 	"os"
 	"strings"
@@ -17,6 +19,7 @@ import (
 	"github.com/warm-metal/csi-driver-image/pkg/backend"
 	"github.com/warm-metal/csi-driver-image/pkg/backend/containerd"
 	"github.com/warm-metal/csi-driver-image/pkg/cri"
+	"github.com/warm-metal/csi-driver-image/pkg/metrics"
 	csicommon "github.com/warm-metal/csi-drivers/pkg/csi-common"
 	"google.golang.org/grpc"
 	"k8s.io/apimachinery/pkg/util/wait"
@@ -43,7 +46,7 @@ func TestNodePublishVolumeAsync(t *testing.T) {
 	asyncImagePulls := true
 	ns := NewNodeServer(driver, mounter, criClient, &testSecretStore{}, asyncImagePulls)
 
-	// based on kubelet's csi mounter pluginc ode
+	// based on kubelet's csi mounter plugin code
 	// check https://github.com/kubernetes/kubernetes/blob/b06a31b87235784bad2858be62115049b6eb6bcd/pkg/volume/csi/csi_mounter.go#L111-L112
 	timeout := 100 * time.Millisecond
 
@@ -166,7 +169,7 @@ func TestNodePublishVolumeSync(t *testing.T) {
 	asyncImagePulls := false
 	ns := NewNodeServer(driver, mounter, criClient, &testSecretStore{}, asyncImagePulls)
 
-	// based on kubelet's csi mounter pluginc ode
+	// based on kubelet's csi mounter plugin code
 	// check https://github.com/kubernetes/kubernetes/blob/b06a31b87235784bad2858be62115049b6eb6bcd/pkg/volume/csi/csi_mounter.go#L111-L112
 	timeout := 100 * time.Millisecond
 
@@ -273,6 +276,165 @@ func TestNodePublishVolumeSync(t *testing.T) {
 	assert.ErrorContains(t, err, "not found")
 }
 
+// Check test/integration/node-server/README.md for how to run this test correctly
+func TestMetrics(t *testing.T) {
+	socketAddr := "unix:///run/containerd/containerd.sock"
+	addr, err := url.Parse(socketAddr)
+	assert.NoError(t, err)
+
+	criClient, err := cri.NewRemoteImageService(socketAddr, time.Minute)
+	assert.NoError(t, err)
+	assert.NotNil(t, criClient)
+
+	mounter := containerd.NewMounter(addr.Path)
+	assert.NotNil(t, mounter)
+
+	driver := csicommon.NewCSIDriver(driverName, driverVersion, "fake-node")
+	assert.NotNil(t, driver)
+
+	asyncImagePulls := true
+	ns := NewNodeServer(driver, mounter, criClient, &testSecretStore{}, asyncImagePulls)
+
+	// based on kubelet's csi mounter plugin code
+	// check https://github.com/kubernetes/kubernetes/blob/b06a31b87235784bad2858be62115049b6eb6bcd/pkg/volume/csi/csi_mounter.go#L111-L112
+	timeout := 10 * time.Second
+
+	server := csicommon.NewNonBlockingGRPCServer()
+
+	addr, err = url.Parse(*endpoint)
+	assert.NoError(t, err)
+
+	os.Remove("/csi/csi.sock")
+
+	// automatically deleted when the server is stopped
+	f, err := os.Create("/csi/csi.sock")
+	assert.NoError(t, err)
+	assert.NotNil(t, f)
+
+	var wg sync.WaitGroup
+	wg.Add(1)
+	go func() {
+		metrics.StartMetricsServer(metrics.RegisterMetrics())
+
+		server.Start(*endpoint,
+			nil,
+			nil,
+			ns)
+		// wait for the GRPC server to start
+		wg.Done()
+		server.Wait()
+	}()
+
+	// give some time for server to start
+	time.Sleep(2 * time.Second)
+	defer func() {
+		klog.Info("server was stopped")
+		server.Stop()
+	}()
+
+	wg.Wait()
+	var conn *grpc.ClientConn
+
+	conn, err = grpc.Dial(
+		addr.Path,
+		grpc.WithInsecure(),
+		grpc.WithContextDialer(func(ctx context.Context, targetPath string) (net.Conn, error) {
+			return (&net.Dialer{}).DialContext(ctx, "unix", targetPath)
+		}),
+	)
+
+	if err != nil {
+		panic(err)
+	}
+
+	assert.NoError(t, err)
+	assert.NotNil(t, conn)
+
+	nodeClient := csipbv1.NewNodeClient(conn)
+	assert.NotNil(t, nodeClient)
+
+	ctx, cancel := context.WithTimeout(context.Background(), 3*timeout)
+	defer cancel()
+	// wrong image id
+	wrongVolId := "docker.io-doesnt-exist/library/redis-doesnt-exist:latest"
+	wrongTargetPath := "wrong-test-path"
+	wrongReq := &csi.NodePublishVolumeRequest{
+		VolumeId:   wrongVolId,
+		TargetPath: wrongTargetPath,
+		VolumeContext: map[string]string{
+			// so that the test would always attempt to pull an image
+			ctxKeyPullAlways: "true",
+		},
+		VolumeCapability: &csi.VolumeCapability{
+			AccessMode: &csi.VolumeCapability_AccessMode{
+				Mode: csi.VolumeCapability_AccessMode_SINGLE_NODE_READER_ONLY,
+			},
+		},
+	}
+
+	r, err := nodeClient.NodePublishVolume(ctx, wrongReq)
+	assert.Error(t, err)
+	assert.Nil(t, r)
+
+	volId := "docker.io/library/redis:latest"
+	targetPath := "test-path"
+	req := &csi.NodePublishVolumeRequest{
+		VolumeId:   volId,
+		TargetPath: targetPath,
+		VolumeContext: map[string]string{
+			// so that the test would always attempt to pull an image
+			ctxKeyPullAlways: "true",
+		},
+		VolumeCapability: &csi.VolumeCapability{
+			AccessMode: &csi.VolumeCapability_AccessMode{
+				Mode: csi.VolumeCapability_AccessMode_SINGLE_NODE_READER_ONLY,
+			},
+		},
+	}
+
+	condFn := func() (done bool, err error) {
+		ctx, cancel := context.WithTimeout(context.Background(), timeout)
+		defer cancel()
+		resp, err := nodeClient.NodePublishVolume(ctx, req)
+		if err != nil && strings.Contains(err.Error(), context.DeadlineExceeded.Error()) {
+			klog.Errorf("context deadline exceeded; retrying: %v", err)
+			return false, nil
+		}
+		if resp != nil {
+			return true, nil
+		}
+		return false, fmt.Errorf("response from `NodePublishVolume` is nil")
+	}
+
+	err = wait.PollImmediate(
+		timeout,
+		30*time.Second,
+		condFn)
+	assert.NoError(t, err)
+
+	resp, err := http.Get("http://:8080/metrics")
+	assert.NoError(t, err)
+	assert.NotNil(t, resp)
+	assert.Equal(t, http.StatusOK, resp.StatusCode)
+
+	b1, err := io.ReadAll(resp.Body)
+	assert.NoError(t, err)
+	respBody := string(b1)
+	assert.Contains(t, respBody, metrics.ImagePullTimeKey)
+	assert.Contains(t, respBody, metrics.ImageMountTimeKey)
+	assert.Contains(t, respBody, metrics.OperationErrorsCountKey)
+
+	// give some time before stopping the server
+	time.Sleep(5 * time.Second)
+
+	// unmount if the volume is already mounted
+	c, ca := context.WithTimeout(context.Background(), time.Second*10)
+	defer ca()
+
+	err = mounter.Unmount(c, volId, backend.MountTarget(targetPath))
+	assert.NoError(t, err)
+}
+
 type testSecretStore struct {
 }
 
diff --git a/pkg/metrics/metrics.go b/pkg/metrics/metrics.go
new file mode 100644
index 00000000..c4104ad8
--- /dev/null
+++ b/pkg/metrics/metrics.go
@@ -0,0 +1,61 @@
+package metrics
+
+import (
+	"net/http"
+
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promhttp"
+	"k8s.io/klog/v2"
+)
+
+const Async = "async"
+const Sync = "sync"
+const ImagePullTimeKey = "pull_duration_seconds"
+const ImageMountTimeKey = "mount_duration_seconds"
+const OperationErrorsCountKey = "operation_errors_total"
+
+var ImagePullTime = prometheus.NewHistogramVec(
+	prometheus.HistogramOpts{
+		Subsystem: "warm_metal",
+		Name:      ImagePullTimeKey,
+		Help:      "The time it took to pull an image",
+		Buckets:   []float64{0, 1, 5, 10, 15, 30, 60, 120, 180},
+	},
+	[]string{"operation_type"},
+)
+
+var ImageMountTime = prometheus.NewHistogramVec(
+	prometheus.HistogramOpts{
+		Subsystem: "warm_metal",
+		Name:      ImageMountTimeKey,
+		Help:      "The time it took to mount an image",
+		Buckets:   []float64{0, 1, 5, 10, 15, 30, 60, 120, 180},
+	},
+	[]string{"operation_type"},
+)
+
+var OperationErrorsCount = prometheus.NewCounterVec(
+	prometheus.CounterOpts{
+		Subsystem: "warm_metal",
+		Name:      OperationErrorsCountKey,
+		Help:      "Cumulative number of operation (pull,mount,unmount) errors in the driver",
+	},
+	[]string{"operation_type"},
+)
+
+func RegisterMetrics() *prometheus.Registry {
+	reg := prometheus.NewRegistry()
+	reg.MustRegister(ImagePullTime)
+	reg.MustRegister(ImageMountTime)
+	reg.MustRegister(OperationErrorsCount)
+
+	return reg
+}
+
+func StartMetricsServer(reg *prometheus.Registry) {
+	go func() {
+		http.Handle("/metrics", promhttp.HandlerFor(reg, promhttp.HandlerOpts{Registry: reg}))
+		klog.Info("serving internal metrics at port 8080")
+		klog.Fatal(http.ListenAndServe(":8080", nil))
+	}()
+}
diff --git a/pkg/mountexecutor/mountexecutor.go b/pkg/mountexecutor/mountexecutor.go
index be5b5d2d..64621878 100644
--- a/pkg/mountexecutor/mountexecutor.go
+++ b/pkg/mountexecutor/mountexecutor.go
@@ -9,6 +9,7 @@ import (
 	"github.com/container-storage-interface/spec/lib/go/csi"
 	"github.com/containerd/containerd/reference/docker"
 	"github.com/warm-metal/csi-driver-image/pkg/backend"
+	"github.com/warm-metal/csi-driver-image/pkg/metrics"
 	"github.com/warm-metal/csi-driver-image/pkg/mountstatus"
 	"github.com/warm-metal/csi-driver-image/pkg/pullstatus"
 	"k8s.io/apimachinery/pkg/util/wait"
@@ -71,10 +72,13 @@ func (m *MountExecutor) StartMounting(o *MountOptions) error {
 
 	if !m.asyncMount {
 		mountstatus.Update(o.TargetPath, mountstatus.StillMounting)
+		startTime := time.Now()
 		if err := m.mounter.Mount(o.Context, o.VolumeId, backend.MountTarget(o.TargetPath), o.NamedRef, ro); err != nil {
+			metrics.OperationErrorsCount.WithLabelValues("StartMounting").Inc()
 			mountstatus.Update(o.TargetPath, mountstatus.Errored)
 			return err
 		}
+		metrics.ImageMountTime.WithLabelValues(metrics.Sync).Observe(time.Since(startTime).Seconds())
 		mountstatus.Update(o.TargetPath, mountstatus.Mounted)
 		return nil
 	}
@@ -86,12 +90,15 @@ func (m *MountExecutor) StartMounting(o *MountOptions) error {
 		defer cancel()
 
 		mountstatus.Update(o.TargetPath, mountstatus.StillMounting)
+		startTime := time.Now()
 		if err := m.mounter.Mount(ctx, o.VolumeId, backend.MountTarget(o.TargetPath), o.NamedRef, ro); err != nil {
 			klog.Errorf("mount err: %v", err.Error())
+			metrics.OperationErrorsCount.WithLabelValues("StartMounting").Inc()
 			mountstatus.Update(o.TargetPath, mountstatus.Errored)
 			m.asyncErrs[o.NamedRef] = fmt.Errorf("err: %v: %v", err, m.asyncErrs[o.NamedRef])
 			return
 		}
+		metrics.ImageMountTime.WithLabelValues(metrics.Async).Observe(time.Since(startTime).Seconds())
 		mountstatus.Update(o.TargetPath, mountstatus.Mounted)
 	}()
 
diff --git a/pkg/pullexecutor/pullexecutor.go b/pkg/pullexecutor/pullexecutor.go
index 6412837e..f24eab2d 100644
--- a/pkg/pullexecutor/pullexecutor.go
+++ b/pkg/pullexecutor/pullexecutor.go
@@ -9,6 +9,7 @@ import (
 	"github.com/containerd/containerd/reference/docker"
 	"github.com/pkg/errors"
 	"github.com/warm-metal/csi-driver-image/pkg/backend"
+	"github.com/warm-metal/csi-driver-image/pkg/metrics"
 	"github.com/warm-metal/csi-driver-image/pkg/pullstatus"
 	"github.com/warm-metal/csi-driver-image/pkg/remoteimage"
 	"github.com/warm-metal/csi-driver-image/pkg/secret"
@@ -59,6 +60,7 @@ func NewPullExecutor(o *PullExecutorOptions) *PullExecutor {
 		imageSvcClient: o.ImageServiceClient,
 		secretStore:    o.SecretStore,
 		mounter:        o.Mounter,
+		asyncErrs:      make(map[docker.Named]error),
 	}
 }
 
@@ -76,10 +78,13 @@ func (m *PullExecutor) StartPulling(o *PullOptions) error {
 		if shouldPull {
 			klog.Infof("pull image %q ", o.Image)
 			pullstatus.Update(o.NamedRef, pullstatus.StillPulling)
+			startTime := time.Now()
 			if err = puller.Pull(o.Context); err != nil {
 				pullstatus.Update(o.NamedRef, pullstatus.Errored)
+				metrics.OperationErrorsCount.WithLabelValues("StartPulling").Inc()
 				return errors.Errorf("unable to pull image %q: %s", o.NamedRef, err)
 			}
+			metrics.ImagePullTime.WithLabelValues(metrics.Sync).Observe(time.Since(startTime).Seconds())
 		}
 		pullstatus.Update(o.NamedRef, pullstatus.Pulled)
 		return nil
@@ -106,11 +111,15 @@ func (m *PullExecutor) StartPulling(o *PullOptions) error {
 			if shouldPull {
 				klog.Infof("pull image %q ", o.Image)
 				pullstatus.Update(o.NamedRef, pullstatus.StillPulling)
+				startTime := time.Now()
+
 				if err = puller.Pull(c); err != nil {
 					pullstatus.Update(o.NamedRef, pullstatus.Errored)
+					metrics.OperationErrorsCount.WithLabelValues("StartPulling").Inc()
 					m.asyncErrs[o.NamedRef] = fmt.Errorf("unable to pull image %q: %s", o.Image, err)
 					return
 				}
+				metrics.ImagePullTime.WithLabelValues(metrics.Async).Observe(time.Since(startTime).Seconds())
 			}
 			pullstatus.Update(o.NamedRef, pullstatus.Pulled)
 		}
diff --git a/test/integration/metrics-manifests/error-ephemeral-volume.yaml b/test/integration/metrics-manifests/error-ephemeral-volume.yaml
new file mode 100644
index 00000000..05ba37cc
--- /dev/null
+++ b/test/integration/metrics-manifests/error-ephemeral-volume.yaml
@@ -0,0 +1,31 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: error-ephemeral-volume
+spec:
+  template:
+    metadata:
+      name: error-ephemeral-volume
+    spec:
+      containers:
+        - name: error-ephemeral-volume
+          image: docker.io/warmmetal/csi-image-test:check-fs
+          env:
+            - name: TARGET
+              value: /target
+          volumeMounts:
+            - mountPath: /target
+              name: target
+      restartPolicy: Never
+      volumes:
+        - name: target
+          csi:
+            driver: csi-image.warm-metal.tech
+            volumeAttributes:
+              image: "docker.io/warmmetal/csi-image-test:simple-fs-doesnt-exist"
+              # # set pullAlways if you want to ignore local images
+              # pullAlways: "true"
+              # # set secret if the image is private
+              # secret: "name of the ImagePullSecret"
+              # secretNamespace: "namespace of the secret"
+  backoffLimit: 0
\ No newline at end of file
diff --git a/test/integration/metrics-manifests/no-error-ephemeral-volume.yaml b/test/integration/metrics-manifests/no-error-ephemeral-volume.yaml
new file mode 100644
index 00000000..e600900e
--- /dev/null
+++ b/test/integration/metrics-manifests/no-error-ephemeral-volume.yaml
@@ -0,0 +1,31 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: no-error-compatible-ephemeral-volume
+spec:
+  template:
+    metadata:
+      name: no-error-compatible-ephemeral-volume
+    spec:
+      containers:
+        - name: no-error-compatible-ephemeral-volume
+          image: docker.io/warmmetal/csi-image-test:check-fs
+          env:
+            - name: TARGET
+              value: /target
+          volumeMounts:
+            - mountPath: /target
+              name: target
+      restartPolicy: Never
+      volumes:
+        - name: target
+          csi:
+            driver: csi-image.warm-metal.tech
+            volumeAttributes:
+              image: "docker.io/warmmetal/csi-image-test:simple-fs"
+              # # set pullAlways if you want to ignore local images
+              # pullAlways: "true"
+              # # set secret if the image is private
+              # secret: "name of the ImagePullSecret"
+              # secretNamespace: "namespace of the secret"
+  backoffLimit: 0
\ No newline at end of file
diff --git a/test/integration/metrics-manifests/rendered-test.yaml b/test/integration/metrics-manifests/rendered-test.yaml
new file mode 100644
index 00000000..03d3d446
--- /dev/null
+++ b/test/integration/metrics-manifests/rendered-test.yaml
@@ -0,0 +1,25 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: test-metrics
+spec:
+  template:
+    metadata:
+      name: test-metrics
+    spec:
+      containers:
+        - name: test-metrics
+          # official curl iamge taken from https://github.com/curl/curl-container
+          image: quay.io/curl/curl:latest
+          command: 
+          - /bin/sh
+          - -c
+          - |
+            (curl $IP:8080/metrics | grep warm_metal_pull_duration_seconds) && \
+            (curl $IP:8080/metrics | grep warm_metal_mount_duration_seconds) && \
+            (curl $IP:8080/metrics | grep warm_metal_operation_errors_total)
+          env:
+            - name: IP
+              value: 172.18.0.2
+      restartPolicy: Never
+  backoffLimit: 0
diff --git a/test/integration/metrics-manifests/test.yaml b/test/integration/metrics-manifests/test.yaml
new file mode 100644
index 00000000..75e90b01
--- /dev/null
+++ b/test/integration/metrics-manifests/test.yaml
@@ -0,0 +1,25 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+  name: test-metrics
+spec:
+  template:
+    metadata:
+      name: test-metrics
+    spec:
+      containers:
+        - name: test-metrics
+          # official curl iamge taken from https://github.com/curl/curl-container
+          image: quay.io/curl/curl:latest
+          command: 
+          - /bin/sh
+          - -c
+          - |
+            (curl $IP:8080/metrics | grep warm_metal_pull_duration_seconds) && \
+            (curl $IP:8080/metrics | grep warm_metal_mount_duration_seconds) && \
+            (curl $IP:8080/metrics | grep warm_metal_operation_errors_total)
+          env:
+            - name: IP
+              value: %IP
+      restartPolicy: Never
+  backoffLimit: 0
diff --git a/test/integration/test-metrics.sh b/test/integration/test-metrics.sh
new file mode 100755
index 00000000..24a2b921
--- /dev/null
+++ b/test/integration/test-metrics.sh
@@ -0,0 +1,19 @@
+#!/usr/bin/env bash
+
+source $(dirname "${BASH_SOURCE[0]}")/../../hack/lib/utils.sh
+
+set -e
+
+TestBase=$(dirname "${BASH_SOURCE[0]}")
+kubectl apply -f "${TestBase}/metrics-manifests/error-ephemeral-volume.yaml"
+lib::run_test_job "${TestBase}/metrics-manifests/no-error-ephemeral-volume.yaml"
+
+
+ip="$(kubectl get po -n kube-system -l=component=nodeplugin -ojsonpath='{.items[*].status.podIP}')"
+cat "${TestBase}/metrics-manifests/test.yaml" | sed "s|%IP|$ip|g" > "${TestBase}/metrics-manifests/rendered-test.yaml"
+
+lib::run_test_job "${TestBase}/metrics-manifests/rendered-test.yaml"
+
+kubectl delete -f "${TestBase}/metrics-manifests/error-ephemeral-volume.yaml"
+
+set +e
\ No newline at end of file