feat: added jobservice queue subcommand

cmd/harbor/root/cmd.go

@@ -23,6 +23,7 @@ import (
 	"github.com/goharbor/harbor-cli/cmd/harbor/root/context"
 	"github.com/goharbor/harbor-cli/cmd/harbor/root/cve"
 	"github.com/goharbor/harbor-cli/cmd/harbor/root/instance"
+	"github.com/goharbor/harbor-cli/cmd/harbor/root/jobservice"
 	"github.com/goharbor/harbor-cli/cmd/harbor/root/labels"
 	"github.com/goharbor/harbor-cli/cmd/harbor/root/ldap"
 	"github.com/goharbor/harbor-cli/cmd/harbor/root/project"
@@ -203,6 +204,10 @@ harbor help
 	cmd.GroupID = "system"
 	root.AddCommand(cmd)
 
+	cmd = jobservice.JobService()
+	cmd.GroupID = "system"
+	root.AddCommand(cmd)
+
 	// Utils
 	cmd = versionCommand()
 	cmd.GroupID = "utils"

cmd/harbor/root/jobservice/cmd.go

@@ -0,0 +1,37 @@
+// Copyright Project Harbor 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.
+package jobservice
+
+import (
+	"github.com/goharbor/harbor-cli/cmd/harbor/root/jobservice/queues"
+	"github.com/spf13/cobra"
+)
+
+// JobService creates the jobservice command
+func JobService() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "jobservice",
+		Short: "Manage Harbor job service (admin only)",
+		Long: `Manage Harbor job service components including worker pools, job queues, schedules, and job logs.
+This requires system admin privileges.
+
+Use "harbor jobservice [command] --help" for detailed examples and flags per subcommand.`,
+	}
+
+	cmd.AddCommand(
+		queues.QueuesCommand(),
+	)
+
+	return cmd
+}

cmd/harbor/root/jobservice/queues/cmd.go

@@ -0,0 +1,29 @@
+// Copyright Project Harbor 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.
+package queues
+
+import "github.com/spf13/cobra"
+
+// QueuesCommand creates the queues subcommand
+func QueuesCommand() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "queues",
+		Short: "Manage job queues (list, stop, pause, resume)",
+		Long:  "List job queues and perform actions on them (stop/pause/resume).",
+	}
+
+	cmd.AddCommand(ListCommand(), StopCommand(), PauseCommand(), ResumeCommand())
+
+	return cmd
+}

cmd/harbor/root/jobservice/queues/list.go

@@ -0,0 +1,54 @@
+// Copyright Project Harbor 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.
+package queues
+
+import (
+	"fmt"
+	"github.com/goharbor/harbor-cli/pkg/api"
+	"github.com/goharbor/harbor-cli/pkg/utils"
+	queuesview "github.com/goharbor/harbor-cli/pkg/views/jobservice/queues"
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+)
+
+// ListCommand lists all job queues
+func ListCommand() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:     "list",
+		Short:   "List all job queues",
+		Long:    "Display all job queues with their pending job counts and latency.",
+		Example: "harbor jobservice queues list",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			response, err := api.ListJobQueues()
+			if err != nil {
+				return fmt.Errorf("failed to retrieve job queues: %w", err)
+			}
+
+			if response == nil || response.Payload == nil || len(response.Payload) == 0 {
+				fmt.Println("No job queues found.")
+				return nil
+			}
+
+			formatFlag := viper.GetString("output-format")
+			if formatFlag != "" {
+				return utils.PrintFormat(response.Payload, formatFlag)
+			}
+
+			queuesview.ListQueues(response.Payload)
+			return nil
+		},
+	}
+
+	return cmd
+}

cmd/harbor/root/jobservice/queues/pause.go

