2 instantiations of Executable
Aspire.Hosting (1)
Dcp\Model\Executable.cs (1)
255var exe = new Executable(new ExecutableSpec
Aspire.Hosting.Tests (1)
ExecutableResourceBuilderExtensionTests.cs (1)
85var exe = new Executable(new ExecutableSpec());
150 references to Executable
Aspire.Hosting (35)
Dcp\DcpExecutor.cs (27)
198var executables = _appResources.OfType<RenderedModelResource>().Where(ar => ar.DcpResource is Executable); 375Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, Model.Dcp.ExecutableKind, (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 424else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out var executable)) 531resource is Executable { LogsAvailable: true } || 613Executable => appModelResource is ProjectResource ? KnownResourceTypes.Project : KnownResourceTypes.Executable, 631if (resource is Executable executable) 650else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable)) 652enumerable = new ResourceLogSource<Executable>(_logger, _kubernetesService, executable, follow: false); 696Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 791"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable) ? executable : null, 809else if (cr is Executable exe) 1072if (appResource.DcpResource is Executable && !_options.Value.EnableAspireContainerTunnel) 1414var exe = Executable.Create(exeInstance.Name, exePath); 1460var exe = Executable.Create(exeInstance.Name, "dotnet"); 1493exe.AnnotateAsObjectList(Executable.LaunchConfigurationsAnnotation, projectLaunchConfiguration); 1544exe.AnnotateAsObjectList(Executable.LaunchConfigurationsAnnotation, projectLaunchConfiguration); 1631Executable exe => s => _snapshotBuilder.ToSnapshot(exe, s), 1726if (er.DcpResource is not Executable exe) 1888exe.Annotate(Executable.LaunchConfigurationsAnnotation, string.Empty); 2505if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 2590case Executable e: 2593var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 2659case Executable e: 2660await EnsureResourceDeletedAsync<Executable>(appResource.DcpResourceName).ConfigureAwait(false);
Dcp\DcpResourceState.cs (1)
13public readonly ConcurrentDictionary<string, Executable> ExecutablesMap = [];
Dcp\Model\Executable.cs (2)
253public static Executable Create(string name, string executablePath) 255var exe = new Executable(new ExecutableSpec
Dcp\Model\GroupVersion.cs (1)
36Schema.Add<Executable>(ExecutableKind, "executables");
Dcp\ResourceSnapshotBuilder.cs (1)
128public CustomResourceSnapshot ToSnapshot(Executable executable, CustomResourceSnapshot previous)
SupportsDebuggingAnnotation.cs (3)
17private SupportsDebuggingAnnotation(string launchConfigurationType, Action<Executable, string> launchConfigurationAnnotator) 24public Action<Executable, string> LaunchConfigurationAnnotator { get; } 30exe.AnnotateAsObjectList(Executable.LaunchConfigurationsAnnotation, launchProfileProducer(mode));
Aspire.Hosting.Tests (115)
Dcp\DcpExecutorTests.cs (91)
90var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 158var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 159var exe = Assert.Single(executables); 193var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 194var exe = Assert.Single(executables); 236var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 238var exe1 = Assert.Single(executables); 253executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 256var exe2 = executables[1]; 280var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 312var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 344var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 377var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 434var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 468var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 502var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 589var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 592foreach (var exe in executables) 902var exes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 905foreach (var dcpExe in exes) 947var exes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 950foreach (var dcpExe in exes) 1417var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1451var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1485var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1521var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1557var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1588var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1619var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1649var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1678var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1718List<Executable> dcpExes = []; 1722dcpExes.AddRange(kubernetesService.CreatedResources.OfType<Executable>()); 1727var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1729Assert.True(debuggableExe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs1)); 1734var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 1736Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 1768var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1771var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1805var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1808var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1810Assert.False(debuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 1812var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 1814Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 1846var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1849var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1882var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1885var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1924var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1927var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1966var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1969var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 2008var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 2011var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 2045var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 2048var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA"); 2082var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 2085var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA"); 2125var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 2128var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA"); 2205var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 2208var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA"); 2375List<Executable> dcpExes = []; 2379dcpExes.AddRange(kubernetesService.CreatedResources.OfType<Executable>()); 2384var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 2424List<Executable> dcpExes = []; 2428dcpExes.AddRange(kubernetesService.CreatedResources.OfType<Executable>()); 2433var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "proj"); 2437Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 2479List<Executable> dcpExes = []; 2483dcpExes.AddRange(kubernetesService.CreatedResources.OfType<Executable>()); 2488var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "proj"); 2528List<Executable> dcpExes = []; 2532dcpExes.AddRange(kubernetesService.CreatedResources.OfType<Executable>()); 2537var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "proj");
Dcp\TestKubernetesService.cs (2)
200if (res is Executable exe && result is Executable eu)
DistributedApplicationTests.cs (20)
1121var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1126serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1131serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration); 1163var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1166var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1241var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1278var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1448await foreach (var resource in s.WatchAsync<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1450Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value)); 1639var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1641var service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName)); 1712var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1714var service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName)); 1851var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.Status?.State == ContainerState.Running, token)
ExecutableResourceBuilderExtensionTests.cs (2)
85var exe = new Executable(new ExecutableSpec()); 89Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var annotations));