1 write to _kubernetesService
Aspire.Hosting (1)
12 references to _kubernetesService
Aspire.Hosting (12)
Dcp\DcpExecutor.cs (12)
302await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false);
311await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
419var changeEnumerator = _kubernetesService.WatchAsync<TDcpResource>(cancellationToken: attemptCancellationToken);
454var fetched = await _kubernetesService.GetAsync<TDcpResource>(name, cancellationToken: cancellationToken).ConfigureAwait(false);
610var result = await _kubernetesService.PatchAsync(obj, patch, cancellationToken).ConfigureAwait(false);
633await _kubernetesService.CreateAsync(rtc, cancellationToken).ConfigureAwait(false);
1148await _kubernetesService.PatchAsync(c, patch, attemptCancellationToken).ConfigureAwait(false);
1149var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1163await _kubernetesService.PatchAsync(e, patch, attemptCancellationToken).ConfigureAwait(false);
1164var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1289var r = await _kubernetesService.DeleteAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1310var r = await _kubernetesService.GetAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);