14public string DcpResourceName => DcpResource.Metadata.Name; 33dr.Metadata.Name == odr.Metadata.Name && 34dr.Metadata.NamespaceProperty == odr.Metadata.NamespaceProperty;

508if (_logStreams.TryRemove(resource.Metadata.Name, out var logStream)) 516_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 523_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 528await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.Metadata.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false); 534_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null)); 543_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.Metadata.Name); 554_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.Metadata.Name), out _); 556else if (resource.Metadata.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true) 561_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.Metadata.Name)] 709_logStreams.GetOrAdd(resource.Metadata.Name, (_) => 719_logger.LogDebug("Starting log streaming for {ResourceName}.", resource.Metadata.Name); 723var logger = _loggerService.GetInternalLogger(resource.Metadata.Name); 736_logger.LogDebug("Log streaming for {ResourceName} was cancelled.", resource.Metadata.Name); 740_logger.LogError(ex, "Error streaming logs for {ResourceName}.", resource.Metadata.Name); 756if (endpoint.Metadata.OwnerReferences is null) 761foreach (var ownerReference in endpoint.Metadata.OwnerReferences) 774foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.Metadata.Name))) 824map.TryAdd(resource.Metadata.Name, resource); 828map[resource.Metadata.Name] = resource; 832map.Remove(resource.Metadata.Name, out _); 871var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Metadata.Name == updated.Metadata.Name); 882AspireEventSource.Instance.DcpServiceAddressAllocated(srvResource.Metadata.Name); 895var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false); 902_distributedApplicationLogger.LogWarning("Unable to allocate a network port for service '{ServiceName}'; service may be unreachable and its clients may not work properly.", sar.Metadata.Name); 903AspireEventSource.Instance.DcpServiceAddressAllocationFailed(sar.Metadata.Name); 928sr.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var _) is true && 929sr.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetwork) is true && 946PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 953.Where(svc => svc.Metadata.Name.Equals(cs.PrimaryServiceName)).First(); 978AspireEventSource.Instance.DcpObjectCreationStart(rtc.Kind, rtc.Metadata.Name); 983AspireEventSource.Instance.DcpObjectCreationStop(rtc.Kind, rtc.Metadata.Name); 1026throw new InvalidDataException($"Service {svc.Metadata.Name} should have valid address at this point"); 1031throw new InvalidOperationException($"Service '{svc.Metadata.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy."); 1041targetPortExpression: $$$"""{{- portForServing "{{{svc.Metadata.Name}}}" -}}""", 1058targetPortExpression: $$$"""{{- portForServing "{{{svc.Metadata.Name}}}" -}}""", 1075targetPortExpression: $$$"""{{- portForServing "{{{svc.Metadata.Name}}}" -}}""", 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 1106throw new InvalidDataException($"Service '{ts.Service!.Metadata.Name}' refers to endpoint '{ts.EndpointName}' that does not exist"); 1112throw new InvalidDataException($"Container tunnel service {ts.Service?.Metadata.Name} should have valid address at this point"); 1333ServerServiceName = serverSvc.DcpResource.Metadata.Name, 1335ClientServiceName = svc.Metadata.Name, 1346svc.Annotate(CustomResource.PrimaryServiceNameAnnotation, serverSvc.DcpResource.Metadata.Name); 1349svc.Annotate(CustomResource.ContainerTunnelInstanceName, tunnelProxy?.Metadata?.Name ?? ""); 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); 2069AspireEventSource.Instance.DcpObjectCreationStart(dcpContainerResource.Kind, dcpContainerResource.Metadata.Name); 2077await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false); 2406var spAnn = new ServiceProducerAnnotation(sp.Service.Metadata.Name); 2415if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 2477AspireEventSource.Instance.StopResourceStart(dcpResource.Kind, dcpResource.Metadata.Name); 2488var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 2503var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 2522AspireEventSource.Instance.StopResourceStop(dcpResource.Kind, dcpResource.Metadata.Name); 2536.SingleOrDefault(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName)); 2550AspireEventSource.Instance.StartResourceStart(appResource.DcpResource.Kind, appResource.DcpResource.Metadata.Name); 2595AspireEventSource.Instance.StartResourceStop(appResource.DcpResource.Kind, appResource.DcpResource.Metadata.Name); 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))

176obj.Metadata.Name, 184obj.Metadata.Name, 349obj.Metadata.Name, 351obj.Metadata.Namespace(),

575c.Metadata.Name = name; 576c.Metadata.NamespaceProperty = string.Empty;

137containerExec.Metadata.Name = name; 138containerExec.Metadata.NamespaceProperty = string.Empty;

