From 04e3391c567283f34f61cc910d3e9603f8f2fdba Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Giedrius=20Statkevi=C4=8Dius?= Date: Thu, 4 May 2023 15:00:58 +0300 Subject: [PATCH] query: use storepb.SeriesServer (#6334) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Use storepb.SeriesServer instead of the concrete struct. This allows implementing functionality on top of the proxy. Signed-off-by: Giedrius Statkevičius --- pkg/query/querier.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/query/querier.go b/pkg/query/querier.go index 074a9f0d3d5..cbc7ec39f57 100644 --- a/pkg/query/querier.go +++ b/pkg/query/querier.go @@ -60,7 +60,7 @@ type QueryableCreator func( func NewQueryableCreator( logger log.Logger, reg prometheus.Registerer, - proxy *store.ProxyStore, + proxy storepb.StoreServer, maxConcurrentSelects int, selectTimeout time.Duration, ) QueryableCreator { @@ -102,7 +102,7 @@ type queryable struct { logger log.Logger replicaLabels []string storeDebugMatchers [][]*labels.Matcher - proxy *store.ProxyStore + proxy storepb.StoreServer deduplicate bool maxResolutionMillis int64 partialResponse bool @@ -127,7 +127,7 @@ type querier struct { mint, maxt int64 replicaLabels []string storeDebugMatchers [][]*labels.Matcher - proxy *store.ProxyStore + proxy storepb.StoreServer deduplicate bool maxResolutionMillis int64 partialResponseStrategy storepb.PartialResponseStrategy @@ -148,7 +148,7 @@ func newQuerier( maxt int64, replicaLabels []string, storeDebugMatchers [][]*labels.Matcher, - proxy *store.ProxyStore, + proxy storepb.StoreServer, deduplicate bool, maxResolutionMillis int64, partialResponse,