1 write to _resourceState
Aspire.Hosting (1)
Dcp\DcpResourceWatcher.cs (1)
132_resourceState = new(model.Resources.ToDictionary(r => r.Name), appResources.Get());
24 references to _resourceState
Aspire.Hosting (24)
Dcp\DcpResourceWatcher.cs (24)
133_snapshotBuilder = new(_resourceState); 155Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, Model.Dcp.ExecutableKind, (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 156Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, Model.Dcp.ContainerKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 157Task.Run(() => WatchKubernetesResourceAsync<ContainerExec>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainerExecsMap, Model.Dcp.ContainerExecKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 202if (_resourceState.ContainersMap.TryGetValue(entry.ResourceName, out var container)) 206else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out var executable)) 210else if (_resourceState.ContainerExecsMap.TryGetValue(entry.ResourceName, out var containerExec)) 332_resourceState.ApplicationModel.TryGetValue(resourceName, out var appModelResource)) 437_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.Metadata.Name), out _); 444_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.Metadata.Name)] 603if (_resourceState.ContainersMap.TryGetValue(resourceName, out var container)) 607else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable)) 611else if (_resourceState.ContainerExecsMap.TryGetValue(resourceName, out var containerExec)) 910if (ProcessResourceChange(_resourceState.EndpointsMap, watchEventType, endpoint) == ResourceChangeResult.Ignored) 936? _resourceState.AppResources.OfType<ServiceWithModelResource>().Select(s => s.Service).FirstOrDefault(s => s.Metadata.Name == serviceName) 946foreach (var (resourceName, resource) in _resourceState.ApplicationModel) 962foreach (var appResource in _resourceState.AppResources) 976if (ProcessResourceChange(_resourceState.ServicesMap, watchEventType, service) == ResourceChangeResult.Ignored) 983DcpModelUtilities.ApplyServiceAddressToEndpoint(service, _resourceState.AppResources); 986foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.Metadata.Name))) 996"Container" => _resourceState.ContainersMap.TryGetValue(resourceName, out var container) ? container : null, 997"ContainerExec" => _resourceState.ContainerExecsMap.TryGetValue(resourceName, out var containerExec) ? containerExec : null, 998"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable) ? executable : null, 1007_resourceState.ApplicationModel.TryGetValue(appModelResourceName, out var appModelResource))