INNER CODE UNIT · Go

newManageCmd

rabbitmq/cluster-operator · kubectl-rabbitmq/commands.go:267

func newManageCmd(getExecutor func() *kubectlExecutor) *cobra.Command {
	return &cobra.Command{
		Use:   "manage INSTANCE",
		Short: "Open Management UI for an instance",
		Args:  cobra.ExactArgs(1),
		RunE: func(cmd *cobra.Command, args []string) error {
			executor := getExecutor()
			instance := args[0]
			serviceName := instance

			// Check if TLS is enabled
			output, err := executor.ExecuteWithOutput("get", "service", serviceName, "-o", "jsonpath={.spec.ports[?(@.name==\"management-tls\")]}")
			if err != nil {
				return err
			}

			var mgmtPort, mgmtURL string
			if len(output) > 0 {

View source record →