diff --git a/doc/thinking/2026-04-26-namespace-manager-step27.md b/doc/thinking/2026-04-26-namespace-manager-step27.md new file mode 100644 index 00000000..e51343f6 --- /dev/null +++ b/doc/thinking/2026-04-26-namespace-manager-step27.md @@ -0,0 +1,20 @@ +# 2026-04-26 — NamespaceManager rewrite, step 27 + +## Цель шага + +Сделать первый реальный runtime hook на `NamespaceManager` в `buildermgr` watcher. + +## Что меняем + +1. `buildermgr.StartNSWatcher()` поднимает локальный `NamespaceManager`. +2. В manager заранее bootstrapped текущий snapshot resolver-а. +3. Watcher `Add/Update` события прогоняет через: + - `Upsert()` + - `DispatchAdd()` или `DispatchResync()` +4. Подписчиком manager-а становится уже существующий `buildermgr` subscriber adapter. + +## Что НЕ меняем + +- не меняем `registerBuilderNamespace()`; +- не добавляем remove path; +- не меняем остальные компоненты. \ No newline at end of file diff --git a/pkg/buildermgr/ns_watcher.go b/pkg/buildermgr/ns_watcher.go index fa78be1b..38a9827c 100644 --- a/pkg/buildermgr/ns_watcher.go +++ b/pkg/buildermgr/ns_watcher.go @@ -30,6 +30,9 @@ func StartNSWatcher( pkgw *packageWatcher, mgr manager.Interface, ) { + nsManager := utils.NewBootstrappedNamespaceManager(utils.DefaultNSResolver(), utils.NamespaceSourceEnv, time.Now().UTC()) + nsManager.Subscribe(NewNamespaceSubscriber(envw, pkgw, mgr)) + factory := k8sInformers.NewSharedInformerFactoryWithOptions( kubeClient, 30*time.Minute, @@ -42,18 +45,26 @@ func StartNSWatcher( _, _ = nsInformer.AddEventHandler(k8sCache.ResourceEventHandlerFuncs{ AddFunc: func(obj interface{}) { - ns := builderNSName(obj) - if ns == "" { + nsObj, ok := obj.(*corev1.Namespace) + if !ok || nsObj.Name == "" { return } - registerBuilderNamespace(ctx, ns, envw, pkgw, mgr) + nsManager.Upsert(utils.NamespaceEventFromNamespace(utils.NamespaceEventAdd, nsObj, utils.NamespaceSourceWatcher, time.Now().UTC())) + if _, _, err := nsManager.DispatchAdd(ctx, nsObj.Name); err != nil { + logger.Error("buildermgr.NSWatcher: DispatchAdd failed", + zap.String("namespace", nsObj.Name), zap.Error(err)) + } }, UpdateFunc: func(_, newObj interface{}) { nsObj, ok := newObj.(*corev1.Namespace) if !ok || !utils.IsManagedNamespace(nsObj.Labels) { return } - registerBuilderNamespace(ctx, nsObj.Name, envw, pkgw, mgr) + nsManager.Upsert(utils.NamespaceEventFromNamespace(utils.NamespaceEventUpdate, nsObj, utils.NamespaceSourceWatcher, time.Now().UTC())) + if _, _, err := nsManager.DispatchResync(ctx, nsObj.Name); err != nil { + logger.Error("buildermgr.NSWatcher: DispatchResync failed", + zap.String("namespace", nsObj.Name), zap.Error(err)) + } }, })