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

381var name = o.Metadata.Name; 406if (!objectsByName.TryGetValue(observed.Metadata.Name, out var original)) 412if (pending.Contains(observed.Metadata.Name) && isInDesiredState(original, observed)) 414pending.Remove(observed.Metadata.Name); 459HashSet<string> stillPending = [.. needAddressAllocated.Select(s => s.Metadata.Name)]; 474activity.AddDcpServiceAddressAllocated(original.Metadata.Name); 483if (stillPending.Contains(sar.Metadata.Name)) 485_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); 486activity.AddDcpServiceAddressAllocationFailed(sar.Metadata.Name); 501PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 508.First(svc => svc.Metadata.Name.Equals(cs.PrimaryServiceName)); 537$"'{volume.Spec.Name ?? volume.Metadata.Name}': current state is '{volume.Status?.State ?? "(unknown)"}'")); 557latest[obj.Metadata.Name] = obj; 569latest[observed.Metadata.Name] = observed; 783var annotation = annotationsByServiceName[serviceProducer.Service.Metadata.Name]; 917r.DcpResource.Metadata.Name, 938r.DcpResource.Metadata.Name, 1009await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1014await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1073.Where(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName)) 1104var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1120var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);

134var spAnn = new ServiceProducerAnnotation(sp.Service.Metadata.Name); 143if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 184.FirstOrDefault(swr => string.Equals(swr.DcpResource.Metadata.Name, observedService.Metadata.Name, StringComparison.Ordinal)); 228throw new InvalidDataException($"Service {svc.Metadata.Name} should have valid address at this point"); 238throw new InvalidOperationException($"Service '{svc.Metadata.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy."); 248throw new InvalidDataException($"Service {svc.Metadata.Name} should have valid address at this point"); 258targetPortExpression: $$$"""{{- portForServing "{{{svc.Metadata.Name}}}" -}}""", 287targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 308targetPortExpression: $$$"""{{- portForServing "{{{sp.DcpResource.Metadata.Name}}}" -}}""", 331ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 332EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 333TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 334ContainerNetworkName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetworkName) == true ? containerNetworkName : null 347throw new InvalidDataException($"Service '{ts.Service!.Metadata.Name}' refers to endpoint '{ts.EndpointName}' that does not exist"); 353throw new InvalidDataException($"Container tunnel service {ts.Service?.Metadata.Name} should have valid address at this point"); 375targetPortExpression: $$$"""{{- 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); 415return 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;

300exe.Metadata.Name = name; 301exe.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);

67CreationTimeStamp = container.Metadata.CreationTimestamp?.ToUniversalTime(), 127CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 205CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 227CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 557var name = resource.Metadata.Name; 563.Select(s => (s.EndpointName!, s.Metadata.Name))); 578&& e.Value.Metadata.OwnerReferences?.Any(or => or.Kind == resource.Kind && or.Name == name) == true) 609var isActive = _resourceState.EndpointsMap.Any(e => e.Value.Spec.ServiceName == endpointOwnerEndpoint?.Metadata.Name);

106.OrderBy(static executable => int.Parse(executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex], CultureInfo.InvariantCulture)) 111Assert.Equal(instances.Select(instance => instance.Name), rendered.Select(executable => executable.Metadata.Name)); 112Assert.Equal(replicas, rendered.Select(executable => executable.Metadata.Annotations[CustomResource.OtelServiceInstanceIdAnnotation]).Distinct().Count()); 116Assert.Equal(index.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 117Assert.Equal(replicas.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 118Assert.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"]); 989var reference = appExecutor.GetResource(exe1.Metadata.Name); 1795var reference = appExecutor.GetResource(firstExecutable.Metadata.Name); 1833var reference = appExecutor.GetResource(firstContainer.Metadata.Name); 2411Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 2449var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 2459Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2486var loggerState = resourceLoggerService.GetResourceLoggerState(exeResource.Metadata.Name); 2499Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2552var watchLogs1 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 2558Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2574var watchLogs2 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 2638dcpResourceName = container.Metadata.Name; 2716using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2729() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null, 2798dcpResourceName = container.Metadata.Name; 2836if (obj.Metadata.Name == blockingDcpResourceName && 2845if (obj.Metadata.Name == blockingDcpResourceName && 2890blockingDcpResourceName = blockingContainer.Metadata.Name; 2891otherDcpResourceName = otherContainer.Metadata.Name; 2971using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2986() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null, 3051using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 3076Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name)); 3089Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name)); 3135using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 3150() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is not null, 3152var firstLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name); 3157Assert.Null(appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name)); 3254dcpResourceName = container.Metadata.Name; 3255Assert.False(string.IsNullOrEmpty(container.Metadata.Uid)); 3410dcpResourceName = container.Metadata.Name; 3411Assert.False(string.IsNullOrEmpty(container.Metadata.Uid)); 3518endpoint.Metadata.OwnerReferences = [new V1OwnerReference 3522Name = container.Metadata.Name, 3523Uid = container.Metadata.Uid 3536container.Metadata.Uid = "database-replacement"; 3593Assert.Equal(executable.Metadata.Name, change.DcpResourceName); 3640container.Metadata.ResourceVersion = null; 3751container.Metadata.Uid = "database-instance-2"; 3791if (container.Metadata.Uid == previousResourceUid && 3797if (container.Metadata.Uid == replacementResourceUid && 3848dcpResourceName = container.Metadata.Name; 3849previousResourceUid = container.Metadata.Uid; 3887container.Metadata.Uid = replacementResourceUid; 4031dcpResourceName = container.Metadata.Name; 4116dcpResourceName = container.Metadata.Name; 4217var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 4222Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 4278var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 4283Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 4343var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 4347Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 5391var reference = appExecutor.GetResource(dcpExe.Metadata.Name); 5413var reference = appExecutor.GetResource(dcpCtr.Metadata.Name); 5435var reference = appExecutor.GetResource(dcpExe.Metadata.Name); 5438Assert.Equal($"Failed to stop resource '{dcpExe.Metadata.Name}'.", ex.Message); 5467var resourceReference = appExecutor.GetResource(dcpCtr.Metadata.Name); 5470Assert.Equal($"Failed to delete '{dcpCtr.Metadata.Name}' successfully before restart.", ex.Message); 5565var annotations = container.Metadata.EnsureAnnotations(); 6062Assert.Equal("TestExecutable-12345678", exe.Metadata.Name); 6639r.Metadata.Annotations is not null && 6640r.Metadata.Annotations.ContainsKey(CustomResource.OtelServiceInstanceIdAnnotation)); 6642return resource.Metadata.Annotations![CustomResource.OtelServiceInstanceIdAnnotation]; 7904Assert.True(executable.Metadata.Annotations.TryGetValue( 9844var reference = appExecutor.GetResource(exe.Metadata.Name); 9852Assert.Equal([exe.Metadata.Name], kubernetesService.DeletedResources); 10048var reference = appExecutor.GetResource(executable.Metadata.Name); 10056Assert.Equal([executable.Metadata.Name], kubernetesService.DeletedResources); 10121var reference = appExecutor.GetResource(exe1.Metadata.Name); 10182var reference = appExecutor.GetResource(exe1.Metadata.Name); 10336&& x.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10421s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10463&& s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10913service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10964service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11001service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11040service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11171service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11201service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11252service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11282service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11332service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11414.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11487.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11851.OrderBy(e => e.Metadata.Annotations?[CustomResource.ResourceReplicaIndex], StringComparer.Ordinal) 11935Assert.Equal("1", exe.Metadata.Annotations?[CustomResource.ResourceReplicaCount]); 11936Assert.Equal("0", exe.Metadata.Annotations?[CustomResource.ResourceReplicaIndex]);

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

235watchedResourceName = enumerator.Current.Item2.Metadata.Name; 357container.Metadata.ResourceVersion = "0"; 362container.Metadata.Annotations = new Dictionary<string, string> { ["padding"] = new('x', 65536) }; 365container.Metadata.ResourceVersion = i.ToString(CultureInfo.InvariantCulture); 388var versions = new List<string> { enumerator.Current.Item2.Metadata.ResourceVersion }; 393versions.Add(enumerator.Current.Item2.Metadata.ResourceVersion); 486Assert.Equal("frontend", enumerator.Current.Item2.Metadata.Name); 595names.Add(container.Metadata.Name); 596if (container.Metadata.Name == "frontend-1") 629container.Metadata.ResourceVersion = requestNumber.ToString(CultureInfo.InvariantCulture); 654versions.Add(container.Metadata.ResourceVersion); 709Assert.Equal("frontend", observed?.Metadata.Name); 745Assert.Equal("frontend", enumerator.Current.Item2.Metadata.Name); 773container.Metadata.Annotations = new Dictionary<string, string> { ["message"] = message }; 800Assert.Equal(message, enumerator.Current.Item2.Metadata.Annotations["message"]); 848container.Metadata.ResourceVersion = requestNumber.ToString(CultureInfo.InvariantCulture); 875versions.Add(container.Metadata.ResourceVersion); 971created.Metadata.Uid = "created-object"; 978Assert.Equal("created-object", result.Metadata.Uid); 991created.Metadata.Uid = "created-object"; 1010Assert.Equal("created-object", result.Metadata.Uid); 1031created.Metadata.Uid = "created-object"; 1041container.Metadata.NamespaceProperty = namespaceParameter; 1045Assert.Equal("created-object", result.Metadata.Uid); 1046Assert.Equal("frontend", result.Metadata.Name); 1047Assert.Equal(namespaceParameter, result.Metadata.NamespaceProperty); 1085created.Metadata.Uid = "retried-object"; 1094Assert.Equal("retried-object", result.Metadata.Uid); 1099Assert.Equal("frontend", first.Metadata.Name); 1101Assert.Equal(container.Metadata.Annotations, first.Metadata.Annotations); 1105Assert.Equal("frontend", second.Metadata.Name); 1107Assert.Equal(container.Metadata.Annotations, second.Metadata.Annotations); 1129created.Metadata.Uid = "late-original"; 1135Assert.Equal(Volatile.Read(ref original)!.Metadata.Name, created.Metadata.Name); 1155Assert.Equal("late-original", result.Metadata.Uid); 1182created.Metadata.Uid = "original-object"; 1204Assert.Equal("original-object", result.Metadata.Uid); 1297existing.Metadata.Uid = "existing-object"; 1309Assert.Equal("existing-object", result.Metadata.Uid); 1312Assert.Equal("preserved", result.Metadata.Annotations["existing-annotation"]); 1388Assert.Equal("frontend", result.Metadata.Name); 1417Assert.Equal("frontend", result.Metadata.Name); 1451created.Metadata.Uid = "original-object"; 1486Assert.Equal("original-object", result.Metadata.Uid); 1518created.Metadata.Uid = "retried-object"; 1527Assert.Equal("retried-object", result.Metadata.Uid); 1657created.Metadata.Uid = "retried-object"; 1665Assert.Equal("retried-object", result.Metadata.Uid); 1686existing.Metadata.Uid = "pre-existing-object"; 1975created.Metadata.Uid = "committed-object"; 2001Assert.Equal("committed-object", result.Metadata.Uid); 2121Assert.Equal("readiness-probe", probe.Metadata.Name); 2233Assert.Equal("frontend", watchEnumerator.Current.Item2.Metadata.Name);

67: (obj, logStreamType, follow) => new MemoryStream(Encoding.UTF8.GetBytes($"Logs for {obj.Metadata.Name} ({logStreamType})"))); 88r.Metadata.Name == name && 89string.Equals(r.Metadata.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty) 115svc.Metadata.Annotations?.ContainsKey(CustomResource.ContainerTunnelInstanceName) is true) 218foreach (var res in CreatedResources.Where(r => !DeletedResources.Contains(r.Metadata.Name))) 234if (string.IsNullOrEmpty(resource.Metadata.Uid)) 236resource.Metadata.Uid = $"test-resource-{Interlocked.Increment(ref _nextResourceUid)}"; 247resource.Metadata.ResourceVersion = Interlocked.Increment(ref _nextResourceVersion).ToString(CultureInfo.InvariantCulture); 268var service = CreatedResources.OfType<Service>().FirstOrDefault(s => s.Metadata.Name == serviceProduced.ServiceName); 312string.Equals(r.Metadata.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty) 395r.Metadata.Name == obj.Metadata.Name && 396string.Equals(r.Metadata.NamespaceProperty, obj.Metadata.NamespaceProperty) 400throw new ArgumentException($"Resource '{obj.Metadata.NamespaceProperty}/{obj.Metadata.Name}' not found");

1014var redisContainer = Assert.Single(list, c => c.Metadata.Name.StartsWith($"{testName}-redis")); 1309await orchestrator.StopResourceAsync(redisContainer.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1314await orchestrator.StartResourceAsync(redisContainer.Metadata.Name, token); 1348await orchestrator.StopResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1353await orchestrator.StartResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1727Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Container.ResourceNameAnnotation, out var value)); 1741Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value)); 2012Assert.All(serviceList.Where(s => s.Metadata.Name.Contains("redis")), s => Assert.Equal(AddressAllocationModes.Proxyless, s.Spec.AddressAllocationMode));

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