Otlp\Storage\TelemetryRepository.cs (27)
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;
461List<OtlpResource>? resources = null;
488List<OtlpResource>? resources = null;
515List<OtlpResource>? resources = null;
594private static bool MatchResources(ResourceKey resourceKey, List<OtlpResource> resources)
596foreach (var resource in resources)
607private static bool MatchResources(OtlpTrace t, List<OtlpResource> resources)
635List<OtlpResource>? resources = null;
672List<OtlpResource>? resources = null;
709List<OtlpResource> resources;
719foreach (var resource in resources)
1127public OtlpResource? GetPeerResource(OtlpSpan span)