Skip to content

Commit 9d96dec

Browse files
committed
Pass headers to Druid query
1 parent d00631f commit 9d96dec

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

pkg/tsdb/druid/druid.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -502,21 +502,21 @@ func (ds *Service) executeQuery(
502502
return nil, errors.New("not implemented")
503503
case "timeseries":
504504
var r result.TimeseriesResult
505-
_, err := s.client.Query().Execute(q, &r)
505+
_, err := s.client.Query().Execute(q, &r, headers)
506506
if err != nil {
507507
return nil, fmt.Errorf("Query error: %w", err)
508508
}
509509
resultFramer = &r
510510
case "topN":
511511
var r result.TopNResult
512-
_, err := s.client.Query().Execute(q, &r)
512+
_, err := s.client.Query().Execute(q, &r, headers)
513513
if err != nil {
514514
return nil, fmt.Errorf("Query error: %w", err)
515515
}
516516
resultFramer = &r
517517
case "groupBy":
518518
var r result.GroupByResult
519-
_, err := s.client.Query().Execute(q, &r)
519+
_, err := s.client.Query().Execute(q, &r, headers)
520520
if err != nil {
521521
return nil, fmt.Errorf("Query error: %w", err)
522522
}

0 commit comments

Comments
 (0)