Function Start

profiling/profiling.go:196–245

Start deploys monitoring service which deploys Parca that collects profiles from all ProfiledRunnable instances in environment created with AsProfiled.

(env e2e.Environment, opts ...Option)

// Start deploys monitoring service which deploys Parca that collects profiles from all
// ProfiledRunnable instances in environment created with AsProfiled.
func Start(env e2e.Environment, opts ...Option) (_ *Service, err error) {
	opt := opt{scrapeInterval: 5 * time.Second}
	for _, o := range opts {
		o(&opt)
	}

	m := http.NewServeMux()
	m.HandleFunc("/debug/pprof/", pprof.Index)

	o := sync.Once{}
	scraped := make(chan struct{})
	m.Handle("/debug/pprof/profile", http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
		o.Do(func() { close(scraped) })
		pprof.Profile(w, req)
	}))

	// Listen on all addresses, since we need to connect to it from docker container.
	list, err := net.Listen("tcp", "0.0.0.0:0")
	if err != nil {
		return nil, err
	}
	s := http.Server{Handler: m}

	go func() { _ = s.Serve(list) }()
	env.AddCloser(func() { _ = s.Close() })

	p := NewParca(env, "profiling", opt.customParcaImage, nil)

	_, port, err := net.SplitHostPort(list.Addr().String())
	if err != nil {
		return nil, err
	}
	l := &listener{p: p, localAddr: net.JoinHostPort(env.HostAddr(), port), scrapeInterval: opt.scrapeInterval}
	if err := l.updateConfig(map[string]Profiled{}); err != nil {
		return nil, err
	}
	env.AddListener(l)

	if err := e2e.StartAndWaitReady(p); err != nil {
		return nil, errors.Wrap(err, "starting profiling and waiting until ready")
	}

	select {
	case <-time.After(2 * time.Minute):
		return nil, errors.New("Parca failed to collect profiles from local process after 2 minutes, check profiling Parca logs")
	case <-scraped:
	}

	return &Service{p: p}, nil
}

func (s *Service) OpenUserInterfaceInBrowser(paths ...string) error {
	return e2einteractive.OpenInBrowser("http://" + s.p.Endpoint("http") + strings.Join(paths, "/"))