1 write to _otlpContext
Aspire.Dashboard (1)
Otlp\Storage\SqliteTelemetryRepository.cs (1)
94_otlpContext = new OtlpContext
39 references to _otlpContext
Aspire.Dashboard (39)
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)); 618var resource = new OtlpResource(key.Name, key.InstanceId, uninstrumentedPeer, _otlpContext);
Otlp\Storage\SqliteTelemetryRepository.cs (3)
118_otlpContext.Logger.LogTrace("{Count} incoming structured log resource(s) ignored because of an active pause.", resourceLogs.Count); 146_otlpContext.Logger.LogTrace("{Count} incoming metric resource(s) ignored because of an active pause.", resourceMetrics.Count); 164_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)
363_otlpContext.Options.MaxMetricsCount,
Otlp\Storage\SqliteTelemetryRepository.Metrics.Writes.cs (11)
55_otlpContext.Logger.LogInformation(exception, "Error adding resource."); 69_otlpContext.Logger.LogInformation(exception, "Error adding metric scope."); 80_otlpContext.Logger.LogInformation( 142_otlpContext.Logger.LogInformation("Error adding {MetricType} metrics. {MetricType} is not supported.", metric.DataCase, metric.DataCase); 163_otlpContext.Logger.LogInformation(exception, "Error adding metric instrument {MetricName}.", metric.Name); 263_otlpContext.Logger.LogInformation(exception, "Error adding metric."); 333_otlpContext.Logger.LogInformation(exception, "Error adding metric."); 510var attributes = pointAttributes.ToKeyValuePairs(_otlpContext); 764if (!double.IsFinite(value) || !OtlpHelpers.TryValidateMetricExemplarTimestamp(exemplar, _otlpContext)) 778Attributes = exemplar.FilteredAttributes.ToKeyValuePairs(_otlpContext) 850var removeCount = dimension.PointCount - _otlpContext.Options.MaxMetricsCount;
Otlp\Storage\SqliteTelemetryRepository.Runtime.cs (1)
151}, ExecutionContext.Capture(), _otlpContext.Logger, _subscriptionMinExecuteInterval);
Otlp\Storage\SqliteTelemetryRepository.Traces.Reads.cs (4)
53IsFull = connection.QuerySingle<int>("SELECT COUNT(*) FROM telemetry_traces;", transaction: transaction) >= _otlpContext.Options.MaxTraceCount 67query.Parameters.Add("MaxTraceCount", _otlpContext.Options.MaxTraceCount); 180new(resourceName, instanceId, uninstrumentedPeer, _otlpContext); 419IsFull = connection.QuerySingle<int>("SELECT COUNT(*) FROM telemetry_traces;", transaction: transaction) >= _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."); 936Attributes = span.Attributes.ToKeyValuePairs(_otlpContext, filter: attribute => attribute.Key != OtlpHelpers.AspireDestinationNameAttribute), 943foreach (var spanEvent in span.Events.OrderBy(spanEvent => spanEvent.TimeUnixNano).Take(_otlpContext.Options.MaxSpanEventCount)) 950Attributes = spanEvent.Attributes.ToKeyValuePairs(_otlpContext) 963Attributes = link.Attributes.ToKeyValuePairs(_otlpContext) 990""", new { _otlpContext.Options.MaxTraceCount }, transaction);