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