feat: add func BdevGetIostat

Signed-off-by: jinhong.kim0 <[email protected]>

Author: hookak

pkg/spdk/client/basic.go

@@ -1313,3 +1313,27 @@ func (c *Client) BdevVirtioDetachController(name string) (deleted bool, err erro
 
 	return deleted, json.Unmarshal(cmdOutput, &deleted)
 }
+
+// BdevGetIostat get I/O statistics of block devices (bdevs).
+//
+//	"name": Optional. If this is not specified, the function will list all block devices.
+//
+//	"per_channel": Optional. Display per channel data for specified block device.
+func (c *Client) BdevGetIostat(name string, perChannel bool) (resp *spdktypes.BdevIostatResponse, err error) {
+	req := spdktypes.BdevIostatRequest{
+		Name:       name,
+		PerChannel: perChannel,
+	}
+
+	cmdOutput, err := c.jsonCli.SendCommand("bdev_get_iostat", req)
+	if err != nil {
+		return nil, fmt.Errorf("failed to execute bdev_get_iostat: %v", err)
+	}
+
+	resp = &spdktypes.BdevIostatResponse{}
+	if err := json.Unmarshal(cmdOutput, resp); err != nil {
+		return nil, fmt.Errorf("failed to parse bdev_get_iostat response: %v", err)
+	}
+
+	return resp, nil
+}

pkg/spdk/types/bdev.go

@@ -135,3 +135,30 @@ type BdevLvolFragmap struct {
 	NumAllocatedClusters uint64 `json:"num_allocated_clusters"`
 	Fragmap              string `json:"fragmap"`
 }
+
+type BdevIostatRequest struct {
+	Name       string `json:"name,omitempty"`
+	PerChannel bool   `json:"per_channel,omitempty"`
+}
+
+type BdevIostatResponse struct {
+	TickRate uint64      `json:"tick_rate"`
+	Ticks    uint64      `json:"ticks"`
+	Bdevs    []BdevStats `json:"bdevs"`
+}
+
+type BdevStats struct {
+	Name              string `json:"name"`
+	BytesRead         uint64 `json:"bytes_read"`
+	NumReadOps        uint64 `json:"num_read_ops"`
+	BytesWritten      uint64 `json:"bytes_written"`
+	NumWriteOps       uint64 `json:"num_write_ops"`
+	BytesUnmapped     uint64 `json:"bytes_unmapped"`
+	NumUnmapOps       uint64 `json:"num_unmap_ops"`
+	ReadLatencyTicks  uint64 `json:"read_latency_ticks"`
+	WriteLatencyTicks uint64 `json:"write_latency_ticks"`
+	UnmapLatencyTicks uint64 `json:"unmap_latency_ticks"`
+	QueueDepth        uint64 `json:"queue_depth"`
+	IoTime            uint64 `json:"io_time"`
+	WeightedIoTime    uint64 `json:"weighted_io_time"`
+}