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

432if (_logStreams.TryRemove(resource.Metadata.Name, out var logStream)) 440_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 447_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 452await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.Metadata.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false); 458_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null)); 467_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.Metadata.Name); 478_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.Metadata.Name), out _); 480else if (resource.Metadata.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true) 485_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.Metadata.Name)] 633_logStreams.GetOrAdd(resource.Metadata.Name, (_) => 643_logger.LogDebug("Starting log streaming for {ResourceName}.", resource.Metadata.Name); 647var logger = _loggerService.GetInternalLogger(resource.Metadata.Name); 660_logger.LogDebug("Log streaming for {ResourceName} was cancelled.", resource.Metadata.Name); 664_logger.LogError(ex, "Error streaming logs for {ResourceName}.", resource.Metadata.Name); 680if (endpoint.Metadata.OwnerReferences is null) 685foreach (var ownerReference in endpoint.Metadata.OwnerReferences) 698foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.Metadata.Name))) 748map.TryAdd(resource.Metadata.Name, resource); 752map[resource.Metadata.Name] = resource; 756map.Remove(resource.Metadata.Name, out _); 789var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Metadata.Name == updated.Metadata.Name); 812var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false); 819_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); 839sr.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var _) is true && 840sr.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetwork) is true && 857PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 864.Where(svc => svc.Metadata.Name.Equals(cs.PrimaryServiceName)).First(); 925throw new InvalidDataException($"Service {svc.Metadata.Name} should have valid address at this point"); 930throw new InvalidOperationException($"Service '{svc.Metadata.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy."); 940targetPortExpression: $$$"""{{- portForServing "{{{svc.Metadata.Name}}}" -}}""", 952ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 953EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 954TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 955ContainerNetworkName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetworkName) == true ? containerNetworkName : null 968throw new InvalidDataException($"Service '{ts.Service!.Metadata.Name}' refers to endpoint '{ts.EndpointName}' that does not exist"); 974throw new InvalidDataException($"Container tunnel service {ts.Service?.Metadata.Name} should have valid address at this point"); 1174ServerServiceName = serverSvc.DcpResource.Metadata.Name, 1176ClientServiceName = svc.Metadata.Name, 1187svc.Annotate(CustomResource.PrimaryServiceNameAnnotation, serverSvc.DcpResource.Metadata.Name); 1190svc.Annotate(CustomResource.ContainerTunnelInstanceName, tunnelProxy?.Metadata?.Name ?? ""); 1462await _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); 1475await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1483await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1764await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false); 1966var spAnn = new ServiceProducerAnnotation(sp.Service.Metadata.Name); 1975if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 2045var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 2060var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 2088.SingleOrDefault(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName));

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

548c.Metadata.Name = name; 549c.Metadata.NamespaceProperty = string.Empty;

137containerExec.Metadata.Name = name; 138containerExec.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;

237exe.Metadata.Name = name; 238exe.Metadata.NamespaceProperty = string.Empty;

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

36public string? AppModelResourceName => Metadata.Annotations?.TryGetValue(ResourceNameAnnotation, out var value) is true ? value : null; 38public string? AppModelInitialState => Metadata.Annotations?.TryGetValue(ResourceStateAnnotation, out var value) is true ? value : null; 45if (Metadata.Annotations is null) 47Metadata.Annotations = new Dictionary<string, string>(); 50Metadata.Annotations[annotationName] = value; 55if (Metadata.Annotations is null) 57Metadata.Annotations = new Dictionary<string, string>(); 60AnnotateAsObjectList<TValue>(Metadata.Annotations, annotationName, value); 65if (Metadata.Annotations is null) 67Metadata.Annotations = new Dictionary<string, string>(); 70Metadata.Annotations[annotationName] = JsonSerializer.Serialize<List<TValue>>(list.ToList()); 75return TryGetAnnotationAsObjectList<TValue>(Metadata.Annotations, annotationName, out list);

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

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

97logger.LogWarning("Failed to write log entry to channel. Logs for {Kind} {Name} may be incomplete", resource.Kind, resource.Metadata.Name); 109logger.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(), 244var name = resource.Metadata.Name; 247var serviceEndpoints = new HashSet<(string EndpointName, string ServiceMetadataName)>(resourceServices.Where(s => !string.IsNullOrEmpty(s.EndpointName)).Select(s => (s.EndpointName!, s.Metadata.Name))); 255var activeEndpoint = _resourceState.EndpointsMap.SingleOrDefault(e => e.Value.Spec.ServiceName == serviceName && e.Value.Metadata.OwnerReferences?.Any(or => or.Kind == resource.Kind && or.Name == name) == true).Value;

48Assert.Equal("CustomName", container.Metadata.Annotations["otel-service-name"]); 210var reference = appExecutor.GetResource(exe1.Metadata.Name); 557Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 595var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 605Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 632var loggerState = resourceLoggerService.GetResourceLoggerState(exeResource.Metadata.Name); 645Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 698var watchLogs1 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 704Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 720var watchLogs2 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 1153var resourceReference = appExecutor.GetResource(dcpCtr.Metadata.Name); 1156Assert.Equal($"Failed to delete '{dcpCtr.Metadata.Name}' successfully before restart.", ex.Message); 1278var annotations = container.Metadata.EnsureAnnotations();

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");

656var redisContainer = Assert.Single(list, c => c.Metadata.Name.StartsWith($"{testName}-redis")); 951await orchestrator.StopResourceAsync(redisContainer.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 956await orchestrator.StartResourceAsync(redisContainer.Metadata.Name, token); 988await orchestrator.StopResourceAsync(serviceA.Metadata.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 993await orchestrator.StartResourceAsync(serviceA.Metadata.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1315Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Container.ResourceNameAnnotation, out var value)); 1329Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value)); 1591Assert.All(serviceList.Where(s => s.Metadata.Name.Contains("redis")), s => Assert.Equal(AddressAllocationModes.Proxyless, s.Spec.AddressAllocationMode));