Skip to content

Commit 892455a

Browse files
committed
fix(dependency-injection): register notification handlers for mirrors
- Registers `SecretMirror` and `ConfigMapMirror` as notification handlers for `WatcherEvent` and `WatcherClosed`. - These were intended to be singletons. Regression from migration from Autofac
1 parent 8985492 commit 892455a

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

src/ES.Kubernetes.Reflector/Program.cs

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,9 @@
88
using ES.Kubernetes.Reflector.Configuration;
99
using ES.Kubernetes.Reflector.Mirroring;
1010
using ES.Kubernetes.Reflector.Watchers;
11+
using ES.Kubernetes.Reflector.Watchers.Core.Events;
1112
using k8s.Models;
13+
using MediatR;
1214

1315
return await ProgramEntry.CreateBuilder(args).UseSerilog().Build().RunAsync(async _ =>
1416
{
@@ -23,7 +25,7 @@
2325
builder.IgniteSeqOpenTelemetryExporter();
2426
builder.IgniteKubernetesClient();
2527
builder.Services.AddMediatR(config =>
26-
config.RegisterServicesFromAssembly(typeof(Program).Assembly));
28+
config.RegisterServicesFromAssembly(typeof(void).Assembly));
2729

2830
builder.Services.Configure<ReflectorOptions>(builder.Configuration.GetSection(nameof(ES.Kubernetes.Reflector)));
2931

@@ -34,6 +36,11 @@
3436
builder.Services.AddSingleton<SecretMirror>();
3537
builder.Services.AddSingleton<ConfigMapMirror>();
3638

39+
builder.Services.AddSingleton<INotificationHandler<WatcherEvent>>(sp => sp.GetRequiredService<SecretMirror>());
40+
builder.Services.AddSingleton<INotificationHandler<WatcherClosed>>(sp => sp.GetRequiredService<SecretMirror>());
41+
42+
builder.Services.AddSingleton<INotificationHandler<WatcherEvent>>(sp => sp.GetRequiredService<ConfigMapMirror>());
43+
builder.Services.AddSingleton<INotificationHandler<WatcherClosed>>(sp => sp.GetRequiredService<ConfigMapMirror>());
3744

3845
var app = builder.Build();
3946
app.Ignite();

0 commit comments

Comments
 (0)