63 writes to Status
Aspire.Hosting (2)
Dcp\ContainerCreator.cs (1)
610
tunnelProxy.
Status
= observedProxy.Status;
Dcp\Model\Service.cs (1)
101
Status
= new();
Aspire.Hosting.Tests (61)
Dcp\DcpExecutorTests.cs (45)
393
exe.
Status
= new ExecutableStatus
439
container.
Status
= new ContainerStatus
1528
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
1627
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
1706
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
1790
container.
Status
= new ContainerStatus { State = ContainerState.Running };
1798
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
1874
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
1960
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Running };
1964
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
1967
otherContainer.
Status
= new ContainerStatus { State = ContainerState.Exited };
1972
blockingContainer.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2047
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2055
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2125
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2130
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2211
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2328
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2337
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2344
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2362
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2484
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2493
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2500
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2584
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2594
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2637
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2651
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2693
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2705
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2815
container.
Status
= new ContainerStatus { State = ContainerState.Running };
2824
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2841
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
2913
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2927
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
2988
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart };
2997
container.
Status
= new ContainerStatus { State = ContainerState.FailedToStart, ExitCode = 1 };
3072
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3076
container.
Status
= new ContainerStatus { State = ContainerState.Exited };
3083
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 1 };
3090
container.
Status
= new ContainerStatus { State = ContainerState.Running };
3096
container.
Status
= new ContainerStatus { State = ContainerState.Exited, ExitCode = 2 };
3178
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
3239
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
3303
exeResource.
Status
= new ContainerStatus { State = ContainerState.Running };
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)
83
svc.
Status
= new ServiceStatus();
95
proxy.
Status
= new ContainerNetworkTunnelProxyStatus();
240
service.
Status
??= new ServiceStatus();
372
exe.
Status
= new ExecutableStatus();
399
ctr.
Status
= new ContainerStatus();
414
proxy.
Status
??= new ContainerNetworkTunnelProxyStatus();
159 references to Status
Aspire.Hosting (62)
Dcp\ContainerCreator.cs (7)
592
var status = p.
Status
;
610
tunnelProxy.Status = observedProxy.
Status
;
612
var failed = string.Equals(observedProxy.
Status
?.State, ContainerNetworkTunnelProxyState.Failed, StringComparison.Ordinal);
613
var observedStatus = observedProxy.
Status
;
623
observedProxy.
Status
?.Message ?? noDetailsAvailable);
629
? $"'{observedProxy.Metadata.Name}': {observedProxy.
Status
?.Message ?? noDetailsAvailable}"
630
: $"'{observedProxy.Metadata.Name}': did not reach a stable state (current state: '{observedProxy.
Status
?.State ?? "(unknown)"}')";
Dcp\DcpExecutor.cs (4)
532
cs.Service!.
Status
!.EffectiveAddress = ContainerHostName;
1150
if (cu.
Status
?.State == ContainerState.Exited)
1165
if (eu.
Status
?.State == ExecutableState.Finished || eu.
Status
?.State == ExecutableState.Terminated)
Dcp\DcpResourceWatcher.cs (12)
503
if (container.Spec.Start == false && (container.
Status
?.State == null || container.
Status
?.State == ContainerState.Pending))
509
return new(container.
Status
?.State, container.
Status
?.StartupTimestamp?.ToUniversalTime(), container.
Status
?.FinishTimestamp?.ToUniversalTime());
513
if (executable.Spec.Start == false && IsNotStartedExecutableState(executable.
Status
?.State))
519
return new(executable.
Status
?.State, executable.
Status
?.StartupTimestamp?.ToUniversalTime(), executable.
Status
?.FinishTimestamp?.ToUniversalTime());
523
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 (97)
Dcp\DcpExecutorTests.cs (61)
638
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
670
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
702
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
735
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
786
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
815
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
850
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
887
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
888
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
924
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
955
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
986
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1018
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
1044
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
1164
Assert.Equal(fixedPort, fixedService.
Status
?.EffectivePort);
1165
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1206
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1245
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1285
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
1319
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1328
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1357
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1366
Assert.Equal(allocatedPort, service.
Status
?.EffectivePort);
1405
Assert.Equal(persistedPort, persistentService.
Status
?.EffectivePort);
1407
Assert.Equal(allocatedPort, dynamicService.
Status
?.EffectivePort);
1667
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
1746
if (obj is Container {
Status
.State: ContainerState.Running } &&
1753
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
1825
if (obj is Container {
Status
.State: ContainerState.Exited } &&
1904
container.
Status
?.State != ContainerState.Exited &&
1912
obj is Container {
Status
.State: ContainerState.Exited } &&
2002
if (obj is Container {
Status
.State: ContainerState.Running } &&
2009
if (obj is Container {
Status
.State: ContainerState.Exited } &&
2175
if (obj is Container {
Status
.State: ContainerState.Running } &&
2266
if (container.
Status
?.State == ContainerState.Running)
2273
if (container.
Status
?.State == ContainerState.Exited)
2424
if (container.
Status
?.State == ContainerState.Running)
2431
if (container.
Status
?.State == ContainerState.Exited)
2745
container.
Status
?.State == ContainerState.Running)
2751
container.
Status
?.State == ContainerState.Exited)
2950
if (obj is Container {
Status
.State: ContainerState.FailedToStart } &&
3022
container.
Status
?.State != ContainerState.Exited &&
3029
if (obj is Container {
Status
.State: ContainerState.Exited } &&
3395
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
3440
Assert.Equal(desiredPortOne, svc.
Status
?.EffectivePort);
3473
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
3510
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
3549
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
3550
Assert.NotEqual(desiredPort, svc.
Status
?.EffectivePort);
3581
Assert.True(svc.
Status
?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange);
3616
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
3699
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
3728
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
3803
Assert.Equal(allocatedPort, svc.
Status
?.EffectivePort);
3850
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
3883
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
3930
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
3972
var allocatedPort = Assert.IsType<int>(svc.
Status
?.EffectivePort);
4040
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4072
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
4106
Assert.Equal(desiredPort, svc.
Status
?.EffectivePort);
Dcp\TestKubernetesService.cs (17)
81
if (svc.
Status
is null)
85
svc.
Status
.EffectiveAddress = svc.Spec.Address ?? "localhost";
86
svc.
Status
.EffectivePort = svc.Spec.Port ?? Interlocked.Increment(ref _nextPort);
93
if (proxy.
Status
is null)
97
proxy.
Status
.State = ContainerNetworkTunnelProxyState.Running;
98
proxy.
Status
.TunnelConfigurationVersion = 1;
99
proxy.
Status
.TunnelStatuses = CreateReadyTunnelStatuses(proxy.Spec.Tunnels);
233
if (service?.Spec.AddressAllocationMode != AddressAllocationModes.Proxyless || service.Spec.Port is not null || service.
Status
?.EffectivePort is not null)
241
service.
Status
.EffectiveAddress = service.Spec.Address ?? "localhost";
242
service.
Status
.EffectivePort = hostPort ?? Interlocked.Increment(ref _nextPort);
370
if (exe.
Status
is null)
374
exe.
Status
.State = ExecutableState.Finished;
397
if (ctr.
Status
is null)
401
ctr.
Status
.State = ContainerState.Exited;
415
proxy.
Status
.State = ContainerNetworkTunnelProxyState.Running;
416
proxy.
Status
.TunnelConfigurationVersion++;
417
proxy.
Status
.TunnelStatuses = CreateReadyTunnelStatuses(proxy.Spec.Tunnels);
DistributedApplicationTests.cs (19)
1225
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1233
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1241
redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.
Status
?.State == ContainerState.Running, token);
1265
var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1270
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1275
serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.
Status
?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration);
1304
var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1307
var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1310
var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
1315
Assert.Equal("6379", GetEnv(redisContainer.
Status
!.EffectiveEnv, "REDIS_PORT"));
1318
var serviceAPortValue = GetEnv(serviceA.
Status
!.EffectiveEnv, "PORT0");
1323
var nodeAppPortValue = GetEnv(nodeApp.
Status
!.EffectiveEnv, "PORT");
1385
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1422
var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.
Status
?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
1517
r => r.
Status
?.State == ContainerState.FailedToStart && (r.
Status
?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
2237
var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.
Status
?.State == ContainerState.Running, token)
2361
service => service.
Status
?.EffectivePort is not null,
2370
var effectivePort = Assert.IsType<int>(service.
Status
?.EffectivePort);