OtlpLogEntry

Api\TelemetryApiService.cs (4)

234Field = nameof(OtlpLogEntry.Severity), 242var allLogs = new List<OtlpLogEntry>(); 363Field = nameof(OtlpLogEntry.Severity), 371await foreach (var log in telemetryRepository.WatchLogsAsync(null, filters, cancellationToken).ConfigureAwait(false))

Components\Controls\PropertyValues\LogLevelValue.razor.cs (1)

18public required OtlpLogEntry LogEntry { get; set; }

Components\Controls\StructuredLogActions.razor.cs (1)

26public required OtlpLogEntry LogEntry { get; set; }

Components\Pages\StructuredLogs.razor.cs (10)

50private FluentDataGrid<OtlpLogEntry>? _dataGrid; 132private async ValueTask<GridItemsProviderResult<OtlpLogEntry>> GetData(GridItemsProviderRequest<OtlpLogEntry> request) 263var logEntryId = TelemetryRepository.GetLog(LogEntryId.Value); 310private async Task OnShowPropertiesAsync(OtlpLogEntry entry, string? buttonId) 419private string GetRowClass(OtlpLogEntry entry) 446if (_dataGrid != null && FluentDataGridHelper<OtlpLogEntry>.TrySetMaxItemCount(_dataGrid, 10_000)) 543private bool IsGenAILogEntry(OtlpLogEntry logEntry) 559private async Task LaunchGenAIVisualizerAsync(OtlpLogEntry logEntry) 607foreach (var l in logs.Items.DistinctBy(l => (l.SpanId, l.TraceId)))

Components\Pages\TraceDetail.razor.cs (1)

513private async Task ToggleSpanLogsAsync(OtlpLogEntry logEntry)

Components\ResourcesGridColumns\LogMessageColumnDisplay.razor.cs (4)

12public required OtlpLogEntry LogEntry { get; set; } 18public required EventCallback<OtlpLogEntry> LaunchGenAIVisualizerCallback { get; set; } 21public required Func<OtlpLogEntry, bool> IsGenAILogCallback { get; set; } 27_exceptionText = OtlpLogEntry.GetExceptionText(LogEntry);

Model\Assistant\AssistantChatDataContext.cs (3)

28private readonly ConcurrentDictionary<long, OtlpLogEntry> _referencedLogs = new(); 349public void AddReferencedLogEntry(OtlpLogEntry logEntry) 354public bool TryGetLog(long internalId, [NotNullWhen(true)] out OtlpLogEntry? logEntry)

Model\Assistant\Markdown\AspireEnrichmentParser.cs (1)

183if (_options.DataContext.TryGetLog(result, out var logEntry))

Model\Assistant\Markdown\LogEntryInline.cs (1)

11public required OtlpLogEntry LogEntry { get; init; }

Model\Assistant\Prompts\IceBreakersBuilder.cs (5)

136public void StructuredLogs(BuildIceBreakersContext context, Func<PagedResult<OtlpLogEntry>> getCurrentLogs, bool hasErrors, Func<PagedResult<OtlpLogEntry>> getErrorLogs) 168public void StructuredLogs(BuildIceBreakersContext context, OtlpResource resource, Func<PagedResult<OtlpLogEntry>> getCurrentLogs, bool hasErrors, Func<PagedResult<OtlpLogEntry>> getErrorLogs) 200public void StructuredLogs(BuildIceBreakersContext context, OtlpLogEntry logEntry)

Model\Assistant\Prompts\KnownChatMessages.cs (4)

180public static ChatMessage CreateErrorStructuredLogsMessage(List<OtlpLogEntry> errorLogs, DashboardOptions options, Func<IOtlpResource, string> getResourceName) 199public static ChatMessage CreateAnalyzeLogEntryMessage(OtlpLogEntry logEntry, DashboardOptions options, Func<IOtlpResource, string> getResourceName) 287public static ChatMessage CreateAnalyzeTraceMessage(OtlpTrace trace, List<OtlpLogEntry> traceLogEntries, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, DashboardOptions options, Func<IOtlpResource, string> getResourceName) 314public static ChatMessage CreateAnalyzeSpanMessage(OtlpSpan span, List<OtlpLogEntry> traceLogEntries, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, DashboardOptions options, Func<IOtlpResource, string> getResourceName)

Model\Assistant\Prompts\PromptContextsBuilder.cs (5)

29public static Task ErrorStructuredLogs(InitializePromptContext promptContext, string displayText, Func<PagedResult<OtlpLogEntry>> getErrorLogs) 34foreach (var log in errorLogs.Items) 55public static Task AnalyzeLogEntry(InitializePromptContext promptContext, string displayText, OtlpLogEntry logEntry) 75foreach (var log in traceLogs) 95foreach (var log in traceLogs)

Model\ExportHelpers.cs (1)

37public static ExportResult GetLogEntryAsJson(OtlpLogEntry logEntry)

Model\GenAI\GenAIVisualizerDialogViewModel.cs (2)

563private static List<OtlpLogEntry> GetSpanLogEntries(TelemetryRepository telemetryRepository, OtlpSpan span) 589foreach (var logEntry in logEntries)

Model\Otlp\SpanLogEntryViewModel.cs (1)

13public required OtlpLogEntry LogEntry { get; init; }

Model\Otlp\SpanWaterfallViewModel.cs (3)

128public static List<SpanWaterfallViewModel> Create(OtlpTrace trace, List<OtlpLogEntry> logs, TraceDetailState state) 147static SpanWaterfallViewModel CreateViewModel(OtlpSpan span, int depth, bool hidden, TraceDetailState state, List<OtlpLogEntry>? spanLogs, ref int currentSpanLogIndex) 168foreach (var log in spanLogs)

