2 instantiations of Executable
Aspire.Hosting (1)
Dcp\Model\Executable.cs (1)
231var exe = new Executable(new ExecutableSpec
Aspire.Hosting.Tests (1)
ExecutableResourceBuilderExtensionTests.cs (1)
84var exe = new Executable(new ExecutableSpec());
110 references to Executable
Aspire.Hosting (33)
Dcp\DcpExecutor.cs (25)
249Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, "Executable", (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 298else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out var executable)) 405resource is Executable { LogsAvailable: true } || 487Executable => appModelResource is ProjectResource ? KnownResourceTypes.Project : KnownResourceTypes.Executable, 505if (resource is Executable executable) 524else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable)) 526enumerable = new ResourceLogSource<Executable>(_logger, _kubernetesService, executable, follow: false); 570Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 660"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable) ? executable : null, 678else if (cr is Executable exe) 800var toCreate = _appResources.Where(r => r.DcpResource is Container or Executable or ContainerExec); 820var executablesTask = CreateExecutablesAsync(toCreate.Where(ar => ar.DcpResource is Executable), cancellationToken); 957var exe = Executable.Create(exeInstance.Name, exePath); 1006var exeSpec = Executable.Create(exeInstance.Name, "dotnet"); 1073exeSpec.AnnotateAsObjectList(Executable.LaunchConfigurationsAnnotation, projectLaunchConfiguration); 1119Executable exe => s => _snapshotBuilder.ToSnapshot(exe, s), 1210if (er.DcpResource is not Executable exe) 1664if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 1770case Executable e: 1773var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1832case Executable e: 1833await EnsureResourceDeletedAsync<Executable>(appResource.DcpResourceName).ConfigureAwait(false);
Dcp\DcpResourceState.cs (1)
13public readonly ConcurrentDictionary<string, Executable> ExecutablesMap = [];
Dcp\Model\Executable.cs (2)
229public static Executable Create(string name, string executablePath) 231var exe = new Executable(new ExecutableSpec
Dcp\Model\GroupVersion.cs (1)
35Schema.Add<Executable>(ExecutableKind, "executables");
Dcp\ResourceSnapshotBuilder.cs (1)
128public CustomResourceSnapshot ToSnapshot(Executable executable, CustomResourceSnapshot previous)
SupportsDebuggingAnnotation.cs (3)
18Action<Executable, string> launchConfigurationAnnotator) 25public Action<Executable, string> LaunchConfigurationAnnotator { get; } 31exe.AnnotateAsObjectList(Executable.LaunchConfigurationsAnnotation, launchProfileProducer(mode));
Aspire.Hosting.Tests (77)
Dcp\DcpExecutorTests.cs (55)
87var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 155var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 157var exe = Assert.Single(executables); 198var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 200var exe1 = Assert.Single(executables); 215executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 218var exe2 = executables[1]; 242var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 274var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 306var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 339var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 396var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 430var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 464var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 551var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 554foreach (var exe in executables) 790var exes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 793foreach (var dcpExe in exes) 835var exes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 838foreach (var dcpExe in exes) 1301var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1336var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1372var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1408var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1439var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1470var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1500var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1529var exe = Assert.Single(kubernetes.CreatedResources.OfType<Executable>()); 1570var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1573var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1575Assert.True(debuggableExe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs1)); 1580var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 1582Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 1614var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1617var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1651var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 1655var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 1657Assert.False(debuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 1659var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 1661Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _));
Dcp\TestKubernetesService.cs (2)
200if (res is Executable exe && result is Executable eu)
DistributedApplicationTests.cs (18)
697var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 702serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 707serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.LongTimeoutDuration); 742var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 745var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 824var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 864var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1039await foreach (var resource in s.WatchAsync<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1041Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value)); 1230var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1232var service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName)); 1288var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1290var service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName));
ExecutableResourceBuilderExtensionTests.cs (2)
84var exe = new Executable(new ExecutableSpec()); 88Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var annotations));