1 write to _kubernetesService
Aspire.Hosting (1)
Dcp\DcpResourceWatcher.cs (1)
125_kubernetesService = kubernetesService;
8 references to _kubernetesService
Aspire.Hosting (8)
Dcp\DcpResourceWatcher.cs (8)
235await foreach (var (eventType, resource) in _kubernetesService.WatchAsync<T>(cancellationToken: pipelineCancellationToken).ConfigureAwait<(global::k8s.WatchEventType, T)>(false)) 505var logSource = new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: follow); 605enumerable = new ResourceLogSource<Container>(_logger, _kubernetesService, container, follow: false); 609enumerable = new ResourceLogSource<Executable>(_logger, _kubernetesService, executable, follow: false); 613enumerable = new ResourceLogSource<ContainerExec>(_logger, _kubernetesService, containerExec, follow: false); 652Container c when c.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 653Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 654ContainerExec e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),