1 write to _kubernetesService
Aspire.Hosting (1)
16 references to _kubernetesService
Aspire.Hosting (16)
Dcp\DcpExecutor.cs (16)
173await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
268await foreach (var (eventType, resource) in _kubernetesService.WatchAsync<T>(cancellationToken: pipelineCancellationToken).ConfigureAwait<(global::k8s.WatchEventType, T)>(false))
407Container c when c.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource),
408Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource),
577var serviceChangeEnumerator = _kubernetesService.WatchAsync<Service>(cancellationToken: attemptCancellationToken);
609var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false);
634await _kubernetesService.CreateAsync(cn, cancellationToken).ConfigureAwait(false);
949createResource = async () => await _kubernetesService.CreateAsync(exe, cancellationToken).ConfigureAwait(false);
1199tasks.Add(_kubernetesService.CreateAsync(ContainerNetwork.Create(DefaultAspireNetworkName), cancellationToken));
1389await _kubernetesService.CreateAsync(dcpContainerResource, cancellationToken).ConfigureAwait(false);
1549await _kubernetesService.CreateAsync(res, cancellationToken).ConfigureAwait(false);
1588await _kubernetesService.PatchAsync(c, patch, cancellationToken).ConfigureAwait(false);
1592await _kubernetesService.PatchAsync(e, patch, cancellationToken).ConfigureAwait(false);
1646await _kubernetesService.DeleteAsync<T>(resourceName, cancellationToken: cancellationToken).ConfigureAwait(false);
1665await _kubernetesService.GetAsync<T>(state, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1679await _kubernetesService.CreateAsync(resource, cancellationToken).ConfigureAwait(false);