1 write to DcpResource
Aspire.Hosting (1)
31 references to DcpResource
Aspire.Hosting (31)
Dcp\DcpExecutor.cs (29)
765var toCreate = _appResources.Where(r => r.DcpResource is ContainerNetwork);
768if (containerNetwork.DcpResource is ContainerNetwork cn)
777var toCreate = _appResources.Where(r => r.DcpResource is Container || r.DcpResource is Executable);
789var containersTask = CreateContainersAsync(toCreate.Where(ar => ar.DcpResource is Container), cancellationToken);
790var executablesTask = CreateExecutablesAsync(toCreate.Where(ar => ar.DcpResource is Executable), cancellationToken);
803var svc = (Service)sp.DcpResource;
1039await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, resource, er.DcpResourceName, new ResourceStatus(null, null, null), s => _snapshotBuilder.ToSnapshot((Executable)er.DcpResource, s))).ConfigureAwait(false);
1048await _executorEvents.PublishAsync(new OnResourceChangedContext(cancellationToken, resourceType, resource, er.DcpResource.Metadata.Name, new ResourceStatus(KnownResourceStates.NotStarted, null, null), s => s with { State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) })).ConfigureAwait(false);
1061await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false);
1069await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false);
1101if (er.DcpResource is not Executable exe)
1103throw new InvalidOperationException($"Expected an Executable resource, but got {er.DcpResource.Kind} instead");
1113if (er.DcpResource.TryGetAnnotationAsObjectList<string>(CustomResource.ResourceProjectArgsAnnotation, out var projectArgs) && projectArgs.Count > 0)
1132er.DcpResource.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, launchArgs.Select(a => new AppLaunchArgumentAnnotation(a.Value, isSensitive: a.IsSensitive)));
1329await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName, new ResourceStatus(null, null, null), s => _snapshotBuilder.ToSnapshot((Container)cr.DcpResource, s))).ConfigureAwait(false);
1333if (cr.DcpResource is Container container)
1353await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false);
1355var dcpContainerResource = (Container)cr.DcpResource;
1498if (HasMultipleReplicas(appResource.DcpResource))
1518if (HasMultipleReplicas(appResource.DcpResource) && ea.TargetPort is int)
1601var resourcesToCreate = _appResources.Select(r => r.DcpResource).OfType<RT>();
1649switch (appResource.DcpResource)
1682throw new InvalidOperationException($"Unexpected resource type: {appResource.DcpResource.GetType().FullName}");
1695.Where(r => r.DcpResource is not Service)
1696.SingleOrDefault(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName));
1708var resourceType = GetResourceType(appResource.DcpResource, appResource.ModelResource);
1717switch (appResource.DcpResource)
1735throw new InvalidOperationException($"Unexpected resource type: {appResource.DcpResource.GetType().FullName}");