Function dialTCPWithConnRefusedRetry

pkg/http2.go:542–559

SimulateGRPC simulates a gRPC call and returns the response This is a simplified version using gRPC client instead of manual HTTP/2 frame handling dialTCPWithConnRefusedRetry dials authority over TCP, retrying a pure connection-refused (the app is still coming up) up to maxConnRefusedRetries with th

(ctx context.Context, logger *zap.Logger, authority string)

// zero mocks, so the re-dial is idempotent; any other dial error, exhaustion of
// the attempts, or a cancelled context returns immediately.
func dialTCPWithConnRefusedRetry(ctx context.Context, logger *zap.Logger, authority string) (net.Conn, error) {
	for attempt := 0; ; attempt++ {
		conn, err := net.Dial("tcp", authority)
		if err == nil {
			return conn, nil
		}
		if attempt >= maxConnRefusedRetries || !isPreResponseConnRefused(err) {
			return nil, err
		}
		logger.Debug("gRPC dial refused; the app may still be coming up — retrying",
			zap.Int("attempt", attempt+1), zap.Int("maxRetries", maxConnRefusedRetries), zap.Error(err))
		select {
		case <-ctx.Done():
			return nil, ctx.Err()
		case <-time.After(connRefusedRetryBackoff * time.Duration(attempt+1)):
		}
	}
}

func SimulateGRPC(ctx context.Context, tc *models.TestCase, testSetID string, logger *zap.Logger, cfg SimulationConfig) (*models.GrpcResp, error) {
	if strings.Contains(tc.HTTPReq.URL, "%7B") { // case in which URL string has encoded template placeholders