607var c = new Container(new ContainerSpec { Image = image });

21internal sealed class ContainerCreator : IObjectCreator<Container, ContainerNetworkEndpointContext>, IObjectCreator<ContainerExec, EmptyCreationContext> 75public IEnumerable<RenderedModelResource<Container>> PrepareObjects() 80var result = new List<RenderedModelResource<Container>>(); 92var ctr = Container.Create(containerObjectInstance.Name, containerImageName); 142var containerAppResource = new RenderedModelResource<Container>(container, ctr); 160public bool IsReadyToCreate(RenderedModelResource<Container> resource, ContainerNetworkEndpointContext context) 165public async Task CreateObjectAsync(RenderedModelResource<Container> cr, ContainerNetworkEndpointContext context, ILogger logger, IDcpObjectFactory factory, CancellationToken cancellationToken) 206private async Task BuildAndCreateContainerAsync(RenderedModelResource<Container> cr, ILogger logger, IDcpObjectFactory factory, CancellationToken cToken) 210var dcpContainer = cr.DcpResource; 351internal async Task CreateHostDependentContainerAsync(RenderedModelResource<Container> cr, ImmutableArray<HostResourceWithEndpoints> hostDependencies, ContainerNetworkEndpointContext context, IDcpObjectFactory factory, CancellationToken cToken) 370BuildContainerConfiguration(RenderedModelResource<Container> cr, ILogger resourceLogger, CancellationToken cancellationToken) 613private static async Task ApplyBuildArgumentsAsync(Container dcpContainerResource, IResource modelContainerResource, DistributedApplicationExecutionContext executionContext, ILogger logger, CancellationToken cancellationToken) 703private static List<ContainerPortSpec> BuildContainerPorts(RenderedModelResource<Container> cr)

163RenderedModelResource<Container>[] containers; 345Container => KnownResourceTypes.Container, 1070Container container => s => _resourceWatcher.SnapshotBuilder.ToSnapshot(container, s), 1106Container { Spec.Start: false } => true, 1185case Container c: 1188var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1256case RenderedModelResource<Container> { DcpResource.Spec.Start: false } cr when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(cr.ModelResource, cr.DcpResource.Spec.Start): 1268case RenderedModelResource<Container> cr: 1269await EnsureResourceDeletedAsync<Container>(resourceReference, cancellationToken).ConfigureAwait(false);

