105 references to CancellationToken
Aspire.Hosting (26)
ApplicationModel\ProjectResource.cs (7)
131
await containerImageBuilder.BuildImageAsync(this, ctx.
CancellationToken
).ConfigureAwait(false);
150
await containerRuntime.TagImageAsync(originalImageName, tempImageName, ctx.
CancellationToken
).ConfigureAwait(false);
161
var containerWorkingDir = await GetContainerWorkingDirectoryAsync(projectMetadata.ProjectPath, logger, ctx.
CancellationToken
).ConfigureAwait(false);
176
await dockerfileBuilder.WriteAsync(writer, ctx.
CancellationToken
).ConfigureAwait(false);
186
cancellationToken: ctx.
CancellationToken
).ConfigureAwait(false);
201
ctx.
CancellationToken
).ConfigureAwait(false);
232
await containerRuntime.RemoveImageAsync(tempImageName, ctx.
CancellationToken
).ConfigureAwait(false);
ContainerResourceBuilderExtensions.cs (1)
50
ctx.
CancellationToken
).ConfigureAwait(false);
Pipelines\DistributedApplicationPipeline.cs (3)
53
await parameterProcessor.InitializeParametersAsync(context.Model, waitForResolution: true, context.
CancellationToken
).ConfigureAwait(false);
99
context.
CancellationToken
).ConfigureAwait(false);
185
context.
CancellationToken
).ConfigureAwait(false);
Pipelines\PipelineStepHelpers.cs (13)
37
context.
CancellationToken
).ConfigureAwait(false);
48
var registryEndpoint = await registry.Endpoint.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false);
66
var targetTag = await cir.GetValueAsync(new ValueProviderContext { ExecutionContext = context.ExecutionContext }, context.
CancellationToken
).ConfigureAwait(false);
70
context.
CancellationToken
).ConfigureAwait(false);
88
await containerRuntime.TagImageAsync(localImageName, targetTag, context.
CancellationToken
).ConfigureAwait(false);
93
context.
CancellationToken
).ConfigureAwait(false);
100
context.
CancellationToken
).ConfigureAwait(false);
108
var registryName = await registry.Name.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false)
112
var targetTag = await cir.GetValueAsync(new ValueProviderContext { ExecutionContext = context.ExecutionContext }, context.
CancellationToken
).ConfigureAwait(false);
116
context.
CancellationToken
).ConfigureAwait(false);
128
await containerImageManager.PushImageAsync(resource, context.
CancellationToken
).ConfigureAwait(false);
133
context.
CancellationToken
).ConfigureAwait(false);
140
context.
CancellationToken
).ConfigureAwait(false);
Publishing\ManifestPublishingExtensions.cs (2)
67
var publishingContext = new ManifestPublishingContext(executionContext, manifestPath, jsonWriter, context.
CancellationToken
);
69
await publishingContext.WriteModel(context.Model, context.
CancellationToken
).ConfigureAwait(false);
Aspire.Hosting.Azure (10)
AzureBicepResource.cs (6)
320
.CreateTaskAsync($"Deploying **{resource.Name}**", context.
CancellationToken
)
328
configuration, resource, context.
CancellationToken
).ConfigureAwait(false))
334
context.
CancellationToken
).ConfigureAwait(false);
339
resource, provisioningContext, context.
CancellationToken
)
345
context.
CancellationToken
).ConfigureAwait(false);
360
context.
CancellationToken
).ConfigureAwait(false);
AzureEnvironmentResource.cs (4)
96
var provisioningContext = await provisioningContextProvider.CreateProvisioningContextAsync(ctx.
CancellationToken
).ConfigureAwait(false);
147
await tokenCredentialProvider.TokenCredential.GetTokenAsync(tokenRequest, context.
CancellationToken
)
153
context.
CancellationToken
).ConfigureAwait(false);
160
context.
CancellationToken
).ConfigureAwait(false);
Aspire.Hosting.Azure.AppContainers (3)
AzureContainerAppEnvironmentResource.cs (2)
124
var domainValue = await ContainerAppDomain.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false);
131
context.
CancellationToken
).ConfigureAwait(false);
AzureContainerAppResource.cs (1)
57
var domainValue = await containerAppEnv.ContainerAppDomain.GetValueAsync(ctx.
CancellationToken
).ConfigureAwait(false);
Aspire.Hosting.Azure.AppService (6)
AzureAppServiceEnvironmentResource.cs (2)
127
var dashboardUri = await DashboardUriReference.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false);
132
context.
CancellationToken
).ConfigureAwait(false);
AzureAppServiceWebSiteResource.cs (4)
127
await computerEnv.DeploymentSlotParameter.GetValueAsync(ctx.
CancellationToken
).ConfigureAwait(false);
218
.GetTokenAsync(tokenRequest, context.
CancellationToken
)
225
using var response = await httpClient.SendAsync(request, context.
CancellationToken
).ConfigureAwait(false);
239
var websiteSuffix = await computerEnv.WebSiteSuffix.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false);
Aspire.Hosting.Azure.ContainerRegistry (6)
AzureContainerRegistryHelpers.cs (6)
29
var registryName = await registry.Name.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false) ??
32
var registryEndpoint = await registry.Endpoint.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false) ??
35
var loginTask = await context.ReportingStep.CreateTaskAsync($"Logging in to **{registryName}**", context.
CancellationToken
).ConfigureAwait(false);
50
context.
CancellationToken
).ConfigureAwait(false);
52
await loginTask.CompleteAsync($"Successfully logged in to **{registryEndpoint}**", CompletionState.Completed, context.
CancellationToken
).ConfigureAwait(false);
56
await loginTask.FailAsync($"Login to ACR **{registryEndpoint}** failed: {ex.Message}", cancellationToken: context.
CancellationToken
).ConfigureAwait(false);
Aspire.Hosting.Docker (14)
DockerComposeEnvironmentResource.cs (13)
213
context.
CancellationToken
);
228
var deployTask = await context.ReportingStep.CreateTaskAsync($"Running docker compose up for **{Name}**", context.
CancellationToken
).ConfigureAwait(false);
259
.WaitAsync(context.
CancellationToken
)
264
await deployTask.FailAsync($"docker compose up failed with exit code {processResult.ExitCode}", cancellationToken: context.
CancellationToken
).ConfigureAwait(false);
268
await deployTask.CompleteAsync($"Service **{Name}** is now running with Docker Compose locally", CompletionState.Completed, context.
CancellationToken
).ConfigureAwait(false);
274
await deployTask.CompleteAsync($"Docker Compose deployment failed: {ex.Message}", CompletionState.CompletedWithError, context.
CancellationToken
).ConfigureAwait(false);
290
var deployTask = await context.ReportingStep.CreateTaskAsync($"Running docker compose down for **{Name}**", context.
CancellationToken
).ConfigureAwait(false);
313
.WaitAsync(context.
CancellationToken
)
318
await deployTask.FailAsync($"docker compose down failed with exit code {processResult.ExitCode}", cancellationToken: context.
CancellationToken
).ConfigureAwait(false);
322
await deployTask.CompleteAsync($"Docker Compose shutdown complete for **{Name}**", CompletionState.Completed, context.
CancellationToken
).ConfigureAwait(false);
328
await deployTask.CompleteAsync($"Docker Compose shutdown failed: {ex.Message}", CompletionState.CompletedWithError, context.
CancellationToken
).ConfigureAwait(false);
353
defaultValue = await parameter.GetValueAsync(context.
CancellationToken
).ConfigureAwait(false);
358
defaultValue = await ((IValueProvider)cir).GetValueAsync(context.
CancellationToken
).ConfigureAwait(false);
DockerComposeServiceResource.cs (1)
384
.WaitAsync(context.
CancellationToken
)
Aspire.Hosting.Kubernetes (1)
KubernetesEnvironmentResource.cs (1)
122
context.
CancellationToken
);
Aspire.Hosting.Tests (3)
Helpers\JsonDocumentManifestPublisher.cs (3)
84
var publishingContext = new ManifestPublishingContext(executionContext, manifestPath, writer, context.
CancellationToken
);
86
await publishingContext.WriteModel(context.Model, context.
CancellationToken
).ConfigureAwait(false);
89
manifestStore.ManifestDocument = await JsonDocument.ParseAsync(stream, cancellationToken: context.
CancellationToken
).ConfigureAwait(false);
Pipelines.AppHost (28)
AppHost.cs (28)
66
.CreateTaskAsync($"Granting file share access to current user", context.
CancellationToken
)
89
context.
CancellationToken
).ConfigureAwait(false);
93
var userObjectId = await getUserProcess.StandardOutput.ReadToEndAsync(context.
CancellationToken
).ConfigureAwait(false);
96
await getUserProcess.WaitForExitAsync(context.
CancellationToken
).ConfigureAwait(false);
100
var error = await getUserProcess.StandardError.ReadToEndAsync(context.
CancellationToken
).ConfigureAwait(false);
104
context.
CancellationToken
).ConfigureAwait(false);
124
context.
CancellationToken
).ConfigureAwait(false);
128
var subscriptionId = await getSubscriptionProcess.StandardOutput.ReadToEndAsync(context.
CancellationToken
).ConfigureAwait(false);
131
await getSubscriptionProcess.WaitForExitAsync(context.
CancellationToken
).ConfigureAwait(false);
135
var error = await getSubscriptionProcess.StandardError.ReadToEndAsync(context.
CancellationToken
).ConfigureAwait(false);
139
context.
CancellationToken
).ConfigureAwait(false);
159
context.
CancellationToken
).ConfigureAwait(false);
163
var resourceGroup = await getResourceGroupProcess.StandardOutput.ReadToEndAsync(context.
CancellationToken
).ConfigureAwait(false);
166
await getResourceGroupProcess.WaitForExitAsync(context.
CancellationToken
).ConfigureAwait(false);
170
var error = await getResourceGroupProcess.StandardError.ReadToEndAsync(context.
CancellationToken
).ConfigureAwait(false);
174
context.
CancellationToken
).ConfigureAwait(false);
197
context.
CancellationToken
).ConfigureAwait(false);
201
await assignRoleProcess.WaitForExitAsync(context.
CancellationToken
).ConfigureAwait(false);
205
var error = await assignRoleProcess.StandardError.ReadToEndAsync(context.
CancellationToken
).ConfigureAwait(false);
209
context.
CancellationToken
).ConfigureAwait(false);
216
context.
CancellationToken
).ConfigureAwait(false);
223
context.
CancellationToken
).ConfigureAwait(false);
265
.CreateTaskAsync($"Uploading {Path.GetFileName(sourcePath)} to {fileShareName}", deployingContext.
CancellationToken
)
275
deployingContext.
CancellationToken
).ConfigureAwait(false);
305
await directoryClient.CreateIfNotExistsAsync(cancellationToken: deployingContext.
CancellationToken
).ConfigureAwait(false);
313
await fileClient.CreateAsync(fileStream.Length, cancellationToken: deployingContext.
CancellationToken
).ConfigureAwait(false);
314
await fileClient.UploadAsync(fileStream, cancellationToken: deployingContext.
CancellationToken
).ConfigureAwait(false);
320
deployingContext.
CancellationToken
).ConfigureAwait(false);
Pipelines.Library (1)
DistributedApplicationPipelineExtensions.cs (1)
47
context.
CancellationToken
).ConfigureAwait(false);
Publishers.AppHost (7)
DistributedApplicationBuilderExtensions.cs (7)
120
cancellationToken: context.
CancellationToken
);
146
cancellationToken: context.
CancellationToken
);
161
cancellationToken: context.
CancellationToken
);
182
cancellationToken: context.
CancellationToken
);
196
cancellationToken: context.
CancellationToken
);
211
cancellationToken: context.
CancellationToken
);
231
cancellationToken: context.
CancellationToken
);