2 instantiations of LogEntry
Aspire.Hosting (2)
src\Shared\ConsoleLogs\LogEntry.cs (2)
29return new LogEntry 51return new LogEntry
43 references to LogEntry
Aspire.Hosting (33)
ApplicationModel\ResourceLoggerService.cs (15)
144internal Action<LogEntry> GetInternalLogger(string resourceName) 365private readonly CircularBuffer<LogEntry> _inMemoryEntries = new(MaxLogCount); 412List<LogEntry> inMemoryEntries; 436var channel = Channel.CreateUnbounded<LogEntry>(); 441void Log(LogEntry log) => channel.Writer.TryWrite(log); 443LogEntry[] backlogSnapshot; 452foreach (var logEntry in _inMemoryEntries) 494private Action<LogEntry>? _onNewLog; 495private event Action<LogEntry> OnNewLog 556internal LogEntry[] GetBacklogSnapshot() 564public void AddLog(LogEntry logEntry, bool inMemorySource) 605loggerState.AddLog(LogEntry.Create(logTime, logMessage, isErrorMessage), inMemorySource: true); 610private static LogLine[] CreateLogLines(ref int lineNumber, IReadOnlyList<LogEntry> entries) 615var entry = entries[i]; 657public IAsyncEnumerable<IReadOnlyList<LogEntry>> GetAllLogsAsync(string resourceName, CancellationToken cancellationToken)
Dcp\DcpExecutor.cs (6)
643public async IAsyncEnumerable<IReadOnlyList<LogEntry>> GetAllLogsAsync(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken) 663var logs = new List<LogEntry>(); 664foreach (var logEntry in CreateLogEntries(batch)) 674private static IEnumerable<LogEntry> CreateLogEntries(IReadOnlyList<(string, bool)> batch) 687yield return LogEntry.Create(timestamp, resolvedContent, content, logEntryType, resourcePrefix: null); 727foreach (var logEntry in CreateLogEntries(batch))
IConsoleLogsService.cs (1)
10IAsyncEnumerable<IReadOnlyList<LogEntry>> GetAllLogsAsync(string resourceName, CancellationToken cancellationToken);
src\Shared\ConsoleLogs\LogEntries.cs (8)
19private readonly CircularBuffer<LogEntry> _logEntries = new(maximumEntryCount); 27public IList<LogEntry> GetEntries() => _logEntries; 45foreach (var pauseEntry in pauseEntries) 60public bool ProcessPauseFilters(LogEntry logEntry) 83public void InsertSorted(LogEntry logLine) 99var entry = _logEntries[i]; 114private void InsertSortedCore(LogEntry logEntry) 126var current = _logEntries[rowIndex];
src\Shared\ConsoleLogs\LogEntry.cs (3)
27public static LogEntry CreatePause(string resourcePrefix, DateTime startTimestamp, DateTime? endTimestamp = null) 44public static LogEntry Create(DateTime? timestamp, string logMessage, bool isErrorMessage) 49public static LogEntry Create(DateTime? timestamp, string logMessage, string rawLogContent, bool isErrorMessage, string? resourcePrefix)
Aspire.Hosting.Tests (10)
Dashboard\DashboardLifecycleHookTests.cs (1)
65dashboardLoggerState.AddLog(LogEntry.Create(timestamp, logMessage, isErrorMessage: false), inMemorySource: true);
Dashboard\DashboardServiceTests.cs (2)
36var getConsoleLogsChannel = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 76await getConsoleLogsChannel.Writer.WriteAsync([LogEntry.Create(null, "Test3", isErrorMessage: false)]);
ResourceLoggerServiceTests.cs (4)
262var consoleLogsChannel0 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 263consoleLogsChannel0.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance0!", isErrorMessage: false)]); 266var consoleLogsChannel1 = Channel.CreateUnbounded<IReadOnlyList<LogEntry>>(); 267consoleLogsChannel1.Writer.TryWrite([LogEntry.Create(timestamp: null, logMessage: "instance1!", isErrorMessage: false)]);
Utils\TestConsoleLogsService.cs (3)
12private readonly Func<string, Channel<IReadOnlyList<LogEntry>>>? _getConsoleLogsChannel; 14public TestConsoleLogsService(Func<string, Channel<IReadOnlyList<LogEntry>>>? getConsoleLogsChannel = null) 19public async IAsyncEnumerable<IReadOnlyList<LogEntry>> GetAllLogsAsync(string resourceName, [EnumeratorCancellation] CancellationToken cancellationToken)