1 write to _resourceWatcher
Aspire.Hosting (1)
Dcp\DcpExecutor.cs (1)
108_resourceWatcher = new DcpResourceWatcher(logger, kubernetesService, loggerService, executorEvents, model, _appResources, profilingTelemetry, _shutdownCancellation.Token);
7 references to _resourceWatcher
Aspire.Hosting (7)
Dcp\DcpExecutor.cs (7)
120internal DcpResourceWatcher ResourceWatcher => _resourceWatcher; 184_resourceWatcher.Start(); 305await _resourceWatcher.StopAsync(cancellationToken).ConfigureAwait(false); 986Container container => s => _resourceWatcher.SnapshotBuilder.ToSnapshot(container, s), 987Executable exe => s => _resourceWatcher.SnapshotBuilder.ToSnapshot(exe, s), 988ContainerExec containerExec => s => _resourceWatcher.SnapshotBuilder.ToSnapshot(containerExec, s), 1292_resourceWatcher.MarkPreviousIncarnationSuperseded(T.ObjectKind, resource.DcpResourceName, deletedUid);