39 references to LogStream
Aspire.Hosting.Native.Core (21)
Runtime\ProviderLifecycle.cs (3)
40private readonly Action<LogStream, string> _log; 46Func<WorkloadPlan, CancellationToken, Task<bool>> execute, Action<LogStream, string> log, 59public void AppendLog(LogStream stream, string message)
Runtime\ResourceWorkload.cs (6)
56internal sealed record WorkloadLog(LogStream Stream, string Message); 113Action<LogStream, string> log, 123Action<ResourceState, WorkloadEndpoint?> publish, Action<LogStream, string> log) 131Action<ResourceState, WorkloadEndpoint?> publish, Action<LogStream, string> log) 215log(LogStream.Stderr, _cleanupFailed ? 339log(LogStream.Stderr, $"Workload failed: {exception.GetType().Name}.");
Runtime\RuntimeGeneration.cs (6)
596private void AppendWorkloadLog(Guid resourceId, LogStream stream, string message) 798internal void AppendLog(Guid resourceId, LogStream stream, string message) 800if (stream is not (LogStream.Stdout or LogStream.Stderr) || message.Length > 8192) 1149public void AppendLog(LogStream stream, string message) 1207internal sealed record RuntimeLogEntry(long Sequence, DateTimeOffset Timestamp, LogStream Stream, string Message);
Runtime\RuntimeStates.cs (6)
43public static LogStream ParseLogStream(string value) => value switch 45"stdout" => LogStream.Stdout, 46"stderr" => LogStream.Stderr, 108public static string ToWire(this LogStream stream) => stream switch 110LogStream.Stdout => "stdout", 111LogStream.Stderr => "stderr",
Aspire.Hosting.Native.Core.Tests (11)
DcpResponseTests.cs (4)
58Assert.Empty(await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0, TestContext.Current.CancellationToken)); 69await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0, TestContext.Current.CancellationToken); 94await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0, TestContext.Current.CancellationToken)); 103Assert.Equal([line], await client.ReadLogsAsync(DcpResourceCollection.Executables, "job", LogStream.Stdout, 0,
NativeProtocolParsingTests.cs (1)
97Assert.Equal(LogStream.Stderr, RuntimeStates.ParseLogStream("stderr"));
NativeProviderLifecycleTests.cs (1)
215Assert.ThrowsAny<OperationCanceledException>(() => authority.AppendLog(LogStream.Stdout, "late log"));
NativeTimeProviderTests.cs (2)
80owner.AppendLog(LogStream.Stdout, "ready"); 274? (Task)client.ReadLogsAsync(DcpResourceCollection.Containers, "cache", LogStream.Stdout, 0, TestContext.Current.CancellationToken)
SymbolicValueTests.cs (3)
89targetOwner.AppendLog(LogStream.Stdout, "credential=launch-secret"); 143owner.AppendLog(LogStream.Stdout, "first-secret second-secret"); 199owner.AppendLog(LogStream.Stdout, "/0/0/ /31/63/");
Aspire.Hosting.Native.Server (7)
Auxiliary\NativeAuxiliaryBackchannel.cs (1)
320var line = new NativeAuxiliaryLogLine(resource.Name, checked((int)log.Sequence), log.Message, log.Stream == LogStream.Stderr);
Dashboard\NativeDashboardService.cs (1)
118Text = line.Message, IsStdErr = line.Stream == LogStream.Stderr,
Dcp\DcpApiClient.cs (1)
143public async Task<string[]> ReadLogsAsync(DcpResourceCollection collection, string name, LogStream source, long offset, CancellationToken cancellationToken)
Dcp\DcpWorkloadExecutor.cs (4)
276var stdout = await client.ReadLogsAsync(collection, name, LogStream.Stdout, _stdout, cancellationToken).ConfigureAwait(false); 277var stderr = await client.ReadLogsAsync(collection, name, LogStream.Stderr, _stderr, cancellationToken).ConfigureAwait(false); 281return stdout.Select(message => new WorkloadLog(LogStream.Stdout, message.TrimEnd('\r'))) 282.Concat(stderr.Select(message => new WorkloadLog(LogStream.Stderr, message.TrimEnd('\r')))).ToImmutableArray();