Function NewParca

profiling/profiling.go:41–78

(env e2e.Environment, name string, image string, flagOverride map[string]string)

}

func NewParca(env e2e.Environment, name string, image string, flagOverride map[string]string) *Parca {
	if image == "" {
		image = "ghcr.io/parca-dev/parca:main-4e20a666"
	}

	f := env.Runnable(name).WithPorts(map[string]int{"http": 7070}).Future()

	args := map[string]string{
		"--config-path": filepath.Join(f.Dir(), "parca.yml"),
	}
	if flagOverride != nil {
		args = e2e.MergeFlagsWithoutRemovingEmpty(args, flagOverride)
	}

	config := `
object_storage:
  bucket:
    type: "FILESYSTEM"
    config:
      directory: "./data"
`
	if err := os.WriteFile(filepath.Join(f.Dir(), "parca.yml"), []byte(config), 0600); err != nil {
		return &Parca{Runnable: e2e.NewFailedRunnable(name, errors.Wrap(err, "create Parca config failed"))}
	}

	p := e2emon.AsInstrumented(f.Init(e2e.StartOptions{
		Image:     image,
		Command:   e2e.NewCommand("/parca", e2e.BuildArgs(args)...),
		User:      strconv.Itoa(os.Getuid()),
		Readiness: e2e.NewTCPReadinessProbe("http"),
	}), "http")

	return &Parca{
		configHeader: config,
		Runnable:     p,
		Instrumented: p,
	}
}

// SetScrapeConfigs updates Parca with new configuration.
func (p *Parca) SetScrapeConfigs(scrapeJobs []parcaconfig.ScrapeConfig) error {