1 write to _resourceState
Aspire.Hosting (1)
Dcp\DcpExecutor.cs (1)
121_resourceState = new(model.Resources.ToDictionary(r => r.Name), _appResources);
20 references to _resourceState
Aspire.Hosting (20)
Dcp\DcpExecutor.cs (20)
122_snapshotBuilder = new(_resourceState); 248Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, "Executable", (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 249Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, "Container", (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 250Task.Run(() => WatchKubernetesResourceAsync<ContainerExec>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainerExecsMap, "ContainerExec", (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 293if (_resourceState.ContainersMap.TryGetValue(entry.ResourceName, out var container)) 297else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out var executable)) 301else if (_resourceState.ContainerExecsMap.TryGetValue(entry.ResourceName, out var containerExec)) 376_resourceState.ApplicationModel.TryGetValue(resourceName, out var appModelResource)) 427_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.Metadata.Name), out _); 434_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.Metadata.Name)] 519if (_resourceState.ContainersMap.TryGetValue(resourceName, out var container)) 523else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable)) 527else if (_resourceState.ContainerExecsMap.TryGetValue(resourceName, out var containerExec)) 624if (!ProcessResourceChange(_resourceState.EndpointsMap, watchEventType, endpoint)) 642if (!ProcessResourceChange(_resourceState.ServicesMap, watchEventType, service)) 647foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.Metadata.Name))) 657"Container" => _resourceState.ContainersMap.TryGetValue(resourceName, out var container) ? container : null, 658"ContainerExec" => _resourceState.ContainerExecsMap.TryGetValue(resourceName, out var containerExec) ? containerExec : null, 659"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable) ? executable : null, 668_resourceState.ApplicationModel.TryGetValue(appModelResourceName, out var appModelResource))