feat(app): register container deployed event handler

Wire up ContainerDeployedHandler in application initialization
to enable proxy cache invalidation during zero-downtime deployments.

1 file · +6 -0

M internal/app/run.go +6 -0


@@ -360,6 +360,12 @@ func registerEventHandlers(ctx context.Context, svc *services) error {
360	360		return fmt.Errorf("failed to subscribe config reload handler: %w", err)
361	361		}
362	362
	363	+	// Proxy cache invalidation on container deployment (for zero-downtime)
	364	+	containerDeployedHandler := proxy.NewContainerDeployedHandler(ctx, svc.proxySvc)
	365	+	if err := svc.eventBus.Subscribe(containerDeployedHandler); err != nil {
	366	+	return fmt.Errorf("failed to subscribe container deployed handler: %w", err)
	367	+	}
	368	+
363	369		return nil
364	370		}
365	371


@@ -360,6 +360,12 @@ func registerEventHandlers(ctx context.Context, svc *services) error {
360	return fmt.Errorf("failed to subscribe config reload handler: %w", err)	360		return fmt.Errorf("failed to subscribe config reload handler: %w", err)
361	}	361		}
362		362
		363	+	// Proxy cache invalidation on container deployment (for zero-downtime)
		364	+	containerDeployedHandler := proxy.NewContainerDeployedHandler(ctx, svc.proxySvc)
		365	+	if err := svc.eventBus.Subscribe(containerDeployedHandler); err != nil {
		366	+	return fmt.Errorf("failed to subscribe container deployed handler: %w", err)
		367	+	}
		368	+
363	return nil	369		return nil
364	}	370		}
365		371