21 instantiations of OtlpTrace
Aspire.Dashboard (2)
Otlp\Model\OtlpTrace.cs (1)
152
var newTrace = new
OtlpTrace
(trace.Key, trace.LastUpdatedDate);
Otlp\Storage\TelemetryRepository.cs (1)
1167
trace = new
OtlpTrace
(span.TraceId.Memory, DateTime.UtcNow);
Aspire.Dashboard.Components.Tests (2)
Controls\GenAIVisualizerDialogTests.cs (2)
33
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
94
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
Aspire.Dashboard.Tests (17)
Model\SpanWaterfallViewModelTests.cs (7)
26
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
57
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
86
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
119
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
180
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
230
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
252
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
Model\TraceHelpersTests.cs (5)
20
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
42
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
69
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
97
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
131
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
TelemetryRepositoryTests\OtlpSpanTests.cs (5)
22
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
73
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
92
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
112
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
175
var trace = new
OtlpTrace
(new byte[] { 1, 2, 3 }, DateTime.MinValue);
113 references to OtlpTrace
Aspire.Dashboard (76)
Api\TelemetryApiService.cs (2)
117
var allTraces = new List<
OtlpTrace
>();
179
var
trace = result.PagedResult.Items.FirstOrDefault(t => OtlpHelpers.MatchTelemetryId(t.TraceId, traceId));
Components\Controls\TraceActions.razor.cs (1)
23
public required
OtlpTrace
Trace { get; set; }
Components\Pages\TraceDetail.razor.cs (1)
35
private
OtlpTrace
? _trace;
Components\Pages\Traces.razor.cs (6)
47
private FluentDataGrid<
OtlpTrace
> _dataGrid = null!;
111
private string GetNameTooltip(
OtlpTrace
trace)
134
private async ValueTask<GridItemsProviderResult<
OtlpTrace
>> GetData(GridItemsProviderRequest<
OtlpTrace
> request)
254
private static string GetRowClass(
OtlpTrace
entry)
268
if (_dataGrid != null && FluentDataGridHelper<
OtlpTrace
>.TrySetMaxItemCount(_dataGrid, 10_000))
Model\Assistant\AssistantChatDataContext.cs (5)
27
private readonly ConcurrentDictionary<string,
OtlpTrace
> _referencedTraces = new();
88
var
trace = TelemetryRepository.GetTrace(traceId);
330
public bool TryGetTrace(string text, [NotNullWhen(true)] out
OtlpTrace
? trace)
371
public IEnumerable<
OtlpTrace
> GetReferencedTraces()
376
public void AddReferencedTrace(
OtlpTrace
trace)
Model\Assistant\Markdown\AspireEnrichmentParser.cs (2)
160
if (_options.DataContext.TryGetTrace(text, out
var
trace))
200
foreach (
var
trace in _options.DataContext.GetReferencedTraces())
Model\Assistant\Prompts\IceBreakersBuilder.cs (6)
212
public void Traces(BuildIceBreakersContext context, Func<PagedResult<
OtlpTrace
>> getCurrentTraces, bool hasErrors, Func<PagedResult<
OtlpTrace
>> getErrorTraces)
244
private InitialPrompt CreateErrorTracesPrompt(Func<PagedResult<
OtlpTrace
>> getErrorTraces)
256
public void Traces(BuildIceBreakersContext context, OtlpResource resource, Func<PagedResult<
OtlpTrace
>> getCurrentTraces, bool hasErrors, Func<PagedResult<
OtlpTrace
>> getErrorTraces)
290
public void Trace(BuildIceBreakersContext context,
OtlpTrace
trace)
Model\Assistant\Prompts\KnownChatMessages.cs (2)
287
public static ChatMessage CreateAnalyzeTraceMessage(
OtlpTrace
trace, List<OtlpLogEntry> traceLogEntries, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, DashboardOptions options, Func<IOtlpResource, string> getResourceName)
341
public static ChatMessage CreateErrorTracesMessage(List<
OtlpTrace
> errorTraces, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, DashboardOptions options, Func<IOtlpResource, string> getResourceName)
Model\Assistant\Prompts\PromptContextsBuilder.cs (3)
11
public static Task ErrorTraces(InitializePromptContext promptContext, string displayText, Func<PagedResult<
OtlpTrace
>> getErrorTraces)
17
foreach (
var
trace in errorTraces.Items)
67
public static Task AnalyzeTrace(InitializePromptContext context, string displayText,
OtlpTrace
trace)
Model\ExportHelpers.cs (1)
47
public static ExportResult GetTraceAsJson(
OtlpTrace
trace, TelemetryRepository telemetryRepository, IOutgoingPeerResolver[] outgoingPeerResolvers)
Model\Otlp\SpanWaterfallViewModel.cs (1)
128
public static List<SpanWaterfallViewModel> Create(
OtlpTrace
trace, List<OtlpLogEntry> logs, TraceDetailState state)
Model\SpanDetailsViewModel.cs (3)
40
var traceCache = new Dictionary<string,
OtlpTrace
>(StringComparer.Ordinal);
62
private static SpanLinkViewModel CreateLinkViewModel(string traceId, string spanId, KeyValuePair<string, string>[] attributes, TelemetryRepository telemetryRepository, Dictionary<string,
OtlpTrace
> traceCache)
64
ref
var
trace = ref CollectionsMarshal.GetValueRefOrAddDefault(traceCache, traceId, out _);
Model\TelemetryExportService.cs (2)
306
internal static OtlpTelemetryDataJson ConvertTracesToOtlpJson(IReadOnlyList<
OtlpTrace
> traces, IOutgoingPeerResolver[] outgoingPeerResolvers)
338
internal static string ConvertTraceToJson(
OtlpTrace
trace, IOutgoingPeerResolver[] outgoingPeerResolvers, List<OtlpLogEntry>? logs = null)
Model\TraceHelpers.cs (2)
16
public static void VisitSpans<TState>(
OtlpTrace
trace, Func<OtlpSpan, TState, TState> spanAction, TState state)
65
public static IEnumerable<OrderedResource> GetOrderedResources(
OtlpTrace
trace)
Model\TraceMenuBuilder.cs (1)
69
OtlpTrace
trace,
Model\TracesViewModel.cs (3)
15
private PagedResult<
OtlpTrace
>? _traces;
78
public PagedResult<
OtlpTrace
> GetTraces()
106
public PagedResult<
OtlpTrace
> GetErrorTraces(int count)
Otlp\Model\OtlpSpan.cs (3)
26
public
OtlpTrace
Trace { get; }
74
public OtlpSpan(OtlpResourceView resourceView,
OtlpTrace
trace, OtlpScope scope)
81
public static OtlpSpan Clone(OtlpSpan item,
OtlpTrace
trace)
Otlp\Model\OtlpTrace.cs (3)
150
public static
OtlpTrace
Clone(
OtlpTrace
trace)
152
var
newTrace = new OtlpTrace(trace.Key, trace.LastUpdatedDate);
Otlp\Storage\GetTracesResponse.cs (1)
10
public required PagedResult<
OtlpTrace
> PagedResult { get; init; }
Otlp\Storage\TelemetryRepository.cs (27)
57
private readonly CircularBuffer<
OtlpTrace
> _traces;
92
private void TracesItemRemovedForCapacity(
OtlpTrace
trace)
601
PagedResult = PagedResult<
OtlpTrace
>.Empty,
654
var copyFunc = static (
OtlpTrace
t) =>
OtlpTrace
.Clone(t);
684
private static bool MatchResources(
OtlpTrace
t, List<OtlpResource> resources)
904
foreach (
var
trace in _traces)
959
public bool HasUpdatedTrace(
OtlpTrace
trace)
965
var
latestTrace = GetTraceUnsynchronized(trace.TraceId);
980
public
OtlpTrace
? GetTrace(string traceId)
994
private
OtlpTrace
? GetTraceUnsynchronized(string traceId)
998
foreach (
var
trace in _traces)
1009
private
OtlpTrace
? GetTraceAndCloneUnsynchronized(string traceId)
1013
var
trace = GetTraceUnsynchronized(traceId);
1015
return trace != null ?
OtlpTrace
.Clone(trace) : null;
1023
var
trace = GetTraceAndCloneUnsynchronized(traceId);
1153
var updatedTraces = new Dictionary<ReadOnlyMemory<byte>,
OtlpTrace
>();
1159
OtlpTrace
? trace;
1203
var
currentTrace = _traces[i];
1225
var
currentTrace = _traces[i];
1294
static bool TryGetTraceById(CircularBuffer<
OtlpTrace
> traces, ReadOnlyMemory<byte> traceId, [NotNullWhen(true)] out
OtlpTrace
? trace)
1324
private void CalculateTraceUninstrumentedPeers(
OtlpTrace
trace)
1372
var
trace = _traces[i];
1390
foreach (
var
trace in _traces)
1418
private static OtlpSpan CreateSpan(OtlpResourceView resourceView, Span span,
OtlpTrace
trace, OtlpScope scope, OtlpContext context)
1567
foreach (
var
trace in _traces)
Otlp\Storage\TelemetryRepository.Watchers.cs (1)
76
foreach (
var
trace in existingTraces.PagedResult.Items)
Aspire.Dashboard.Components.Tests (6)
Controls\GenAIVisualizerDialogTests.cs (5)
33
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
94
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
157
var
trace = tracesResult.PagedResult.Items[0];
241
var
trace = tracesResult.PagedResult.Items[0];
247
var
currentTrace = repository.GetTraces(new GetTracesRequest
tests\Shared\Telemetry\TelemetryTestHelpers.cs (1)
307
public static OtlpSpan CreateOtlpSpan(OtlpResource resource,
OtlpTrace
trace, OtlpScope scope, string spanId, string? parentSpanId, DateTime startDate,
Aspire.Dashboard.Tests (31)
Integration\OtlpHttpJsonTests.cs (1)
441
var
trace = traces.PagedResult.Items.First();
Model\SpanWaterfallViewModelTests.cs (7)
26
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
57
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
86
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
119
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
180
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
230
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
252
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
Model\TelemetryExportServiceTests.cs (2)
1002
var
trace = repository.GetTraces(GetTracesRequest.ForResourceKey(repository.GetResources()[0].ResourceKey)).PagedResult.Items[0];
1043
var
trace = repository.GetTraces(GetTracesRequest.ForResourceKey(repository.GetResources()[0].ResourceKey)).PagedResult.Items[0];
Model\TraceHelpersTests.cs (5)
20
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
42
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
69
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
97
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
131
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
TelemetryRepositoryTests\OtlpSpanTests.cs (5)
22
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
73
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
92
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
112
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
175
var
trace = new OtlpTrace(new byte[] { 1, 2, 3 }, DateTime.MinValue);
TelemetryRepositoryTests\TraceTests.cs (10)
756
var
trace1 = repository.GetTrace(GetHexId("1"))!;
757
var
trace2 = repository.GetTrace(GetHexId("1"))!;
822
var
trace = Assert.Single(traces.PagedResult.Items);
875
var
trace = Assert.Single(traces.PagedResult.Items);
1341
var
trace = Assert.Single(repository.GetTraces(request).PagedResult.Items);
1520
var
trace = Assert.Single(traces.PagedResult.Items);
1825
var
trace = Assert.Single(traces.PagedResult.Items);
1917
var
trace = Assert.Single(traces.PagedResult.Items);
1989
var
trace = Assert.Single(traces.PagedResult.Items);
2068
var
trace = Assert.Single(traces.PagedResult.Items);
tests\Shared\Telemetry\TelemetryTestHelpers.cs (1)
307
public static OtlpSpan CreateOtlpSpan(OtlpResource resource,
OtlpTrace
trace, OtlpScope scope, string spanId, string? parentSpanId, DateTime startDate,