1 write to _resourceWatcher
Aspire.Hosting (1)
Dcp\DcpExecutor.cs (1)
112
_resourceWatcher
= new DcpResourceWatcher(logger, kubernetesService, loggerService, executorEvents, model, _appResources, profilingTelemetry, _shutdownCancellation.Token);
7 references to _resourceWatcher
Aspire.Hosting (7)
Dcp\DcpExecutor.cs (7)
124
internal DcpResourceWatcher ResourceWatcher =>
_resourceWatcher
;
185
_resourceWatcher
.Start();
294
await
_resourceWatcher
.StopAsync(cancellationToken).ConfigureAwait(false);
1070
Container container => s =>
_resourceWatcher
.SnapshotBuilder.ToSnapshot(container, s),
1071
Executable exe => s =>
_resourceWatcher
.SnapshotBuilder.ToSnapshot(exe, s),
1072
ContainerExec containerExec => s =>
_resourceWatcher
.SnapshotBuilder.ToSnapshot(containerExec, s),
1373
_resourceWatcher
.MarkPreviousIncarnationSuperseded(T.ObjectKind, resource.DcpResourceName, deletedUid);