32 instantiations of OtlpResource
Aspire.Dashboard (1)
Otlp\Storage\TelemetryRepository.cs (1)
241return new OtlpResource(key.Name, key.InstanceId, uninstrumentedPeer, _otlpContext);
Aspire.Dashboard.Components.Tests (3)
Controls\GenAIVisualizerDialogTests.cs (2)
32var resource = new OtlpResource("app", "instance", uninstrumentedPeer: false, context); 62var resource = new OtlpResource("app", "instance", uninstrumentedPeer: false, context);
Controls\StructuredLogDetailsTests.cs (1)
26var app = new OtlpResource("app1", "instance1", uninstrumentedPeer: false, context);
Aspire.Dashboard.Tests (28)
Model\ApplicationsSelectHelpersTests.cs (1)
279return new OtlpResource(key.Name, key.InstanceId, uninstrumentedPeer: false, TelemetryTestHelpers.CreateContext());
Model\SpanWaterfallViewModelTests.cs (9)
23var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 24var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 53var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 83var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 84var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 118var app = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 179var app = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 229var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 251var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context);
Model\TraceHelpersTests.cs (11)
19var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 40var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 41var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 67var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 68var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 94var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 95var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 96var app3 = new OtlpResource("app3", "instance", uninstrumentedPeer: false, context); 128var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 129var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 130var app3 = new OtlpResource("app3", "instance", uninstrumentedPeer: true, context);
TelemetryRepositoryTests\OtlpSpanTests.cs (7)
21var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 72var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 90var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 91var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: true, context); 110var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 111var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: true, context); 174var app = new OtlpResource("app", "instance", uninstrumentedPeer: false, context);
212 references to OtlpResource
Aspire.Dashboard (130)
Components\Controls\Chart\ChartBase.cs (1)
59public required List<OtlpResource> Resources { get; set; }
Components\Controls\Chart\ChartContainer.razor.cs (1)
44public required List<OtlpResource> Resources { get; set; }
Components\Controls\PropertyValues\ResourceNameButtonValue.razor.cs (1)
22public required OtlpResource Resource { get; set; }
Components\Dialogs\GenAIVisualizerDialog.razor.cs (1)
337TelemetryRepository telemetryRepository, ITelemetryErrorRecorder errorRecorder, List<OtlpResource> resources, Func<List<OtlpSpan>> getContextGenAISpans)
Components\Dialogs\ManageDataDialog.razor.cs (6)
128foreach (var otlpResource in TelemetryRepository.GetResources()) 213var otlpResource = TelemetryRepository.GetResourceByCompositeName(resource.Name); 228private static ResourceDataRow CreateTelemetryOnlyResourceDataRow(OtlpResource otlpResource) 243private static void PopulateDataRows(List<TelemetryDataRow> data, OtlpResource otlpResource, string resourceName) 339private string GetOtlpResourceName(OtlpResource resource) => OtlpResource.GetResourceName(resource, TelemetryRepository.GetResources());
Components\Pages\Metrics.razor.cs (1)
28private List<OtlpResource> _resources = default!;
Components\Pages\StructuredLogs.razor.cs (3)
41private List<OtlpResource> _resources = default!; 236var application = _resources?.SingleOrDefault(a => a.ResourceKey == PageViewModel.SelectedResource.Id?.GetResourceKey()); 418private string GetResourceName(OtlpResourceView app) => OtlpResource.GetResourceName(app.Resource, _resources);
Components\Pages\TraceDetail.razor.cs (3)
42private List<OtlpResource> _resources = default!; 324var apps = new HashSet<OtlpResource>(); 527private string GetResourceName(OtlpResourceView app) => OtlpResource.GetResourceName(app, _resources);
Components\Pages\Traces.razor.cs (5)
40private List<OtlpResource> _resources = default!; 251private string GetResourceName(OtlpResource app) => OtlpResource.GetResourceName(app, _resources); 252private string GetResourceName(OtlpResourceView app) => OtlpResource.GetResourceName(app, _resources); 439var resource = _resources?.SingleOrDefault(a => a.ResourceKey == PageViewModel.SelectedResource.Id?.GetResourceKey());
Components\ResourcesGridColumns\UnreadLogErrorsBadge.razor.cs (1)
37var otlpResource = TelemetryRepository.GetResourceByCompositeName(resource.Name);
Components_Controls_Chart_ChartContainer_razor.g.cs (2)
532), global::Microsoft.AspNetCore.Components.CompilerServices.RuntimeHelpers.TypeCheck<global::System.Collections.Generic.List<global::Aspire.Dashboard.Otlp.Model.OtlpResource>>( 709), global::Microsoft.AspNetCore.Components.CompilerServices.RuntimeHelpers.TypeCheck<global::System.Collections.Generic.List<global::Aspire.Dashboard.Otlp.Model.OtlpResource>>(
Components_Controls_SpanDetails_razor.g.cs (1)
2183? ColorGenerator.Instance.GetColorVariableByKey(OtlpResource.GetResourceName(context.Span.Source, ViewModel.Resources))
Components_Dialogs_ExemplarsDialog_razor.g.cs (1)
313context.Span != null ? ColorGenerator.Instance.GetColorVariableByKey(OtlpResource.GetResourceName(context.Span.Source, Content.Resources)) : "transparent"
Components_Pages_Metrics_razor.g.cs (1)
1131), global::Microsoft.AspNetCore.Components.CompilerServices.RuntimeHelpers.TypeCheck<global::System.Collections.Generic.List<global::Aspire.Dashboard.Otlp.Model.OtlpResource>>(
Mcp\AspireTelemetryMcpTools.cs (4)
79getResourceName: r => OtlpResource.GetResourceName(r, resources)); 131getResourceName: r => OtlpResource.GetResourceName(r, resources)); 174getResourceName: r => OtlpResource.GetResourceName(r, resources)); 201if (!AIHelpers.TryGetResource(resources, resourceName, out var resource))
Model\Assistant\AIHelpers.cs (8)
51internal static object GetTraceDto(OtlpTrace trace, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, PromptContext context, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null) 119public static (string json, string limitMessage) GetTracesJson(List<OtlpTrace> traces, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null) 133internal static string GetTraceJson(OtlpTrace trace, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, PromptContext context, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null) 313public static (string json, string limitMessage) GetStructuredLogsJson(List<OtlpLogEntry> errorLogs, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null) 327internal static string GetStructuredLogJson(OtlpLogEntry l, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null) 335public static object GetLogEntryDto(OtlpLogEntry l, PromptContext context, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null) 416public static bool TryGetResource(IReadOnlyList<OtlpResource> resources, string resourceName, [NotNullWhen(true)] out OtlpResource? resource)
Model\Assistant\Prompts\IceBreakersBuilder.cs (2)
168public void StructuredLogs(BuildIceBreakersContext context, OtlpResource resource, Func<PagedResult<OtlpLogEntry>> getCurrentLogs, bool hasErrors, Func<PagedResult<OtlpLogEntry>> getErrorLogs) 256public void Traces(BuildIceBreakersContext context, OtlpResource resource, Func<PagedResult<OtlpTrace>> getCurrentTraces, bool hasErrors, Func<PagedResult<OtlpTrace>> getErrorTraces)
Model\Assistant\Prompts\KnownChatMessages.cs (2)
213public static ChatMessage CreateResourceStructuredLogsMessage(OtlpResource resource) 273public static ChatMessage CreateResourceTracesMessage(OtlpResource resource)
Model\ExemplarsDialogViewModel.cs (1)
12public required List<OtlpResource> Resources { get; init; }
Model\GenAI\GenAIVisualizerDialogViewModel.cs (2)
66SourceName = OtlpResource.GetResourceName(spanDetailsViewModel.Span.Source, resources), 68? OtlpResource.GetResourceName(peerResource, resources)
Model\ManageData\ResourceDataRow.cs (1)
21public OtlpResource? OtlpResource { get; init; }
Model\Otlp\ResourcesSelectHelpers.cs (4)
81public static List<SelectViewModel<ResourceTypeDetails>> CreateResources(List<OtlpResource> resources) 83var replicasByResourceName = OtlpResource.GetReplicasByResourceName(resources); 92var resource = replicas.Single(); 114Name = OtlpResource.GetResourceName(replica, resources)
Model\Otlp\SpanWaterfallViewModel.cs (6)
36public string GetTooltip(List<OtlpResource> allResources) 121public sealed record TraceDetailState(IOutgoingPeerResolver[] OutgoingPeerResolvers, List<string> CollapsedSpanIds, List<OtlpResource> AllResources); 123public static string GetTitle(OtlpSpan span, List<OtlpResource> allResources) 125return $"{OtlpResource.GetResourceName(span.Source, allResources)}: {span.GetDisplaySummary()}"; 216private static string? ResolveUninstrumentedPeerName(OtlpSpan span, IOutgoingPeerResolver[] outgoingPeerResolvers, List<OtlpResource> allResources) 223return OtlpResource.GetResourceName(span.UninstrumentedPeer, allResources);
Model\ResourceMenuItems.cs (1)
156var telemetryResource = telemetryRepository.GetResourceByCompositeName(resource.Name);
Model\SpanDetailsViewModel.cs (3)
20public required List<OtlpResource> Resources { get; init; } 22public static SpanDetailsViewModel Create(OtlpSpan span, TelemetryRepository telemetryRepository, List<OtlpResource> resources) 35Value = OtlpResource.GetResourceName(destination, resources)
Model\TelemetryExportService.cs (12)
114private void ExportStructuredLogs(ZipArchive archive, List<OtlpResource> resources) 116foreach (var resource in resources) 125var resourceName = OtlpResource.GetResourceName(resource, resources); 131private void ExportTraces(ZipArchive archive, List<OtlpResource> resources) 133foreach (var resource in resources) 142var resourceName = OtlpResource.GetResourceName(resource, resources); 148private void ExportMetrics(ZipArchive archive, List<OtlpResource> resources) 150foreach (var resource in resources) 183var resourceName = OtlpResource.GetResourceName(resource, resources); 417internal static OtlpTelemetryDataJson ConvertMetricsToOtlpJson(OtlpResource resource, List<OtlpInstrumentData> instruments) 562Key = OtlpResource.SERVICE_NAME, 567Key = OtlpResource.SERVICE_INSTANCE_ID,
Model\TraceHelpers.cs (5)
67var resourceFirstTimes = new Dictionary<OtlpResource, OrderedResource>(); 89private static void ProcessSpanResource(OtlpSpan span, OtlpResource resource, Dictionary<OtlpResource, OrderedResource> resourceFirstTimes, DateTime currentMinDate) 168public sealed class OrderedResource(OtlpResource resource, int index, DateTime firstDateTime, int totalSpans, int erroredSpans) 170public OtlpResource Resource { get; } = resource;
Otlp\Model\OtlpHelpers.cs (3)
38if (attribute.Key == OtlpResource.SERVICE_INSTANCE_ID) 42if (attribute.Key == OtlpResource.SERVICE_NAME) 46if (attribute.Key == OtlpResource.PROCESS_EXECUTABLE_NAME)
Otlp\Model\OtlpResource.cs (6)
277public static Dictionary<string, List<OtlpResource>> GetReplicasByResourceName(IEnumerable<OtlpResource> allResources) 284public static string GetResourceName(OtlpResourceView resource, List<OtlpResource> allResources) => 287public static string GetResourceName(OtlpResource resource, List<OtlpResource> allResources) 290foreach (var item in allResources)
Otlp\Model\OtlpResourceView.cs (4)
16public OtlpResource Resource { get; } 19public OtlpResourceView(OtlpResource resource, RepeatedField<KeyValue> attributes) 27case OtlpResource.SERVICE_NAME: 28case OtlpResource.SERVICE_INSTANCE_ID:
Otlp\Model\OtlpSpan.cs (4)
46public OtlpResource? UninstrumentedPeer { get => _uninstrumentedPeer; init => _uninstrumentedPeer = value; } 52private OtlpResource? _uninstrumentedPeer; 54public void SetUninstrumentedPeer(OtlpResource? peer) 136public OtlpResource? GetDestination()
Otlp\Model\OtlpTrace.cs (1)
180public void SetSpanUninstrumentedPeer(OtlpSpan span, OtlpResource? resource)
Otlp\Storage\TelemetryRepository.cs (33)
41private readonly ConcurrentDictionary<ResourceKey, OtlpResource> _resources = new(); 46private readonly HashSet<(OtlpResource Resource, string PropertyKey)> _logPropertyKeys = new(); 47private readonly HashSet<(OtlpResource Resource, string PropertyKey)> _tracePropertyKeys = new(); 99public List<OtlpResource> GetResources(bool includeUninstrumentedPeers = false) 104public List<OtlpResource> GetResourcesByName(string name, bool includeUninstrumentedPeers = false) 109private List<OtlpResource> GetResourcesCore(bool includeUninstrumentedPeers, string? name) 111IEnumerable<OtlpResource> results = _resources.Values; 125public OtlpResource? GetResourceByCompositeName(string compositeName) 138public OtlpResource? GetResource(ResourceKey key) 145_resources.TryGetValue(key, out var resource); 149public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false) 156var resource = GetResource(key); 196foreach (var resource in resources) 226private (OtlpResource Resource, bool IsNew) GetOrAddResource(ResourceKey key, bool uninstrumentedPeer) 229if (_resources.TryGetValue(key, out var resource)) 405List<OtlpResource>? resources = null; 520List<OtlpResource>? resources = null; 547List<OtlpResource>? resources = null; 574List<OtlpResource>? resources = null; 653private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources) 655foreach (var resource in resources) 666private static bool MatchResources(OtlpTrace t, List<OtlpResource> resources) 685private void SetResourceHasLogs(OtlpResource resource, bool value) 694private void SetResourceHasTraces(OtlpResource resource, bool value) 703private void SetResourceHasMetrics(OtlpResource resource, bool value) 720foreach (var otlpResource in allOtlpResources) 764List<OtlpResource>? resources = null; 791foreach (var resource in resources) 807List<OtlpResource>? resources = null; 834foreach (var resource in resources) 859List<OtlpResource> resources; 869foreach (var resource in resources) 1280public OtlpResource? GetPeerResource(OtlpSpan span)
Aspire.Dashboard.Components.Tests (8)
Controls\GenAIVisualizerDialogTests.cs (4)
32var resource = new OtlpResource("app", "instance", uninstrumentedPeer: false, context); 62var resource = new OtlpResource("app", "instance", uninstrumentedPeer: false, context); 153var resource = resources[0]; 239var resource = resources[0];
Controls\StructuredLogDetailsTests.cs (2)
26var app = new OtlpResource("app1", "instance1", uninstrumentedPeer: false, context); 31new KeyValue { Key = OtlpResource.SERVICE_NAME, Value = new AnyValue { StringValue = "value1" } }
tests\Shared\Telemetry\TelemetryTestHelpers.cs (2)
307public static OtlpSpan CreateOtlpSpan(OtlpResource resource, OtlpTrace trace, OtlpScope scope, string spanId, string? parentSpanId, DateTime startDate, 309OtlpResource? uninstrumentedPeer = null, DateTime? endDate = null, string? spanName = null)
Aspire.Dashboard.Tests (74)
Integration\OtlpHttpJsonTests.cs (6)
392private static OtlpResource AssertMyServiceResource(TelemetryRepository telemetryRepository) 395var resource = Assert.Single(resources); 429var resource = AssertMyServiceResource(telemetryRepository); 490var resource = AssertMyServiceResource(telemetryRepository); 567var resource = AssertMyServiceResource(telemetryRepository); 617var resource = AssertMyServiceResource(telemetryRepository);
Model\ApplicationsSelectHelpersTests.cs (9)
23var appVMs = ResourcesSelectHelpers.CreateResources(new List<OtlpResource> 68var appVMs = ResourcesSelectHelpers.CreateResources(new List<OtlpResource> 85var appVMs = ResourcesSelectHelpers.CreateResources(new List<OtlpResource> 106var appVMs = ResourcesSelectHelpers.CreateResources(new List<OtlpResource> 122var appVMs = ResourcesSelectHelpers.CreateResources(new List<OtlpResource> 173var apps = new Dictionary<string, OtlpResource>(); 197var appVMs = ResourcesSelectHelpers.CreateResources(new List<OtlpResource> 234var appVMs = ResourcesSelectHelpers.CreateResources(new List<OtlpResource> 268private static OtlpResource CreateOtlpResource(string name, string? instanceId)
Model\SpanWaterfallViewModelTests.cs (9)
23var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 24var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 53var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 83var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 84var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 118var app = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 179var app = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 229var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 251var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context);
Model\TelemetryExportServiceTests.cs (11)
47var resource = resources[0]; 66Assert.Contains(resourceLogs.Resource.Attributes, a => a.Key == OtlpResource.SERVICE_NAME && a.Value?.StringValue == "TestService"); 67Assert.Contains(resourceLogs.Resource.Attributes, a => a.Key == OtlpResource.SERVICE_INSTANCE_ID && a.Value?.StringValue == "instance-1"); 123var resource = resources[0]; 195var resource = resources[0]; 242var resource = resources[0]; 262Assert.Contains(resourceSpans.Resource.Attributes, a => a.Key == OtlpResource.SERVICE_NAME && a.Value?.StringValue == "TestService"); 315var resource = resources[0]; 354var resource = resources[0]; 385Assert.Contains(resourceMetrics.Resource.Attributes, a => a.Key == OtlpResource.SERVICE_NAME && a.Value?.StringValue == "TestService"); 440var resource = resources[0];
Model\TelemetryImportServiceTests.cs (2)
153var logResource = resources.FirstOrDefault(r => r.ResourceName == "LogService"); 156var traceResource = resources.FirstOrDefault(r => r.ResourceName == "TraceService");
Model\TraceHelpersTests.cs (11)
19var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 40var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 41var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 67var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 68var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 94var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 95var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 96var app3 = new OtlpResource("app3", "instance", uninstrumentedPeer: false, context); 128var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 129var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: false, context); 130var app3 = new OtlpResource("app3", "instance", uninstrumentedPeer: true, context);
TelemetryRepositoryTests\MetricsTests.cs (1)
1111var resources = Assert.Single(repository.GetResources());
TelemetryRepositoryTests\OtlpSpanTests.cs (10)
21var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 72var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 79var destination = span.GetDestination(); 90var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 91var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: true, context); 99var destination = span.GetDestination(); 110var app1 = new OtlpResource("app1", "instance", uninstrumentedPeer: false, context); 111var app2 = new OtlpResource("app2", "instance", uninstrumentedPeer: true, context); 124var destination = parentSpan.GetDestination(); 174var app = new OtlpResource("app", "instance", uninstrumentedPeer: false, context);
TelemetryRepositoryTests\ResourceTests.cs (5)
41var app1 = repository.GetResourceByCompositeName("app1-TestId"); 42var app2 = repository.GetResourceByCompositeName("APP2-TESTID"); 43var notFound = repository.GetResourceByCompositeName("APP2_TESTID"); 141var instance1Name = OtlpResource.GetResourceName(resources[0], resources); 142var instance2Name = OtlpResource.GetResourceName(resources[1], resources);
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (5)
52var resource = repository.GetResource(resourceKey); 289var resource2 = repository.GetResource(new ResourceKey("resource2", "222")); 302var resourceBefore = repository.GetResource(new ResourceKey("resource1", "123")); 313var resourceAfter = repository.GetResource(new ResourceKey("resource1", "123")); 344var resourceAfter = repository.GetResource(new ResourceKey("resource1", "123"));
TelemetryRepositoryTests\TraceTests.cs (3)
1481var resource = Assert.Single(repository.GetResources()); 1978var uninstrumentedPeerApp = resources.Single(a => a.UninstrumentedPeer); 2099var uninstrumentedPeerApp = resources.Single(a => a.UninstrumentedPeer);
tests\Shared\Telemetry\TelemetryTestHelpers.cs (2)
307public static OtlpSpan CreateOtlpSpan(OtlpResource resource, OtlpTrace trace, OtlpScope scope, string spanId, string? parentSpanId, DateTime startDate, 309OtlpResource? uninstrumentedPeer = null, DateTime? endDate = null, string? spanName = null)