22DcpResource = dcpResource;

15public string DcpResourceName => DcpResource.Metadata.Name; 28public Service Service => (Service)DcpResource;

788var toCreate = _appResources.Where(r => r.DcpResource is ContainerNetwork); 791if (containerNetwork.DcpResource is ContainerNetwork cn) 800var toCreate = _appResources.Where(r => r.DcpResource is Container or Executable or ContainerExec); 819var containersTask = CreateContainersAsync(toCreate.Where(ar => ar.DcpResource is Container), cancellationToken); 820var executablesTask = CreateExecutablesAsync(toCreate.Where(ar => ar.DcpResource is Executable), cancellationToken); 821var containerExecsTask = CreateContainerExecutablesAsync(toCreate.Where(ar => ar.DcpResource is ContainerExec), cancellationToken); 834var svc = (Service)sp.DcpResource; 1129Func<CustomResourceSnapshot, CustomResourceSnapshot> snapshotBuild = er.DcpResource switch 1149await _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); 1162await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1170await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1203if (er.DcpResource is not ContainerExec containerExe) 1205throw new InvalidOperationException($"Expected an {nameof(ContainerExec)} resource, but got {er.DcpResource.Kind} instead"); 1222if (er.DcpResource is not Executable exe) 1224throw new InvalidOperationException($"Expected an Executable resource, but got {er.DcpResource.Kind} instead"); 1234if (er.DcpResource.TryGetAnnotationAsObjectList<string>(CustomResource.ResourceProjectArgsAnnotation, out var projectArgs) && projectArgs.Count > 0) 1253er.DcpResource.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, launchArgs.Select(a => new AppLaunchArgumentAnnotation(a.Value, isSensitive: a.IsSensitive))); 1458await _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); 1462if (cr.DcpResource is Container container) 1482await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false); 1484var dcpContainerResource = (Container)cr.DcpResource; 1627if (HasMultipleReplicas(appResource.DcpResource)) 1647if (HasMultipleReplicas(appResource.DcpResource) && ea.TargetPort is int) 1704var resourcesToCreate = _appResources.Select(r => r.DcpResource).OfType<RT>(); 1752switch (appResource.DcpResource) 1785throw new InvalidOperationException($"Unexpected resource type: {appResource.DcpResource.GetType().FullName}"); 1798.Where(r => r.DcpResource is not Service) 1799.SingleOrDefault(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName)); 1811var resourceType = GetResourceType(appResource.DcpResource, appResource.ModelResource); 1820switch (appResource.DcpResource) 1839throw new InvalidOperationException($"Unexpected resource type: {appResource.DcpResource.GetType().FullName}");