25public string DcpResourceName => DcpResource.Metadata.Name; 53dr.Metadata.Name == odr.Metadata.Name && 54dr.Metadata.NamespaceProperty == odr.Metadata.NamespaceProperty;

303var containerExes = _appResources.Get().OfType<RenderedModelResource<ContainerExec>>().Where(ar => ar.DcpResource.Spec.ContainerName == dcpContainer.Metadata.Name).ToArray();

202ServerServiceName = serverService.DcpResource.Metadata.Name, 204ClientServiceName = service.Metadata.Name, 212service.Annotate(CustomResource.PrimaryServiceNameAnnotation, serverService.DcpResource.Metadata.Name); 470observedProxy.Metadata.Name, 477? $"'{observedProxy.Metadata.Name}': {observedProxy.Status?.Message ?? noDetailsAvailable}" 478: $"'{observedProxy.Metadata.Name}': did not reach a stable state (current state: '{observedProxy.Status?.State ?? "(unknown)"}')";

370var name = o.Metadata.Name; 395if (!objectsByName.TryGetValue(observed.Metadata.Name, out var original)) 401if (pending.Contains(observed.Metadata.Name) && isInDesiredState(original, observed)) 403pending.Remove(observed.Metadata.Name); 448HashSet<string> stillPending = [.. needAddressAllocated.Select(s => s.Metadata.Name)]; 463activity.AddDcpServiceAddressAllocated(original.Metadata.Name); 472if (stillPending.Contains(sar.Metadata.Name)) 474_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); 475activity.AddDcpServiceAddressAllocationFailed(sar.Metadata.Name); 490PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 497.First(svc => svc.Metadata.Name.Equals(cs.PrimaryServiceName)); 526$"'{volume.Spec.Name ?? volume.Metadata.Name}': current state is '{volume.Status?.State ?? "(unknown)"}'")); 546latest[obj.Metadata.Name] = obj; 558latest[observed.Metadata.Name] = observed; 782var annotation = annotationsByServiceName[serviceProducer.Service.Metadata.Name]; 1001r.DcpResource.Metadata.Name, 1022r.DcpResource.Metadata.Name, 1093await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1098await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1157.Where(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName)) 1188var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1203var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);

92var spAnn = new ServiceProducerAnnotation(sp.Service.Metadata.Name); 101if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 142.FirstOrDefault(swr => string.Equals(swr.DcpResource.Metadata.Name, observedService.Metadata.Name, StringComparison.Ordinal)); 186throw new InvalidDataException($"Service {svc.Metadata.Name} should have valid address at this point"); 196throw new InvalidOperationException($"Service '{svc.Metadata.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy."); 206throw new InvalidDataException($"Service {svc.Metadata.Name} should have valid address at this point"); 216targetPortExpression: $$$"""{{- portForServing "{{{svc.Metadata.Name}}}" -}}""", 245targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 266targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 289ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 290EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 291TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 292ContainerNetworkName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetworkName) == true ? containerNetworkName : null 305throw new InvalidDataException($"Service '{ts.Service!.Metadata.Name}' refers to endpoint '{ts.EndpointName}' that does not exist"); 311throw new InvalidDataException($"Container tunnel service {ts.Service?.Metadata.Name} should have valid address at this point"); 333targetPortExpression: $$$"""{{- portForServing "{{{ts.Service.Metadata.Name}}}" -}}""",

