bur

Documentation

Index

• Variables

Variables

var CmdBur = &cobra.Command{
	Use:     "burrow",
	Example: "  kafkactl burrow <groupName>",
	Short:   "Show Burrow Lag Evaluations <wip>",
	PersistentPreRun: func(cmd *cobra.Command, args []string) {
		switch {
		case cmd.Flags().Changed("burrow"):
			burrow.LaunchBurrowClient(cfg.AdhocContext(cxFlags), burFlags)
		default:
			burrow.LaunchBurrowClient(cfg.GetContext(burFlags.Context), burFlags)
		}
	},
	Run: func(cmd *cobra.Command, args []string) {
		var burrowParts []jbbur.Partition
		switch {
		default:
			burrowParts = burrow.SearchBurrowConsumers(burFlags, args...)
		}
		switch {
		case cmd.Flags().Changed("out"):
			outFmt, err := cmd.Flags().GetString("out")
			if err != nil {
				out.Warnf("WARN: %v", err)
			}
			out.IfErrf(out.Marshal(burrowParts, outFmt))
		default:
			if burFlags.ShowID {
				printBur(burrowParts, "id")
				return
			}
			printBur(burrowParts)
		}
	},
}