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