Function main

cmd/thanosconvert/main.go:18–80

()

)

func main() {
	var (
		configFilename string
		dryRun         bool
		cfg            bucket.Config
	)

	logfmt, loglvl := logging.Format{}, logging.Level{}
	logfmt.RegisterFlags(flag.CommandLine)
	loglvl.RegisterFlags(flag.CommandLine)
	cfg.RegisterFlags(flag.CommandLine)
	flag.StringVar(&configFilename, "config", "", "Path to bucket config YAML")
	flag.BoolVar(&dryRun, "dry-run", false, "Don't make changes; only report what needs to be done")
	flag.Usage = func() {
		fmt.Fprintf(flag.CommandLine.Output(), "%s is a tool to convert block metadata from Thanos to Cortex.\nPlease see %s for instructions on how to run it.\n\n", os.Args[0], "https://cortexmetrics.io/docs/blocks-storage/migrate-storage-from-thanos-and-prometheus/")
		fmt.Fprintf(flag.CommandLine.Output(), "Flags:\n")
		flag.PrintDefaults()
	}
	flag.Parse()

	logger, err := log.NewPrometheusLogger(loglvl, logfmt)
	if err != nil {
		fatal("failed to create logger: %v", err)
	}

	if configFilename != "" {
		buf, err := os.ReadFile(configFilename)
		if err != nil {
			fatal("failed to load config file from %s: %v", configFilename, err)
		}
		err = yaml.UnmarshalStrict(buf, &cfg)
		if err != nil {
			fatal("failed to parse config file: %v", err)
		}
	}

	if err := cfg.Validate(); err != nil {
		fatal("bucket config is invalid: %v", err)
	}

	ctx := context.Background()

	converter, err := thanosconvert.NewThanosBlockConverter(ctx, cfg, dryRun, logger)
	if err != nil {
		fatal("couldn't initialize converter: %v", err)
	}

	iterCtx := context.Background()
	results, err := converter.Run(iterCtx)

	fmt.Println("Results:")
	for user, res := range results {
		fmt.Printf("User %s:\n", user)
		fmt.Printf("  Converted %d:\n  %s", len(res.ConvertedBlocks), strings.Join(res.ConvertedBlocks, ","))
		fmt.Printf("  Unchanged %d:\n  %s", len(res.UnchangedBlocks), strings.Join(res.UnchangedBlocks, ","))
		fmt.Printf("  Failed %d:\n  %s", len(res.FailedBlocks), strings.Join(res.FailedBlocks, ","))
	}