160foreach (var containerResource in appResources.OfType<RenderedModelResource<Container>>() 225if (resource.DcpResource is not Container ctr || ctr.Spec.Networks is null)

12public readonly ConcurrentDictionary<string, Container> ContainersMap = [];

156Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, Model.Dcp.ContainerKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 202if (_resourceState.ContainersMap.TryGetValue(entry.ResourceName, out var container)) 548return resource is Container { LogsAvailable: true } || 555if (resource is Container container) 603if (_resourceState.ContainersMap.TryGetValue(resourceName, out var container)) 605enumerable = new ResourceLogSource<Container>(_logger, _kubernetesService, container, follow: false); 652Container c when c.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 996"Container" => _resourceState.ContainersMap.TryGetValue(resourceName, out var container) ? container : null, 1022if (cr is Container container)

605public static Container Create(string name, string image) 607var c = new Container(new ContainerSpec { Image = image });

12/// The name of the <see cref="Container"/> resource (DCP model name, not the Docker/Podman name) 103/// Represents a command to be executed in a given <see cref="Container"/> resource.

37Schema.Add<Container>(ContainerKind, "containers");

24public CustomResourceSnapshot ToSnapshot(Container container, CustomResourceSnapshot previous) 636if (resource is Container container)

215var containers = await kubernetes.ListAsync<Container>(); 217var container = Assert.Single(containers); 248var containers = await kubernetes.ListAsync<Container>(); 250var container = Assert.Single<Container>(containers); 485var containers = await kubernetes.ListAsync<Container>(); 487var container = Assert.Single<Container>(containers); 556var containers = await kubernetes.ListAsync<Container>(); 558var container = Assert.Single<Container>(containers);

417var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 441var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 463var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 784var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer"); 890Assert.Equal(3, kubernetesService.CreatedResources.OfType<Container>().Count()); 1538Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == emulator.Resource.Name); 1646var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1760var firstContainer = Assert.Single(GetCreatedContainersForResource(kubernetesService, "database")); 1958var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2062var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2116if (obj is Container { Status.State: ContainerState.FailedToStart } && 2152var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2195if (obj is Container { Status.State: ContainerState.Running } && 2202if (obj is Container { Status.State: ContainerState.FailedToStart } && 2230var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2274if (obj is Container { Status.State: ContainerState.Exited } && 2312var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2352obj is Container container && 2361obj is Container { Status.State: ContainerState.Exited } && 2403var blockingContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "blocking"); 2404var otherContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "other"); 2451if (obj is Container { Status.State: ContainerState.Running } && 2458if (obj is Container { Status.State: ContainerState.Exited } && 2485var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2564var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2624if (obj is Container { Status.State: ContainerState.Running } && 2649var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2711if (obj is Container container && 2768var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2869if (obj is Container container && 2924var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3027var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3144var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3197var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3253var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3302if (obj is Container container && 3362var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3471var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3512if (obj is Container { Status.State: ContainerState.FailedToStart } && 3545var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3583if (obj is Container container && 3591if (obj is Container { Status.State: ContainerState.Exited } && 3630var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3727var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3789var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 3854var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4145var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4180var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4411var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4444var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4517var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4565var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4599var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4647var dcpCtr = kubernetesService.CreatedResources.OfType<Container>().Single(c => c.AppModelResourceName == "database"); 4689var dcpCtr = kubernetesService.CreatedResources.OfType<Container>().Single(c => c.AppModelResourceName == "database"); 4752var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4787var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4818var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4860var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 4912Assert.Equal(5, kubernetesService.CreatedResources.OfType<Container>().Count()); 4913var implicitDefaultContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ImplicitDefault"); 4916var explicitDefaultContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitDefault"); 4919var explicitAlwaysContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitAlways"); 4922var explicitMissingContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitMissing"); 4925var explicitNeverContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitNever"); 4959var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 5838var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 5991var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 7989var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 9662var dcpContainer = kubernetesService.CreatedResources 9663.OfType<Container>() 9728var dcpContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer"); 9770var dcpContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer"); 9888var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer"); 9967Assert.DoesNotContain(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer"); 9975var startedContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer" && c.Spec.Start == true); 10073var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer"); 10085Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer"); 10162var createdContainers = kubernetesService.CreatedResources.OfType<Container>().ToList(); 10703while (!kubernetesService.CreatedResources.OfType<Container>().Any(c => c.AppModelResourceName == container.Resource.Name)) 10718var createdContainers = kubernetesService.CreatedResources.OfType<Container>().ToList(); 10721var waitingConsumingContainer = Assert.Single(createdContainers, c => c.AppModelResourceName == waitingConsumingEndpoint.Resource.Name); 10772while (!kubernetesService.CreatedResources.OfType<Container>().Any(c => c.AppModelResourceName == tunnelDependentContainer.Resource.Name)) 10790var tunnelDependentDcpContainer = Assert.Single(createdResources.OfType<Container>(), c => c.AppModelResourceName == tunnelDependentContainer.Resource.Name); 10841var createdContainers = kubernetesService.CreatedResources.OfType<Container>().ToList(); 10878var createdContainers = kubernetesService.CreatedResources.OfType<Container>().ToList(); 11122private static List<Container> GetCreatedContainersForResource(TestKubernetesService kubernetesService, string appModelResourceName) 11125.OfType<Container>() 11277var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "aContainer");

