OtlpSpan

Api\TelemetryApiService.cs (2)

46var allSpans = new List<OtlpSpan>(); 293await foreach (var span in telemetryRepository.WatchSpansAsync(null, cancellationToken).ConfigureAwait(false))

Components\Controls\Chart\ChartBase.cs (6)

60private Dictionary<SpanKey, OtlpSpan> _currentCache = new Dictionary<SpanKey, OtlpSpan>(); 61private Dictionary<SpanKey, OtlpSpan> _newCache = new Dictionary<SpanKey, OtlpSpan>(); 315if (!_currentCache.TryGetValue(key, out var span)) 514_newCache = new Dictionary<SpanKey, OtlpSpan>();

Components\Controls\Chart\ChartExemplar.cs (1)

16public required OtlpSpan? Span { get; init; }

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

22public required OtlpSpan Span { get; set; }

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

18public required OtlpSpan Span { get; set; }

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

27public required EventCallback<OtlpSpan> OnLaunchGenAI { get; set; }

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

29public EventCallback<OtlpSpan> LaunchGenAICallback { get; set; }

Components\Dialogs\GenAIVisualizerDialog.razor.cs (8)

33private List<OtlpSpan> _contextSpans = default!; 110var span = newContextSpans.Find(s => s.SpanId == Content.Span.SpanId)!; 191if (TryGetContextSpanByIndex(_currentSpanContextIndex - 1, out var span)) 199if (TryGetContextSpanByIndex(_currentSpanContextIndex + 1, out var span)) 205private bool TryGetContextSpanByIndex(int index, [NotNullWhen(true)] out OtlpSpan? span) 211private bool TryUpdateViewedGenAISpan(OtlpSpan newSpan) 336OtlpSpan span, long? selectedLogEntryId, 337TelemetryRepository telemetryRepository, ITelemetryErrorRecorder errorRecorder, List<OtlpResource> resources, Func<List<OtlpSpan>> getContextGenAISpans)

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

572var span = TelemetryRepository.GetSpan(logEntry.TraceId, logEntry.SpanId)!; 606var genAISpans = new List<OtlpSpan>(); 609var span = TelemetryRepository.GetSpan(l.TraceId, l.SpanId);

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

218var headerSpan = _trace.RootOrFirstSpan; 309foreach (var span in _trace.Spans) 533private async Task OnGenAIClickedAsync(OtlpSpan span) 544var genAISpans = new List<OtlpSpan>();

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

202var span = trace.Spans.FirstOrDefault(s => OtlpHelpers.MatchTelemetryId(text, s.SpanId));

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

305public void Span(BuildIceBreakersContext context, OtlpSpan span)

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

314public static ChatMessage CreateAnalyzeSpanMessage(OtlpSpan span, List<OtlpLogEntry> traceLogEntries, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, DashboardOptions options, Func<IOtlpResource, string> getResourceName)

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

87public static Task AnalyzeSpan(InitializePromptContext context, string displayText, OtlpSpan span)

Model\ExportHelpers.cs (1)

24public static ExportResult GetSpanAsJson(OtlpSpan span, TelemetryRepository telemetryRepository, IOutgoingPeerResolver[] outgoingPeerResolvers)

Model\GenAI\GenAIItemViewModel.cs (1)

27public required OtlpSpan Parent { get; init; }

Model\GenAI\GenAIVisualizerDialogViewModel.cs (4)

26public required OtlpSpan Span { get; init; } 30public required Func<List<OtlpSpan>> GetContextGenAISpans { get; init; } 55Func<List<OtlpSpan>> getContextGenAISpans) 563private static List<OtlpLogEntry> GetSpanLogEntries(TelemetryRepository telemetryRepository, OtlpSpan span)

Model\Otlp\SpanWaterfallViewModel.cs (5)

