Otlp\Storage\TelemetryRepository.cs (23)
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)
437public List<string> GetLogPropertyKeys(ResourceKey? resourceKey)
464public List<string> GetTracePropertyKeys(ResourceKey? resourceKey)
572private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources)
589var resourceKey = resources[i].ResourceKey;
611public void ClearTraces(ResourceKey? resourceKey = null)
648public void ClearStructuredLogs(ResourceKey? resourceKey = null)
685public void ClearMetrics(ResourceKey? resourceKey = null)
1122var resourceKey = ResourceKey.Create(name: uninstrumentedPeer.DisplayName, instanceId: uninstrumentedPeer.Name);
1258public List<OtlpInstrumentSummary> GetInstrumentsSummaries(ResourceKey key)