1 write to DcpResource
Aspire.Hosting (1)
Dcp\AppResource.cs (1)
40DcpResource = dcpResource;
51 references to DcpResource
Aspire.Hosting (51)
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 (19)
201var proxiedWithNoAddress = _appResources.Get().OfType<AppResource<Service>>().Select(r => r.DcpResource) 522Service: r.DcpResource, 523PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 596var objects = _appResources.Get().OfType<AppResource<RT>>().Select(ar => ar.DcpResource); 929var resourceType = GetResourceType(replicaResources.First().DcpResource, modelResource); 943var snapshotBuild = BuildSnapshotFunc(r.DcpResource); 964r.DcpResource.Metadata.Name, 975if (replicas.All(r => IsDelayedStart(r.DcpResource))) 984r.DcpResource.Metadata.Name, 1054await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1059await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1217case RenderedModelResource<Container> { DcpResource.Spec.Start: false } cr when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(cr.ModelResource, cr.DcpResource.Spec.Start): 1220await PatchDcpObjectAsync(cr.DcpResource, static c => c.Spec.Start = true, cancellationToken).ConfigureAwait(false); 1223case RenderedModelResource<Executable> { DcpResource.Spec.Start: false } er when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(er.ModelResource, er.DcpResource.Spec.Start): 1226await PatchDcpObjectAsync(er.DcpResource, static e => e.Spec.Start = true, cancellationToken).ConfigureAwait(false); 1233cr.DcpResource.Spec.Start = true; 1245er.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;