Method ReplaceProviders

coderd/aibridged/pool.go:121–140

ReplaceProviders swaps the provider snapshot used by future Acquires. It is safe to call concurrently with Acquire and is a no-op after Shutdown.

(providers []aibridge.Provider)

// It is safe to call concurrently with Acquire and is a no-op after
// Shutdown.
func (p *CachedBridgePool) ReplaceProviders(providers []aibridge.Provider) {
	select {
	case <-p.shuttingDownCh:
		return
	default:
	}
	snapshot := slices.Clone(providers)
	p.providers.Store(&snapshot)
	version := time.Now().UnixNano()
	p.providerVersion.Store(version)
	// Clear evicts every cached bridge; OnEvict shuts each one down in
	// the background. Wait for buffered writes to drain so a replacement
	// immediately followed by an Acquire always sees the cleared cache.
	p.cache.Clear()
	p.cache.Wait()
	p.logger.Info(context.Background(), "request bridge pool reloaded",
		slog.F("provider_count", len(snapshot)),
		slog.F("provider_version", version),
	)
}

// loadProviders returns the current providers snapshot. The returned
// slice must not be mutated.