21 references to RuntimeStates
Aspire.Hosting.Native.Core.Tests (11)
NativeProtocolParsingTests.cs (11)
82Assert.Equal(wire, RuntimeStates.ParseObservation(wire).ToWire()); 90Assert.Throws<ArgumentException>(() => RuntimeStates.ParseObservation(wire)); 95Assert.Equal(ConfigurationStatus.Succeeded, RuntimeStates.ParseConfigurationResult("succeeded")); 96Assert.Equal(RequestOutcome.Cancelled, RuntimeStates.ParseCommandResult("cancelled")); 97Assert.Equal(LogStream.Stderr, RuntimeStates.ParseLogStream("stderr")); 98Assert.Equal(WorkloadProtocol.Udp, RuntimeStates.ParseProtocol("UDP")); 99Assert.Equal(WorkloadMountKind.Volume, RuntimeStates.ParseMountKind("volume")); 100Assert.Throws<ArgumentException>(() => RuntimeStates.ParseConfigurationResult("pending")); 101Assert.Throws<ArgumentException>(() => RuntimeStates.ParseCommandResult("accepted")); 102Assert.Throws<ArgumentException>(() => RuntimeStates.ParseProtocol("tcp")); 103Assert.Throws<ArgumentException>(() => RuntimeStates.ParseMountKind("0"));
Aspire.Hosting.Native.Server (10)
Api\DeclarativeWorkloadApi.cs (1)
113new WorkloadPort(endpoint.Name, RuntimeStates.ParseProtocol(endpoint.Protocol), endpoint.UriScheme,
Api\ResourceLifecycleScope.cs (1)
25public void WriteLifecycleLog(string stream, string message) => authority.AppendLog(RuntimeStates.ParseLogStream(stream), message);
Api\RuntimeApi.cs (4)
232owner.Publish(RuntimeStates.ParseObservation(observation.State), observation.Healthy, observation.Urls.ToImmutableArray()); 237public void AppendResourceLog(string stream, string message) => owner.AppendLog(RuntimeStates.ParseLogStream(stream), message); 257owner.CompleteConfiguration(revision, RuntimeStates.ParseConfigurationResult(result.Status), result.Message); 304owner.CompleteCommand(Guid.Parse(requestId), RuntimeStates.ParseCommandResult(result.Status), result.Message);
Api\WorkloadApi.cs (2)
106launch.Mounts.Select(mount => new WorkloadMount(RuntimeStates.ParseMountKind(mount.Type), mount.Source, mount.Target, mount.ReadOnly)).ToImmutableArray(), 149return endpoints.Select(endpoint => new WorkloadPort(endpoint.Name, RuntimeStates.ParseProtocol(endpoint.Protocol), endpoint.UriScheme,
Dcp\DcpStates.cs (2)
96RuntimeStates.ParseProtocol(reader.GetString() ?? throw new JsonException("A protocol is required.")); 104RuntimeStates.ParseMountKind(reader.GetString() ?? throw new JsonException("A mount kind is required."));