6 writes to Status
Aspire.Hosting (1)
Dcp\Model\Service.cs (1)
99
Status
= new();
Aspire.Hosting.Tests (5)
Dcp\DcpExecutorTests.cs (2)
604
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
700
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
Dcp\TestKubernetesService.cs (3)
75
svc.
Status
= new ServiceStatus();
207
exe.
Status
= new ExecutableStatus();
220
ctr.
Status
= new ContainerStatus();
104 references to Status
Aspire.Hosting (66)
Dcp\DcpExecutor.cs (14)
496
if (container.Spec.Start == false && (container.
Status
?.State == null || container.
Status
?.State == ContainerState.Pending))
502
return new(container.
Status
?.State, container.
Status
?.StartupTimestamp?.ToUniversalTime(), container.
Status
?.FinishTimestamp?.ToUniversalTime());
506
return new(executable.
Status
?.State, executable.
Status
?.StartupTimestamp?.ToUniversalTime(), executable.
Status
?.FinishTimestamp?.ToUniversalTime());
510
return new(containerExec.
Status
?.State, containerExec.
Status
?.StartupTimestamp?.ToUniversalTime(), containerExec.
Status
?.FinishTimestamp?.ToUniversalTime());
1727
if (cu.
Status
?.State == ContainerState.Exited)
1742
if (eu.
Status
?.State == ExecutableState.Finished || eu.
Status
?.State == ExecutableState.Terminated)
Dcp\Model\Container.cs (8)
547
this.
Status
?.State == ContainerState.Starting
548
|| this.
Status
?.State == ContainerState.Building
549
|| this.
Status
?.State == ContainerState.Running
550
|| this.
Status
?.State == ContainerState.Paused
551
|| this.
Status
?.State == ContainerState.Stopping
552
|| this.
Status
?.State == ContainerState.Exited
553
|| (this.
Status
?.State == ContainerState.FailedToStart && this.
Status
?.ContainerId is not null);
Dcp\Model\ContainerExec.cs (4)
144
this.
Status
?.State == ExecutableState.Running
145
|| this.
Status
?.State == ExecutableState.Finished
146
|| this.
Status
?.State == ExecutableState.Terminated
147
|| this.
Status
?.State == ExecutableState.Stopping;
Dcp\Model\Executable.cs (3)
244
this.
Status
?.State == ExecutableState.Running
245
|| this.
Status
?.State == ExecutableState.Finished
246
|| this.
Status
?.State == ExecutableState.Terminated;
Dcp\Model\Service.cs (9)
87
public int? AllocatedPort => Spec.Port ??
Status
?.EffectivePort;
88
public string? AllocatedAddress => Spec.Address ??
Status
?.EffectiveAddress;
97
if (
Status
is null)
101
if (other.
Status
?.EffectiveAddress is not null)
103
Status
.EffectiveAddress = other.
Status
.EffectiveAddress;
105
if (other.
Status
?.EffectivePort is not null)
107
Status
.EffectivePort = other.
Status
.EffectivePort;
Dcp\ResourceSnapshotBuilder.cs (28)
22
var containerId = container.
Status
?.ContainerId;
23
var urls = GetUrls(container, container.
Status
?.State);
26
var environment = GetEnvironmentVariables(container.
Status
?.EffectiveEnv ?? container.Spec.Env, container.Spec.Env);
27
var state = container.
Status
?.State;
50
ExitCode = container.
Status
?.ExitCode is null or Conventions.UnknownExitCode ? null : container.
Status
.ExitCode,
55
new(KnownProperties.Container.Args, container.
Status
?.EffectiveArgs ?? []) { IsSensitive = true },
63
StartTimeStamp = container.
Status
?.StartupTimestamp?.ToUniversalTime(),
64
StopTimeStamp = container.
Status
?.FinishTimestamp?.ToUniversalTime(),
99
var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.
Status
?.State;
100
var environment = GetEnvironmentVariables(executable.
Status
?.EffectiveEnv, executable.Spec.Env);
113
ExitCode = executable.
Status
?.ExitCode,
116
new(KnownProperties.Executable.Args, executable.
Status
?.EffectiveArgs ?? []) { IsSensitive = true },
122
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
123
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
139
var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.
Status
?.State;
141
var urls = GetUrls(executable, executable.
Status
?.State);
143
var environment = GetEnvironmentVariables(executable.
Status
?.EffectiveEnv, executable.Spec.Env);
159
ExitCode = executable.
Status
?.ExitCode,
163
new(KnownProperties.Executable.Args, executable.
Status
?.EffectiveArgs ?? []) { IsSensitive = true },
164
new(KnownProperties.Executable.Pid, executable.
Status
?.ProcessId),
171
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
172
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
182
ExitCode = executable.
Status
?.ExitCode,
186
new(KnownProperties.Executable.Args, executable.
Status
?.EffectiveArgs ?? []) { IsSensitive = true },
187
new(KnownProperties.Executable.Pid, executable.
Status
?.ProcessId),
193
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
194
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
Aspire.Hosting.Tests (38)
Dcp\DcpExecutorTests.cs (15)
251
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
283
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
315
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
348
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
404
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
438
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
472
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
803
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
848
Assert.Equal(desiredPortOne, svc.
Status
?.EffectivePort);
881
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
916
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
996
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1032
Assert.Equal(desiredTargetPort, svc.
Status
?.EffectivePort);
1069
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1106
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
Dcp\TestKubernetesService.cs (7)
73
if (svc.
Status
is null)
77
svc.
Status
.EffectiveAddress = svc.Spec.Address ?? "localhost";
78
svc.
Status
.EffectivePort = svc.Spec.Port ?? Interlocked.Increment(ref _nextPort);
205
if (exe.
Status
is null)
209
exe.
Status
.State = ExecutableState.Finished;
218
if (ctr.
Status
is null)
222
ctr.
Status
.State = ContainerState.Exited;
DistributedApplicationTests.cs (16)
634
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
642
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
650
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token);
674
var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
679
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Finished).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
684
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running).DefaultTimeout(TestConstants.LongTimeoutDuration);
716
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
719
var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
722
var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
727
Assert.Equal("6379", GetEnv(redisContainer.
Status
!.EffectiveEnv, "REDIS_PORT"));
730
var serviceAPortValue = GetEnv(serviceA.
Status
!.EffectiveEnv, "PORT0");
735
var nodeAppPortValue = GetEnv(nodeApp.
Status
!.EffectiveEnv, "PORT");
771
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
811
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
845
r => r.
Status
?.State == ContainerState.FailedToStart && (r.
Status
?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);