147await using var enumerator = service.WatchAsync<Container>(namespaceParameter, watchCts.Token).GetAsyncEnumerator(); 211await WriteWatchEventAsync(context, Container.Create(resourceName, "test-image")); 227await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 314await using var enumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 319await Assert.ThrowsAsync<TimeoutRejectedException>(() => service.ListAsync<Container>(cancellationToken: cts.Token)) 356var container = Container.Create("frontend", "test-image"); 380await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 424await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 468await WriteWatchEventAsync(context, Container.Create("frontend", "test-image")); 478await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 526await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 558var container = Container.Create("frontend", "test-image"); 582await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 616await WriteWatchEventAsync(context, Container.Create("frontend", "test-image")); 628Container? observed = null; 632await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 657var container = Container.Create("frontend", "test-image"); 669await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 702var container = Container.Create("frontend", "test-image"); 722await using var enumerator = service.WatchAsync<Container>(cancellationToken: cts.Token).GetAsyncEnumerator(); 777var container = Container.Create("frontend", "test-image"); 803await foreach (var (_, container) in service.WatchAsync<Container>(cancellationToken: token)) 863await foreach (var _ in service.WatchAsync<Container>(cancellationToken: token)) 870private static async Task WriteWatchEventAsync(HttpContext context, Container container) 900var created = await ReadContainerAsync(context); 906var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 920var created = await ReadContainerAsync(context); 933Container.Create("frontend", "test-image"), 938var result = KubernetesJson.Deserialize<Container>(response.Body.ToString()); 954Container? stored = null; 960var created = await ReadContainerAsync(context); 970var container = Container.Create("frontend", "test-image"); 973var result = await service.CreateAsync(container, cts.Token); 996var postedObjects = new ConcurrentQueue<Container>(); 1007var created = await ReadContainerAsync(context); 1019var container = Container.Create("frontend", "test-image"); 1022var result = await service.CreateAsync(container, cts.Token); 1049Container? original = null; 1056var created = await ReadContainerAsync(context); 1083var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1101Container? stored = null; 1109var created = await ReadContainerAsync(context); 1132var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1172() => service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token)); 1201() => service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token)); 1226var existing = Container.Create("frontend", "test-image"); 1237var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1262Container? stored = null; 1289var created = await ReadContainerAsync(context); 1313Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token)); 1315var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1330Container? stored = null; 1345var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1362Container? stored = null; 1378var created = await ReadContainerAsync(context); 1411Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token)); 1413var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1438var created = await ReadContainerAsync(context); 1455var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1490var createTask = service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1532var createTask = service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1577var created = await ReadContainerAsync(context); 1591Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token).DefaultTimeout()); 1593var result = await service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token).DefaultTimeout(); 1615var existing = Container.Create("frontend", "test-image"); 1625var createTask = service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1675var createTask = service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1704() => service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token)); 1737var createTask = service.CreateAsync(Container.Create("frontend", "test-image"), createCts.Token); 1762var listTask = service.ListAsync<Container>(cancellationToken: cts.Token); 1786var listTask = service.ListAsync<Container>(cancellationToken: cts.Token); 1813Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token)); 1815() => service.ListAsync<Container>(cancellationToken: cts.Token)); 1833() => service.ListAsync<Container>(cancellationToken: cts.Token)); 1867var listTask = service.ListAsync<Container>(cancellationToken: cts.Token); 1894Container? stored = null; 1904var created = await ReadContainerAsync(context); 1921var createTask = service.CreateAsync(Container.Create("frontend", "test-image"), cts.Token); 1928var result = await createTask.DefaultTimeout(); 1949var listTask = service.ListAsync<Container>(cancellationToken: cts.Token); 1972var result = await service.ListAsync<Container>(cancellationToken: cts.Token); 1977() => service.ListAsync<Container>(cancellationToken: cts.Token)); 1997Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token)); 2002nameof(KubernetesService.ListAsync) => () => service.ListAsync<Container>(cancellationToken: cts.Token), 2003nameof(KubernetesService.GetAsync) => () => service.GetAsync<Container>("frontend", cancellationToken: cts.Token), 2004nameof(KubernetesService.PatchAsync) => () => service.PatchAsync(Container.Create("frontend", "test-image"), new V1Patch("[]", V1Patch.PatchType.JsonPatch), cts.Token), 2005nameof(KubernetesService.DeleteAsync) => () => service.DeleteAsync<Container>("frontend", cancellationToken: cts.Token), 2028await WriteContainerAsync(context, Container.Create("readiness-probe", "test-image")); 2047var listTask = service.ListAsync<Container>(cancellationToken: cts.Token); 2049var probe = await service.GetAsync<Container>("readiness-probe", cancellationToken: cts.Token); 2054() => service.ListAsync<Container>(cancellationToken: cts.Token)); 2074await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2082Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token)); 2106await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2111Assert.Empty(await service.ListAsync<Container>(cancellationToken: cts.Token)); 2142var container = Container.Create("frontend", "test-image"); 2160await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2203await using var stream = await service.GetLogStreamAsync(Container.Create("frontend", "test-image"), "stdout", cts.Token).DefaultTimeout(); 2232await using var watchEnumerator = service.WatchAsync<Container>(cancellationToken: watchCts.Token).GetAsyncEnumerator(); 2261var listTask = service.ListAsync<Container>(cancellationToken: cts.Token); 2312private static async Task<Container> ReadContainerAsync(HttpContext context) 2315return KubernetesJson.Deserialize<Container>(await reader.ReadToEndAsync(context.RequestAborted)); 2318private static Task WriteContainerAsync(HttpContext context, Container container, int statusCode = StatusCodes.Status200OK)

24var container = Container.Create("container", "redis:latest");

254if (resource is not Container container || 433if (res is Container ctr && result is Container cu)

838var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 895var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 939var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 941var redisContainer = Assert.Single(list, c => c.Metadata.Name.StartsWith($"{testName}-redis")); 1014var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1146var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1186var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1230var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1238redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1246redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token); 1312var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1524var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(s, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", 1552var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1580var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1609var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1652await foreach (var resource in s.WatchAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1654Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Container.ResourceNameAnnotation, out var value)); 1870var list = await s.ListAsync<Container>().DefaultTimeout(); 1871var redisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redis-{ReplicaIdRegex}")); 1890var otherRedisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redisNoPort-{ReplicaIdRegex}")); 1950var list = await s.ListAsync<Container>().DefaultTimeout(); 1951var redisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redis-{ReplicaIdRegex}")); 1971var otherRedisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redisNoPort-{ReplicaIdRegex}")); 2068var containers = await kubernetes.ListAsync<Container>(cancellationToken: token) 2070var dcpContainer = Assert.Single(containers, c => c.AppModelResourceName == container.Resource.Name);