1 write to DcpResource
Aspire.Hosting (1)
Dcp\AppResource.cs (1)
40DcpResource = dcpResource;
54 references to DcpResource
Aspire.Hosting (53)
Dcp\AppResource.cs (5)
25public string DcpResourceName => DcpResource.Metadata.Name; 36CustomResource IAppResource.DcpResource => DcpResource; 50var dr = DcpResource; 51var odr = other.DcpResource; 84public Service Service => DcpResource;
Dcp\ContainerCreator.cs (4)
162return !DcpModelUtilities.ShouldDeferCreateForExplicitStart(resource.ModelResource, resource.DcpResource.Spec.Start); 210var dcpContainer = cr.DcpResource; 303var containerExes = _appResources.Get().OfType<RenderedModelResource<ContainerExec>>().Where(ar => ar.DcpResource.Spec.ContainerName == dcpContainer.Metadata.Name).ToArray(); 316if (er.DcpResource is not ContainerExec containerExe)
Dcp\ContainerNetworkEndpointProvisioner.cs (4)
202ServerServiceName = serverService.DcpResource.Metadata.Name, 212service.Annotate(CustomResource.PrimaryServiceNameAnnotation, serverService.DcpResource.Metadata.Name); 352var serviceObjects = containerNetworkServices.Select(service => service.ServiceResource.DcpResource).ToArray(); 389tunnelProxyResource.DcpResource,
Dcp\DcpExecutor.cs (21)
194var proxiedWithNoAddress = _appResources.Get().OfType<AppResource<Service>>().Select(r => r.DcpResource) 490Service: r.DcpResource, 491PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 581var objects = _appResources.Get().OfType<AppResource<RT>>().Select(ar => ar.DcpResource); 764if (!executable.DcpResource.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>( 795executable.DcpResource.SetAnnotationAsObjectList( 966var resourceType = GetResourceType(replicaResources.First().DcpResource, modelResource); 980var snapshotBuild = BuildSnapshotFunc(r.DcpResource); 1002r.DcpResource.Metadata.Name, 1014if (replicas.All(r => IsDelayedStart(r.DcpResource))) 1023r.DcpResource.Metadata.Name, 1094await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1099await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1257case RenderedModelResource<Container> { DcpResource.Spec.Start: false } cr when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(cr.ModelResource, cr.DcpResource.Spec.Start): 1260await PatchDcpObjectAsync(cr.DcpResource, static c => c.Spec.Start = true, cancellationToken).ConfigureAwait(false); 1263case RenderedModelResource<Executable> { DcpResource.Spec.Start: false } er when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(er.ModelResource, er.DcpResource.Spec.Start): 1266await PatchDcpObjectAsync(er.DcpResource, static e => e.Spec.Start = true, cancellationToken).ConfigureAwait(false); 1273cr.DcpResource.Spec.Start = true; 1285er.DcpResource.Spec.Start = true;
Dcp\DcpModelUtilities.cs (15)
69if (HasMultipleReplicas(appResource.DcpResource)) 84if (HasMultipleReplicas(appResource.DcpResource) && ea.TargetPort is int) 95appResource.DcpResource.AnnotateAsObjectList(CustomResource.ServiceProducerAnnotation, spAnn); 142.FirstOrDefault(swr => string.Equals(swr.DcpResource.Metadata.Name, observedService.Metadata.Name, StringComparison.Ordinal)); 169var svc = sp.DcpResource; 225if (resource.DcpResource is not Container ctr || ctr.Spec.Networks is null) 245targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 254if (resource.DcpResource is not Executable || enableAspireContainerTunnel) 264(int)sp.DcpResource.AllocatedPort!, 266targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 288Service: r.DcpResource, 289ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 290EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 291TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 292ContainerNetworkName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetworkName) == true ? containerNetworkName : null
Dcp\ExecutableConfigurationResolver.cs (1)
37var executable = renderedResource.DcpResource;
Dcp\ExecutableCreator.cs (3)
50resource.DcpResource.Spec.Start); 120.CreateDcpObjectsAsync([renderedResource.DcpResource], cancellationToken) 241var executable = renderedResource.DcpResource;
Aspire.Hosting.Dotnet.Tests (1)
DotnetProjectResourceTests.cs (1)
115.Select(item => item.DcpResource)