Otlp\Storage\TelemetryRepository.cs (26)
41private readonly ConcurrentDictionary<ResourceKey, OtlpResource> _resources = new();
48private readonly Dictionary<ResourceKey, int> _resourceUnviewedErrorLogs = new();
138public OtlpResource? GetResource(ResourceKey key)
142throw new InvalidOperationException($"{nameof(ResourceKey)} must have an instance ID.");
149public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false)
165public Dictionary<ResourceKey, int> GetResourceUnviewedErrorLogsCount()
179internal void MarkViewedErrorLogs(ResourceKey? key)
215var key = resource.GetResourceKey();
226private (OtlpResource Resource, bool IsNew) GetOrAddResource(ResourceKey key, bool uninstrumentedPeer)
259public Subscription OnNewLogs(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback)
264public Subscription OnNewMetrics(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback)
269public Subscription OnNewTraces(ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback)
274private Subscription AddSubscription(string name, ResourceKey? resourceKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions)
518public List<string> GetLogPropertyKeys(ResourceKey? resourceKey)
545public List<string> GetTracePropertyKeys(ResourceKey? resourceKey)
653private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources)
670var resourceKey = resources[i].ResourceKey;
762public void ClearTraces(ResourceKey? resourceKey = null)
805public void ClearStructuredLogs(ResourceKey? resourceKey = null)
849private void ClearResource(ResourceKey resourceKey)
857public void ClearMetrics(ResourceKey? resourceKey = null)
1288var resourceKey = ResourceKey.Create(name: peer.DisplayName, instanceId: peer.Name);
1310var resourceKey = ResourceKey.Create(name: uninstrumentedPeer.DisplayName, instanceId: uninstrumentedPeer.Name);
1446public List<OtlpInstrumentSummary> GetInstrumentsSummaries(ResourceKey key)