Otlp\Storage\TelemetryRepository.cs (26)
40private readonly ConcurrentDictionary<ResourceKey, OtlpResource> _resources = new();
45private readonly HashSet<(OtlpResource Resource, string PropertyKey)> _logPropertyKeys = new();
46private readonly HashSet<(OtlpResource Resource, string PropertyKey)> _tracePropertyKeys = new();
98public List<OtlpResource> GetResources(bool includeUninstrumentedPeers = false)
103public List<OtlpResource> GetResourcesByName(string name, bool includeUninstrumentedPeers = false)
108private List<OtlpResource> GetResourcesCore(bool includeUninstrumentedPeers, string? name)
110IEnumerable<OtlpResource> results = _resources.Values;
124public OtlpResource? GetResourceByCompositeName(string compositeName)
137public OtlpResource? GetResource(ResourceKey key)
144_resources.TryGetValue(key, out var resource);
148public List<OtlpResource> GetResources(ResourceKey key, bool includeUninstrumentedPeers = false)
155var resource = GetResource(key);
195foreach (var resource in resources)
225private (OtlpResource Resource, bool IsNew) GetOrAddResource(ResourceKey key, bool uninstrumentedPeer)
228if (_resources.TryGetValue(key, out var resource))
403List<OtlpResource>? resources = null;
439List<OtlpResource>? resources = null;
466List<OtlpResource>? resources = null;
493List<OtlpResource>? resources = null;
572private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources)
574foreach (var resource in resources)
585private static bool MatchResources(OtlpTrace t, List<OtlpResource> resources)
613List<OtlpResource>? resources = null;
650List<OtlpResource>? resources = null;
687List<OtlpResource> resources;
697foreach (var resource in resources)