1 write to DcpResource
Aspire.Hosting (1)
Dcp\AppResource.cs (1)
40DcpResource = dcpResource;
53 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 (8)
254return !DcpModelUtilities.ShouldDeferCreateForExplicitStart(resource.ModelResource, resource.DcpResource.Spec.Start); 302var dcpContainer = cr.DcpResource; 395var containerExes = _appResources.Get().OfType<RenderedModelResource<ContainerExec>>().Where(ar => ar.DcpResource.Spec.ContainerName == dcpContainer.Metadata.Name).ToArray(); 408if (er.DcpResource is not ContainerExec containerExe) 456ServerServiceName = serverSvc.DcpResource.Metadata.Name, 466svc.Annotate(CustomResource.PrimaryServiceNameAnnotation, serverSvc.DcpResource.Metadata.Name); 533var serviceObjects = containerNetworkServices.Select(cns => cns.ServiceResource.DcpResource).ToArray(); 563await factory.PatchDcpObjectAsync(tunnelProxyResource.DcpResource,
Dcp\DcpExecutor.cs (21)
202var proxiedWithNoAddress = _appResources.Get().OfType<AppResource<Service>>().Select(r => r.DcpResource) 523Service: r.DcpResource, 524PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 597var objects = _appResources.Get().OfType<AppResource<RT>>().Select(ar => ar.DcpResource); 780if (!executable.DcpResource.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>( 811executable.DcpResource.SetAnnotationAsObjectList( 982var resourceType = GetResourceType(replicaResources.First().DcpResource, modelResource); 996var snapshotBuild = BuildSnapshotFunc(r.DcpResource); 1017r.DcpResource.Metadata.Name, 1028if (replicas.All(r => IsDelayedStart(r.DcpResource))) 1037r.DcpResource.Metadata.Name, 1107await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1112await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1270case RenderedModelResource<Container> { DcpResource.Spec.Start: false } cr when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(cr.ModelResource, cr.DcpResource.Spec.Start): 1273await PatchDcpObjectAsync(cr.DcpResource, static c => c.Spec.Start = true, cancellationToken).ConfigureAwait(false); 1276case RenderedModelResource<Executable> { DcpResource.Spec.Start: false } er when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(er.ModelResource, er.DcpResource.Spec.Start): 1279await PatchDcpObjectAsync(er.DcpResource, static e => e.Spec.Start = true, cancellationToken).ConfigureAwait(false); 1286cr.DcpResource.Spec.Start = true; 1298er.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)); 164var svc = sp.DcpResource; 220if (resource.DcpResource is not Container ctr || ctr.Spec.Networks is null) 240targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 249if (resource.DcpResource is not Executable || enableAspireContainerTunnel) 259(int)sp.DcpResource.AllocatedPort!, 261targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 283Service: r.DcpResource, 284ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 285EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 286TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 287ContainerNetworkName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetworkName) == true ? containerNetworkName : null
Dcp\ExecutableConfigurationResolver.cs (1)
36var executable = renderedResource.DcpResource;
Dcp\ExecutableCreator.cs (3)
47resource.DcpResource.Spec.Start); 113.CreateDcpObjectsAsync([renderedResource.DcpResource], cancellationToken) 165var executable = renderedResource.DcpResource;