From 3159fba65b392defb3395acf68ba124f75d15f81 Mon Sep 17 00:00:00 2001 From: Naeel Date: Sun, 26 Apr 2026 10:27:09 +0300 Subject: [PATCH] layer1: align builder watcher flow step 21 --- .../2026-04-26-namespace-manager-step21.md | 15 +++++++++++++++ pkg/buildermgr/ns_watcher.go | 8 ++------ 2 files changed, 17 insertions(+), 6 deletions(-) create mode 100644 doc/thinking/2026-04-26-namespace-manager-step21.md diff --git a/doc/thinking/2026-04-26-namespace-manager-step21.md b/doc/thinking/2026-04-26-namespace-manager-step21.md new file mode 100644 index 00000000..850330dc --- /dev/null +++ b/doc/thinking/2026-04-26-namespace-manager-step21.md @@ -0,0 +1,15 @@ +# 2026-04-26 — NamespaceManager rewrite, step 21 + +## Цель шага + +Свести текущий watcher flow и новый subscriber flow `buildermgr` к одному helper. + +## Что меняем + +1. `buildermgr/ns_watcher.go` больше не дублирует логику add/resync. +2. Watcher вызывает `registerBuilderNamespace()`. + +## Что НЕ меняем + +- не меняем внешний API watcher-а; +- не переключаем `StartNSWatcher()` на `NamespaceManager`. \ No newline at end of file diff --git a/pkg/buildermgr/ns_watcher.go b/pkg/buildermgr/ns_watcher.go index c2464d6f..fa78be1b 100644 --- a/pkg/buildermgr/ns_watcher.go +++ b/pkg/buildermgr/ns_watcher.go @@ -46,18 +46,14 @@ func StartNSWatcher( if ns == "" { return } - utils.DefaultNSResolver().AddNamespace(ns) - envw.AddNamespace(ctx, ns, mgr) - pkgw.AddNamespace(ctx, ns, mgr) + registerBuilderNamespace(ctx, ns, envw, pkgw, mgr) }, UpdateFunc: func(_, newObj interface{}) { nsObj, ok := newObj.(*corev1.Namespace) if !ok || !utils.IsManagedNamespace(nsObj.Labels) { return } - utils.DefaultNSResolver().AddNamespace(nsObj.Name) - envw.AddNamespace(ctx, nsObj.Name, mgr) - pkgw.AddNamespace(ctx, nsObj.Name, mgr) + registerBuilderNamespace(ctx, nsObj.Name, envw, pkgw, mgr) }, })