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