Model\Assistant\AIHelpers.cs (8)
51internal static object GetTraceDto(OtlpTrace trace, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, PromptContext context, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null)
119public static (string json, string limitMessage) GetTracesJson(List<OtlpTrace> traces, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null)
133internal static string GetTraceJson(OtlpTrace trace, IEnumerable<IOutgoingPeerResolver> outgoingPeerResolvers, PromptContext context, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null)
313public static (string json, string limitMessage) GetStructuredLogsJson(List<OtlpLogEntry> errorLogs, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null)
327internal static string GetStructuredLogJson(OtlpLogEntry l, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null)
335public static object GetLogEntryDto(OtlpLogEntry l, PromptContext context, DashboardOptions options, bool includeDashboardUrl = false, Func<OtlpResource, string>? getResourceName = null)
416public static bool TryGetResource(IReadOnlyList<OtlpResource> resources, string resourceName, [NotNullWhen(true)] out OtlpResource? resource)
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)