1 write to _kubernetesService
Aspire.Hosting (1)
10 references to _kubernetesService
Aspire.Hosting (10)
Dcp\DcpExecutor.cs (10)
181await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false);
190await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
294await foreach (var (eventType, resource) in _kubernetesService.WatchAsync<T>(cancellationToken: pipelineCancellationToken).ConfigureAwait<(global::k8s.WatchEventType, T)>(false))
434enumerable = new ResourceLogSource<Container>(_logger, _kubernetesService, container, follow: false);
438enumerable = new ResourceLogSource<Executable>(_logger, _kubernetesService, executable, follow: false);
477Container c when c.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),
478Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),
638var serviceChangeEnumerator = _kubernetesService.WatchAsync<Service>(cancellationToken: attemptCancellationToken);
670var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false);
695await _kubernetesService.CreateAsync(cn, cancellationToken).ConfigureAwait(false);