6 writes to Status
Aspire.Hosting (1)
Dcp\Model\Service.cs (1)
99Status = new();
Aspire.Hosting.Tests (5)
Dcp\DcpExecutorTests.cs (2)
604exeResource.Status = new ContainerStatus { State = ContainerState.Running }; 700exeResource.Status = new ContainerStatus { State = ContainerState.Running };
Dcp\TestKubernetesService.cs (3)
75svc.Status = new ServiceStatus(); 207exe.Status = new ExecutableStatus(); 220ctr.Status = new ContainerStatus();
104 references to Status
Aspire.Hosting (66)
Dcp\DcpExecutor.cs (14)
496if (container.Spec.Start == false && (container.Status?.State == null || container.Status?.State == ContainerState.Pending)) 502return new(container.Status?.State, container.Status?.StartupTimestamp?.ToUniversalTime(), container.Status?.FinishTimestamp?.ToUniversalTime()); 506return new(executable.Status?.State, executable.Status?.StartupTimestamp?.ToUniversalTime(), executable.Status?.FinishTimestamp?.ToUniversalTime()); 510return new(containerExec.Status?.State, containerExec.Status?.StartupTimestamp?.ToUniversalTime(), containerExec.Status?.FinishTimestamp?.ToUniversalTime()); 1727if (cu.Status?.State == ContainerState.Exited) 1742if (eu.Status?.State == ExecutableState.Finished || eu.Status?.State == ExecutableState.Terminated)
Dcp\Model\Container.cs (8)
547this.Status?.State == ContainerState.Starting 548|| this.Status?.State == ContainerState.Building 549|| this.Status?.State == ContainerState.Running 550|| this.Status?.State == ContainerState.Paused 551|| this.Status?.State == ContainerState.Stopping 552|| this.Status?.State == ContainerState.Exited 553|| (this.Status?.State == ContainerState.FailedToStart && this.Status?.ContainerId is not null);
Dcp\Model\ContainerExec.cs (4)
144this.Status?.State == ExecutableState.Running 145|| this.Status?.State == ExecutableState.Finished 146|| this.Status?.State == ExecutableState.Terminated 147|| this.Status?.State == ExecutableState.Stopping;
Dcp\Model\Executable.cs (3)
244this.Status?.State == ExecutableState.Running 245|| this.Status?.State == ExecutableState.Finished 246|| this.Status?.State == ExecutableState.Terminated;
Dcp\Model\Service.cs (9)
87public int? AllocatedPort => Spec.Port ?? Status?.EffectivePort; 88public string? AllocatedAddress => Spec.Address ?? Status?.EffectiveAddress; 97if (Status is null) 101if (other.Status?.EffectiveAddress is not null) 103Status.EffectiveAddress = other.Status.EffectiveAddress; 105if (other.Status?.EffectivePort is not null) 107Status.EffectivePort = other.Status.EffectivePort;
Dcp\ResourceSnapshotBuilder.cs (28)
22var containerId = container.Status?.ContainerId; 23var urls = GetUrls(container, container.Status?.State); 26var environment = GetEnvironmentVariables(container.Status?.EffectiveEnv ?? container.Spec.Env, container.Spec.Env); 27var state = container.Status?.State; 50ExitCode = container.Status?.ExitCode is null or Conventions.UnknownExitCode ? null : container.Status.ExitCode, 55new(KnownProperties.Container.Args, container.Status?.EffectiveArgs ?? []) { IsSensitive = true }, 63StartTimeStamp = container.Status?.StartupTimestamp?.ToUniversalTime(), 64StopTimeStamp = container.Status?.FinishTimestamp?.ToUniversalTime(), 99var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.Status?.State; 100var environment = GetEnvironmentVariables(executable.Status?.EffectiveEnv, executable.Spec.Env); 113ExitCode = executable.Status?.ExitCode, 116new(KnownProperties.Executable.Args, executable.Status?.EffectiveArgs ?? []) { IsSensitive = true }, 122StartTimeStamp = executable.Status?.StartupTimestamp?.ToUniversalTime(), 123StopTimeStamp = executable.Status?.FinishTimestamp?.ToUniversalTime(), 144var state = executable.AppModelInitialState is "Hidden" ? "Hidden" : executable.Status?.State; 146var urls = GetUrls(executable, executable.Status?.State); 148var environment = GetEnvironmentVariables(executable.Status?.EffectiveEnv, executable.Spec.Env); 164ExitCode = executable.Status?.ExitCode, 168new(KnownProperties.Executable.Args, executable.Status?.EffectiveArgs ?? []) { IsSensitive = true }, 169new(KnownProperties.Executable.Pid, executable.Status?.ProcessId), 177StartTimeStamp = executable.Status?.StartupTimestamp?.ToUniversalTime(), 178StopTimeStamp = executable.Status?.FinishTimestamp?.ToUniversalTime(), 188ExitCode = executable.Status?.ExitCode, 192new(KnownProperties.Executable.Args, executable.Status?.EffectiveArgs ?? []) { IsSensitive = true }, 193new(KnownProperties.Executable.Pid, executable.Status?.ProcessId), 199StartTimeStamp = executable.Status?.StartupTimestamp?.ToUniversalTime(), 200StopTimeStamp = executable.Status?.FinishTimestamp?.ToUniversalTime(),
Aspire.Hosting.Tests (38)
Dcp\DcpExecutorTests.cs (15)
251Assert.True(svc.Status?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange); 283Assert.Equal(desiredPort, svc.Status?.EffectivePort); 315Assert.True(svc.Status?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange); 348Assert.Equal(desiredPort, svc.Status?.EffectivePort); 404Assert.Equal(desiredPort, svc.Status?.EffectivePort); 438Assert.Equal(desiredPort, svc.Status?.EffectivePort); 472Assert.Equal(desiredPort, svc.Status?.EffectivePort); 803Assert.True(svc.Status?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange); 848Assert.Equal(desiredPortOne, svc.Status?.EffectivePort); 881Assert.True(svc.Status?.EffectivePort >= TestKubernetesService.StartOfAutoPortRange); 916Assert.Equal(desiredPort, svc.Status?.EffectivePort); 996Assert.Equal(desiredPort, svc.Status?.EffectivePort); 1032Assert.Equal(desiredTargetPort, svc.Status?.EffectivePort); 1069Assert.Equal(desiredPort, svc.Status?.EffectivePort); 1106Assert.Equal(desiredPort, svc.Status?.EffectivePort);
Dcp\TestKubernetesService.cs (7)
73if (svc.Status is null) 77svc.Status.EffectiveAddress = svc.Spec.Address ?? "localhost"; 78svc.Status.EffectivePort = svc.Spec.Port ?? Interlocked.Increment(ref _nextPort); 205if (exe.Status is null) 209exe.Status.State = ExecutableState.Finished; 218if (ctr.Status is null) 222ctr.Status.State = ContainerState.Exited;
DistributedApplicationTests.cs (16)
634var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 642redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 650redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token); 674var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 679serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 684serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.LongTimeoutDuration); 716var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 719var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 722var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 727Assert.Equal("6379", GetEnv(redisContainer.Status!.EffectiveEnv, "REDIS_PORT")); 730var serviceAPortValue = GetEnv(serviceA.Status!.EffectiveEnv, "PORT0"); 735var nodeAppPortValue = GetEnv(nodeApp.Status!.EffectiveEnv, "PORT"); 771var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 811var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 845r => r.Status?.State == ContainerState.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);