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); 469observedProxy.Metadata.Name, 476? $"'{observedProxy.Metadata.Name}': {observedProxy.Status?.Message ?? noDetailsAvailable}" 477: $"'{observedProxy.Metadata.Name}': did not reach a stable state (current state: '{observedProxy.Status?.State ?? "(unknown)"}')";

371var name = o.Metadata.Name; 396if (!objectsByName.TryGetValue(observed.Metadata.Name, out var original)) 402if (pending.Contains(observed.Metadata.Name) && isInDesiredState(original, observed)) 404pending.Remove(observed.Metadata.Name); 449HashSet<string> stillPending = [.. needAddressAllocated.Select(s => s.Metadata.Name)]; 464activity.AddDcpServiceAddressAllocated(original.Metadata.Name); 473if (stillPending.Contains(sar.Metadata.Name)) 475_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); 476activity.AddDcpServiceAddressAllocationFailed(sar.Metadata.Name); 491PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 498.First(svc => svc.Metadata.Name.Equals(cs.PrimaryServiceName)); 527$"'{volume.Spec.Name ?? volume.Metadata.Name}': current state is '{volume.Status?.State ?? "(unknown)"}'")); 547latest[obj.Metadata.Name] = obj; 559latest[observed.Metadata.Name] = observed; 783var annotation = annotationsByServiceName[serviceProducer.Service.Metadata.Name]; 1002r.DcpResource.Metadata.Name, 1023r.DcpResource.Metadata.Name, 1094await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name, ex.Message)).ConfigureAwait(false); 1099await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1158.Where(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName)) 1189var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1204var 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 &&

180obj.Metadata.Name, 188obj.Metadata.Name, 357obj.Metadata.Name, 359obj.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) 352var isActive = _resourceState.EndpointsMap.Any(e => e.Value.Spec.ServiceName == endpointOwnerEndpoint?.Metadata.Name);

