Otlp\Storage\TelemetryRepository.cs (23)
40private readonly ConcurrentDictionary<ApplicationKey, OtlpApplication> _applications = new();
47private readonly Dictionary<ApplicationKey, int> _applicationUnviewedErrorLogs = new();
137public OtlpApplication? GetApplication(ApplicationKey key)
141throw new InvalidOperationException($"{nameof(ApplicationKey)} must have an instance ID.");
148public List<OtlpApplication> GetApplications(ApplicationKey key, bool includeUninstrumentedPeers = false)
164public Dictionary<ApplicationKey, int> GetApplicationUnviewedErrorLogsCount()
178internal void MarkViewedErrorLogs(ApplicationKey? key)
214var key = resource.GetApplicationKey();
225private (OtlpApplication Application, bool IsNew) GetOrAddApplication(ApplicationKey key, bool uninstrumentedPeer)
254public Subscription OnNewLogs(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback)
259public Subscription OnNewMetrics(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback)
264public Subscription OnNewTraces(ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback)
269private Subscription AddSubscription(string name, ApplicationKey? applicationKey, SubscriptionType subscriptionType, Func<Task> callback, List<Subscription> subscriptions)
432public List<string> GetLogPropertyKeys(ApplicationKey? applicationKey)
459public List<string> GetTracePropertyKeys(ApplicationKey? applicationKey)
567private static bool MatchApplications(ApplicationKey applicationKey, List<OtlpApplication> applications)
584var applicationKey = applications[i].ApplicationKey;
606public void ClearTraces(ApplicationKey? applicationKey = null)
643public void ClearStructuredLogs(ApplicationKey? applicationKey = null)
680public void ClearMetrics(ApplicationKey? applicationKey = null)
1085var appKey = ApplicationKey.Create(uninstrumentedPeer.Name);
1221public List<OtlpInstrumentSummary> GetInstrumentsSummaries(ApplicationKey key)