Function DrainErrGroup

utils/drain.go:27–39

DrainErrGroup waits for g.Wait() to return, but gives up after `timeout`. Why this exists: keploy's record/replay teardown runs in a deferred function that is also the path SIGINT/SIGTERM takes (the signal cancels the root context, which triggers the defer). The teardown calls g.Wait() to drain the

(logger *zap.Logger, name string, g *errgroup.Group, timeout time.Duration)

// nil; the leaked goroutine is reaped when the process exits. In the normal
// case the goroutines drain in well under the timeout, so this is a no-op.
func DrainErrGroup(logger *zap.Logger, name string, g *errgroup.Group, timeout time.Duration) error {
	done := make(chan error, 1)
	go func() { done <- g.Wait() }()
	select {
	case err := <-done:
		return err
	case <-time.After(timeout):
		logger.Error("teardown drain timed out after cancellation; forcing shutdown so stop/SIGINT isn't swallowed — a goroutine is ignoring context cancellation",
			zap.String("group", name),
			zap.Duration("timeout", timeout))
		return nil
	}
}