Method Initialize

pkg/api/group-client-manager.go:98–185

Initialize creates and connects clients for all profiles in the group. Returns an error only if ALL connections fail; partial failures are logged.

(ctx context.Context, profiles []ProfileEntry)

// Initialize creates and connects clients for all profiles in the group.
// Returns an error only if ALL connections fail; partial failures are logged.
func (m *GroupClientManager) Initialize(ctx context.Context, profiles []ProfileEntry) error {
	m.mu.Lock()
	defer m.mu.Unlock()

	// Clear existing clients
	m.clients = make(map[string]*ProfileClient)

	if len(profiles) == 0 {
		return fmt.Errorf("no profiles provided for group '%s'", m.groupName)
	}

	var wg sync.WaitGroup
	errChan := make(chan error, len(profiles))
	clientChan := make(chan *ProfileClient, len(profiles))

	// Connect to all profiles concurrently
	for _, entry := range profiles {
		wg.Add(1)
		go func(pe ProfileEntry) {
			defer wg.Done()

			pc := &ProfileClient{
				ProfileName: pe.Name,
				Status:      ProfileStatusUnknown,
			}

			// Create cache key prefix for this profile
			// Using simple key prefixing instead of namespace
			cacheKeyPrefix := fmt.Sprintf("group:%s:profile:%s:",
				m.groupName, pe.Name)

			// Create client with prefixed cache keys
			// For now, we'll just use the shared cache with prefixed keys
			client, err := NewClient(pe.Config,
				WithLogger(m.logger),
				WithCache(m.cache),
			)

			_ = cacheKeyPrefix // Will be used when we implement cache key prefixing

			if err != nil {
				pc.SetStatus(ProfileStatusError, err)
				m.logger.Error("Failed to connect to profile %s: %v", pe.Name, err)
				errChan <- fmt.Errorf("profile %s: %w", pe.Name, err)
			} else {
				pc.Client = client
				pc.SetStatus(ProfileStatusConnected, nil)
				m.logger.Debug("Successfully connected to profile %s", pe.Name)
			}

			clientChan <- pc
		}(entry)
	}

	// Wait for all connections to complete
	wg.Wait()
	close(errChan)
	close(clientChan)