1 instantiation of Executable
Aspire.Hosting (1)
Dcp\Model\Executable.cs (1)
231
var exe = new
Executable
(new ExecutableSpec
106 references to Executable
Aspire.Hosting (31)
Dcp\DcpExecutor.cs (26)
249
Task.Run(() => WatchKubernetesResourceAsync<
Executable
>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, "Executable", (e, s) => _snapshotBuilder.ToSnapshot(e, s)))),
298
else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out
var
executable))
405
resource is
Executable
{ LogsAvailable: true } ||
487
Executable
=> appModelResource is ProjectResource ? KnownResourceTypes.Project : KnownResourceTypes.Executable,
505
if (resource is
Executable
executable)
524
else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out
var
executable))
526
enumerable = new ResourceLogSource<
Executable
>(_logger, _kubernetesService, executable, follow: false);
570
Executable
e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true),
660
"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out
var
executable) ? executable : null,
678
else if (cr is
Executable
exe)
800
var toCreate = _appResources.Where(r => r.DcpResource is Container or
Executable
or ContainerExec);
820
var executablesTask = CreateExecutablesAsync(toCreate.Where(ar => ar.DcpResource is
Executable
), cancellationToken);
957
var
exe =
Executable
.Create(exeInstance.Name, exePath);
980
exe.AnnotateAsObjectList(
Executable
.LaunchConfigurationsAnnotation, projectLaunchConfiguration);
1013
var
exeSpec =
Executable
.Create(exeInstance.Name, "dotnet");
1085
exeSpec.AnnotateAsObjectList(
Executable
.LaunchConfigurationsAnnotation, projectLaunchConfiguration);
1131
Executable
exe => s => _snapshotBuilder.ToSnapshot(exe, s),
1222
if (er.DcpResource is not
Executable
exe)
1663
if (resource is
Executable
exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1)
1769
case
Executable
e:
1772
var
eu = await _kubernetesService.GetAsync<
Executable
>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1831
case
Executable
e:
1832
await EnsureResourceDeletedAsync<
Executable
>(appResource.DcpResourceName).ConfigureAwait(false);
Dcp\DcpResourceState.cs (1)
13
public readonly ConcurrentDictionary<string,
Executable
> ExecutablesMap = [];
Dcp\Model\Executable.cs (2)
229
public static
Executable
Create(string name, string executablePath)
231
var
exe = new Executable(new ExecutableSpec
Dcp\Model\GroupVersion.cs (1)
35
Schema.Add<
Executable
>(ExecutableKind, "executables");
Dcp\ResourceSnapshotBuilder.cs (1)
128
public CustomResourceSnapshot ToSnapshot(
Executable
executable, CustomResourceSnapshot previous)
Aspire.Hosting.Tests (75)
Dcp\DcpExecutorTests.cs (55)
87
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
155
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
157
var
exe = Assert.Single(executables);
198
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
200
var
exe1 = Assert.Single(executables);
215
executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
218
var
exe2 = executables[1];
242
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
274
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
306
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
339
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
396
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
430
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
464
var
dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<
Executable
>());
551
var executables = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
554
foreach (
var
exe in executables)
790
var exes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
793
foreach (
var
dcpExe in exes)
835
var exes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
838
foreach (
var
dcpExe in exes)
1301
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1336
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1372
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1408
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1439
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1470
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1500
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1529
var
exe = Assert.Single(kubernetes.CreatedResources.OfType<
Executable
>());
1570
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1573
var
debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1575
Assert.True(debuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out var launchConfigs1));
1581
var
nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable");
1583
Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out _));
1616
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1619
var
exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1653
var dcpExes = kubernetesService.CreatedResources.OfType<
Executable
>().ToList();
1657
var
debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable");
1659
Assert.False(debuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out _));
1661
var
nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable");
1663
Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(
Executable
.LaunchConfigurationsAnnotation, out _));
Dcp\TestKubernetesService.cs (2)
200
if (res is
Executable
exe && result is
Executable
eu)
DistributedApplicationTests.cs (18)
679
var
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
684
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
689
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.LongTimeoutDuration);
724
var
serviceA = await KubernetesHelper.GetResourceByNameAsync<
Executable
>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
727
var
nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
776
var
aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
816
var
aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<
Executable
>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
991
await foreach (var resource in s.WatchAsync<
Executable
>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout))
993
Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(
Executable
.ResourceNameAnnotation, out var value));
1182
var exeList = await s.ListAsync<
Executable
>().DefaultTimeout();
1184
var
service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName));
1240
var exeList = await s.ListAsync<
Executable
>().DefaultTimeout();
1242
var
service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName));