Function StartProxy

tests/common_test.go:57–85

StartProxy returns a proxyExec representing a running instance of the proxy.

(ctx context.Context, args ...string)

// StartProxy returns a proxyExec representing a running instance of the proxy.
func StartProxy(ctx context.Context, args ...string) (*ProxyExec, error) {
	ctx, cancel := context.WithCancel(ctx)
	// Open a pipe for tracking the output from the cmd
	pr, pw, err := os.Pipe()
	if err != nil {
		cancel()
		return nil, fmt.Errorf("unable to open stdout pipe: %w", err)
	}

	c := cmd.NewCommand(cmd.WithLogger(log.NewStdLogger(pw, pw)))
	c.SetArgs(args)
	c.SetOut(pw)
	c.SetErr(pw)

	p := &ProxyExec{
		Out:     pr,
		cmd:     c,
		cancel:  cancel,
		closers: []io.Closer{pr, pw},
		done:    make(chan bool),
	}
	// Start the command in the background
	go func() {
		defer close(p.done)
		defer cancel()
		p.err = c.ExecuteContext(ctx)
	}()
	return p, nil
}

// Stop sends the TERM signal to the proxy and returns.
func (p *ProxyExec) Stop() {