Function runMigrateConfig

cmd/tempo-cli/cmd-migrate-config_test.go:364–390

runMigrateConfig runs the full migrate config pipeline end-to-end, capturing stdout. Warnings printed to stderr are not captured here.

(t *testing.T, inputFile, kafkaAddress, kafkaTopic, mode string)

// runMigrateConfig runs the full migrate config pipeline end-to-end, capturing
// stdout. Warnings printed to stderr are not captured here.
func runMigrateConfig(t *testing.T, inputFile, kafkaAddress, kafkaTopic, mode string) (stdout string, err error) {
	t.Helper()
	cmd := &migrateConfigCmd{
		ConfigFile:   inputFile,
		KafkaAddress: kafkaAddress,
		KafkaTopic:   kafkaTopic,
		Mode:         mode,
	}

	// Capture stdout.
	orig := os.Stdout
	r, w, _ := os.Pipe()
	os.Stdout = w
	defer func() { os.Stdout = orig }()

	done := make(chan struct{})
	var buf bytes.Buffer
	go func() {
		_, _ = io.Copy(&buf, r)
		close(done)
	}()

	err = cmd.Run(nil)
	_ = w.Close()
	<-done
	return buf.String(), err
}

func TestMigrateConfigEndToEnd(t *testing.T) {
	tests := []struct {