External/signoz
1
0
Fork 0
mirror of https://github.com/SigNoz/signoz.git synced 2025-12-20 17:07:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: resolved conflicts

Browse Source
This commit is contained in:
eKuG 2025-08-11 11:48:13 +05:30
parent 33f47993d3
commit 90366975d8
1 changed files with 19 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
pkg/querier/querier.go
View File

@ -24,16 +24,15 @@ import (
) )
type querier struct { type querier struct {
logger *slog.Logger logger *slog.Logger
telemetryStore telemetrystore.TelemetryStore telemetryStore telemetrystore.TelemetryStore
metadataStore telemetrytypes.MetadataStore metadataStore telemetrytypes.MetadataStore
promEngine prometheus.Prometheus promEngine prometheus.Prometheus
traceStmtBuilder qbtypes.StatementBuilder[qbtypes.TraceAggregation] traceStmtBuilder qbtypes.StatementBuilder[qbtypes.TraceAggregation]
logStmtBuilder qbtypes.StatementBuilder[qbtypes.LogAggregation] logStmtBuilder qbtypes.StatementBuilder[qbtypes.LogAggregation]
metricStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation] metricStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation]
meterStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation] meterStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation]
bucketCache BucketCache bucketCache BucketCache
traceOperatorStmtBuilder qbtypes.TraceOperatorStatementBuilder
} }
var _ Querier = (*querier)(nil) var _ Querier = (*querier)(nil)
@ -48,20 +47,18 @@ func New(
metricStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation], metricStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation],
meterStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation], meterStmtBuilder qbtypes.StatementBuilder[qbtypes.MetricAggregation],
bucketCache BucketCache, bucketCache BucketCache,
traceOperatorStmtBuilder qbtypes.TraceOperatorStatementBuilder,
) *querier { ) *querier {
querierSettings := factory.NewScopedProviderSettings(settings, "github.com/SigNoz/signoz/pkg/querier") querierSettings := factory.NewScopedProviderSettings(settings, "github.com/SigNoz/signoz/pkg/querier")
return &querier{ return &querier{
logger: querierSettings.Logger(), logger: querierSettings.Logger(),
telemetryStore: telemetryStore, telemetryStore: telemetryStore,
metadataStore: metadataStore, metadataStore: metadataStore,
promEngine: promEngine, promEngine: promEngine,
traceStmtBuilder: traceStmtBuilder, traceStmtBuilder: traceStmtBuilder,
logStmtBuilder: logStmtBuilder, logStmtBuilder: logStmtBuilder,
metricStmtBuilder: metricStmtBuilder, metricStmtBuilder: metricStmtBuilder,
meterStmtBuilder: meterStmtBuilder, meterStmtBuilder: meterStmtBuilder,
bucketCache: bucketCache, bucketCache: bucketCache,
traceOperatorStmtBuilder: traceOperatorStmtBuilder,
} }
} }
@ -606,6 +603,7 @@ func (q *querier) createRangedQuery(originalQuery qbtypes.Query, timeRange qbtyp
return newBuilderQuery(q.telemetryStore, q.meterStmtBuilder, specCopy, adjustedTimeRange, qt.kind, qt.variables) return newBuilderQuery(q.telemetryStore, q.meterStmtBuilder, specCopy, adjustedTimeRange, qt.kind, qt.variables)
} }
return newBuilderQuery(q.telemetryStore, q.metricStmtBuilder, specCopy, adjustedTimeRange, qt.kind, qt.variables) return newBuilderQuery(q.telemetryStore, q.metricStmtBuilder, specCopy, adjustedTimeRange, qt.kind, qt.variables)
default: default:
return nil return nil
} }