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