@@ -0,0 +1,59 @@
+// Copyright Project Harbor 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.
+
+package queues
+
+import (
+	"fmt"
+
+	"github.com/spf13/cobra"
+)
+
+// PauseCommand pauses a job queue
+func PauseCommand() *cobra.Command {
+	var jobTypes []string
+	var interactive bool
+
+	cmd := &cobra.Command{
+		Use:     "pause",
+		Short:   "Pause queue(s) (--type or --interactive)",
+		Long:    "Pause a job queue or all queues.",
+		Example: "harbor jobservice queues pause --type REPLICATION\nharbor jobservice queues pause --type REPLICATION --type RETENTION\nharbor jobservice queues pause --type all",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			if len(jobTypes) == 0 && !interactive {
+				interactive = true
+			}
+
+			if interactive {
+				selectedTypes, err := selectQueueTypes("pause")
+				if err != nil {
+					return err
+				}
+				jobTypes = selectedTypes
+			}
+
+			if len(jobTypes) == 0 {
+				return fmt.Errorf("at least one job type must be specified with --type or interactive mode")
+			}
+
+			return executeQueueAction("pause", jobTypes)
+		},
+	}
+
+	flags := cmd.Flags()
+	flags.StringSliceVar(&jobTypes, "type", nil, "Job type(s) to pause (repeat flag or comma-separate values; use 'all' for all queues)")
+	flags.BoolVarP(&interactive, "interactive", "i", false, "Interactive mode to choose queue type(s) instead of passing --type")
+
+	return cmd
+}

cmd/harbor/root/jobservice/queues/resume.go

@@ -0,0 +1,58 @@
+// Copyright Project Harbor 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.
+package queues
+
+import (
+	"fmt"
+
+	"github.com/spf13/cobra"
+)
+
+// ResumeCommand resumes a job queue
+func ResumeCommand() *cobra.Command {
+	var jobTypes []string
+	var interactive bool
+
+	cmd := &cobra.Command{
+		Use:     "resume",
+		Short:   "Resume queue(s) (--type or --interactive)",
+		Long:    "Resume a paused job queue or all queues.",
+		Example: "harbor jobservice queues resume --type REPLICATION\nharbor jobservice queues resume --type REPLICATION --type RETENTION\nharbor jobservice queues resume --type all",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			if len(jobTypes) == 0 && !interactive {
+				interactive = true
+			}
+
+			if interactive {
+				selectedTypes, err := selectQueueTypes("resume")
+				if err != nil {
+					return err
+				}
+				jobTypes = selectedTypes
+			}
+
+			if len(jobTypes) == 0 {
+				return fmt.Errorf("at least one job type must be specified with --type or interactive mode")
+			}
+
+			return executeQueueAction("resume", jobTypes)
+		},
+	}
+
+	flags := cmd.Flags()
+	flags.StringSliceVar(&jobTypes, "type", nil, "Job type(s) to resume (repeat flag or comma-separate values; use 'all' for all queues)")
+	flags.BoolVarP(&interactive, "interactive", "i", false, "Interactive mode to choose queue type(s) instead of passing --type")
+
+	return cmd
+}

cmd/harbor/root/jobservice/queues/stop.go

@@ -0,0 +1,59 @@
+// Copyright Project Harbor 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.
+
+package queues
+
+import (
+	"fmt"
+
+	"github.com/spf13/cobra"
+)
+
+// StopCommand stops a job queue
+func StopCommand() *cobra.Command {
+	var jobTypes []string
+	var interactive bool
+
+	cmd := &cobra.Command{
+		Use:     "stop",
+		Short:   "Stop queue(s) (--type or --interactive)",
+		Long:    "Stop a job queue or all queues.",
+		Example: "harbor jobservice queues stop --type REPLICATION\nharbor jobservice queues stop --type REPLICATION --type RETENTION\nharbor jobservice queues stop --type all",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			if len(jobTypes) == 0 && !interactive {
+				interactive = true
+			}
+
+			if interactive {
+				selectedTypes, err := selectQueueTypes("stop")
+				if err != nil {
+					return err
+				}
+				jobTypes = selectedTypes
+			}
+
+			if len(jobTypes) == 0 {
+				return fmt.Errorf("at least one job type must be specified with --type or interactive mode")
+			}
+
+			return executeQueueAction("stop", jobTypes)
+		},
+	}
+
+	flags := cmd.Flags()
+	flags.StringSliceVar(&jobTypes, "type", nil, "Job type(s) to stop (repeat flag or comma-separate values; use 'all' for all queues)")
+	flags.BoolVarP(&interactive, "interactive", "i", false, "Interactive mode to choose queue type(s) instead of passing --type")
+
+	return cmd
+}