Method ResolveAddrsParallel

internal/resolver/resolver.go:235–271

ResolveAddrsParallel resolves multiple addresses concurrently and caches results. This should be called before rendering to pre-warm the cache.

(addrs []string)

// ResolveAddrsParallel resolves multiple addresses concurrently and caches results.
// This should be called before rendering to pre-warm the cache.
func (r *Resolver) ResolveAddrsParallel(addrs []string) {
	// dedupe and filter addresses that need resolution
	unique := make(map[string]struct{})
	for _, addr := range addrs {
		if addr == "" || addr == "*" {
			continue
		}
		// skip if already cached
		r.mutex.RLock()
		_, exists := r.cache[addr]
		r.mutex.RUnlock()
		if exists {
			continue
		}
		unique[addr] = struct{}{}
	}

	if len(unique) == 0 {
		return
	}

	var wg sync.WaitGroup
	// limit concurrency to avoid overwhelming dns
	sem := make(chan struct{}, 32)

	for addr := range unique {
		wg.Add(1)
		go func(a string) {
			defer wg.Done()
			sem <- struct{}{}
			defer func() { <-sem }()
			r.ResolveAddr(a)
		}(addr)
	}

	wg.Wait()
}

// ResolveAddrsParallel is a convenience function using the global resolver
func ResolveAddrsParallel(addrs []string) {