1 write to DcpResource
Aspire.Hosting (1)
Dcp\AppResource.cs (1)
19DcpResource = dcpResource;
64 references to DcpResource
Aspire.Hosting (64)
Dcp\AppResource.cs (6)
14public string DcpResourceName => DcpResource.Metadata.Name; 15public string DcpResourceKind => DcpResource.Kind; 30var dr = DcpResource; 31var odr = other.DcpResource; 40public Service Service => (Service)DcpResource; 66public Service Service => (Service)DcpResource;
Dcp\DcpExecutor.cs (58)
190var proxiedWithNoAddress = _appResources.Where(r => r.DcpResource is Service { }).Select(r => (Service)r.DcpResource) 198var executables = _appResources.OfType<RenderedModelResource>().Where(ar => ar.DcpResource is Executable); 918var containerTunnelProxies = _appResources.Where(r => r.DcpResource is ContainerNetworkTunnelProxy { }).ToImmutableArray(); 921var containerNetworkName = (ctp.DcpResource as ContainerNetworkTunnelProxy)?.Spec.ContainerNetworkName; 925var tunnelServices = _appResources.Where(r => r.DcpResource is Service { }).Select(r => (Service)r.DcpResource) 944var containerServices = _appResources.Where(r => r.DcpResource is Service { }).Select(r => ( 945Service: r.DcpResource as Service, 946PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 962var toCreate = _appResources.Select(r => r.DcpResource).OfType<RT>().ToImmutableArray(); 1020var svc = (Service)sp.DcpResource; 1044if (appResource.DcpResource is Container ctr && ctr.Spec.Networks is not null) 1067if (appResource.DcpResource is Executable && !_options.Value.EnableAspireContainerTunnel) 1089Service: r.DcpResource as Service, 1090ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 1091EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 1092TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 1093ContainerNetworkName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetworkName) == true ? containerNetworkName : null 1333ServerServiceName = serverSvc.DcpResource.Metadata.Name, 1346svc.Annotate(CustomResource.PrimaryServiceNameAnnotation, serverSvc.DcpResource.Metadata.Name); 1609Func<CustomResourceSnapshot, CustomResourceSnapshot> snapshotBuild = er.DcpResource switch 1627er.DcpResource.Metadata.Name, new ResourceStatus(KnownResourceStates.NotStarted, null, null), s => s with { State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) }) 1658await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1666await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1687if (er.DcpResource is not ContainerExec containerExe) 1689throw new InvalidOperationException($"Expected an {nameof(ContainerExec)} resource, but got {er.DcpResource.Kind} instead"); 1695AspireEventSource.Instance.DcpObjectCreationStart(er.DcpResource.Kind, er.DcpResourceName); 1700AspireEventSource.Instance.DcpObjectCreationStop(er.DcpResource.Kind, er.DcpResourceName); 1706if (er.DcpResource is not Executable exe) 1708throw new InvalidOperationException($"Expected an Executable resource, but got {er.DcpResource.Kind} instead"); 1712AspireEventSource.Instance.DcpObjectCreationStart(er.DcpResource.Kind, er.DcpResourceName); 1723if (er.DcpResource.TryGetAnnotationAsObjectList<string>(CustomResource.ResourceProjectArgsAnnotation, out var projectArgs) && projectArgs.Count > 0) 1832er.DcpResource.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, displayArgs.Select(a => new AppLaunchArgumentAnnotation(a.Value, isSensitive: a.IsSensitive))); 1845AspireEventSource.Instance.DcpObjectCreationStop(er.DcpResource.Kind, er.DcpResourceName); 2041await _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); 2045if (cr.DcpResource is Container container) 2067var dcpContainerResource = (Container)cr.DcpResource; 2077await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false); 2271AspireEventSource.Instance.DcpObjectCreationStop(cr.DcpResource.Kind, cr.DcpResourceName); 2379if (HasMultipleReplicas(appResource.DcpResource)) 2399if (HasMultipleReplicas(appResource.DcpResource) && ea.TargetPort is int) 2474var dcpResource = ((RenderedModelResource)resourceReference).DcpResource; 2535.Where(r => r.DcpResource is not Service) 2536.SingleOrDefault(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName)); 2548var resourceType = GetResourceType(appResource.DcpResource, appResource.ModelResource); 2550AspireEventSource.Instance.StartResourceStart(appResource.DcpResource.Kind, appResource.DcpResource.Metadata.Name); 2558switch (appResource.DcpResource) 2577throw new InvalidOperationException($"Unexpected resource type: {appResource.DcpResource.Kind}"); 2595AspireEventSource.Instance.StartResourceStop(appResource.DcpResource.Kind, appResource.DcpResource.Metadata.Name); 2995var containers = _appResources.OfType<RenderedModelResource>().Where(ar => ar.DcpResource is Container); 3020var persistentTunnelDependent = tunnelDependent.Where(td => td.DcpResource is Container c && c.Spec.Persistent is true); 3031.Where(ar => ar.DcpResource is ContainerExec ce && regular.Any(td => td.DcpResource is Container c && c.Metadata.Name == ce.Spec.ContainerName)), 3033.Where(ar => ar.DcpResource is ContainerExec ce && tunnelDependent.Any(td => td.DcpResource is Container c && c.Metadata.Name == ce.Spec.ContainerName))