Function runPauseCmd

pkg/cmd/crawler/pause/pause.go:66–109

(opts *PauseOptions)

}

func runPauseCmd(opts *PauseOptions) error {
	if opts.DryRun {
		summary := map[string]any{
			"action": "pause_crawlers",
			"ids":    opts.IDs,
			"dryRun": true,
		}

		return cmdutil.PrintRunSummary(
			opts.IO,
			opts.PrintFlags,
			summary,
			fmt.Sprintf("Dry run: would pause %s", utils.Pluralize(len(opts.IDs), "crawler")),
		)
	}

	client, err := opts.CrawlerClient()
	if err != nil {
		return err
	}
	cs := opts.IO.ColorScheme()

	opts.IO.StartProgressIndicatorWithLabel(
		fmt.Sprintf("Pausing %s", utils.Pluralize(len(opts.IDs), "crawler")),
	)
	for _, id := range opts.IDs {
		if _, err := client.Reindex(id); err != nil {
			opts.IO.StopProgressIndicator()
			return fmt.Errorf("cannot pause crawler %s: %w", cs.Bold(id), err)
		}
	}
	opts.IO.StopProgressIndicator()

	if opts.IO.IsStdoutTTY() {
		fmt.Fprintf(
			opts.IO.Out,
			"%s %s\n",
			cs.SuccessIconWithColor(cs.Green),
			fmt.Sprintf("Successfully paused %s", utils.Pluralize(len(opts.IDs), "crawler")),
		)
	}

	return nil
}