1 write to _kubernetesService
Aspire.Hosting (1)
12 references to _kubernetesService
Aspire.Hosting (12)
Dcp\DcpExecutor.cs (12)
310await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false);
319await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
387var changeEnumerator = _kubernetesService.WatchAsync<TDcpResource>(cancellationToken: attemptCancellationToken);
422var fetched = await _kubernetesService.GetAsync<TDcpResource>(name, cancellationToken: cancellationToken).ConfigureAwait(false);
595var result = await _kubernetesService.PatchAsync(obj, patch, cancellationToken).ConfigureAwait(false);
618await _kubernetesService.CreateAsync(rtc, cancellationToken).ConfigureAwait(false);
1188await _kubernetesService.PatchAsync(c, patch, attemptCancellationToken).ConfigureAwait(false);
1189var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1203await _kubernetesService.PatchAsync(e, patch, attemptCancellationToken).ConfigureAwait(false);
1204var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1330var r = await _kubernetesService.DeleteAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1351var r = await _kubernetesService.GetAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);