rbd: added rbd info to validateRBDImageCount func

Signed-off-by: Oded Viner <[email protected]>

e2e/rbd.go

@@ -189,12 +189,27 @@ func validateRBDImageCount(f *framework.Framework, count int, pool string) {
 		framework.Failf("failed to list rbd images: %v", err)
 	}
 	if len(imageList) != count {
+		var imageDetails []string // To collect details for all images
+		for _, image := range imageList {
+			imgInfo, err := getImageInfo(f, image, pool)
+			if err != nil {
+				framework.Logf("Error getting image info: %v", err)
+			}
+			imgStatus, err := getImageStatus(f, image, pool)
+			if err != nil {
+				framework.Logf("Error getting image status: %v", err)
+			}
+			// Collecting image details for printing
+			imageDetails = append(imageDetails, fmt.Sprintf(
+				"Pool: %s, Image: %s, Info: %v, Status: %v", pool, image, imgInfo, imgStatus))
+		}
 		framework.Failf(
 			"backend images not matching kubernetes resource count,image count %d kubernetes resource count %d"+
-				"\nbackend image Info:\n %v",
+				"\nbackend image Info:\n %v\n images information and status %v",
 			len(imageList),
 			count,
-			imageList)
+			imageList,
+			strings.Join(imageDetails, "\n"))
 	}
 }
 
@@ -475,7 +490,7 @@ var _ = Describe("RBD", func() {
 					framework.Failf("failed to create PVC: %v", err)
 				}
 				// validate created backend rbd images
-				validateRBDImageCount(f, 1, defaultRBDPool)
+				validateRBDImageCount(f, 11, defaultRBDPool)
 				validateOmapCount(f, 1, rbdType, defaultRBDPool, volumesType)
 
 				imageList, err := listRBDImages(f, defaultRBDPool)

e2e/rbd_helper.go

@@ -1069,6 +1069,16 @@ type imageInfo struct {
 	ObjectSize  int    `json:"object_size"`
 }
 
+// imageStatus strongly typed JSON spec for image status.
+type imageStatus struct {
+	Name     string `json:"name"`
+	Pool     string `json:"pool"`
+	Watchers int    `json:"watchers"`
+	InUse    bool   `json:"in_use"` // Indicates if the image is currently in use.
+	Size     int64  `json:"size"`   // Total size of the image in bytes.
+	Format   string `json:"format"` // Format of the image (e.g., raw, qcow2).
+}
+
 // getImageInfo queries rbd about the given image and returns its metadata, and returns
 // error if provided image is not found.
 func getImageInfo(f *framework.Framework, imageName, poolName string) (imageInfo, error) {
@@ -1094,6 +1104,31 @@ func getImageInfo(f *framework.Framework, imageName, poolName string) (imageInfo
 	return imgInfo, nil
 }
 
+// getImageStatus queries rbd about the given image and returns its metadata, and returns
+// error if provided image is not found.
+func getImageStatus(f *framework.Framework, imageName, poolName string) (imageStatus, error) {
+	// rbd --format=json status [image-spec | snap-spec]
+	var imgStatus imageStatus
+
+	stdOut, stdErr, err := execCommandInToolBoxPod(
+		f,
+		fmt.Sprintf("rbd status %s %s --format json", rbdOptions(poolName), imageName),
+		rookNamespace)
+	if err != nil {
+		return imgStatus, fmt.Errorf("error retrieving rbd status: %w", err)
+	}
+	if stdErr != "" {
+		return imgStatus, fmt.Errorf("failed to get rbd status: %v", stdErr)
+	}
+	err = json.Unmarshal([]byte(stdOut), &imgStatus)
+	if err != nil {
+		return imgStatus, fmt.Errorf("unmarshal failed: %w. raw buffer response: %s",
+			err, stdOut)
+	}
+
+	return imgStatus, nil
+}
+
 // validateStripe validate the stripe count, stripe unit and object size of the
 // image.
 func validateStripe(f *framework.Framework,