From 478551622d99e489536cd1f2a7c0b0a5261ebbaa Mon Sep 17 00:00:00 2001 From: jochen Date: Thu, 12 Nov 2026 12:01:54 +0100 Subject: [PATCH] mesh-recovery consumes mesh-broker recreated and dropped, which its process binding hears (A-274) Builds: design 47 G A-274 Claude-Session: https://claude.ai/code/session_01NcbgfGKaxw984XyAPfLm4h --- modules/mesh-recovery/internal/recovery/manifest_test.go | 2 +- modules/mesh-recovery/module.json | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/modules/mesh-recovery/internal/recovery/manifest_test.go b/modules/mesh-recovery/internal/recovery/manifest_test.go index 099ab70ed..506739ee8 100644 --- a/modules/mesh-recovery/internal/recovery/manifest_test.go +++ b/modules/mesh-recovery/internal/recovery/manifest_test.go @@ -139,7 +139,7 @@ func TestTheManifestSaysWhatTheModuleIs(t *testing.T) { t.Error("the process does not invoke seat:mesh-catalog.seat-definitions") } } - for _, c := range []string{"node-backup.item-started", "node-backup.item-ended", "mesh-broker.snapshot-restored", + for _, c := range []string{"node-backup.item-started", "node-backup.item-ended", "mesh-broker.snapshot-restored", "mesh-broker.recreated", "mesh-broker.dropped", "mesh-catalog.seat-definition-changed", "mesh-catalog.seat-definition-removed"} { if !slices.Contains(m.Consumes, c) { t.Errorf("does not consume %s", c) diff --git a/modules/mesh-recovery/module.json b/modules/mesh-recovery/module.json index 9ad3e4fa9..9a955a3f8 100644 --- a/modules/mesh-recovery/module.json +++ b/modules/mesh-recovery/module.json @@ -37,6 +37,8 @@ "node-backup.item-ended", "node-engine.running", "mesh-broker.snapshot-restored", + "mesh-broker.recreated", + "mesh-broker.dropped", "mesh-conditions.findings-asked", "mesh-catalog.seat-definition-changed", "mesh-catalog.seat-definition-removed"