1 write to _kubernetesService
Aspire.Hosting (1)
Dcp\DcpExecutor.cs (1)
109_kubernetesService = kubernetesService;
23 references to _kubernetesService
Aspire.Hosting (23)
Dcp\DcpExecutor.cs (23)
210await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false); 219await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false); 328await foreach (var (eventType, resource) in _kubernetesService.WatchAsync<T>(cancellationToken: pipelineCancellationToken).ConfigureAwait<(global::k8s.WatchEventType, T)>(false)) 521enumerable = new ResourceLogSource<Container>(_logger, _kubernetesService, container, follow: false); 525enumerable = new ResourceLogSource<Executable>(_logger, _kubernetesService, executable, follow: false); 529enumerable = new ResourceLogSource<ContainerExec>(_logger, _kubernetesService, containerExec, follow: false); 568Container c when c.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 569Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 570ContainerExec e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 735var serviceChangeEnumerator = _kubernetesService.WatchAsync<Service>(cancellationToken: attemptCancellationToken); 767var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false); 792await _kubernetesService.CreateAsync(cn, cancellationToken).ConfigureAwait(false); 1181await _kubernetesService.CreateAsync(containerExe, cancellationToken).ConfigureAwait(false); 1234await _kubernetesService.CreateAsync(exe, cancellationToken).ConfigureAwait(false); 1420tasks.Add(_kubernetesService.CreateAsync(network, cancellationToken)); 1492await _kubernetesService.CreateAsync(dcpContainerResource, cancellationToken).ConfigureAwait(false); 1682await _kubernetesService.CreateAsync(res, cancellationToken).ConfigureAwait(false); 1725await _kubernetesService.PatchAsync(c, patch, attemptCancellationToken).ConfigureAwait(false); 1726var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1740await _kubernetesService.PatchAsync(e, patch, attemptCancellationToken).ConfigureAwait(false); 1741var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1838var r = await _kubernetesService.DeleteAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1859var r = await _kubernetesService.GetAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);