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)
84
var exe = new
Executable
(new ExecutableSpec());
132 references to Executable
Aspire.Hosting (32)
Dcp\DcpExecutor.cs (24)
183
var executables = _appResources.OfType<RenderedModelResource>().Where(ar => ar.DcpResource is
Executable
);
312
Task.Run(() => WatchKubernetesResourceAsync<
Executable
>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, Model.Dcp.ExecutableKind, (e, s) => _snapshotBuilder.ToSnapshot(e, s)))),
361
else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out
var
executable))
468
resource is
Executable
{ LogsAvailable: true } ||
550
Executable
=> appModelResource is ProjectResource ? KnownResourceTypes.Project : KnownResourceTypes.Executable,
568
if (resource is
Executable
executable)
587
else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out
var
executable))
589
enumerable = new ResourceLogSource<
Executable
>(_logger, _kubernetesService, executable, follow: false);
633
Executable
e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),
723
"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out
var
executable) ? executable : null,
741
else if (cr is
Executable
exe)
1288
var
exe =
Executable
.Create(exeInstance.Name, exePath);
1333
var
exe =
Executable
.Create(exeInstance.Name, "dotnet");
1405
exe.AnnotateAsObjectList(
Executable
.LaunchConfigurationsAnnotation, projectLaunchConfiguration);
1490
Executable
exe => s => _snapshotBuilder.ToSnapshot(exe, s),
1585
if (er.DcpResource is not
Executable
exe)
2293
if (resource is
Executable
exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1)
2378
case
Executable
e:
2381
var
eu = await _kubernetesService.GetAsync<
Executable
>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
2447
case
Executable
e:
2448
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 (100)
Dcp\DcpExecutorTests.cs (76)
89
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
157
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
158
var
exe = Assert.Single(executables);
192
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
193
var
exe = Assert.Single(executables);
235
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
237
var
exe1 = Assert.Single(executables);
252
executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
255
var
exe2 = executables[1];
279
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
311
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
343
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
376
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
433
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
467
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
501
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
588
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
591
foreach (
var
exe in executables)
901
var exes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
904
foreach (
var
dcpExe in exes)
946
var exes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
949
foreach (
var
dcpExe in exes)
1416
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1451
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1487
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1523
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1554
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1585
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1615
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1644
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1684
List<
Executable
> dcpExes = [];
1688
dcpExes.AddRange(kubernetesService.CreatedResources.OfType<
Executable
>());
1693
var
debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1695
Assert.True(debuggableExe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out var launchConfigs1));
1700
var
nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable");
1702
Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out _));
1734
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1737
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1771
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1774
var
debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1776
Assert.False(debuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out _));
1778
var
nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable");
1780
Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out _));
1812
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1815
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1848
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1851
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1890
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1893
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1932
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1935
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1974
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1977
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
2011
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
2014
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA");
2048
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
2051
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA");
2091
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
2094
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA");
2171
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
2174
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "ServiceA");
Dcp\TestKubernetesService.cs (2)
200
if (res is
Executable
exe && result is
Executable
eu)
DistributedApplicationTests.cs (20)
1120
var
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1125
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1130
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration);
1162
var
serviceA = await KubernetesHelper.GetResourceByNameAsync<
Executable
>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1165
var
nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1240
var
aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1277
var
aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1447
await foreach (var resource in s.WatchAsync<
Executable
>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout))
1449
Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(
Executable
.ResourceNameAnnotation, out var value));
1635
var exeList = await s.ListAsync<
Executable
>().DefaultTimeout();
1637
var
service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName));
1707
var exeList = await s.ListAsync<
Executable
>().DefaultTimeout();
1709
var
service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName));
1846
var
worker = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, workerNamePattern, r => r.Status?.State == ContainerState.Running, token)
ExecutableResourceBuilderExtensionTests.cs (2)
84
var
exe = new Executable(new ExecutableSpec());
88
Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out var annotations));