14public required OtlpSpan Span { get; init; } 123public static string GetTitle(OtlpSpan span, List<OtlpResource> allResources) 134TraceHelpers.VisitSpans(trace, (OtlpSpan span, SpanWaterfallViewModelState s) => 147static SpanWaterfallViewModel CreateViewModel(OtlpSpan span, int depth, bool hidden, TraceDetailState state, List<OtlpLogEntry>? spanLogs, ref int currentSpanLogIndex) 216private static string? ResolveUninstrumentedPeerName(OtlpSpan span, IOutgoingPeerResolver[] outgoingPeerResolvers, List<OtlpResource> allResources)

Model\Otlp\TelemetryFilter.cs (3)

20public abstract bool Apply(OtlpSpan span); 144public override bool Apply(OtlpSpan span) 146var fieldValue = OtlpSpan.GetFieldValue(span, Field);

Model\SpanDetailsViewModel.cs (3)

15public required OtlpSpan Span { get; init; } 22public static SpanDetailsViewModel Create(OtlpSpan span, TelemetryRepository telemetryRepository, List<OtlpResource> resources) 68var linkSpan = trace?.Spans.FirstOrDefault(s => s.SpanId == spanId);

Model\SpanLinkViewModel.cs (1)

13public required OtlpSpan? Span { get; init; }

Model\SpanMenuBuilder.cs (2)

73OtlpSpan span, 75EventCallback<OtlpSpan> onLaunchGenAI,

Model\SpanType.cs (3)

94public override bool Apply(OtlpSpan span) 127public override bool Apply(OtlpSpan span) 160public override bool Apply(OtlpSpan span)

Model\StructuredLogsViewModel.cs (1)

49var span = _telemetryRepository.GetSpan(spanKey.TraceId, spanKey.SpanId);

Model\TelemetryExportService.cs (6)

279internal static OtlpTelemetryDataJson ConvertSpansToOtlpJson(IReadOnlyList<OtlpSpan> spans, IOutgoingPeerResolver[] outgoingPeerResolvers) 286var firstSpan = resourceGroup.First(); 313internal static string ConvertSpanToJson(OtlpSpan span, IOutgoingPeerResolver[] outgoingPeerResolvers, List<OtlpLogEntry>? logs = null, bool indent = true) 345var firstSpan = resourceGroup.First(); 390private static OtlpSpanJson ConvertSpan(OtlpSpan span, IOutgoingPeerResolver[] outgoingPeerResolvers) 810private static string? GetDestination(OtlpSpan span, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers)

Model\TraceHelpers.cs (17)

16public static void VisitSpans<TState>(OtlpTrace trace, Func<OtlpSpan, TState, TState> spanAction, TState state) 19var spanLookup = new Dictionary<OtlpSpan, List<OtlpSpan>>(); 20var unrootedSpans = new List<OtlpSpan>(); 21foreach (var item in trace.Spans) 23if (string.IsNullOrEmpty(item.ParentSpanId) || !trace.Spans.TryGetValue(item.ParentSpanId, out var parentSpan)) 35var orderByFunc = static (OtlpSpan s) => s.StartTime; 37foreach (var unrootedSpan in unrootedSpans.OrderBy(orderByFunc)) 44static void Visit(Dictionary<OtlpSpan, List<OtlpSpan>> spanLookup, OtlpSpan span, Func<OtlpSpan, TState, TState> spanAction, TState state, Func<OtlpSpan, DateTime> orderByFunc) 48foreach (var childSpan in childSpans.OrderBy(orderByFunc)) 69VisitSpans(trace, (OtlpSpan span, OrderedResourcesState state) => 89private static void ProcessSpanResource(OtlpSpan span, OtlpResource resource, Dictionary<OtlpResource, OrderedResource> resourceFirstTimes, DateTime currentMinDate) 128public static Icon? TryGetSpanIcon(OtlpSpan span, IconVariant iconVariant)

Model\TraceLinkHelpers.cs (1)

20Func<string, string, OtlpSpan?> getSpan,

Otlp\Model\OtlpHelpers.cs (5)

363var address = GetValue(values, OtlpSpan.PeerServiceAttributeKey); 370if (GetValue(values, OtlpSpan.ServerAddressAttributeKey) is { } server) 372if (GetValue(values, OtlpSpan.ServerPortAttributeKey) is { } serverPort) 380if (GetValue(values, OtlpSpan.NetPeerNameAttributeKey) is { } peer) 382if (GetValue(values, OtlpSpan.NetPeerPortAttributeKey) is { } peerPort)

Otlp\Model\OtlpSpan.cs (9)

48public IEnumerable<OtlpSpan> GetChildSpans() => GetChildSpans(this, Trace.Spans); 49public static IEnumerable<OtlpSpan> GetChildSpans(OtlpSpan parentSpan, OtlpSpanCollection spans) => spans.Where(s => s.ParentSpanId == parentSpan.SpanId); 59public OtlpSpan? GetParentSpan() 66if (Trace.Spans.TryGetValue(ParentSpanId, out var span)) 81public static OtlpSpan Clone(OtlpSpan item, OtlpTrace trace) 169static string BuildDisplaySummary(OtlpSpan span) 228public static FieldValues GetFieldValue(OtlpSpan span, string field)

Otlp\Model\OtlpSpanCollection.cs (4)

8public sealed class OtlpSpanCollection : KeyedCollection<string, OtlpSpan> 17protected override string GetKeyForItem(OtlpSpan item) 22public new List<OtlpSpan>.Enumerator GetEnumerator() 25return ((List<OtlpSpan>)this.Items).GetEnumerator();

Otlp\Model\OtlpSpanEvent.cs (1)

16public class OtlpSpanEvent(OtlpSpan span) : IPropertyGridItem

Otlp\Model\OtlpTrace.cs (19)

11private OtlpSpan? _rootSpan; 18public OtlpSpan FirstSpan => Spans[0]; // There should always be at least one span in a trace. 20public OtlpSpan? RootSpan => _rootSpan; 21public OtlpSpan RootOrFirstSpan => RootSpan ?? FirstSpan; 26public int CalculateDepth(OtlpSpan span) 29var currentSpan = span; 40public void AddSpan(OtlpSpan span, bool skipLastUpdatedDate = false) 72foreach (var existingSpan in Spans) 95static string BuildFullName(OtlpSpan existingSpan) 101private static bool HasCircularReference(OtlpSpan span) 111var currentSpan = span; 132var span = Spans[i]; 153foreach (var item in trace.Spans) 155newTrace.AddSpan(OtlpSpan.Clone(item, newTrace), skipLastUpdatedDate: true); 165foreach (var span in Spans) 180public void SetSpanUninstrumentedPeer(OtlpSpan span, OtlpResource? resource) 191private sealed class SpanStartDateComparer : IComparer<OtlpSpan> 195public int Compare(OtlpSpan? x, OtlpSpan? y)

Otlp\Storage\TelemetryRepository.cs (18)

95foreach (var span in trace.Spans) 631foreach (var span in t.Spans) 691foreach (var span in t.Spans) 906foreach (var span in trace.Spans) 908var values = OtlpSpan.GetFieldValue(span, attributeName); 1018private OtlpSpan? GetSpanAndCloneUnsynchronized(string traceId, string spanId) 1026foreach (var span in trace.Spans) 1038public OtlpSpan? GetSpan(string traceId, string spanId) 1139List<OtlpSpan>? addedSpans = null; 1172var newSpan = CreateSpan(resourceView, span, trace, scope, _otlpContext); 1190var linkedSpan = GetSpanAndCloneUnsynchronized(link.TraceId, link.SpanId); 1260addedSpans ??= new List<OtlpSpan>(); 1311public OtlpResource? GetPeerResource(OtlpSpan span) 1326foreach (var span in trace.Spans) 1352private static ResourceViewModel? ResolveUninstrumentedPeerResource(OtlpSpan span, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers) 1392foreach (var span in trace.Spans) 1418private static OtlpSpan CreateSpan(OtlpResourceView resourceView, Span span, OtlpTrace trace, OtlpScope scope, OtlpContext context) 1442var newSpan = new OtlpSpan(resourceView, trace, scope)

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

35public async IAsyncEnumerable<OtlpSpan> WatchSpansAsync( 40var channel = Channel.CreateBounded<OtlpSpan>(new BoundedChannelOptions(1000) 78foreach (var span in trace.Spans) 92while (channel.Reader.TryRead(out var pendingSpan)) 105await foreach (var span in channel.Reader.ReadAllAsync(cancellationToken).ConfigureAwait(false)) 212private void PushSpansToWatchers(List<OtlpSpan> spans, ResourceKey resourceKey) 225foreach (var span in spans) 331private sealed class SpanWatcher(ResourceKey? resourceKey, Channel<OtlpSpan> channel) 334public Channel<OtlpSpan> Channel => channel;