42 instantiations of ResourceLogLine
Aspire.Dashboard (4)
ServiceClient\DashboardClient.cs (1)
1084
resourceLogLines[i] = new
ResourceLogLine
(logLines[i].LineNumber, logLines[i].Text, logLines[i].IsStdErr);
ServiceClient\SqliteResourceRepository.cs (3)
104
.Select(line => new
ResourceLogLine
(line.LineNumber, line.Content, line.IsStdErr))
132
.Select(line => new
ResourceLogLine
(line.LineNumber, line.Content, line.IsStdErr))
320
var viewModelLines = logLines.Select(line => new
ResourceLogLine
(line.LineNumber, line.Text, line.IsStdErr)).ToArray();
Aspire.Dashboard.Components.Tests (23)
Pages\ConsoleLogsTerminalTests.cs (1)
41
await logs.Writer.WriteAsync([new
ResourceLogLine
(1, "startup output", false)]);
Pages\ConsoleLogsTests.cs (17)
132
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(1, "Test content", IsErrorMessage: false)]);
201
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(1, "Test content", IsErrorMessage: false)]);
211
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(2, "Late content", IsErrorMessage: false)]);
406
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(1, "Hello world", IsErrorMessage: false)]);
446
liveConsoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(1, "Live log", IsErrorMessage: false)]);
494
new
ResourceLogLine
(1, "apple log", IsErrorMessage: false),
495
new
ResourceLogLine
(2, "banana log", IsErrorMessage: false)
676
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]);
701
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]);
782
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(1, "2025-02-08T10:16:08Z Hello world", IsErrorMessage: false)]);
794
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(2, "2025-03-08T10:16:08Z Hello world", IsErrorMessage: false)]);
822
new
ResourceLogLine
(1, clearedLog, IsErrorMessage: false),
823
new
ResourceLogLine
(2, newLog, IsErrorMessage: false)
1068
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(1, pauseContent, IsErrorMessage: false)]);
1069
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(2, pauseContent, IsErrorMessage: false)]);
1070
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(3, pauseContent, IsErrorMessage: false)]);
1116
consoleLogsChannel.Writer.TryWrite([new
ResourceLogLine
(4, resumeContent, IsErrorMessage: false)]);
Pages\ResourceOverviewConsoleTests.cs (2)
67
await apiLogs.Writer.WriteAsync([new
ResourceLogLine
(99, "old api output", false)]);
74
await cacheLogs.Writer.WriteAsync([new
ResourceLogLine
(1, "current cache output", false)]);
Pages\ResourceOverviewEmptyPanelsTests.cs (3)
130
.Select(number => new
ResourceLogLine
(number, $"line-{number}", false)).ToArray());
137
.Select(number => new
ResourceLogLine
(number, $"line-{number}", false)).ToArray());
174
await console.Writer.WriteAsync([
new
(1, "Application output", false)]);
Aspire.Dashboard.Tests (15)
Model\DashboardClientTests.cs (1)
471
Assert.Equal(new
ResourceLogLine
(1, "Hello", false), line);
Model\SqliteResourceRepositoryTests.cs (14)
127
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(2, "second", true), line),
128
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(1, "first", false), line),
129
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(3, "third", false), line),
130
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(4, "fourth", false), line));
166
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(4, "2025-02-08T10:16:09Z api-fourth-after-clear", false), line));
175
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(1, "worker-first", false), line));
213
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(1, "first", false), line),
214
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(2, "second", false), line),
215
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(1, "new-first", false), line),
216
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(2, "new-second", false), line),
217
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(3, "new-third", false), line));
271
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(2, "api-second", false), line));
280
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(1, "worker-first", false), line),
281
line => Assert.Equal(new global::Aspire.Dashboard.Model.
ResourceLogLine
(2, "worker-second", false), line));
80 references to ResourceLogLine
Aspire.Dashboard (21)
Components\Pages\ResourceOverview.razor.cs (2)
433
foreach (
var
line in batch)
576
private static ConsolePreviewLine CreatePreviewLine(
ResourceLogLine
line)
Model\ConsoleLogsFetcher.cs (1)
42
foreach (
var
logLine in batch)
ServiceClient\DashboardClient.cs (5)
993
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
1013
var channel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>(
1041
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
1078
private static
ResourceLogLine
[] CreateLogLines(IList<ConsoleLogLine> logLines)
1080
var resourceLogLines = new
ResourceLogLine
[logLines.Count];
ServiceClient\IResourceRepository.cs (2)
31
IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken);
36
IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken);
ServiceClient\SelectedDashboardClient.cs (2)
42
public IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken) =>
46
public IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken) =>
ServiceClient\SqliteResourceRepository.cs (9)
28
private readonly Dictionary<string, ImmutableHashSet<Channel<IReadOnlyList<
ResourceLogLine
>>>> _consoleChannels = new(StringComparers.ResourceName);
91
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(
95
ResourceLogLine
[] lines;
114
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(
118
ResourceLogLine
[] initialLines;
119
Channel<IReadOnlyList<
ResourceLogLine
>> channel;
135
channel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>(new UnboundedChannelOptions
321
Channel<IReadOnlyList<
ResourceLogLine
>>[] channels;
533
Channel<IReadOnlyList<
ResourceLogLine
>>[] consoleChannels;
Aspire.Dashboard.Components.Tests (34)
Pages\ConsoleLogsTerminalTests.cs (1)
27
var logs = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
Pages\ConsoleLogsTests.cs (22)
41
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
91
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
151
consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
175
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
227
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
316
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
368
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
415
var liveConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
416
var repositoryConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
460
consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>(),
478
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
519
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
545
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
594
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
643
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
708
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
746
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
801
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
842
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
918
consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>(),
951
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
1010
var consoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
Pages\ResourceOverviewConsoleTests.cs (3)
32
var apiLogs = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
33
var cacheLogs = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
155
consoleLogsChannelProvider: _ => Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>());
Pages\ResourceOverviewEmptyPanelsTests.cs (4)
34
var console = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
123
var console = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
153
var console = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
239
var console = Channel.CreateUnbounded<IReadOnlyList<
ResourceLogLine
>>();
tests\Shared\TestDashboardClient.cs (4)
18
private readonly Func<string, Channel<IReadOnlyList<
ResourceLogLine
>>>? _consoleLogsChannelProvider;
61
Func<string, Channel<IReadOnlyList<
ResourceLogLine
>>>? consoleLogsChannelProvider = null,
164
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
190
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Playwright.Tests (6)
tests\Aspire.Dashboard.Tests\Shared\MockDashboardClient.cs (2)
71
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
77
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
tests\Shared\TestDashboardClient.cs (4)
18
private readonly Func<string, Channel<IReadOnlyList<
ResourceLogLine
>>>? _consoleLogsChannelProvider;
61
Func<string, Channel<IReadOnlyList<
ResourceLogLine
>>>? consoleLogsChannelProvider = null,
164
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
190
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
Aspire.Dashboard.Tests (19)
Model\DashboardClientTests.cs (2)
464
var batches = new List<IReadOnlyList<
ResourceLogLine
>>();
470
var
line = Assert.Single(Assert.Single(batches));
Model\SqliteResourceRepositoryTests.cs (7)
120
var batches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.
ResourceLogLine
>>();
159
var apiBatches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.
ResourceLogLine
>>();
168
var workerBatches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.
ResourceLogLine
>>();
205
var batches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.
ResourceLogLine
>>();
234
var batches = new List<IReadOnlyList<global::Aspire.Dashboard.Model.
ResourceLogLine
>>();
264
var apiLogs = new List<global::Aspire.Dashboard.Model.
ResourceLogLine
>();
273
var workerLogs = new List<global::Aspire.Dashboard.Model.
ResourceLogLine
>();
ResourceOutgoingPeerResolverTests.cs (2)
703
public IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException();
706
public IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException();
Shared\MockDashboardClient.cs (2)
71
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
77
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
Terminal\DefaultTerminalConnectionResolverTests.cs (2)
201
public IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException();
202
public IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, CancellationToken cancellationToken) => throw new NotImplementedException();
tests\Shared\TestDashboardClient.cs (4)
18
private readonly Func<string, Channel<IReadOnlyList<
ResourceLogLine
>>>? _consoleLogsChannelProvider;
61
Func<string, Channel<IReadOnlyList<
ResourceLogLine
>>>? consoleLogsChannelProvider = null,
164
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> SubscribeConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
190
public async IAsyncEnumerable<IReadOnlyList<
ResourceLogLine
>> GetConsoleLogs(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)