Otlp\Storage\TelemetryRepository.cs (26)
40private readonly ConcurrentDictionary<ApplicationKey, OtlpApplication> _applications = new();
45private readonly HashSet<(OtlpApplication Application, string PropertyKey)> _logPropertyKeys = new();
46private readonly HashSet<(OtlpApplication Application, string PropertyKey)> _tracePropertyKeys = new();
98public List<OtlpApplication> GetApplications(bool includeUninstrumentedPeers = false)
103public List<OtlpApplication> GetApplicationsByName(string name, bool includeUninstrumentedPeers = false)
108private List<OtlpApplication> GetApplicationsCore(bool includeUninstrumentedPeers, string? name)
110IEnumerable<OtlpApplication> results = _applications.Values;
124public OtlpApplication? GetApplicationByCompositeName(string compositeName)
137public OtlpApplication? GetApplication(ApplicationKey key)
144_applications.TryGetValue(key, out var application);
148public List<OtlpApplication> GetApplications(ApplicationKey key, bool includeUninstrumentedPeers = false)
155var app = GetApplication(key);
195foreach (var application in applications)
225private (OtlpApplication Application, bool IsNew) GetOrAddApplication(ApplicationKey key, bool uninstrumentedPeer)
228if (_applications.TryGetValue(key, out var application))
398List<OtlpApplication>? applications = null;
434List<OtlpApplication>? applications = null;
461List<OtlpApplication>? applications = null;
488List<OtlpApplication>? applications = null;
567private static bool MatchApplications(ApplicationKey applicationKey, List<OtlpApplication> applications)
569foreach (var application in applications)
580private static bool MatchApplications(OtlpTrace t, List<OtlpApplication> applications)
608List<OtlpApplication>? applications = null;
645List<OtlpApplication>? applications = null;
682List<OtlpApplication> applications;
692foreach (var app in applications)