Otlp\Storage\TelemetryRepository.cs (33)
46private readonly ConcurrentDictionary<ResourceKey, OtlpResource> _resources = new();
51private readonly HashSet<(OtlpResource Resource, string PropertyKey)> _logPropertyKeys = new();
52private readonly HashSet<(OtlpResource Resource, string PropertyKey)> _tracePropertyKeys = new();
104public List<OtlpResource> GetResources(bool includeUninstrumentedPeers = false)
109public List<OtlpResource> GetResourcesByName(string name, bool includeUninstrumentedPeers = false)
114private List<OtlpResource> GetResourcesCore(bool includeUninstrumentedPeers, string? name)
116IEnumerable<OtlpResource> results = _resources.Values;
130public OtlpResource? GetResourceByCompositeName(string compositeName)
143public OtlpResource? GetResource(ResourceKey key)
150_resources.TryGetValue(key, out var resource);
154public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false)
161var resource = GetResource(key);
201foreach (var resource in resources)
231private (OtlpResource Resource, bool IsNew) GetOrAddResource(ResourceKey key, bool uninstrumentedPeer)
234if (_resources.TryGetValue(key, out var resource))
423List<OtlpResource>? resources = null;
538List<OtlpResource>? resources = null;
565List<OtlpResource>? resources = null;
592List<OtlpResource>? resources = null;
671private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources)
673foreach (var resource in resources)
684private static bool MatchResources(OtlpTrace t, List<OtlpResource> resources)
703private void SetResourceHasLogs(OtlpResource resource, bool value)
712private void SetResourceHasTraces(OtlpResource resource, bool value)
721private void SetResourceHasMetrics(OtlpResource resource, bool value)
738foreach (var otlpResource in allOtlpResources)
782List<OtlpResource>? resources = null;
809foreach (var resource in resources)
825List<OtlpResource>? resources = null;
852foreach (var resource in resources)
877List<OtlpResource> resources;
887foreach (var resource in resources)
1311public OtlpResource? GetPeerResource(OtlpSpan span)