1 instantiation of Container
Aspire.Hosting (1)
Dcp\Model\Container.cs (1)
571var c = new Container(new ContainerSpec { Image = image });
118 references to Container
Aspire.Hosting (35)
Dcp\DcpExecutor.cs (27)
376Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, Model.Dcp.ContainerKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 420if (_resourceState.ContainersMap.TryGetValue(entry.ResourceName, out var container)) 530if (resource is Container { LogsAvailable: true } || 612Container => KnownResourceTypes.Container, 621if (resource is Container container) 646if (_resourceState.ContainersMap.TryGetValue(resourceName, out var container)) 648enumerable = new ResourceLogSource<Container>(_logger, _kubernetesService, container, follow: false); 695Container c when c.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 784"Container" => _resourceState.ContainersMap.TryGetValue(resourceName, out var container) ? container : null, 800if (cr is Container container) 1044if (appResource.DcpResource is Container ctr && ctr.Spec.Networks is not null) 1925var ctr = Container.Create(containerObjectInstance.Name, containerImageName); 2041await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName, new ResourceStatus(null, null, null), s => _snapshotBuilder.ToSnapshot((Container)cr.DcpResource, s))).ConfigureAwait(false); 2045if (cr.DcpResource is Container container) 2067var dcpContainerResource = (Container)cr.DcpResource; 2275private static async Task ApplyBuildArgumentsAsync(Container dcpContainerResource, IResource modelContainerResource, IServiceProvider serviceProvider, CancellationToken cancellationToken) 2485case Container c: 2488var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 2560case Container c: 2561await EnsureResourceDeletedAsync<Container>(appResource.DcpResourceName).ConfigureAwait(false); 2995var containers = _appResources.OfType<RenderedModelResource>().Where(ar => ar.DcpResource is Container); 3020var persistentTunnelDependent = tunnelDependent.Where(td => td.DcpResource is Container c && c.Spec.Persistent is true); 3031.Where(ar => ar.DcpResource is ContainerExec ce && regular.Any(td => td.DcpResource is Container c && c.Metadata.Name == ce.Spec.ContainerName)), 3033.Where(ar => ar.DcpResource is ContainerExec ce && tunnelDependent.Any(td => td.DcpResource is Container c && c.Metadata.Name == ce.Spec.ContainerName))
Dcp\DcpResourceState.cs (1)
12public readonly ConcurrentDictionary<string, Container> ContainersMap = [];
Dcp\Model\Container.cs (2)
569public static Container Create(string name, string image) 571var c = new Container(new ContainerSpec { Image = image });
Dcp\Model\ContainerExec.cs (2)
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.
Dcp\Model\GroupVersion.cs (1)
37Schema.Add<Container>(ContainerKind, "containers");
Dcp\ResourceSnapshotBuilder.cs (2)
20public CustomResourceSnapshot ToSnapshot(Container container, CustomResourceSnapshot previous) 326if (resource is Container container)
Aspire.Hosting.Containers.Tests (11)
WithDockerfileTests.cs (11)
210var containers = await kubernetes.ListAsync<Container>(); 212var container = Assert.Single(containers); 242var containers = await kubernetes.ListAsync<Container>(); 244var container = Assert.Single<Container>(containers); 470var containers = await kubernetes.ListAsync<Container>(); 472var container = Assert.Single<Container>(containers); 540var containers = await kubernetes.ListAsync<Container>(); 542var container = Assert.Single<Container>(containers);
Aspire.Hosting.Tests (72)
Dcp\DcpExecutorTests.cs (39)
48var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 626var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 730var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 810var exeResource = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 984var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1019var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1100var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1136var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1173var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1210var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1252var dcpCtr = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 1304Assert.Equal(5, kubernetesService.CreatedResources.OfType<Container>().Count()); 1305var implicitDefaultContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ImplicitDefault"); 1308var explicitDefaultContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitDefault"); 1311var explicitAlwaysContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitAlways"); 1314var explicitMissingContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitMissing"); 1317var explicitNeverContainer = Assert.Single(kubernetesService.CreatedResources.OfType<Container>(), c => c.AppModelResourceName == "ExplicitNever"); 1382var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2123var container = Assert.Single(kubernetesService.CreatedResources.OfType<Container>()); 2247var dcpContainer = kubernetesService.CreatedResources 2248.OfType<Container>()
Dcp\TestKubernetesService.cs (2)
213if (res is Container ctr && result is Container cu)
DistributedApplicationTests.cs (31)
689var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 746var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 790var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 792var redisContainer = Assert.Single(list, c => c.Metadata.Name.StartsWith($"{testName}-redis")); 865var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 997var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1037var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1081var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1089redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1097redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token); 1160var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1310var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(s, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", 1338var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1366var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1395var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>( 1434await foreach (var resource in s.WatchAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1436Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Container.ResourceNameAnnotation, out var value)); 1648var list = await s.ListAsync<Container>().DefaultTimeout(); 1649var redisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redis-{ReplicaIdRegex}")); 1665var otherRedisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redisNoPort-{ReplicaIdRegex}")); 1721var list = await s.ListAsync<Container>().DefaultTimeout(); 1722var redisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redis-{ReplicaIdRegex}")); 1739var otherRedisContainer = Assert.Single(list, c => Regex.IsMatch(c.Name(), $"{testName}-redisNoPort-{ReplicaIdRegex}"));