Otlp\Storage\TelemetryRepository.cs (25)
40private readonly ConcurrentDictionary<ResourceKey, OtlpResource> _resources = new();
47private readonly Dictionary<ResourceKey, int> _resourceUnviewedErrorLogs = new();
137public OtlpResource? GetResource(ResourceKey key)
141throw new InvalidOperationException($"{nameof(ResourceKey)} must have an instance ID.");
148public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false)
164public Dictionary<ResourceKey, int> GetResourceUnviewedErrorLogsCount()
178internal void MarkViewedErrorLogs(ResourceKey? key)
214var key = resource.GetResourceKey();
225private (OtlpResource Resource, bool IsNew) GetOrAddResource(ResourceKey key, bool uninstrumentedPeer)
258public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback)
263public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback)
268public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback)
273private Subscription AddSubscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions)
459public List<string> GetLogPropertyKeys(ResourceKey? resourceKey)
486public List<string> GetTracePropertyKeys(ResourceKey? resourceKey)
594private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources)
611var resourceKey = resources[i].ResourceKey;
633public void ClearTraces(ResourceKey? resourceKey = null)
670public void ClearStructuredLogs(ResourceKey? resourceKey = null)
707public void ClearMetrics(ResourceKey? resourceKey = null)
1135var resourceKey = ResourceKey.Create(name: peer.DisplayName, instanceId: peer.Name);
1157var resourceKey = ResourceKey.Create(name: uninstrumentedPeer.DisplayName, instanceId: uninstrumentedPeer.Name);
1293public List<OtlpInstrumentSummary> GetInstrumentsSummaries(ResourceKey key)