OtlpTrace

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

42public required OtlpTrace Trace { get; set; }

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

Components\Pages\Traces.razor.cs (6)

47private FluentDataGrid<OtlpTrace> _dataGrid = null!; 111private string GetNameTooltip(OtlpTrace trace) 134private async ValueTask<GridItemsProviderResult<OtlpTrace>> GetData(GridItemsProviderRequest<OtlpTrace> request) 254private static string GetRowClass(OtlpTrace entry) 268if (_dataGrid != null && FluentDataGridHelper<OtlpTrace>.TrySetMaxItemCount(_dataGrid, 10_000))

Components_Pages_Traces_razor.g.cs (30)

Model\Assistant\AIHelpers.cs (3)

43internal static object GetTraceDto(OtlpTrace trace, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, PromptContext context) 103public static (string json, string limitMessage) GetTracesJson(List<OtlpTrace> traces, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers) 117internal static string GetTraceJson(OtlpTrace trace, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, PromptContext context)

Model\Assistant\AssistantChatDataContext.cs (5)

32private readonly ConcurrentDictionary<string, OtlpTrace> _referencedTraces = new(); 91var trace = TelemetryRepository.GetTrace(traceId); 371public bool TryGetTrace(string text, [NotNullWhen(true)] out OtlpTrace? trace) 412public IEnumerable<OtlpTrace> GetReferencedTraces() 417public void AddReferencedTrace(OtlpTrace trace)

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

160if (_options.DataContext.TryGetTrace(text, out var trace)) 200foreach (var trace in _options.DataContext.GetReferencedTraces())

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

212public void Traces(BuildIceBreakersContext context, Func<PagedResult<OtlpTrace>> getCurrentTraces, bool hasErrors, Func<PagedResult<OtlpTrace>> getErrorTraces) 244private InitialPrompt CreateErrorTracesPrompt(Func<PagedResult<OtlpTrace>> getErrorTraces) 256public void Traces(BuildIceBreakersContext context, OtlpResource resource, Func<PagedResult<OtlpTrace>> getCurrentTraces, bool hasErrors, Func<PagedResult<OtlpTrace>> getErrorTraces) 290public void Trace(BuildIceBreakersContext context, OtlpTrace trace)

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

282public static ChatMessage CreateAnalyzeTraceMessage(OtlpTrace trace, List<OtlpLogEntry> traceLogEntries, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers) 328public static ChatMessage CreateErrorTracesMessage(List<OtlpTrace> errorTraces, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers)

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

12public static Task ErrorTraces(InitializePromptContext promptContext, string displayText, Func<PagedResult<OtlpTrace>> getErrorTraces) 16foreach (var trace in errorTraces.Items) 62public static Task AnalyzeTrace(InitializePromptContext context, string displayText, OtlpTrace trace)

Model\Otlp\SpanWaterfallViewModel.cs (1)

128public static List<SpanWaterfallViewModel> Create(OtlpTrace trace, List<OtlpLogEntry> logs, TraceDetailState state)

Model\SpanDetailsViewModel.cs (3)

40var traceCache = new Dictionary<string, OtlpTrace>(StringComparer.Ordinal); 62private static SpanLinkViewModel CreateLinkViewModel(string traceId, string spanId, KeyValuePair<string, string>[] attributes, TelemetryRepository telemetryRepository, Dictionary<string, OtlpTrace> traceCache) 64ref var trace = ref CollectionsMarshal.GetValueRefOrAddDefault(traceCache, traceId, out _);

Model\TraceHelpers.cs (2)

16public static void VisitSpans<TState>(OtlpTrace trace, Func<OtlpSpan, TState, TState> spanAction, TState state) 65public static IEnumerable<OrderedResource> GetOrderedResources(OtlpTrace trace)

Model\TracesViewModel.cs (3)

15private PagedResult<OtlpTrace>? _traces; 78public PagedResult<OtlpTrace> GetTraces() 106public PagedResult<OtlpTrace> GetErrorTraces(int count)

Otlp\Model\OtlpSpan.cs (3)

26public OtlpTrace Trace { get; } 74public OtlpSpan(OtlpResourceView resourceView, OtlpTrace trace, OtlpScope scope) 81public static OtlpSpan Clone(OtlpSpan item, OtlpTrace trace)

Otlp\Model\OtlpTrace.cs (3)

150public static OtlpTrace Clone(OtlpTrace trace) 152var newTrace = new OtlpTrace(trace.Key, trace.LastUpdatedDate);

Otlp\Storage\GetTracesResponse.cs (1)

10public required PagedResult<OtlpTrace> PagedResult { get; init; }

Otlp\Storage\TelemetryRepository.cs (27)

51private readonly CircularBuffer<OtlpTrace> _traces; 86private void TracesItemRemovedForCapacity(OtlpTrace trace) 524PagedResult = PagedResult<OtlpTrace>.Empty, 577var copyFunc = static (OtlpTrace t) => OtlpTrace.Clone(t); 607private static bool MatchResources(OtlpTrace t, List<OtlpResource> resources) 735foreach (var trace in _traces) 790public bool HasUpdatedTrace(OtlpTrace trace) 796var latestTrace = GetTraceUnsynchronized(trace.TraceId); 811public OtlpTrace? GetTrace(string traceId) 825private OtlpTrace? GetTraceUnsynchronized(string traceId) 829foreach (var trace in _traces) 840private OtlpTrace? GetTraceAndCloneUnsynchronized(string traceId) 844var trace = GetTraceUnsynchronized(traceId); 846return trace != null ? OtlpTrace.Clone(trace) : null; 854var trace = GetTraceAndCloneUnsynchronized(traceId); 980var updatedTraces = new Dictionary<ReadOnlyMemory<byte>, OtlpTrace>(); 986OtlpTrace? trace; 1030var currentTrace = _traces[i]; 1052var currentTrace = _traces[i]; 1110static bool TryGetTraceById(CircularBuffer<OtlpTrace> traces, ReadOnlyMemory<byte> traceId, [NotNullWhen(true)] out OtlpTrace? trace) 1140private void CalculateTraceUninstrumentedPeers(OtlpTrace trace) 1188var trace = _traces[i]; 1206foreach (var trace in _traces) 1234private static OtlpSpan CreateSpan(OtlpResourceView resourceView, Span span, OtlpTrace trace, OtlpScope scope, OtlpContext context) 1383foreach (var trace in _traces)