304var previousState = resourceByName.TryGetValue(resource.Metadata.Name, out var previousResource) 316ResetResourceLogState(resource.Metadata.Name); 339_logger.LogTrace("Deleting application model resource {AppResourceName} with {ResourceKind} resource {DcpResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 346_logger.LogTrace("Updating application model resource {AppResourceName} with {ResourceKind} resource {DcpResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 375_loggerService.HasActiveSubscribers(resource.Metadata.Name) && 376!_allLogsFlushed.ContainsKey(resource.Metadata.Name)) 381_allLogsFlushed.TryAdd(resource.Metadata.Name, true); 387_allLogsFlushed.TryRemove(resource.Metadata.Name, out _); 396if (IsSuperseded(resourceKind, resource.Metadata.Name, resource.Metadata.Uid)) 401publishTask = _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownToken, resourceType, appModelResource, resource.Metadata.Name, status, 416!_allLogsFlushed.ContainsKey(resource.Metadata.Name); 417_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null, ShouldStartStream: shouldStartStream)); 426_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.Metadata.Name); 437_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.Metadata.Name), out _); 439else if (resource.Metadata.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true) 444_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.Metadata.Name)] 525_logger.LogDebug("Current log flush for {ResourceName} timed out after {Timeout}.", resource.Metadata.Name, _terminalLogFlushTimeout); 529_logger.LogDebug("Current log flush for {ResourceName} ended because the resource was deleted.", resource.Metadata.Name); 533_logger.LogError(ex, "Error flushing current logs for {ResourceName}.", resource.Metadata.Name); 539SetPendingFollowLogDeduplication(resource.Metadata.Name, resource.Metadata.Uid, logEntries); 540_loggerService.AddLogEntries(resource.Metadata.Name, logEntries, inMemorySource: false, skipExisting: true); 588resource.Metadata.Name, 592resource.Metadata.Annotations); 664var resourceName = resource.Metadata.Name; 665var logStream = new LogStreamState(resource.Metadata.Uid); 915if (endpoint.Metadata.OwnerReferences is not null) 917foreach (var ownerReference in endpoint.Metadata.OwnerReferences) 936? _resourceState.AppResources.OfType<ServiceWithModelResource>().Select(s => s.Service).FirstOrDefault(s => s.Metadata.Name == serviceName) 986foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.Metadata.Name))) 1014if (IsSuperseded(resourceKind, resourceName, cr.Metadata.Uid)) 1046var resourceKey = (T.ObjectKind, resource.Metadata.Name); 1048if (IsSuperseded(resourceKey.ObjectKind, resourceKey.Name, resource.Metadata.Uid)) 1054!string.Equals(current.Uid, resource.Metadata.Uid, StringComparison.Ordinal))) 1083var resourceUid = resource.Metadata.Uid; 1084var resourceVersion = resource.Metadata.ResourceVersion; 1097_logger.LogTrace("Ignoring {ResourceKind} resource {ResourceName} reported by the DCP watch because its resource version {ResourceVersion} is unchanged.", T.ObjectKind, resource.Metadata.Name, resourceVersion); 1113map[resource.Metadata.Name] = resource; 1119if (!string.IsNullOrEmpty(resource.Metadata.Uid)) 1121_supersededResourceUids[resourceKey] = resource.Metadata.Uid; 1124map.Remove(resource.Metadata.Name, out _);

174return Path.Join(_aspireStore.BasePath, "dcp", "executables", executable.Metadata.Name, "certificates"); 177return Path.Join(_locations.DcpSessionDir, executable.Metadata.Name);

261executable.Metadata.Annotations?.Remove(Executable.LaunchConfigurationsAnnotation); 408return executable.Metadata.Annotations is { } annotations &&

138var name = obj.Metadata.Name; 221obj.Metadata.Name, 229obj.Metadata.Name, 423obj.Metadata.Name, 425obj.Metadata.Namespace(),

611c.Metadata.Name = name; 612c.Metadata.NamespaceProperty = string.Empty;

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

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

283tp.Metadata.Name = name; 284tp.Metadata.NamespaceProperty = string.Empty;

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

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

299exe.Metadata.Name = name; 300exe.Metadata.NamespaceProperty = string.Empty;

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

40public string? AppModelResourceName => Metadata.Annotations?.TryGetValue(ResourceNameAnnotation, out var value) is true ? value : null; 42public string? AppModelInitialState => Metadata.Annotations?.TryGetValue(ResourceStateAnnotation, out var value) is true ? value : null; 49if (Metadata.Annotations is null) 51Metadata.Annotations = new Dictionary<string, string>(); 54Metadata.Annotations[annotationName] = value; 59if (Metadata.Annotations is null) 61Metadata.Annotations = new Dictionary<string, string>(); 64AnnotateAsObjectList<TValue>(Metadata.Annotations, annotationName, value); 69if (Metadata.Annotations is null) 71Metadata.Annotations = new Dictionary<string, string>(); 74Metadata.Annotations[annotationName] = JsonSerializer.Serialize<List<TValue>>(list.ToList()); 79return 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;

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

