Dcp\DcpResourceWatcher.cs (4)
156Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, Model.Dcp.ContainerKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))),
202if (_resourceState.ContainersMap.TryGetValue(entry.ResourceName, out var container))
603if (_resourceState.ContainersMap.TryGetValue(resourceName, out var container))
996"Container" => _resourceState.ContainersMap.TryGetValue(resourceName, out var container) ? container : null,