74 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 (72)
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 };
745
exe.
Status
= new ExecutableStatus
791
container.
Status
= new ContainerStatus
1976
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
2075
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
2154
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2238
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2246
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2322
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2408
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Running };
2412
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
2415
otherContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
2420
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2495
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2503
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2573
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2578
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2659
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2776
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2785
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2792
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2810
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2932
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2941
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2948
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3057
container.
Status
= new ContainerStatus { State = state };
3104
executable.
Status
= new ExecutableStatus { State = state };
3145
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3155
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3198
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3212
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3254
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3266
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3376
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3385
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3402
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
3474
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
3488
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3549
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
3558
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart, ExitCode = 1 };
3633
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3637
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3644
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
3651
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3657
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 2 };
3739
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
3800
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
3864
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
4225
service.
Status
= new ServiceStatus
4316
service.
Status
= new ServiceStatus
11356
volume.
Status
= new ContainerVolumeStatus { State = state };
11370
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)
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 (7)
206
volume => volume.
Status
?.State,
499
cs.Service!.
Status
!.EffectiveAddress = ContainerHostName;
516
.Where(volume => !string.Equals(volume.
Status
?.State, ContainerVolumeState.Ready, StringComparison.Ordinal))
526
$"'{volume.Spec.Name ?? volume.Metadata.Name}': current state is '{volume.
Status
?.State ?? "(unknown)"}'"));
1189
if (cu.
Status
?.State == ContainerState.Exited)
1204
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)
120
if (context.Resource is Executable {
Status
.ExitCode: 7 })
997
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1035
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1066
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1131
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1182
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1211
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1246
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1290
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
1291
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
1327
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1358
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1389
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1421
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1447
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
1567
Assert.Equal(fixedPort, fixedService.
Status
?.EffectivePort);
1568
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1609
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1648
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1688
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1722
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1731
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1760
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1769
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1808
Assert.Equal(persistedPort, persistentService.
Status
?.EffectivePort);
1810
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1855
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1856
Assert.NotEqual(persistedPort, service.
Status
?.EffectivePort);
2115
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
2194
if (obj is Container {
Status
.State: ContainerState.Running } &&
2201
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
2273
if (obj is Container {
Status
.State: ContainerState.Exited } &&
2352
container.
Status
?.State != ContainerState.Exited &&
2360
obj is Container {
Status
.State: ContainerState.Exited } &&
2450
if (obj is Container {
Status
.State: ContainerState.Running } &&
2457
if (obj is Container {
Status
.State: ContainerState.Exited } &&
2623
if (obj is Container {
Status
.State: ContainerState.Running } &&
2714
if (container.
Status
?.State == ContainerState.Running)
2721
if (container.
Status
?.State == ContainerState.Exited)
2872
if (container.
Status
?.State == ContainerState.Running)
2879
if (container.
Status
?.State == ContainerState.Exited)
3306
container.
Status
?.State == ContainerState.Running)
3312
container.
Status
?.State == ContainerState.Exited)
3511
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
3583
container.
Status
?.State != ContainerState.Exited &&
3590
if (obj is Container {
Status
.State: ContainerState.Exited } &&
3957
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4004
Assert.Equal(desiredPortOne, svc.
Status
?.EffectivePort);
4038
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4075
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4121
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4122
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
4153
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
4188
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4263
service.
Status
?.EffectivePort == 0)
4270
service.
Status
?.EffectivePort == 0)
4276
service.
Status
?.EffectivePort > 0)
4289
service.
Status
?.EffectivePort == 0)
4295
service.
Status
?.EffectivePort > 0)
4418
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4447
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4522
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
4569
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4602
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4649
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4691
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4759
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4791
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4825
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);