Method poll

operator/controllers/watcher_bridge.go:96–134

(ctx context.Context)

}

func (wb *WatcherBridge) poll(ctx context.Context) {
	if !wb.serverClient.IsConnected() {
		if err := wb.discoverAndConnect(ctx); err != nil {
			wb.logger.Debug("Server discovery failed", zap.Error(err))
			return
		}
	}

	resp, err := wb.serverClient.GetAlerts(ctx)
	if err != nil {
		wb.logger.Warn("GetAlerts RPC failed", zap.Error(err))
		return
	}

	if len(resp.Alerts) == 0 {
		return
	}

	wb.logger.Info("Received alerts from server", zap.Int("count", len(resp.Alerts)))

	for _, alert := range resp.Alerts {
		hash := wb.computeAlertHash(ctx, alert)
		if wb.isDuplicate(hash) {
			continue
		}

		if err := wb.createAnomaly(ctx, alert); err != nil {
			wb.logger.Error("Failed to create Anomaly CR", zap.Error(err), zap.String("alert_type", alert.Type))
			continue
		}
		ns := alert.Namespace
		if ns == "" {
			ns = "default"
		}
		wb.markSeen(hash, alert.Deployment, ns)
	}

	wb.pruneDedup()
}

// discoverAndConnect finds a ready Instance CR and connects to its server.
func (wb *WatcherBridge) discoverAndConnect(ctx context.Context) error {