Method CollectAll

agent-source-code/internal/integrations/manager.go:82–135

CollectAll collects data from all available integrations Returns a map of integration name -> integration data Errors in individual integrations do not stop collection from others

(ctx context.Context)

// Returns a map of integration name -> integration data
// Errors in individual integrations do not stop collection from others
func (m *Manager) CollectAll(ctx context.Context) map[string]*models.IntegrationData {
	available := m.DiscoverIntegrations()

	if len(available) == 0 {
		m.logger.Debug("No integrations available for collection")
		return make(map[string]*models.IntegrationData)
	}

	results := make(map[string]*models.IntegrationData)
	var wg sync.WaitGroup
	var resultsMu sync.Mutex

	m.logger.WithField("count", len(available)).Info("Collecting data from integrations...")

	for _, integration := range available {
		wg.Add(1)
		go func(integ Integration) {
			defer wg.Done()

			name := integ.Name()
			m.logger.WithField("integration", name).Debug("Starting collection")
			startTime := time.Now()

			data, err := integ.Collect(ctx)
			if err != nil {
				m.logger.WithFields(logrus.Fields{
					"integration": name,
					"error":       err.Error(),
				}).Warn("Integration collection failed")

				// Still add the result but with error
				data = &models.IntegrationData{
					Name:          name,
					Enabled:       true,
					CollectedAt:   utils.GetCurrentTimeUTC(),
					ExecutionTime: time.Since(startTime).Seconds(),
					Error:         err.Error(),
				}
			} else {
				m.logger.WithFields(logrus.Fields{
					"integration":    name,
					"execution_time": data.ExecutionTime,
				}).Info("Integration collection completed")
			}

			resultsMu.Lock()
			results[name] = data
			resultsMu.Unlock()
		}(integration)
	}

	wg.Wait()
	return results
}

// GetIntegration returns a specific integration by name
func (m *Manager) GetIntegration(name string) (Integration, error) {