86 writes to Status
Aspire.Hosting (2)
Dcp\ContainerNetworkEndpointProvisioner.cs (1)
458
tunnelProxy.
Status
= observedProxy.Status;
Dcp\Model\Service.cs (1)
101
Status
= new();
Aspire.Hosting.Tests (84)
Dcp\DcpExecutorTests.cs (56)
81
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 };
151
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 };
173
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 7 };
186
replacement.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 2 };
243
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 };
788
exe.
Status
= new ExecutableStatus
834
container.
Status
= new ContainerStatus
2462
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
2561
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
2640
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2724
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2732
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2808
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2894
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Running };
2898
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
2901
otherContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
2906
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2981
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2989
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3059
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3064
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3145
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3262
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3271
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3278
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3296
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
3418
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3427
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3434
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3543
container.
Status
= new ContainerStatus { State = state };
3590
executable.
Status
= new ExecutableStatus { State = state };
3631
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3641
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3684
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3698
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3740
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3752
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3862
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3871
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3888
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
3960
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
3974
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
4035
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
4044
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart, ExitCode = 1 };
4119
container.
Status
= new ContainerStatus { State = ContainerState.Running };
4123
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
4130
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
4137
container.
Status
= new ContainerStatus { State = ContainerState.Running };
4143
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 2 };
4225
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
4286
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
4350
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
4711
service.
Status
= new ServiceStatus
4802
service.
Status
= new ServiceStatus
12046
volume.
Status
= new ContainerVolumeStatus { State = state };
12060
volume.
Status
= new ContainerVolumeStatus { State = ContainerVolumeState.Ready };
Dcp\ResourceSnapshotBuilderTests.cs (22)
28
container.
Status
= new ContainerStatus
48
executable.
Status
= new ExecutableStatus
71
executable.
Status
= new ExecutableStatus
100
executable.
Status
= new ExecutableStatus
139
executable.
Status
= new ExecutableStatus
191
executable.
Status
= new ExecutableStatus
235
executable.
Status
= new ExecutableStatus
344
executable.
Status
= new ExecutableStatus
381
executable.
Status
= new ExecutableStatus
423
executable.
Status
= new ExecutableStatus
467
executable.
Status
= new ExecutableStatus
496
executable.
Status
= new ExecutableStatus
529
executable.
Status
= new ExecutableStatus
553
executable.
Status
= new ExecutableStatus
576
executable.
Status
= new ExecutableStatus
636
executable.
Status
= new ExecutableStatus
665
executable.
Status
= new ExecutableStatus
722
executable.
Status
= new ExecutableStatus
737
executable.
Status
= new ExecutableStatus
752
executable.
Status
= new ExecutableStatus
767
executable.
Status
= new ExecutableStatus
781
executable.
Status
= new ExecutableStatus
Dcp\TestKubernetesService.cs (6)
119
svc.
Status
= new ServiceStatus();
131
proxy.
Status
= new ContainerNetworkTunnelProxyStatus();
276
service.
Status
??= new ServiceStatus();
426
exe.
Status
= new ExecutableStatus();
453
ctr.
Status
= new ContainerStatus();
468
proxy.
Status
??= new ContainerNetworkTunnelProxyStatus();
183 references to Status
Aspire.Hosting (64)
Dcp\ContainerNetworkEndpointProvisioner.cs (7)
440
var status = proxy.
Status
;
458
tunnelProxy.Status = observedProxy.
Status
;
460
var failed = string.Equals(observedProxy.
Status
?.State, ContainerNetworkTunnelProxyState.Failed, StringComparison.Ordinal);
461
var observedStatus = observedProxy.
Status
;
471
observedProxy.
Status
?.Message ?? noDetailsAvailable);
477
? $"'{observedProxy.Metadata.Name}': {observedProxy.
Status
?.Message ?? noDetailsAvailable}"
478
: $"'{observedProxy.Metadata.Name}': did not reach a stable state (current state: '{observedProxy.
Status
?.State ?? "(unknown)"}')";
Dcp\DcpExecutor.cs (6)
205
volume => volume.
Status
?.State,
510
cs.Service!.
Status
!.EffectiveAddress = ContainerHostName;
527
.Where(volume => !string.Equals(volume.
Status
?.State, ContainerVolumeState.Ready, StringComparison.Ordinal))
537
$"'{volume.Spec.Name ?? volume.Metadata.Name}': current state is '{volume.
Status
?.State ?? "(unknown)"}'"));
1106
if (cu.
Status
?.State is ContainerState.Exited or ContainerState.FailedToStart)
1123
if (eu.
Status
?.State is ExecutableState.Finished or ExecutableState.Terminated or ExecutableState.FailedToStart)
Dcp\DcpResourceWatcher.cs (12)
557
if (container.Spec.Start == false && (container.
Status
?.State == null || container.
Status
?.State == ContainerState.Pending))
563
return new(container.
Status
?.State, container.
Status
?.StartupTimestamp?.ToUniversalTime(), container.
Status
?.FinishTimestamp?.ToUniversalTime());
567
if (executable.Spec.Start == false && IsNotStartedExecutableState(executable.
Status
?.State))
573
return new(executable.
Status
?.State, executable.
Status
?.StartupTimestamp?.ToUniversalTime(), executable.
Status
?.FinishTimestamp?.ToUniversalTime());
577
return new(containerExec.
Status
?.State, containerExec.
Status
?.StartupTimestamp?.ToUniversalTime(), containerExec.
Status
?.FinishTimestamp?.ToUniversalTime());
Dcp\Model\Container.cs (1)
617
public bool LogsAvailable => !string.IsNullOrEmpty(this.
Status
?.State);
Dcp\Model\ContainerExec.cs (1)
143
public bool LogsAvailable => !string.IsNullOrEmpty(this.
Status
?.State);
Dcp\Model\Executable.cs (1)
306
public bool LogsAvailable => !string.IsNullOrEmpty(this.
Status
?.State);
Dcp\Model\Service.cs (9)
89
public int? AllocatedPort => Spec.Port ??
Status
?.EffectivePort;
90
public string? AllocatedAddress => Spec.Address ??
Status
?.EffectiveAddress;
99
if (
Status
is null)
103
if (other.
Status
?.EffectiveAddress is not null)
105
Status
.EffectiveAddress = other.
Status
.EffectiveAddress;
107
if (other.
Status
?.EffectivePort is not null)
109
Status
.EffectivePort = other.
Status
.EffectivePort;
Dcp\ResourceSnapshotBuilder.cs (27)
26
var containerId = container.
Status
?.ContainerId;
27
var urls = GetUrls(container, container.
Status
?.State);
30
var effectiveArgs = container.
Status
?.EffectiveArgs;
31
var environment = GetEnvironmentVariables(container.
Status
?.EffectiveEnv ?? container.Spec.Env, container.Spec.Env);
32
var state = container.
Status
?.State;
55
ExitCode = container.
Status
?.ExitCode is null or Conventions.UnknownExitCode ? null : container.
Status
.ExitCode,
68
StartTimeStamp = container.
Status
?.StartupTimestamp?.ToUniversalTime(),
69
StopTimeStamp = container.
Status
?.FinishTimestamp?.ToUniversalTime(),
104
var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.
Status
?.State;
105
var environment = GetEnvironmentVariables(executable.
Status
?.EffectiveEnv, executable.Spec.Env);
106
var effectiveArgs = executable.
Status
?.EffectiveArgs;
119
ExitCode = executable.
Status
?.ExitCode,
128
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
129
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
156
var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.
Status
?.State;
162
var urls = GetUrls(executable, executable.
Status
?.State);
164
var effectiveArgs = executable.
Status
?.EffectiveArgs;
165
var environment = GetEnvironmentVariables(executable.
Status
?.EffectiveEnv, executable.Spec.Env);
192
ExitCode = executable.
Status
?.ExitCode,
197
ResourcePropertySnapshotMetadata.Create(KnownResourceTypes.Project, KnownProperties.Executable.Pid, executable.
Status
?.ProcessId),
206
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
207
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
217
ExitCode = executable.
Status
?.ExitCode,
222
ResourcePropertySnapshotMetadata.Create(KnownResourceTypes.Executable, KnownProperties.Executable.Pid, executable.
Status
?.ProcessId),
228
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
229
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
Aspire.Hosting.Tests (119)
Dcp\DcpExecutorTests.cs (82)
120
if (context.Resource is Executable {
Status
.ExitCode: 7 })
1040
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1078
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1109
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1174
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1225
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1254
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1289
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1333
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1334
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
1370
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1401
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1432
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1464
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1490
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
1610
Assert.Equal(fixedPort, fixedService.
Status
?.EffectivePort);
1611
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1654
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1696
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1728
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1765
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1792
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1801
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1830
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1839
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1891
Assert.Equal(persistedPort, persistentService.
Status
?.EffectivePort);
1893
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1947
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1993
Assert.Equal(persistedPort, storedService.
Status
?.EffectivePort);
1994
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
2047
Assert.Equal(persistedPort, persistentService.
Status
?.EffectivePort);
2048
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
2098
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
2145
Assert.Equal(fixedPort, fixedService.
Status
?.EffectivePort);
2146
Assert.Equal(storedPort, dynamicService.
Status
?.EffectivePort);
2190
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
2191
Assert.NotEqual(persistedPort, service.
Status
?.EffectivePort);
2237
Assert.Equal(persistedPort, service.
Status
?.EffectivePort);
2291
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
2601
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
2680
if (obj is Container {
Status
.State: ContainerState.Running } &&
2687
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
2759
if (obj is Container {
Status
.State: ContainerState.Exited } &&
2838
container.
Status
?.State != ContainerState.Exited &&
2846
obj is Container {
Status
.State: ContainerState.Exited } &&
2936
if (obj is Container {
Status
.State: ContainerState.Running } &&
2943
if (obj is Container {
Status
.State: ContainerState.Exited } &&
3109
if (obj is Container {
Status
.State: ContainerState.Running } &&
3200
if (container.
Status
?.State == ContainerState.Running)
3207
if (container.
Status
?.State == ContainerState.Exited)
3358
if (container.
Status
?.State == ContainerState.Running)
3365
if (container.
Status
?.State == ContainerState.Exited)
3792
container.
Status
?.State == ContainerState.Running)
3798
container.
Status
?.State == ContainerState.Exited)
3997
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
4069
container.
Status
?.State != ContainerState.Exited &&
4076
if (obj is Container {
Status
.State: ContainerState.Exited } &&
4443
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4490
Assert.Equal(desiredPortOne, svc.
Status
?.EffectivePort);
4524
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4561
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4607
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4608
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
4639
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4674
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4749
service.
Status
?.EffectivePort == 0)
4756
service.
Status
?.EffectivePort == 0)
4762
service.
Status
?.EffectivePort > 0)
4775
service.
Status
?.EffectivePort == 0)
4781
service.
Status
?.EffectivePort > 0)
4904
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4933
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
5012
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
5059
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
5092
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
5139
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
5181
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
5297
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
5329
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
5363
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
5396
Assert.Equal(ExecutableState.FailedToStart, dcpExe.
Status
?.State);
5418
Assert.Equal(ContainerState.FailedToStart, dcpCtr.
Status
?.State);
Dcp\TestKubernetesService.cs (17)
117
if (svc.
Status
is null)
121
svc.
Status
.EffectiveAddress = svc.Spec.Address ?? "localhost";
122
svc.
Status
.EffectivePort = svc.Spec.Port ?? Interlocked.Increment(ref _nextPort);
129
if (proxy.
Status
is null)
133
proxy.
Status
.State = ContainerNetworkTunnelProxyState.Running;
134
proxy.
Status
.TunnelConfigurationVersion = 1;
135
proxy.
Status
.TunnelStatuses = CreateReadyTunnelStatuses(proxy.Spec.Tunnels);
269
if (service?.Spec.AddressAllocationMode != AddressAllocationModes.Proxyless || service.Spec.Port is not null || service.
Status
?.EffectivePort is not null)
277
service.
Status
.EffectiveAddress = service.Spec.Address ?? "localhost";
278
service.
Status
.EffectivePort = hostPort ?? Interlocked.Increment(ref _nextPort);
424
if (exe.
Status
is null)
428
exe.
Status
.State = StoppedExecutableState;
451
if (ctr.
Status
is null)
455
ctr.
Status
.State = StoppedContainerState;
469
proxy.
Status
.State = ContainerNetworkTunnelProxyState.Running;
470
proxy.
Status
.TunnelConfigurationVersion++;
471
proxy.
Status
.TunnelStatuses = CreateReadyTunnelStatuses(proxy.Spec.Tunnels);
DistributedApplicationTests.cs (20)
1303
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1311
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1319
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token);
1343
var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1350
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1355
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration);
1385
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1388
var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1391
var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1396
Assert.Equal("6379", GetEnv(redisContainer.
Status
!.EffectiveEnv, "REDIS_PORT"));
1399
var serviceAPortValue = GetEnv(serviceA.
Status
!.EffectiveEnv, "PORT0");
1404
var nodeAppPortValue = GetEnv(nodeApp.
Status
!.EffectiveEnv, "PORT");
1466
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1503
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1598
r => r.
Status
?.State == ContainerState.FailedToStart && (r.
Status
?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1692
Assert.Equal(ContainerVolumeState.Ready, containerVolume.
Status
?.State);
2326
var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.
Status
?.State == ContainerState.Running, token)
2450
service => service.
Status
?.EffectivePort is not null,
2459
var effectivePort = Assert.IsType<int>(service.
Status
?.EffectivePort);