1 write to _otlpContext
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.cs (1)
69_otlpContext = new OtlpContext
37 references to _otlpContext
Aspire.Dashboard (37)
Otlp\Storage\SqliteTelemetryRepository.Caching.cs (4)
80if (resourceCount >= _otlpContext.Options.MaxResourceCount) 82throw new InvalidOperationException($"Resource limit of {_otlpContext.Options.MaxResourceCount} reached. Resource '{resourceKey}' will not be added."); 192instrumentationScope.Attributes.ToKeyValuePairs(_otlpContext)); 620var resource = new OtlpResource(key.Name, key.InstanceId, uninstrumentedPeer, _otlpContext);
Otlp\Storage\SqliteTelemetryRepository.cs (3)
93_otlpContext.Logger.LogTrace("{Count} incoming structured log resource(s) ignored because of an active pause.", resourceLogs.Count); 116_otlpContext.Logger.LogTrace("{Count} incoming metric resource(s) ignored because of an active pause.", resourceMetrics.Count); 133_otlpContext.Logger.LogTrace("{Count} incoming trace resource(s) ignored because of an active pause.", resourceSpans.Count);
Otlp\Storage\SqliteTelemetryRepository.Logs.cs (7)
50_otlpContext.Logger.LogInformation(exception, "Error adding resource."); 68_otlpContext.Logger.LogInformation(exception, "Error adding log scope."); 83_otlpContext)); 88_otlpContext.Logger.LogInformation(exception, "Error adding log entry."); 193""", new { _otlpContext.Options.MaxLogCount }, transaction); 272IsFull = totalCount >= _otlpContext.Options.MaxLogCount 284query.Parameters.Add("MaxLogCount", _otlpContext.Options.MaxLogCount);
Otlp\Storage\SqliteTelemetryRepository.Metrics.Reads.cs (1)
313_otlpContext.Options.MaxMetricsCount,
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (9)
53_otlpContext.Logger.LogInformation(exception, "Error adding resource."); 67_otlpContext.Logger.LogInformation(exception, "Error adding metric scope."); 123_otlpContext.Logger.LogInformation("Error adding {MetricType} metrics. {MetricType} is not supported.", metric.DataCase, metric.DataCase); 139_otlpContext.Logger.LogInformation(exception, "Error adding metric instrument {MetricName}.", metric.Name); 238_otlpContext.Logger.LogInformation(exception, "Error adding metric."); 314_otlpContext.Logger.LogInformation(exception, "Error adding metric."); 417var attributes = pointAttributes.ToKeyValuePairs(_otlpContext); 666Attributes = exemplar.FilteredAttributes.ToKeyValuePairs(_otlpContext) 751""", new { DimensionIds = batch.Select(dimension => dimension.DimensionId).ToArray(), _otlpContext.Options.MaxMetricsCount }, transaction);
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
152}, ExecutionContext.Capture(), _otlpContext.Logger, _subscriptionMinExecuteInterval);
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (4)
51IsFull = connection.QuerySingle<int>("SELECT COUNT(*) FROM telemetry_traces;") >= _otlpContext.Options.MaxTraceCount 65query.Parameters.Add("MaxTraceCount", _otlpContext.Options.MaxTraceCount); 175new(resourceName, instanceId, uninstrumentedPeer, _otlpContext); 406IsFull = connection.QuerySingle<int>("SELECT COUNT(*) FROM telemetry_traces;") >= _otlpContext.Options.MaxTraceCount
Otlp\Storage\SqliteTelemetryRepository.Traces.Writes.cs (8)
68_otlpContext.Logger.LogInformation(exception, "Error adding resource."); 86_otlpContext.Logger.LogInformation(exception, "Error adding trace scope."); 111_otlpContext.Logger.LogInformation(exception, "Error adding span."); 935Attributes = span.Attributes.ToKeyValuePairs(_otlpContext, filter: attribute => attribute.Key != OtlpHelpers.AspireDestinationNameAttribute), 942foreach (var spanEvent in span.Events.OrderBy(spanEvent => spanEvent.TimeUnixNano).Take(_otlpContext.Options.MaxSpanEventCount)) 949Attributes = spanEvent.Attributes.ToKeyValuePairs(_otlpContext) 962Attributes = link.Attributes.ToKeyValuePairs(_otlpContext) 989""", new { _otlpContext.Options.MaxTraceCount }, transaction);