64 instantiations of ResourceKey
Aspire.Dashboard (7)
Model\ResourceTypeDetails.cs (1)
32return new ResourceKey(ReplicaSetName, InstanceId: null);
Otlp\Model\OtlpHelpers.cs (1)
64return new ResourceKey(serviceName, serviceInstanceId);
Otlp\Model\OtlpResource.cs (1)
45public ResourceKey ResourceKey => new ResourceKey(ResourceName, InstanceId);
Otlp\Storage\ResourceKey.cs (4)
14return new ResourceKey(Name: name, InstanceId: null); 25return new ResourceKey(name, instanceId.Substring(name.Length + 1)); 34return new ResourceKey(Name: instanceId, InstanceId: null); 37return new ResourceKey(Name: instanceId.Substring(0, separator), InstanceId: instanceId.Substring(separator + 1));
Aspire.Dashboard.Tests (57)
TelemetryRepositoryTests\LogTests.cs (18)
248Assert.True(unviewedCounts1.TryGetValue(new ResourceKey("TestService", "1"), out var unviewedCount1)); 251Assert.True(unviewedCounts1.TryGetValue(new ResourceKey("TestService", "2"), out var unviewedCount2)); 254repository.MarkViewedErrorLogs(new ResourceKey("TestService", "1")); 258Assert.False(unviewedCounts2.TryGetValue(new ResourceKey("TestService", "1"), out _)); 260Assert.True(unviewedCounts2.TryGetValue(new ResourceKey("TestService", "2"), out unviewedCount2)); 267Assert.False(unviewedCounts3.TryGetValue(new ResourceKey("TestService", "1"), out _)); 268Assert.False(unviewedCounts3.TryGetValue(new ResourceKey("TestService", "2"), out _)); 319Assert.False(unviewedCounts.TryGetValue(new ResourceKey("TestService", "1"), out _)); 320Assert.False(unviewedCounts.TryGetValue(new ResourceKey("TestService", "2"), out _)); 328using var subscription = repository.OnNewLogs(resourceKey: new ResourceKey("TestService", "1"), SubscriptionType.Read, () => Task.CompletedTask); 371Assert.False(unviewedCounts.TryGetValue(new ResourceKey("TestService", "1"), out _)); 372Assert.True(unviewedCounts.TryGetValue(new ResourceKey("TestService", "2"), out var unviewedCount)); 409Assert.True(unviewedCounts.TryGetValue(new ResourceKey("TestService", "1"), out var unviewedCount)); 422ResourceKey = new ResourceKey("TestService", "UnknownResource"), 439var propertyKeys = repository.GetLogPropertyKeys(new ResourceKey("TestService", "UnknownResource")); 1022var resourceKey = new ResourceKey("resource1", InstanceId: null); 1173repository.ClearStructuredLogs(new ResourceKey("resource1", "123")); 1247repository.ClearStructuredLogs(new ResourceKey("resource1", null));
TelemetryRepositoryTests\MetricsTests.cs (12)
572var resourceKey = new ResourceKey("resource1", InstanceId: null); 693var resource1Key = new ResourceKey("resource1", InstanceId: null); 697var resource2Key = new ResourceKey("resource2", InstanceId: null); 763repository.ClearMetrics(new ResourceKey("resource1", "456")); 768var resource1Key = new ResourceKey("resource1", InstanceId: null); 811var resource2Key = new ResourceKey("resource2", InstanceId: null); 921repository.ClearMetrics(new ResourceKey("resource1", null)); 926var resource1Key = new ResourceKey("resource1", InstanceId: null); 952var resource2Key = new ResourceKey("resource2", InstanceId: null); 1033var resource1Key = new ResourceKey("resource1", InstanceId: null); 1172ResourceKey = new ResourceKey("TestService", "TestId"), 1184ResourceKey = new ResourceKey("TestService", "TestId"),
TelemetryRepositoryTests\ResourceKeyTests.cs (2)
32var key = new ResourceKey(name, instanceId); 51var key = new ResourceKey(name, instanceId);
TelemetryRepositoryTests\ResourceTests.cs (2)
68var resources1 = repository.GetResources(new ResourceKey("app1", InstanceId: null)); 84var resources2 = repository.GetResources(new ResourceKey("app2", InstanceId: null));
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (16)
40var resourceKey = new ResourceKey("resource", "resource"); 214Assert.True(unviewedBefore.TryGetValue(new ResourceKey("resource1", "123"), out var errorCount1)); 216Assert.True(unviewedBefore.TryGetValue(new ResourceKey("resource2", "456"), out var errorCount2)); 228Assert.False(unviewedAfter.TryGetValue(new ResourceKey("resource1", "123"), out _)); 229Assert.True(unviewedAfter.TryGetValue(new ResourceKey("resource2", "456"), out errorCount2)); 240var resource1Metrics = repository.GetInstrumentsSummaries(new ResourceKey("resource1", "123")); 244var resource2Key = new ResourceKey("resource2", "456"); 252var resource2Metrics = repository.GetInstrumentsSummaries(new ResourceKey("resource2", "456")); 283var resource1Metrics = repository.GetInstrumentsSummaries(new ResourceKey("resource1", "111")); 286var resource3Metrics = repository.GetInstrumentsSummaries(new ResourceKey("resource3", "333")); 290var resource2 = repository.GetResource(new ResourceKey("resource2", "222")); 303var resourceBefore = repository.GetResource(new ResourceKey("resource1", "123")); 314var resourceAfter = repository.GetResource(new ResourceKey("resource1", "123")); 345var resourceAfter = repository.GetResource(new ResourceKey("resource1", "123")); 355var metrics = repository.GetInstrumentsSummaries(new ResourceKey("resource1", "123")); 643await foreach (var span in repository.WatchSpansAsync(new ResourceKey("service1", "inst1"), cts.Token))
TelemetryRepositoryTests\TraceTests.cs (7)
1113var resourceKey = new ResourceKey("resource1", InstanceId: null); 1175var resourceKey = new ResourceKey("resource1", InstanceId: null); 1265var resourceKey = new ResourceKey("resource1", InstanceId: null); 1311ResourceKey = new ResourceKey("TestService", "TestId"), 1704repository.ClearTraces(new ResourceKey("resource1", "123")); 1810repository.ClearTraces(new ResourceKey("resource1", null)); 1902repository.ClearTraces(new ResourceKey("resource1", null));
100 references to ResourceKey
Aspire.Dashboard (79)
Api\TelemetryApiService.cs (2)
416private static List<ResourceKey?>? ResolveResourceKeys(IReadOnlyList<OtlpResource> resources, string[]? resourceNames) 424var keys = new List<ResourceKey?>();
Components\Controls\Chart\ChartContainer.razor.cs (1)
26public required ResourceKey ResourceKey { get; set; }
Components\Controls\ClearSignalsButton.razor.cs (1)
27public required Func<ResourceKey?, Task> HandleClearSignal { get; set; }
Components\Controls\SignalsActionsDisplay.razor.cs (1)
25public required Func<ResourceKey?, Task> HandleClearSignal { get; set; }
Components\Pages\ConsoleLogs.razor.cs (1)
909private async Task ClearConsoleLogs(ResourceKey? key)
Components\Pages\Metrics.razor.cs (1)
237private Task ClearMetrics(ResourceKey? key)
Components\Pages\Resources.razor.cs (2)
46private Dictionary<ResourceKey, int>? _resourceUnviewedErrorCounts; 617private bool ResourceErrorCountsChanged(Dictionary<ResourceKey, int> newResourceUnviewedErrorCounts)
Components\Pages\StructuredLogs.razor.cs (1)
626private Task ClearStructureLogs(ResourceKey? key)
Components\Pages\Traces.razor.cs (1)
415private Task ClearTraces(ResourceKey? key)
Components\ResourcesGridColumns\StateColumnDisplay.razor.cs (1)
18public required Dictionary<ResourceKey, int>? UnviewedErrorCounts { get; set; }
Components\ResourcesGridColumns\UnreadLogErrorsBadge.razor.cs (1)
20public required Dictionary<ResourceKey, int>? UnviewedErrorCounts { get; set; }
Components_Controls_SignalsActionsDisplay_razor.g.cs (2)
275), (global::System.Func<global::Aspire.Dashboard.Otlp.Storage.ResourceKey?, global::System.Threading.Tasks.Task>)( 398), (global::System.Func<global::Aspire.Dashboard.Otlp.Storage.ResourceKey?, global::System.Threading.Tasks.Task>)(
Components_Pages_ConsoleLogs_razor.g.cs (1)
440), (global::System.Func<global::Aspire.Dashboard.Otlp.Storage.ResourceKey?, global::System.Threading.Tasks.Task>)(
Components_Pages_Metrics_razor.g.cs (2)
534), (global::System.Func<global::Aspire.Dashboard.Otlp.Storage.ResourceKey?, global::System.Threading.Tasks.Task>)( 1029), global::Microsoft.AspNetCore.Components.CompilerServices.RuntimeHelpers.TypeCheck<global::Aspire.Dashboard.Otlp.Storage.ResourceKey>(
Components_Pages_Resources_razor.g.cs (1)
2013), global::Microsoft.AspNetCore.Components.CompilerServices.RuntimeHelpers.TypeCheck<global::System.Collections.Generic.Dictionary<global::Aspire.Dashboard.Otlp.Storage.ResourceKey, global::System.Int32>>(
Components_Pages_StructuredLogs_razor.g.cs (1)
457), (global::System.Func<global::Aspire.Dashboard.Otlp.Storage.ResourceKey?, global::System.Threading.Tasks.Task>)(
Components_Pages_Traces_razor.g.cs (1)
440), (global::System.Func<global::Aspire.Dashboard.Otlp.Storage.ResourceKey?, global::System.Threading.Tasks.Task>)(
Components_ResourcesGridColumns_StateColumnDisplay_razor.g.cs (1)
278), global::Microsoft.AspNetCore.Components.CompilerServices.RuntimeHelpers.TypeCheck<global::System.Collections.Generic.Dictionary<global::Aspire.Dashboard.Otlp.Storage.ResourceKey, global::System.Int32>>(
Mcp\AspireTelemetryMcpTools.cs (1)
186private bool TryResolveResourceNameForTelemetry([NotNullWhen(false)] string? resourceName, [NotNullWhen(false)] out string? message, out ResourceKey? resourceKey)
Model\Assistant\AIHelpers.cs (1)
271out ResourceKey? resourceKey)
Model\Assistant\AssistantChatDataContext.cs (2)
299private bool TryResolveResourceNameForTelemetry([NotNullWhen(false)] string? resourceName, [NotNullWhen(false)] out string? message, out ResourceKey? resourceKey) 317resourceKey = ResourceKey.Create(resource.DisplayName, resource.Name);
Model\ResourceTypeDetails.cs (2)
24public ResourceKey GetResourceKey() 35return ResourceKey.Create(name: ReplicaSetName, instanceId: InstanceId);
Model\StructuredLogsViewModel.cs (2)
20private ResourceKey? _resourceKey; 32public ResourceKey? ResourceKey { get => _resourceKey; set => SetValue(ref _resourceKey, value); }
Model\TracesViewModel.cs (2)
16private ResourceKey? _resourceKey; 28public ResourceKey? ResourceKey { get => _resourceKey; set => SetValue(ref _resourceKey, value); }
Otlp\Model\OtlpHelpers.cs (1)
29public static ResourceKey GetResourceKey(this Resource resource)
Otlp\Model\OtlpResource.cs (1)
45public ResourceKey ResourceKey => new ResourceKey(ResourceName, InstanceId);
Otlp\Model\OtlpResourceView.cs (1)
15public ResourceKey ResourceKey => Resource.ResourceKey;
Otlp\Storage\GetInstrumentRequest.cs (1)
9public required ResourceKey ResourceKey { get; init; }
Otlp\Storage\GetLogsContext.cs (2)
10public required ResourceKey? ResourceKey { get; init; } 15public static GetLogsContext ForResourceKey(ResourceKey resourceKey) => new()
Otlp\Storage\GetTracesRequest.cs (2)
10public required ResourceKey? ResourceKey { get; init; } 16public static GetTracesRequest ForResourceKey(ResourceKey resourceKey) => new()
Otlp\Storage\ResourceKey.cs (3)
6public readonly record struct ResourceKey(string Name, string? InstanceId) : IComparable<ResourceKey> 8public static ResourceKey Create(string name, string instanceId) 40public int CompareTo(ResourceKey other)
Otlp\Storage\Subscription.cs (2)
23public ResourceKey? ResourceKey { get; } 27public Subscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, Action unsubscribe, ExecutionContext? executionContext, TelemetryRepository telemetryRepository)
Otlp\Storage\TelemetryRepository.cs (26)
46private readonly ConcurrentDictionary<ResourceKey, OtlpResource> _resources = new(); 53private readonly Dictionary<ResourceKey, int> _resourceUnviewedErrorLogs = new(); 143public OtlpResource? GetResource(ResourceKey key) 147throw new InvalidOperationException($"{nameof(ResourceKey)} must have an instance ID."); 154public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false) 170public Dictionary<ResourceKey, int> GetResourceUnviewedErrorLogsCount() 184internal void MarkViewedErrorLogs(ResourceKey? key) 220var key = resource.GetResourceKey(); 231private (OtlpResource Resource, bool IsNew) GetOrAddResource(ResourceKey key, bool uninstrumentedPeer) 264public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 269public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 274public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback) 279private Subscription AddSubscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions) 536public List<string> GetLogPropertyKeys(ResourceKey? resourceKey) 563public List<string> GetTracePropertyKeys(ResourceKey? resourceKey) 671private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources) 688var resourceKey = resources[i].ResourceKey; 780public void ClearTraces(ResourceKey? resourceKey = null) 823public void ClearStructuredLogs(ResourceKey? resourceKey = null) 867private void ClearResource(ResourceKey resourceKey) 875public void ClearMetrics(ResourceKey? resourceKey = null) 1319var resourceKey = ResourceKey.Create(name: peer.DisplayName, instanceId: peer.Name); 1341var resourceKey = ResourceKey.Create(name: uninstrumentedPeer.DisplayName, instanceId: uninstrumentedPeer.Name); 1477public List<OtlpInstrumentSummary> GetInstrumentsSummaries(ResourceKey key)
Otlp\Storage\TelemetryRepository.Watchers.cs (8)
36ResourceKey? resourceKey, 131ResourceKey? resourceKey, 212private void PushSpansToWatchers(List<OtlpSpan> spans, ResourceKey resourceKey) 244private void PushLogsToWatchers(List<OtlpLogEntry> logs, ResourceKey resourceKey) 331private sealed class SpanWatcher(ResourceKey? resourceKey, Channel<OtlpSpan> channel) 333public ResourceKey? ResourceKey => resourceKey; 341private sealed class LogWatcher(ResourceKey? resourceKey, List<TelemetryFilter> filters, Channel<OtlpLogEntry> channel) 343public ResourceKey? ResourceKey => resourceKey;
Aspire.Dashboard.Tests (21)
Model\ApplicationsSelectHelpersTests.cs (1)
277var key = OtlpHelpers.GetResourceKey(resource);
TelemetryRepositoryTests\LogTests.cs (3)
805var resourceKey = repository.GetResources().First().ResourceKey; 852var resourceKey = repository.GetResources().First().ResourceKey; 1022var resourceKey = new ResourceKey("resource1", InstanceId: null);
TelemetryRepositoryTests\MetricsTests.cs (8)
572var resourceKey = new ResourceKey("resource1", InstanceId: null); 693var resource1Key = new ResourceKey("resource1", InstanceId: null); 697var resource2Key = new ResourceKey("resource2", InstanceId: null); 768var resource1Key = new ResourceKey("resource1", InstanceId: null); 811var resource2Key = new ResourceKey("resource2", InstanceId: null); 926var resource1Key = new ResourceKey("resource1", InstanceId: null); 952var resource2Key = new ResourceKey("resource2", InstanceId: null); 1033var resource1Key = new ResourceKey("resource1", InstanceId: null);
TelemetryRepositoryTests\ResourceKeyTests.cs (4)
18var key = ResourceKey.Create(name, instanceId); 32var key = new ResourceKey(name, instanceId); 51var key = new ResourceKey(name, instanceId);
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (2)
40var resourceKey = new ResourceKey("resource", "resource"); 244var resource2Key = new ResourceKey("resource2", "456");
TelemetryRepositoryTests\TraceTests.cs (3)
1113var resourceKey = new ResourceKey("resource1", InstanceId: null); 1175var resourceKey = new ResourceKey("resource1", InstanceId: null); 1265var resourceKey = new ResourceKey("resource1", InstanceId: null);