116.OrderBy(static executable => int.Parse(executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex], CultureInfo.InvariantCulture)) 121Assert.Equal(instances.Select(instance => instance.Name), rendered.Select(executable => executable.Metadata.Name)); 122Assert.Equal(replicas, rendered.Select(executable => executable.Metadata.Annotations[CustomResource.OtelServiceInstanceIdAnnotation]).Distinct().Count()); 126Assert.Equal(index.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 127Assert.Equal(replicas.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 128Assert.Equal("svc", executable.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]);

87Assert.NotEqual(previous.Metadata.Uid, replacement.Metadata.Uid); 166kubernetesService.DeletedResources.Enqueue(previous.Metadata.Name); 169var reference = executor.GetResource(previous.Metadata.Name); 185Assert.NotEqual(previous.Metadata.Uid, replacement.Metadata.Uid); 217if (context.Resource is Endpoint { Metadata.Name: "program-endpoint" }) 251endpoint.Metadata.OwnerReferences = [new V1OwnerReference 255Name = previous.Metadata.Name, 256Uid = previous.Metadata.Uid 263var restartTask = executor.StartResourceAsync(executor.GetResource(previous.Metadata.Name), TestContext.Current.CancellationToken); 311Assert.Equal(service.Metadata.Name, producer.ServiceName); 316$"{{{{- portForServing \"{service.Metadata.Name}\" -}}}}", 320var firstName = executables[0].Metadata.Name; 321var secondName = executables[1].Metadata.Name; 328Assert.Equal(2, afterRestart.Count(executable => executable.Metadata.Name == firstName)); 329Assert.Single(afterRestart, executable => executable.Metadata.Name == secondName); 395Assert.Equal("1", executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 396Assert.Equal("0", executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 418Assert.Equal("CustomName", container.Metadata.Annotations["otel-service-name"]); 947var reference = appExecutor.GetResource(exe1.Metadata.Name); 1726var reference = appExecutor.GetResource(firstExecutable.Metadata.Name); 1764var reference = appExecutor.GetResource(firstContainer.Metadata.Name); 1926Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 1964var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 1974Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2001var loggerState = resourceLoggerService.GetResourceLoggerState(exeResource.Metadata.Name); 2014Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2067var watchLogs1 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 2073Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 2089var watchLogs2 = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 2153dcpResourceName = container.Metadata.Name; 2231using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2244() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null, 2313dcpResourceName = container.Metadata.Name; 2351if (obj.Metadata.Name == blockingDcpResourceName && 2360if (obj.Metadata.Name == blockingDcpResourceName && 2405blockingDcpResourceName = blockingContainer.Metadata.Name; 2406otherDcpResourceName = otherContainer.Metadata.Name; 2486using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2501() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is null, 2566using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2591Assert.True(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name)); 2604Assert.False(appExecutor.ResourceWatcher.HasLogStreamPendingDeduplication(container.Metadata.Name)); 2650using var subscription = resourceLoggerService.Subscribe(container.Metadata.Name, batch => 2665() => appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name) is not null, 2667var firstLogStreamTask = appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name); 2672Assert.Null(appExecutor.ResourceWatcher.GetLogStreamTask(container.Metadata.Name)); 2769dcpResourceName = container.Metadata.Name; 2770Assert.False(string.IsNullOrEmpty(container.Metadata.Uid)); 2925dcpResourceName = container.Metadata.Name; 2926Assert.False(string.IsNullOrEmpty(container.Metadata.Uid)); 3033endpoint.Metadata.OwnerReferences = [new V1OwnerReference 3037Name = container.Metadata.Name, 3038Uid = container.Metadata.Uid 3051container.Metadata.Uid = "database-replacement"; 3108Assert.Equal(executable.Metadata.Name, change.DcpResourceName); 3155container.Metadata.ResourceVersion = null; 3266container.Metadata.Uid = "database-instance-2"; 3306if (container.Metadata.Uid == previousResourceUid && 3312if (container.Metadata.Uid == replacementResourceUid && 3363dcpResourceName = container.Metadata.Name; 3364previousResourceUid = container.Metadata.Uid; 3402container.Metadata.Uid = replacementResourceUid; 3546dcpResourceName = container.Metadata.Name; 3631dcpResourceName = container.Metadata.Name; 3732var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 3737Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 3793var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 3798Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 3858var watchLogs = resourceLoggerService.WatchAsync(exeResource.Metadata.Name); 3862Assert.Equal(exeResource.Metadata.Name, watchSubscribersEnumerator.Current.Name); 4862var resourceReference = appExecutor.GetResource(dcpCtr.Metadata.Name); 4865Assert.Equal($"Failed to delete '{dcpCtr.Metadata.Name}' successfully before restart.", ex.Message); 4960var annotations = container.Metadata.EnsureAnnotations(); 5457Assert.Equal("TestExecutable-12345678", exe.Metadata.Name); 5955r.Metadata.Annotations is not null && 5956r.Metadata.Annotations.ContainsKey(CustomResource.OtelServiceInstanceIdAnnotation)); 5958return resource.Metadata.Annotations![CustomResource.OtelServiceInstanceIdAnnotation]; 7220Assert.True(executable.Metadata.Annotations.TryGetValue( 9160var reference = appExecutor.GetResource(exe.Metadata.Name); 9168Assert.Equal([exe.Metadata.Name], kubernetesService.DeletedResources); 9364var reference = appExecutor.GetResource(executable.Metadata.Name); 9372Assert.Equal([executable.Metadata.Name], kubernetesService.DeletedResources); 9437var reference = appExecutor.GetResource(exe1.Metadata.Name); 9498var reference = appExecutor.GetResource(exe1.Metadata.Name); 9652&& x.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 9734s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 9774&& s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10198service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10249service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10286service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10325service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10456service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10486service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10537service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10567service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10617service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10699.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10772.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11136.OrderBy(e => e.Metadata.Annotations?[CustomResource.ResourceReplicaIndex], StringComparer.Ordinal) 11220Assert.Equal("1", exe.Metadata.Annotations?[CustomResource.ResourceReplicaCount]); 11221Assert.Equal("0", exe.Metadata.Annotations?[CustomResource.ResourceReplicaIndex]);

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

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