layer1: align router watcher flow step 23
This commit is contained in:
@@ -0,0 +1,15 @@
|
|||||||
|
# 2026-04-26 — NamespaceManager rewrite, step 23
|
||||||
|
|
||||||
|
## Цель шага
|
||||||
|
|
||||||
|
Свести текущий watcher flow и новый subscriber flow `router` к одному helper.
|
||||||
|
|
||||||
|
## Что меняем
|
||||||
|
|
||||||
|
1. `router/ns_watcher.go` больше не дублирует add/resync логику.
|
||||||
|
2. Watcher вызывает `registerRouterNamespace()`.
|
||||||
|
|
||||||
|
## Что НЕ меняем
|
||||||
|
|
||||||
|
- не переключаем `StartNSWatcher()` на `NamespaceManager`;
|
||||||
|
- не меняем внешний API watcher-а.
|
||||||
@@ -46,7 +46,7 @@ func StartNSWatcher(
|
|||||||
if ns == "" {
|
if ns == "" {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if err := ts.AddNamespace(ctx, ns, mgr); err != nil {
|
if err := registerRouterNamespace(ctx, ns, ts, mgr); err != nil {
|
||||||
logger.Error("router.NSWatcher: AddNamespace failed",
|
logger.Error("router.NSWatcher: AddNamespace failed",
|
||||||
zap.String("namespace", ns), zap.Error(err))
|
zap.String("namespace", ns), zap.Error(err))
|
||||||
}
|
}
|
||||||
@@ -56,7 +56,7 @@ func StartNSWatcher(
|
|||||||
if !ok || !utils.IsManagedNamespace(nsObj.Labels) {
|
if !ok || !utils.IsManagedNamespace(nsObj.Labels) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
if err := ts.AddNamespace(ctx, nsObj.Name, mgr); err != nil {
|
if err := registerRouterNamespace(ctx, nsObj.Name, ts, mgr); err != nil {
|
||||||
logger.Error("router.NSWatcher: AddNamespace failed",
|
logger.Error("router.NSWatcher: AddNamespace failed",
|
||||||
zap.String("namespace", nsObj.Name), zap.Error(err))
|
zap.String("namespace", nsObj.Name), zap.Error(err))
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user