91c.Metadata.Name = name; 92c.Metadata.NamespaceProperty = string.Empty;

271tp.Metadata.Name = name; 272tp.Metadata.NamespaceProperty = string.Empty;

78containerVolume.Metadata.Name = name; 79containerVolume.Metadata.NamespaceProperty = string.Empty;

48e.Metadata.Name = name; 49e.Metadata.NamespaceProperty = string.Empty;

261exe.Metadata.Name = name; 262exe.Metadata.NamespaceProperty = string.Empty;

107ers.Metadata.Name = name; 108ers.Metadata.NamespaceProperty = string.Empty;

41public string? AppModelResourceName => Metadata.Annotations?.TryGetValue(ResourceNameAnnotation, out var value) is true ? value : null; 43public string? AppModelInitialState => Metadata.Annotations?.TryGetValue(ResourceStateAnnotation, out var value) is true ? value : null; 50if (Metadata.Annotations is null) 52Metadata.Annotations = new Dictionary<string, string>(); 55Metadata.Annotations[annotationName] = value; 60if (Metadata.Annotations is null) 62Metadata.Annotations = new Dictionary<string, string>(); 65AnnotateAsObjectList<TValue>(Metadata.Annotations, annotationName, value); 70if (Metadata.Annotations is null) 72Metadata.Annotations = new Dictionary<string, string>(); 75Metadata.Annotations[annotationName] = JsonSerializer.Serialize<List<TValue>>(list.ToList()); 80return TryGetAnnotationAsObjectList<TValue>(Metadata.Annotations, annotationName, out list);

83s.Metadata.Name = name; 84s.Metadata.NamespaceProperty = string.Empty; 93public string? EndpointName => Metadata.Annotations?.TryGetValue(EndpointNameAnnotation, out var value) is true ? value : null;

69logger.LogWarning("Failed to write log entry to channel. Logs for {Kind} {Name} may be incomplete", resource.Kind, resource.Metadata.Name); 81logger.LogError(ex, "Unexpected error happened when capturing logs for {Kind} {Name}", resource.Kind, resource.Metadata.Name);

62CreationTimeStamp = container.Metadata.CreationTimestamp?.ToUniversalTime(), 121CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 176CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 198CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 247var name = resource.Metadata.Name; 253.Select(s => (s.EndpointName!, s.Metadata.Name))); 268&& e.Value.Metadata.OwnerReferences?.Any(or => or.Kind == resource.Kind && or.Name == name) == true) 299var isActive = _resourceState.EndpointsMap.Any(e => e.Value.Spec.ServiceName == endpointOwnerEndpoint?.Metadata.Name);

49Assert.Equal("CustomName", container.Metadata.Annotations["otel-service-name"]); 247var reference = appExecutor.GetResource(exe1.Metadata.Name); 594Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 632var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 642Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 669var loggerState = resourceLoggerService.GetResourceLoggerState(exeResource.Metadata.Name); 682Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 735var watchLogs1 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 741Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 757var watchLogs2 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 815var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 820Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 1254var resourceReference = appExecutor.GetResource(dcpCtr.Metadata.Name); 1257Assert.Equal($"Failed to delete '{dcpCtr.Metadata.Name}' successfully before restart.", ex.Message); 1383var annotations = container.Metadata.EnsureAnnotations(); 2237&& x.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName))

34_startStream = startStream ?? ((obj, logStreamType) => new MemoryStream(Encoding.UTF8.GetBytes($"Logs for {obj.Metadata.Name} ({logStreamType})"))); 49r.Metadata.Name == name && 50string.Equals(r.Metadata.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty) 127string.Equals(r.Metadata.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty) 190r.Metadata.Name == obj.Metadata.Name && 191string.Equals(r.Metadata.NamespaceProperty, obj.Metadata.NamespaceProperty) 195throw new ArgumentException($"Resource '{obj.Metadata.NamespaceProperty}/{obj.Metadata.Name}' not found");

792var redisContainer = Assert.Single(list, c => c.Metadata.Name.StartsWith($"{testName}-redis")); 1087await orchestrator.StopResourceAsync(redisContainer.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1092await orchestrator.StartResourceAsync(redisContainer.Metadata.Name, token); 1124await orchestrator.StopResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1129await orchestrator.StartResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1436Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Container.ResourceNameAnnotation, out var value)); 1450Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value)); 1710Assert.All(serviceList.Where(s => s.Metadata.Name.Contains("redis")), s => Assert.Equal(AddressAllocationModes.Proxyless, s.Spec.AddressAllocationMode));