1 write to _kubernetesService
Aspire.Hosting (1)
21 references to _kubernetesService
Aspire.Hosting (21)
Dcp\DcpExecutor.cs (21)
261await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false);
270await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
379await foreach (var (eventType, resource) in _kubernetesService.WatchAsync<T>(cancellationToken: pipelineCancellationToken).ConfigureAwait<(global::k8s.WatchEventType, T)>(false))
572enumerable = new ResourceLogSource<Container>(_logger, _kubernetesService, container, follow: false);
576enumerable = new ResourceLogSource<Executable>(_logger, _kubernetesService, executable, follow: false);
580enumerable = new ResourceLogSource<ContainerExec>(_logger, _kubernetesService, containerExec, follow: false);
619Container c when c.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),
620Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),
621ContainerExec e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),
780var serviceChangeEnumerator = _kubernetesService.WatchAsync<Service>(cancellationToken: attemptCancellationToken);
812var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false);
887tasks.Add(Task.Run(() => _kubernetesService.CreateAsync(rtc, cancellationToken), cancellationToken));
1509await _kubernetesService.CreateAsync(containerExe, cancellationToken).ConfigureAwait(false);
1573await _kubernetesService.CreateAsync(exe, cancellationToken).ConfigureAwait(false);
1832await _kubernetesService.CreateAsync(dcpContainerResource, cancellationToken).ConfigureAwait(false);
2044await _kubernetesService.PatchAsync(c, patch, attemptCancellationToken).ConfigureAwait(false);
2045var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
2059await _kubernetesService.PatchAsync(e, patch, attemptCancellationToken).ConfigureAwait(false);
2060var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
2158var r = await _kubernetesService.DeleteAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
2179var r = await _kubernetesService.GetAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);