1 write to _resourceState
Aspire.Hosting (1)
16 references to _resourceState
Aspire.Hosting (16)
Dcp\DcpExecutor.cs (16)
99_snapshotBuilder = new(_resourceState);
224Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, "Executable", (e, s) => _snapshotBuilder.ToSnapshot(e, s)))),
225Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, "Container", (c, s) => _snapshotBuilder.ToSnapshot(c, s)))),
268if (_resourceState.ContainersMap.TryGetValue(entry.ResourceName, out var container))
272else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out var executable))
347_resourceState.ApplicationModel.TryGetValue(resourceName, out var appModelResource))
397_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.Metadata.Name), out _);
404_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.Metadata.Name)]
437if (_resourceState.ContainersMap.TryGetValue(resourceName, out var container))
441else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable))
537if (!ProcessResourceChange(_resourceState.EndpointsMap, watchEventType, endpoint))
555if (!ProcessResourceChange(_resourceState.ServicesMap, watchEventType, service))
560foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.Metadata.Name)))
570"Container" => _resourceState.ContainersMap.TryGetValue(resourceName, out var container) ? container : null,
571"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable) ? executable : null,
580_resourceState.ApplicationModel.TryGetValue(appModelResourceName, out var appModelResource))