Function startLocalDuckgres

tests/perf/harness_test.go:288–371

(t *testing.T, username, password string, logOutput *bytes.Buffer)

	if err := server.EnsureCertificates(certPath, keyPath); err != nil {
		return nil, fmt.Errorf("generate tls certs: %w", err)
	}

	port, err := freePort()
	if err != nil {
		return nil, fmt.Errorf("allocate pgwire port: %w", err)
	}
	dataDir := filepath.Join(tmpDir, "data")
	if err := os.MkdirAll(dataDir, 0o755); err != nil {
		return nil, fmt.Errorf("create data dir: %w", err)
	}
	socketDir, err := os.MkdirTemp("/tmp", "perf-cp-")
	if err != nil {
		return nil, fmt.Errorf("create socket dir: %w", err)
	}

	cfgPath := filepath.Join(tmpDir, "duckgres.yaml")
	cfg := fmt.Sprintf(`host: 127.0.0.1
port: %d
data_dir: %s
tls:
  cert: %s
  key: %s
users:
  %s: %s
`, port, dataDir, certPath, keyPath, username, password)
	if err := os.WriteFile(cfgPath, []byte(cfg), 0o644); err != nil {
		return nil, fmt.Errorf("write config: %w", err)
	}

	cmd := exec.Command(binaryPath, "--config", cfgPath, "--mode", "control-plane", "--socket-dir", socketDir)
	cmd.Stdout = logOutput
	cmd.Stderr = logOutput
	cmd.Env = []string{
		"HOME=" + os.Getenv("HOME"),
		"PATH=" + os.Getenv("PATH"),
	}
	if err := cmd.Start(); err != nil {
		return nil, fmt.Errorf("start duckgres: %w", err)
	}

	dsn := fmt.Sprintf(
		"host=127.0.0.1 port=%d user=%s password=%s sslmode=require connect_timeout=5",
		port,
		username,
		password,
	)
	if err := waitForPGWireReady(dsn, 30*time.Second); err != nil {
		_ = cmd.Process.Kill()
		_, _ = cmd.Process.Wait()
		return nil, fmt.Errorf("duckgres did not become ready: %w\nlogs:\n%s", err, logOutput.String())
	}

	return &localDuckgres{
		cmd:       cmd,
		pgwireDSN: dsn,
		socketDir: socketDir,
	}, nil
}