diff --git a/cmd/metricstest/iteration10a_test.go b/cmd/metricstest/iteration10a_test.go index 81c5761..13f4593 100644 --- a/cmd/metricstest/iteration10a_test.go +++ b/cmd/metricstest/iteration10a_test.go @@ -59,18 +59,18 @@ func (suite *Iteration10ASuite) SetupSuite() { } func (suite *Iteration10ASuite) serverUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return diff --git a/cmd/metricstest/iteration10b_test.go b/cmd/metricstest/iteration10b_test.go index c6fc126..5ea732f 100644 --- a/cmd/metricstest/iteration10b_test.go +++ b/cmd/metricstest/iteration10b_test.go @@ -54,18 +54,18 @@ func (suite *Iteration10BSuite) SetupSuite() { } func (suite *Iteration10BSuite) serverUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Logf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return diff --git a/cmd/metricstest/iteration11_test.go b/cmd/metricstest/iteration11_test.go index 6b9f460..986dcd8 100644 --- a/cmd/metricstest/iteration11_test.go +++ b/cmd/metricstest/iteration11_test.go @@ -85,23 +85,22 @@ func (suite *Iteration11Suite) SetupSuite() { } func (suite *Iteration11Suite) serverUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration11Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration12_test.go b/cmd/metricstest/iteration12_test.go index b5dcdc3..c5d664d 100644 --- a/cmd/metricstest/iteration12_test.go +++ b/cmd/metricstest/iteration12_test.go @@ -86,23 +86,22 @@ func (suite *Iteration12Suite) SetupSuite() { } func (suite *Iteration12Suite) serverUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration12Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration13_test.go b/cmd/metricstest/iteration13_test.go index d7b1020..51e2b5c 100644 --- a/cmd/metricstest/iteration13_test.go +++ b/cmd/metricstest/iteration13_test.go @@ -60,43 +60,41 @@ func (suite *Iteration13Suite) SetupSuite() { } func (suite *Iteration13Suite) serverUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration13Suite) agentUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.agentProcess, err, envs, args) return } - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - suite.agentProcess = p } func (suite *Iteration13Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration14_test.go b/cmd/metricstest/iteration14_test.go index 79028a9..793499d 100644 --- a/cmd/metricstest/iteration14_test.go +++ b/cmd/metricstest/iteration14_test.go @@ -66,43 +66,41 @@ func (suite *Iteration14Suite) SetupSuite() { } func (suite *Iteration14Suite) serverUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration14Suite) agentUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.agentProcess, err, envs, args) return } - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - suite.agentProcess = p } func (suite *Iteration14Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration1_test.go b/cmd/metricstest/iteration1_test.go index 6bcfab5..b021f44 100644 --- a/cmd/metricstest/iteration1_test.go +++ b/cmd/metricstest/iteration1_test.go @@ -31,27 +31,25 @@ func (suite *Iteration1Suite) SetupSuite() { envs := append(os.Environ(), []string{ "RESTORE=false", }...) - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second) defer cancel() - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.serverProcess, err, envs) return } port := "8080" - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - - suite.serverProcess = p } func (suite *Iteration1Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration2a_test.go b/cmd/metricstest/iteration2a_test.go index a798a4a..c335012 100644 --- a/cmd/metricstest/iteration2a_test.go +++ b/cmd/metricstest/iteration2a_test.go @@ -28,27 +28,25 @@ func (suite *Iteration2ASuite) SetupSuite() { envs := append(os.Environ(), []string{ "RESTORE=false", }...) - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second) defer cancel() - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.agentProcess, err, envs) return } port := "8080" - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - - suite.agentProcess = p } func (suite *Iteration2ASuite) TearDownSuite() { diff --git a/cmd/metricstest/iteration3b_test.go b/cmd/metricstest/iteration3b_test.go index 80d7a4f..306d55b 100644 --- a/cmd/metricstest/iteration3b_test.go +++ b/cmd/metricstest/iteration3b_test.go @@ -34,27 +34,25 @@ func (suite *Iteration3BSuite) SetupSuite() { envs := append(os.Environ(), []string{ "RESTORE=false", }...) - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second) defer cancel() - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.serverProcess, err, envs) return } port := "8080" - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - - suite.serverProcess = p } func (suite *Iteration3BSuite) TearDownSuite() { diff --git a/cmd/metricstest/iteration4_test.go b/cmd/metricstest/iteration4_test.go index e680823..86f6174 100644 --- a/cmd/metricstest/iteration4_test.go +++ b/cmd/metricstest/iteration4_test.go @@ -63,43 +63,41 @@ func (suite *Iteration4Suite) SetupSuite() { } func (suite *Iteration4Suite) serverUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.serverProcess, err, envs, args) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration4Suite) agentUp(ctx context.Context, envs, args []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), fork.WithArgs(args...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", p, err, envs, args) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v, флаги командной строки: %+v", suite.agentProcess, err, envs, args) return } - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - suite.agentProcess = p } func (suite *Iteration4Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration5_test.go b/cmd/metricstest/iteration5_test.go index 5104f58..65041be 100644 --- a/cmd/metricstest/iteration5_test.go +++ b/cmd/metricstest/iteration5_test.go @@ -50,41 +50,39 @@ func (suite *Iteration5Suite) SetupSuite() { } func (suite *Iteration5Suite) serverUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", suite.serverProcess, err, envs) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration5Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.agentProcess, err, envs) return } - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - suite.agentProcess = p } func (suite *Iteration5Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration7_test.go b/cmd/metricstest/iteration7_test.go index 9d651e4..164b698 100644 --- a/cmd/metricstest/iteration7_test.go +++ b/cmd/metricstest/iteration7_test.go @@ -61,41 +61,39 @@ func (suite *Iteration7Suite) SetupSuite() { } func (suite *Iteration7Suite) serverUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.serverProcess, err, envs) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration7Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.agentProcess, err, envs) return } - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - suite.agentProcess = p } func (suite *Iteration7Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration8_test.go b/cmd/metricstest/iteration8_test.go index e05b41d..77ebc0e 100644 --- a/cmd/metricstest/iteration8_test.go +++ b/cmd/metricstest/iteration8_test.go @@ -51,41 +51,39 @@ func (suite *Iteration8Suite) SetupSuite() { } func (suite *Iteration8Suite) serverUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, + suite.serverProcess = fork.NewBackgroundProcess(context.Background(), flagServerBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.serverProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", suite.serverProcess, err, envs) return } - err = p.WaitPort(ctx, "tcp", port) + err = suite.serverProcess.WaitPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока порт %s станет доступен для запроса: %s", port, err) return } - suite.serverProcess = p } func (suite *Iteration8Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %q: %s. Переменные окружения: %+v", suite.agentProcess, err, envs) return } - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - suite.agentProcess = p } func (suite *Iteration8Suite) TearDownSuite() { diff --git a/cmd/metricstest/iteration9_test.go b/cmd/metricstest/iteration9_test.go index 1e589e2..ca9b4cd 100644 --- a/cmd/metricstest/iteration9_test.go +++ b/cmd/metricstest/iteration9_test.go @@ -74,22 +74,21 @@ func (suite *Iteration9Suite) serverUp(ctx context.Context, envs []string, port } func (suite *Iteration9Suite) agentUp(ctx context.Context, envs []string, port string) { - p := fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, + suite.agentProcess = fork.NewBackgroundProcess(context.Background(), flagAgentBinaryPath, fork.WithEnv(envs...), ) - err := p.Start(ctx) + err := suite.agentProcess.Start(ctx) if err != nil { - suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", p, err, envs) + suite.T().Errorf("Невозможно запустить процесс командой %s: %s. Переменные окружения: %+v", suite.agentProcess, err, envs) return } - err = p.ListenPort(ctx, "tcp", port) + err = suite.agentProcess.ListenPort(ctx, "tcp", port) if err != nil { suite.T().Errorf("Не удалось дождаться пока на порт %s начнут поступать данные: %s", port, err) return } - suite.agentProcess = p } func (suite *Iteration9Suite) TearDownSuite() {