Model\Otlp\TelemetryFilter.cs (8)

18public abstract IEnumerable<OtlpLogEntry> Apply(IEnumerable<OtlpLogEntry> input); 112public override IEnumerable<OtlpLogEntry> Apply(IEnumerable<OtlpLogEntry> input) 116case nameof(OtlpLogEntry.TimeStamp): 122case nameof(OtlpLogEntry.Severity): 131case nameof(OtlpLogEntry.Message): 139return input.Where(x => func(OtlpLogEntry.GetFieldValue(x, Field) ?? string.Empty, Value));

Model\SpanType.cs (6)

89public override IEnumerable<OtlpLogEntry> Apply(IEnumerable<OtlpLogEntry> input) 122public override IEnumerable<OtlpLogEntry> Apply(IEnumerable<OtlpLogEntry> input) 155public override IEnumerable<OtlpLogEntry> Apply(IEnumerable<OtlpLogEntry> input)

Model\StructuredLogMenuBuilder.cs (1)

63OtlpLogEntry logEntry,

Model\StructuredLogsViewModel.cs (7)

19private PagedResult<OtlpLogEntry>? _logs; 109public PagedResult<OtlpLogEntry> GetLogs() 135filters.Add(new FieldTelemetryFilter { Field = nameof(OtlpLogEntry.Message), Condition = FilterCondition.Contains, Value = FilterText }); 140filters.Add(new FieldTelemetryFilter { Field = nameof(OtlpLogEntry.Severity), Condition = FilterCondition.GreaterThanOrEqual, Value = _logLevel.Value.ToString() }); 149public PagedResult<OtlpLogEntry> GetErrorLogs(int count) 152filters.RemoveAll(f => f is FieldTelemetryFilter fieldFilter && fieldFilter.Field == nameof(OtlpLogEntry.Severity)); 153filters.Add(new FieldTelemetryFilter { Field = nameof(OtlpLogEntry.Severity), Condition = FilterCondition.GreaterThanOrEqual, Value = Microsoft.Extensions.Logging.LogLevel.Error.ToString() });

Model\StructureLogsDetailsViewModel.cs (2)

11public required OtlpLogEntry LogEntry { get; init; } 13public static string GetEventName(OtlpLogEntry logEntry, IStringLocalizer<Dashboard.Resources.StructuredLogs> loc)

Model\TelemetryExportService.cs (8)

234internal static OtlpTelemetryDataJson ConvertLogsToOtlpJson(List<OtlpLogEntry> logs) 241var firstLog = resourceGroup.First(); 261private static OtlpLogRecordJson ConvertLogEntry(OtlpLogEntry log) 314internal static string ConvertSpanToJson(OtlpSpan span, IOutgoingPeerResolver[] outgoingPeerResolvers, List<OtlpLogEntry>? logs = null, bool indent = true) 339internal static string ConvertTraceToJson(OtlpTrace trace, IOutgoingPeerResolver[] outgoingPeerResolvers, List<OtlpLogEntry>? logs = null) 368internal static string ConvertLogEntryToJson(OtlpLogEntry logEntry) 451private static OtlpResourceLogsJson[]? ConvertLogsToResourceLogs(List<OtlpLogEntry>? logs) 463var firstLog = resourceGroup.First();

Otlp\Model\OtlpHelpers.cs (1)

492public static string? GetEventName(OtlpLogEntry logEntry)

Otlp\Model\OtlpLogEntry.cs (3)

126public static string? GetFieldValue(OtlpLogEntry log, string field) 146public static string? GetExceptionText(OtlpLogEntry logEntry) 167static string? GetProperty(OtlpLogEntry logEntry, string propertyName)

Otlp\Storage\TelemetryRepository.cs (12)

50private readonly CircularBuffer<OtlpLogEntry> _logs; 340List<OtlpLogEntry>? addedLogs = null; 358var logEntry = new OtlpLogEntry(record, resourceView, scope, _otlpContext); 396addedLogs ??= new List<OtlpLogEntry>(); 421public PagedResult<OtlpLogEntry> GetLogs(GetLogsContext context) 430return PagedResult<OtlpLogEntry>.Empty; 457public OtlpLogEntry? GetLog(long logId) 463foreach (var logEntry in _logs) 485public List<OtlpLogEntry> GetLogsForSpan(string traceId, string spanId) 516public List<OtlpLogEntry> GetLogsForTrace(string traceId) 940foreach (var log in _logs) 942var value = OtlpLogEntry.GetFieldValue(log, attributeName);

Otlp\Storage\TelemetryRepository.Watchers.cs (11)

127public async IAsyncEnumerable<OtlpLogEntry> WatchLogsAsync( 133var channel = Channel.CreateBounded<OtlpLogEntry>(new BoundedChannelOptions(1000) 164foreach (var log in existingLogs.Items) 175while (channel.Reader.TryRead(out var pendingLog)) 186await foreach (var log in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 241private void PushLogsToWatchers(List<OtlpLogEntry> logs, ResourceKey resourceKey) 259foreach (var log in logs) 284private static bool MatchesFilters(OtlpLogEntry log, List<TelemetryFilter> filters) 288IEnumerable<OtlpLogEntry> result = [log]; 338private sealed class LogWatcher(ResourceKey? resourceKey, List<TelemetryFilter> filters, Channel<OtlpLogEntry> channel) 342public Channel<OtlpLogEntry> Channel => channel;