2 instantiations of LogEntry
Aspire.Hosting (2)
src\Shared\ConsoleLogs\LogEntry.cs (2)
28
return new
LogEntry
48
return new
LogEntry
43 references to LogEntry
Aspire.Hosting (33)
ApplicationModel\ResourceLoggerService.cs (15)
142
internal Action<
LogEntry
> GetInternalLogger(string resourceName)
348
private readonly CircularBuffer<
LogEntry
> _inMemoryEntries = new(MaxLogCount);
395
List<
LogEntry
> inMemoryEntries;
419
var channel = Channel.CreateUnbounded<
LogEntry
>();
424
void Log(
LogEntry
log) => channel.Writer.TryWrite(log);
426
LogEntry
[] backlogSnapshot;
435
foreach (
var
logEntry in _inMemoryEntries)
477
private Action<
LogEntry
>? _onNewLog;
478
private event Action<
LogEntry
> OnNewLog
539
internal
LogEntry
[] GetBacklogSnapshot()
547
public void AddLog(
LogEntry
logEntry, bool inMemorySource)
588
loggerState.AddLog(
LogEntry
.Create(logTime, logMessage, isErrorMessage), inMemorySource: true);
593
private static LogLine[] CreateLogLines(ref int lineNumber, IReadOnlyList<
LogEntry
> entries)
598
var
entry = entries[i];
619
public IAsyncEnumerable<IReadOnlyList<
LogEntry
>> GetAllLogsAsync(string resourceName, CancellationToken cancellationToken)
Dcp\DcpExecutor.cs (6)
445
public async IAsyncEnumerable<IReadOnlyList<
LogEntry
>> GetAllLogsAsync(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)
461
var logs = new List<
LogEntry
>();
462
foreach (
var
logEntry in CreateLogEntries(batch))
472
private static IEnumerable<
LogEntry
> CreateLogEntries(IReadOnlyList<(string, bool)> batch)
485
yield return
LogEntry
.Create(timestamp, resolvedContent, content, isError);
524
foreach (
var
logEntry in CreateLogEntries(batch))
IConsoleLogsService.cs (1)
8
IAsyncEnumerable<IReadOnlyList<
LogEntry
>> GetAllLogsAsync(string resourceName, CancellationToken cancellationToken);
src\Shared\ConsoleLogs\LogEntries.cs (8)
19
private readonly CircularBuffer<
LogEntry
> _logEntries = new(maximumEntryCount);
27
public IList<
LogEntry
> GetEntries() => _logEntries;
45
foreach (
var
pauseEntry in pauseEntries)
60
public bool ProcessPauseFilters(
LogEntry
logEntry)
83
public void InsertSorted(
LogEntry
logLine)
99
var
entry = _logEntries[i];
114
private void InsertSortedCore(
LogEntry
logEntry)
126
var
current = _logEntries[rowIndex];
src\Shared\ConsoleLogs\LogEntry.cs (3)
26
public static
LogEntry
CreatePause(DateTime startTimestamp, DateTime? endTimestamp = null)
41
public static
LogEntry
Create(DateTime? timestamp, string logMessage, bool isErrorMessage)
46
public static
LogEntry
Create(DateTime? timestamp, string logMessage, string rawLogContent, bool isErrorMessage)
Aspire.Hosting.Tests (10)
Dashboard\DashboardLifecycleHookTests.cs (1)
64
dashboardLoggerState.AddLog(
LogEntry
.Create(timestamp, logMessage, isErrorMessage: false), inMemorySource: true);
Dashboard\DashboardServiceTests.cs (2)
35
var getConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<
LogEntry
>>();
75
await getConsoleLogsChannel.Writer.WriteAsync([
LogEntry
.Create(null, "Test3", isErrorMessage: false)]);
ResourceLoggerServiceTests.cs (4)
262
var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<
LogEntry
>>();
263
consoleLogsChannel0.Writer.TryWrite([
LogEntry
.Create(timestamp: null, logMessage: "instance0!", isErrorMessage: false)]);
266
var consoleLogsChannel1 = Channel.CreateUnbounded<IReadOnlyList<
LogEntry
>>();
267
consoleLogsChannel1.Writer.TryWrite([
LogEntry
.Create(timestamp: null, logMessage: "instance1!", isErrorMessage: false)]);
Utils\TestConsoleLogsService.cs (3)
12
private readonly Func<string, Channel<IReadOnlyList<
LogEntry
>>>? _getConsoleLogsChannel;
14
public TestConsoleLogsService(Func<string, Channel<IReadOnlyList<
LogEntry
>>>? getConsoleLogsChannel = null)
19
public async IAsyncEnumerable<IReadOnlyList<
LogEntry
>> GetAllLogsAsync(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)