Skip to content

Commit b28ed51

Browse files
committed
DEV-46512 - Add LogzioHeaders in Elasticsearch Plugin Resource API
1 parent 43c1afd commit b28ed51

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

pkg/tsdb/elasticsearch/elasticsearch.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@ import (
66
"encoding/json"
77
"errors"
88
"fmt"
9+
"github.com/grafana/grafana/pkg/models" // LOGZ.IO GRAFANA CHANGE :: DEV-43889 - Add headers for logzio datasources support
910
"io"
1011
"net/http"
1112
"net/url"
@@ -225,6 +226,13 @@ func (s *Service) CallResource(ctx context.Context, req *backend.CallResourceReq
225226

226227
logger.Debug("Sending request to Elasticsearch", "resourcePath", req.Path)
227228
start := time.Now()
229+
230+
// LOGZ.IO GRAFANA CHANGE :: DEV-43889 - Add headers for logzio datasources support
231+
logzIoHeaders := &models.LogzIoHeaders{RequestHeaders: req.Headers}
232+
request.Header = logzIoHeaders.GetDatasourceQueryHeaders(request.Header)
233+
request.Header.Set("Content-Type", "application/json")
234+
logger.Debug("request details", "headers", request.Header, "url", request.URL.String())
235+
// LOGZ.IO GRAFANA CHANGE :: End
228236
response, err := ds.HTTPClient.Do(request)
229237
if err != nil {
230238
status := "error"

0 commit comments

Comments
 (0)