1 write to _kubernetesService
Aspire.Hosting (1)
12 references to _kubernetesService
Aspire.Hosting (12)
Dcp\DcpExecutor.cs (12)
309await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false);
318await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
386var changeEnumerator = _kubernetesService.WatchAsync<TDcpResource>(cancellationToken: attemptCancellationToken);
421var fetched = await _kubernetesService.GetAsync<TDcpResource>(name, cancellationToken: cancellationToken).ConfigureAwait(false);
594var result = await _kubernetesService.PatchAsync(obj, patch, cancellationToken).ConfigureAwait(false);
617await _kubernetesService.CreateAsync(rtc, cancellationToken).ConfigureAwait(false);
1187await _kubernetesService.PatchAsync(c, patch, attemptCancellationToken).ConfigureAwait(false);
1188var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1202await _kubernetesService.PatchAsync(e, patch, attemptCancellationToken).ConfigureAwait(false);
1203var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1331var r = await _kubernetesService.DeleteAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1353var r = await _kubernetesService.GetAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);