Skip to content

Commit

Permalink
chore: [release-3.0.x] fix: codec not initialized in downstream rou…
Browse files Browse the repository at this point in the history
…ndtripper (#12879)

Co-authored-by: Kaviraj Kanagaraj <kavirajkanagaraj@gmail.com>
  • Loading branch information
grafanabot and kavirajk committed May 3, 2024
1 parent b45199f commit 7300af7
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion pkg/lokifrontend/frontend/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ func InitFrontend(cfg CombinedFrontendConfig, ring ring.ReadRing, limits v1.Limi
switch {
case cfg.DownstreamURL != "":
// If the user has specified a downstream Prometheus, then we should use that.
rt, err := NewDownstreamRoundTripper(cfg.DownstreamURL, http.DefaultTransport)
rt, err := NewDownstreamRoundTripper(cfg.DownstreamURL, http.DefaultTransport, codec)
return rt, nil, nil, err
case cfg.FrontendV2.SchedulerAddress != "" || ring != nil:
// If query-scheduler address is configured, use Frontend.
Expand Down
4 changes: 2 additions & 2 deletions pkg/lokifrontend/frontend/downstream_roundtripper.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,13 +20,13 @@ type downstreamRoundTripper struct {
codec queryrangebase.Codec
}

func NewDownstreamRoundTripper(downstreamURL string, transport http.RoundTripper) (queryrangebase.Handler, error) {
func NewDownstreamRoundTripper(downstreamURL string, transport http.RoundTripper, codec queryrangebase.Codec) (queryrangebase.Handler, error) {
u, err := url.Parse(downstreamURL)
if err != nil {
return nil, err
}

return &downstreamRoundTripper{downstreamURL: u, transport: transport}, nil
return &downstreamRoundTripper{downstreamURL: u, transport: transport, codec: codec}, nil
}

func (d downstreamRoundTripper) Do(ctx context.Context, req queryrangebase.Request) (queryrangebase.Response, error) {
Expand Down

0 comments on commit 7300af7

Please sign in to comment.