1 write to _kubernetesService
Aspire.Hosting (1)
12 references to _kubernetesService
Aspire.Hosting (12)
Dcp\DcpExecutor.cs (12)
320await _kubernetesService.CleanupResourcesAsync(cancellationToken).ConfigureAwait(false);
329await _kubernetesService.StopServerAsync(Model.ResourceCleanup.Full, cancellationToken).ConfigureAwait(false);
397var changeEnumerator = _kubernetesService.WatchAsync<TDcpResource>(cancellationToken: attemptCancellationToken);
432var fetched = await _kubernetesService.GetAsync<TDcpResource>(name, cancellationToken: cancellationToken).ConfigureAwait(false);
605var result = await _kubernetesService.PatchAsync(obj, patch, cancellationToken).ConfigureAwait(false);
628await _kubernetesService.CreateAsync(rtc, cancellationToken).ConfigureAwait(false);
1103await _kubernetesService.PatchAsync(c, patch, attemptCancellationToken).ConfigureAwait(false);
1104var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1119await _kubernetesService.PatchAsync(e, patch, attemptCancellationToken).ConfigureAwait(false);
1120var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1250var r = await _kubernetesService.DeleteAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1272var r = await _kubernetesService.GetAsync<T>(resourceName, cancellationToken: attemptCancellationToken).ConfigureAwait(false);