feat(vm): add domain jobs info subcommands to vlctl

Signed-off-by: Yaroslav Borbat <yaroslav.borbat@flant.com>

Author: yaroslavborbat

build/components/versions.yml

@@ -3,7 +3,7 @@ firmware:
   libvirt: v10.9.0
   edk2: stable202411
 core:
-  3p-kubevirt: v1.6.2-v12n.25
+  3p-kubevirt: feat/get-domain-jobs-status # v1.6.2-v12n.25
   3p-containerized-data-importer: v1.60.3-v12n.18
   distribution: 2.8.3
 package:

images/virt-artifact/werf.inc.yaml

@@ -9,6 +9,7 @@
 image: {{ .ModuleNamePrefix }}{{ .ImageName }}-src-artifact
 final: false
 fromImage: builder/src
+fromCacheVersion: "001"
 secrets:
 - id: SOURCE_REPO
   value: {{ $.SOURCE_REPO }}

images/virt-launcher/vlctl/cmd/vlctl/app/domain.go

@@ -41,7 +41,11 @@ func NewDomainCommand() *cobra.Command {
 	}
 
 	cmd.Flags().BoolVarP(&fromFile, "from-file", "f", false, "Read domain specification from file")
-	cmd.AddCommand(NewDomainStatsCommand())
+	cmd.AddCommand(
+		NewDomainStatsCommand(),
+		NewDomainBlockJobsCommand(),
+		NewDomainJobsCommand(),
+	)
 
 	return cmd
 }
@@ -103,6 +107,30 @@ func NewDomainStatsCommand() *cobra.Command {
 
 }
 
+func NewDomainBlockJobsCommand() *cobra.Command {
+	return &cobra.Command{
+		Use:   "block-jobs",
+		Short: "Get current QEMU block jobs status",
+		Args:  cobra.NoArgs,
+		RunE: func(cmd *cobra.Command, _ []string) error {
+			baseOpts := BaseOptionsFromCommand(cmd)
+			return runDomainBlockJobsCommand(baseOpts)
+		},
+	}
+}
+
+func NewDomainJobsCommand() *cobra.Command {
+	return &cobra.Command{
+		Use:   "jobs",
+		Short: "Get current QEMU jobs status",
+		Args:  cobra.NoArgs,
+		RunE: func(cmd *cobra.Command, _ []string) error {
+			baseOpts := BaseOptionsFromCommand(cmd)
+			return runDomainJobsCommand(baseOpts)
+		},
+	}
+}
+
 func runDomainStatsCommand(opts BaseOptions) error {
 	if err := opts.Validate(); err != nil {
 		return err
@@ -124,3 +152,41 @@ func runDomainStatsCommand(opts BaseOptions) error {
 
 	return marshalAndPrintOutput(&opts, stats)
 }
+
+func runDomainBlockJobsCommand(opts BaseOptions) error {
+	if err := opts.Validate(); err != nil {
+		return err
+	}
+
+	client, err := opts.Client()
+	if err != nil {
+		return fmt.Errorf("failed to create client: %w", err)
+	}
+	defer client.Close()
+
+	jobs, err := client.GetBlockJobsStatus()
+	if err != nil {
+		return fmt.Errorf("failed to get block jobs status: %w", err)
+	}
+
+	return marshalAndPrintOutput(&opts, jobs)
+}
+
+func runDomainJobsCommand(opts BaseOptions) error {
+	if err := opts.Validate(); err != nil {
+		return err
+	}
+
+	client, err := opts.Client()
+	if err != nil {
+		return fmt.Errorf("failed to create client: %w", err)
+	}
+	defer client.Close()
+
+	jobs, err := client.GetJobsStatus()
+	if err != nil {
+		return fmt.Errorf("failed to get jobs status: %w", err)
+	}
+
+	return marshalAndPrintOutput(&opts, jobs)
+}