74 writes to Status
Aspire.Hosting (2)
Dcp\ContainerNetworkEndpointProvisioner.cs (1)
457
tunnelProxy.
Status
= observedProxy.Status;
Dcp\Model\Service.cs (1)
101
Status
= new();
Aspire.Hosting.Tests (72)
Dcp\DcpExecutorTests.cs (56)
82
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 };
152
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 };
174
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 7 };
187
replacement.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 2 };
244
previous.
Status
= new ExecutableStatus { State = ExecutableState.Finished, ExitCode = 0 };
746
exe.
Status
= new ExecutableStatus
792
container.
Status
= new ContainerStatus
1977
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
2076
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
2155
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2239
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2247
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2323
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2409
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Running };
2413
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
2416
otherContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
2421
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2496
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2504
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2574
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2579
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2660
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2777
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2786
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2793
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2811
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2933
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2942
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2949
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3058
container.
Status
= new ContainerStatus { State = state };
3105
executable.
Status
= new ExecutableStatus { State = state };
3146
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3156
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3199
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3213
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3255
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3267
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3377
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3386
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3403
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
3475
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
3489
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3550
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
3559
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart, ExitCode = 1 };
3634
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3638
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3645
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
3652
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3658
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 2 };
3740
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
3801
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
3865
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
4226
service.
Status
= new ServiceStatus
4317
service.
Status
= new ServiceStatus
11331
volume.
Status
= new ContainerVolumeStatus { State = state };
11345
volume.
Status
= new ContainerVolumeStatus { State = ContainerVolumeState.Ready };
Dcp\ResourceSnapshotBuilderTests.cs (10)
27
container.
Status
= new ContainerStatus
47
executable.
Status
= new ExecutableStatus
70
executable.
Status
= new ExecutableStatus
134
executable.
Status
= new ExecutableStatus
163
executable.
Status
= new ExecutableStatus
220
executable.
Status
= new ExecutableStatus
235
executable.
Status
= new ExecutableStatus
250
executable.
Status
= new ExecutableStatus
265
executable.
Status
= new ExecutableStatus
279
executable.
Status
= new ExecutableStatus
Dcp\TestKubernetesService.cs (6)
114
svc.
Status
= new ServiceStatus();
126
proxy.
Status
= new ContainerNetworkTunnelProxyStatus();
271
service.
Status
??= new ServiceStatus();
421
exe.
Status
= new ExecutableStatus();
448
ctr.
Status
= new ContainerStatus();
463
proxy.
Status
??= new ContainerNetworkTunnelProxyStatus();
171 references to Status
Aspire.Hosting (65)
Dcp\ContainerNetworkEndpointProvisioner.cs (7)
439
var status = proxy.
Status
;
457
tunnelProxy.Status = observedProxy.
Status
;
459
var failed = string.Equals(observedProxy.
Status
?.State, ContainerNetworkTunnelProxyState.Failed, StringComparison.Ordinal);
460
var observedStatus = observedProxy.
Status
;
470
observedProxy.
Status
?.Message ?? noDetailsAvailable);
476
? $"'{observedProxy.Metadata.Name}': {observedProxy.
Status
?.Message ?? noDetailsAvailable}"
477
: $"'{observedProxy.Metadata.Name}': did not reach a stable state (current state: '{observedProxy.
Status
?.State ?? "(unknown)"}')";
Dcp\DcpExecutor.cs (7)
207
volume => volume.
Status
?.State,
500
cs.Service!.
Status
!.EffectiveAddress = ContainerHostName;
517
.Where(volume => !string.Equals(volume.
Status
?.State, ContainerVolumeState.Ready, StringComparison.Ordinal))
527
$"'{volume.Spec.Name ?? volume.Metadata.Name}': current state is '{volume.
Status
?.State ?? "(unknown)"}'"));
1190
if (cu.
Status
?.State == ContainerState.Exited)
1205
if (eu.
Status
?.State == ExecutableState.Finished || eu.
Status
?.State == ExecutableState.Terminated)
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)
305
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)
25
var containerId = container.
Status
?.ContainerId;
26
var urls = GetUrls(container, container.
Status
?.State);
29
var effectiveArgs = container.
Status
?.EffectiveArgs;
30
var environment = GetEnvironmentVariables(container.
Status
?.EffectiveEnv ?? container.Spec.Env, container.Spec.Env);
31
var state = container.
Status
?.State;
54
ExitCode = container.
Status
?.ExitCode is null or Conventions.UnknownExitCode ? null : container.
Status
.ExitCode,
67
StartTimeStamp = container.
Status
?.StartupTimestamp?.ToUniversalTime(),
68
StopTimeStamp = container.
Status
?.FinishTimestamp?.ToUniversalTime(),
103
var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.
Status
?.State;
104
var environment = GetEnvironmentVariables(executable.
Status
?.EffectiveEnv, executable.Spec.Env);
105
var effectiveArgs = executable.
Status
?.EffectiveArgs;
118
ExitCode = executable.
Status
?.ExitCode,
127
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
128
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
155
var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.
Status
?.State;
161
var urls = GetUrls(executable, executable.
Status
?.State);
163
var effectiveArgs = executable.
Status
?.EffectiveArgs;
164
var environment = GetEnvironmentVariables(executable.
Status
?.EffectiveEnv, executable.Spec.Env);
183
ExitCode = executable.
Status
?.ExitCode,
188
ResourcePropertySnapshotMetadata.Create(KnownResourceTypes.Project, KnownProperties.Executable.Pid, executable.
Status
?.ProcessId),
196
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
197
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
207
ExitCode = executable.
Status
?.ExitCode,
212
ResourcePropertySnapshotMetadata.Create(KnownResourceTypes.Executable, KnownProperties.Executable.Pid, executable.
Status
?.ProcessId),
218
StartTimeStamp = executable.
Status
?.StartupTimestamp?.ToUniversalTime(),
219
StopTimeStamp = executable.
Status
?.FinishTimestamp?.ToUniversalTime(),
Aspire.Hosting.Tests (106)
Dcp\DcpExecutorTests.cs (69)
121
if (context.Resource is Executable {
Status
.ExitCode: 7 })
998
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1036
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1067
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1132
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1183
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1212
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1247
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1291
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1292
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
1328
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1359
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1390
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1422
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1448
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
1568
Assert.Equal(fixedPort, fixedService.
Status
?.EffectivePort);
1569
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1610
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1649
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1689
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1723
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1732
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1761
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1770
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1809
Assert.Equal(persistedPort, persistentService.
Status
?.EffectivePort);
1811
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1856
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1857
Assert.NotEqual(persistedPort, service.
Status
?.EffectivePort);
2116
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
2195
if (obj is Container {
Status
.State: ContainerState.Running } &&
2202
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
2274
if (obj is Container {
Status
.State: ContainerState.Exited } &&
2353
container.
Status
?.State != ContainerState.Exited &&
2361
obj is Container {
Status
.State: ContainerState.Exited } &&
2451
if (obj is Container {
Status
.State: ContainerState.Running } &&
2458
if (obj is Container {
Status
.State: ContainerState.Exited } &&
2624
if (obj is Container {
Status
.State: ContainerState.Running } &&
2715
if (container.
Status
?.State == ContainerState.Running)
2722
if (container.
Status
?.State == ContainerState.Exited)
2873
if (container.
Status
?.State == ContainerState.Running)
2880
if (container.
Status
?.State == ContainerState.Exited)
3307
container.
Status
?.State == ContainerState.Running)
3313
container.
Status
?.State == ContainerState.Exited)
3512
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
3584
container.
Status
?.State != ContainerState.Exited &&
3591
if (obj is Container {
Status
.State: ContainerState.Exited } &&
3958
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4005
Assert.Equal(desiredPortOne, svc.
Status
?.EffectivePort);
4039
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4076
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4122
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4123
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
4154
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4189
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4264
service.
Status
?.EffectivePort == 0)
4271
service.
Status
?.EffectivePort == 0)
4277
service.
Status
?.EffectivePort > 0)
4290
service.
Status
?.EffectivePort == 0)
4296
service.
Status
?.EffectivePort > 0)
4419
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4448
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4523
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
4570
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4603
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4650
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4692
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4760
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4792
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4826
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
Dcp\TestKubernetesService.cs (17)
112
if (svc.
Status
is null)
116
svc.
Status
.EffectiveAddress = svc.Spec.Address ?? "localhost";
117
svc.
Status
.EffectivePort = svc.Spec.Port ?? Interlocked.Increment(ref _nextPort);
124
if (proxy.
Status
is null)
128
proxy.
Status
.State = ContainerNetworkTunnelProxyState.Running;
129
proxy.
Status
.TunnelConfigurationVersion = 1;
130
proxy.
Status
.TunnelStatuses = CreateReadyTunnelStatuses(proxy.Spec.Tunnels);
264
if (service?.Spec.AddressAllocationMode != AddressAllocationModes.Proxyless || service.Spec.Port is not null || service.
Status
?.EffectivePort is not null)
272
service.
Status
.EffectiveAddress = service.Spec.Address ?? "localhost";
273
service.
Status
.EffectivePort = hostPort ?? Interlocked.Increment(ref _nextPort);
419
if (exe.
Status
is null)
423
exe.
Status
.State = ExecutableState.Finished;
446
if (ctr.
Status
is null)
450
ctr.
Status
.State = ContainerState.Exited;
464
proxy.
Status
.State = ContainerNetworkTunnelProxyState.Running;
465
proxy.
Status
.TunnelConfigurationVersion++;
466
proxy.
Status
.TunnelStatuses = CreateReadyTunnelStatuses(proxy.Spec.Tunnels);
DistributedApplicationTests.cs (20)
1229
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1237
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1245
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token);
1269
var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1276
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1281
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration);
1311
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1314
var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1317
var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1322
Assert.Equal("6379", GetEnv(redisContainer.
Status
!.EffectiveEnv, "REDIS_PORT"));
1325
var serviceAPortValue = GetEnv(serviceA.
Status
!.EffectiveEnv, "PORT0");
1330
var nodeAppPortValue = GetEnv(nodeApp.
Status
!.EffectiveEnv, "PORT");
1392
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1429
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1524
r => r.
Status
?.State == ContainerState.FailedToStart && (r.
Status
?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1618
Assert.Equal(ContainerVolumeState.Ready, containerVolume.
Status
?.State);
2248
var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.
Status
?.State == ContainerState.Running, token)
2372
service => service.
Status
?.EffectivePort is not null,
2381
var effectivePort = Assert.IsType<int>(service.
Status
?.EffectivePort);