Function commandWithLogging

cmd/prometheus/reload_test.go:201–233

(t *testing.T, logProcessor func(*testing.T, io.Reader), name string, args ...string)

}

func commandWithLogging(t *testing.T, logProcessor func(*testing.T, io.Reader), name string, args ...string) *exec.Cmd {
	if logProcessor == nil {
		logProcessor = captureLogsToTLog
	}

	stdoutPipe, stdoutWriter := io.Pipe()
	stderrPipe, stderrWriter := io.Pipe()

	var wg sync.WaitGroup
	wg.Add(2)

	cmd := exec.Command(name, args...)
	cmd.Stdout = stdoutWriter
	cmd.Stderr = stderrWriter

	go func() {
		defer wg.Done()
		logProcessor(t, stdoutPipe)
	}()
	go func() {
		defer wg.Done()
		logProcessor(t, stderrPipe)
	}()

	t.Cleanup(func() {
		cmd.Process.Kill()
		cmd.Wait()
		stdoutWriter.Close()
		stderrWriter.Close()
		wg.Wait()
	})
	return cmd
}

func prometheusCommandWithLogging(t *testing.T, configFilePath string, port int, extraArgs ...string) *exec.Cmd {
	args := []string{