66CreationTimeStamp = container.Metadata.CreationTimestamp?.ToUniversalTime(), 126CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 195CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 217CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 298var name = resource.Metadata.Name; 304.Select(s => (s.EndpointName!, s.Metadata.Name))); 319&& e.Value.Metadata.OwnerReferences?.Any(or => or.Kind == resource.Kind && or.Name == name) == true) 350var isActive = _resourceState.EndpointsMap.Any(e => e.Value.Spec.ServiceName == endpointOwnerEndpoint?.Metadata.Name);

114.OrderBy(static executable => int.Parse(executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex], CultureInfo.InvariantCulture)) 119Assert.Equal(instances.Select(instance => instance.Name), rendered.Select(executable => executable.Metadata.Name)); 120Assert.Equal(replicas, rendered.Select(executable => executable.Metadata.Annotations[CustomResource.OtelServiceInstanceIdAnnotation]).Distinct().Count()); 124Assert.Equal(index.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 125Assert.Equal(replicas.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 126Assert.Equal("svc", executable.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]);

86Assert.NotEqual(previous.Metadata.Uid, replacement.Metadata.Uid); 165kubernetesService.DeletedResources.Enqueue(previous.Metadata.Name); 168var reference = executor.GetResource(previous.Metadata.Name); 184Assert.NotEqual(previous.Metadata.Uid, replacement.Metadata.Uid); 216if (context.Resource is Endpoint { Metadata.Name: "program-endpoint" }) 250endpoint.Metadata.OwnerReferences = [new V1OwnerReference 254Name = previous.Metadata.Name, 255Uid = previous.Metadata.Uid 262var restartTask = executor.StartResourceAsync(executor.GetResource(previous.Metadata.Name), TestContext.Current.CancellationToken); 310Assert.Equal(service.Metadata.Name, producer.ServiceName); 315$"{{{{- portForServing \"{service.Metadata.Name}\" -}}}}", 319var firstName = executables[0].Metadata.Name; 320var secondName = executables[1].Metadata.Name; 327Assert.Equal(2, afterRestart.Count(executable => executable.Metadata.Name == firstName)); 328Assert.Single(afterRestart, executable => executable.Metadata.Name == secondName); 394Assert.Equal("1", executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 395Assert.Equal("0", executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 417Assert.Equal("CustomName", container.Metadata.Annotations["otel-service-name"]); 946var reference = appExecutor.GetResource(exe1.Metadata.Name); 1725var reference = appExecutor.GetResource(firstExecutable.Metadata.Name); 1763var reference = appExecutor.GetResource(firstContainer.Metadata.Name); 1925Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 1963var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 1973Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2000var loggerState = resourceLoggerService.GetResourceLoggerState(exeResource.Metadata.Name); 2013Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2066var watchLogs1 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 2072Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2088var watchLogs2 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 2152dcpResourceName = container.Metadata.Name; 2230using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2243() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null, 2312dcpResourceName = container.Metadata.Name; 2350if (obj.Metadata.Name == blockingDcpResourceName && 2359if (obj.Metadata.Name == blockingDcpResourceName && 2404blockingDcpResourceName = blockingContainer.Metadata.Name; 2405otherDcpResourceName = otherContainer.Metadata.Name; 2485using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2500() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null, 2565using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2590Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name)); 2603Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name)); 2649using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2664() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is not null, 2666var firstLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name); 2671Assert.Null(appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name)); 2768dcpResourceName = container.Metadata.Name; 2769Assert.False(string.IsNullOrEmpty(container.Metadata.Uid)); 2924dcpResourceName = container.Metadata.Name; 2925Assert.False(string.IsNullOrEmpty(container.Metadata.Uid)); 3032endpoint.Metadata.OwnerReferences = [new V1OwnerReference 3036Name = container.Metadata.Name, 3037Uid = container.Metadata.Uid 3050container.Metadata.Uid = "database-replacement"; 3107Assert.Equal(executable.Metadata.Name, change.DcpResourceName); 3154container.Metadata.ResourceVersion = null; 3265container.Metadata.Uid = "database-instance-2"; 3305if (container.Metadata.Uid == previousResourceUid && 3311if (container.Metadata.Uid == replacementResourceUid && 3362dcpResourceName = container.Metadata.Name; 3363previousResourceUid = container.Metadata.Uid; 3401container.Metadata.Uid = replacementResourceUid; 3545dcpResourceName = container.Metadata.Name; 3630dcpResourceName = container.Metadata.Name; 3731var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 3736Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 3792var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 3797Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 3857var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 3861Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 4861var resourceReference = appExecutor.GetResource(dcpCtr.Metadata.Name); 4864Assert.Equal($"Failed to delete '{dcpCtr.Metadata.Name}' successfully before restart.", ex.Message); 4959var annotations = container.Metadata.EnsureAnnotations(); 5456Assert.Equal("TestExecutable-12345678", exe.Metadata.Name); 5954r.Metadata.Annotations is not null && 5955r.Metadata.Annotations.ContainsKey(CustomResource.OtelServiceInstanceIdAnnotation)); 5957return resource.Metadata.Annotations![CustomResource.OtelServiceInstanceIdAnnotation]; 7219Assert.True(executable.Metadata.Annotations.TryGetValue( 9159var reference = appExecutor.GetResource(exe.Metadata.Name); 9167Assert.Equal([exe.Metadata.Name], kubernetesService.DeletedResources); 9363var reference = appExecutor.GetResource(executable.Metadata.Name); 9371Assert.Equal([executable.Metadata.Name], kubernetesService.DeletedResources); 9436var reference = appExecutor.GetResource(exe1.Metadata.Name); 9497var reference = appExecutor.GetResource(exe1.Metadata.Name); 9651&& x.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 9733s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 9773&& s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10223service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10274service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10311service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10350service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10481service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10511service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10562service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10592service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10642service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10724.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10797.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11161.OrderBy(e => e.Metadata.Annotations?[CustomResource.ResourceReplicaIndex], StringComparer.Ordinal) 11245Assert.Equal("1", exe.Metadata.Annotations?[CustomResource.ResourceReplicaCount]); 11246Assert.Equal("0", exe.Metadata.Annotations?[CustomResource.ResourceReplicaIndex]);

234Assert.False(executable.Metadata.Annotations?.ContainsKey(Executable.LaunchConfigurationsAnnotation) is true);

194watchedResourceName = enumerator.Current.Item2.Metadata.Name; 316container.Metadata.ResourceVersion = "0"; 321container.Metadata.Annotations = new Dictionary<string, string> { ["padding"] = new('x', 65536) }; 324container.Metadata.ResourceVersion = i.ToString(CultureInfo.InvariantCulture); 347var versions = new List<string> { enumerator.Current.Item2.Metadata.ResourceVersion }; 352versions.Add(enumerator.Current.Item2.Metadata.ResourceVersion); 445Assert.Equal("frontend", enumerator.Current.Item2.Metadata.Name); 518container.Metadata.ResourceVersion = requestNumber.ToString(CultureInfo.InvariantCulture); 543versions.Add(container.Metadata.ResourceVersion); 598Assert.Equal("frontend", observed?.Metadata.Name); 634Assert.Equal("frontend", enumerator.Current.Item2.Metadata.Name); 662container.Metadata.Annotations = new Dictionary<string, string> { ["message"] = message }; 689Assert.Equal(message, enumerator.Current.Item2.Metadata.Annotations["message"]); 737container.Metadata.ResourceVersion = requestNumber.ToString(CultureInfo.InvariantCulture); 764versions.Add(container.Metadata.ResourceVersion); 860created.Metadata.Uid = "created-object"; 867Assert.Equal("created-object", result.Metadata.Uid); 880created.Metadata.Uid = "created-object"; 899Assert.Equal("created-object", result.Metadata.Uid); 920created.Metadata.Uid = "created-object"; 930container.Metadata.NamespaceProperty = namespaceParameter; 934Assert.Equal("created-object", result.Metadata.Uid); 935Assert.Equal("frontend", result.Metadata.Name); 936Assert.Equal(namespaceParameter, result.Metadata.NamespaceProperty); 974created.Metadata.Uid = "retried-object"; 983Assert.Equal("retried-object", result.Metadata.Uid); 988Assert.Equal("frontend", first.Metadata.Name); 990Assert.Equal(container.Metadata.Annotations, first.Metadata.Annotations); 994Assert.Equal("frontend", second.Metadata.Name); 996Assert.Equal(container.Metadata.Annotations, second.Metadata.Annotations); 1018created.Metadata.Uid = "late-original"; 1024Assert.Equal(Volatile.Read(ref original)!.Metadata.Name, created.Metadata.Name); 1044Assert.Equal("late-original", result.Metadata.Uid); 1071created.Metadata.Uid = "original-object"; 1093Assert.Equal("original-object", result.Metadata.Uid); 1186existing.Metadata.Uid = "existing-object"; 1198Assert.Equal("existing-object", result.Metadata.Uid); 1201Assert.Equal("preserved", result.Metadata.Annotations["existing-annotation"]); 1277Assert.Equal("frontend", result.Metadata.Name); 1306Assert.Equal("frontend", result.Metadata.Name); 1340created.Metadata.Uid = "original-object"; 1375Assert.Equal("original-object", result.Metadata.Uid); 1407created.Metadata.Uid = "retried-object"; 1416Assert.Equal("retried-object", result.Metadata.Uid); 1546created.Metadata.Uid = "retried-object"; 1554Assert.Equal("retried-object", result.Metadata.Uid); 1575existing.Metadata.Uid = "pre-existing-object"; 1864created.Metadata.Uid = "committed-object"; 1890Assert.Equal("committed-object", result.Metadata.Uid); 2010Assert.Equal("readiness-probe", probe.Metadata.Name); 2122Assert.Equal("frontend", watchEnumerator.Current.Item2.Metadata.Name);

62: (obj, logStreamType, follow) => new MemoryStream(Encoding.UTF8.GetBytes($"Logs for {obj.Metadata.Name} ({logStreamType})"))); 83r.Metadata.Name == name && 84string.Equals(r.Metadata.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty) 110svc.Metadata.Annotations?.ContainsKey(CustomResource.ContainerTunnelInstanceName) is true) 213foreach (var res in CreatedResources.Where(r => !DeletedResources.Contains(r.Metadata.Name))) 229if (string.IsNullOrEmpty(resource.Metadata.Uid)) 231resource.Metadata.Uid = $"test-resource-{Interlocked.Increment(ref _nextResourceUid)}"; 242resource.Metadata.ResourceVersion = Interlocked.Increment(ref _nextResourceVersion).ToString(CultureInfo.InvariantCulture); 263var service = CreatedResources.OfType<Service>().FirstOrDefault(s => s.Metadata.Name == serviceProduced.ServiceName); 307string.Equals(r.Metadata.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty) 390r.Metadata.Name == obj.Metadata.Name && 391string.Equals(r.Metadata.NamespaceProperty, obj.Metadata.NamespaceProperty) 395throw new ArgumentException($"Resource '{obj.Metadata.NamespaceProperty}/{obj.Metadata.Name}' not found");

940var redisContainer = Assert.Single(list, c => c.Metadata.Name.StartsWith($"{testName}-redis")); 1235await orchestrator.StopResourceAsync(redisContainer.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1240await orchestrator.StartResourceAsync(redisContainer.Metadata.Name, token); 1274await orchestrator.StopResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1279await orchestrator.StartResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1653Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Container.ResourceNameAnnotation, out var value)); 1667Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value)); 1934Assert.All(serviceList.Where(s => s.Metadata.Name.Contains("redis")), s => Assert.Equal(AddressAllocationModes.Proxyless, s.Spec.AddressAllocationMode));

213Assert.Matches("^volume-[0-9a-f]{32}$", volume.Metadata.Name);