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