Skip to content

Commit 01e0f91

Browse files
committed
Remove now-gone remote.WriteResponse usage
1 parent 5300416 commit 01e0f91

File tree

2 files changed

+1
-18
lines changed

2 files changed

+1
-18
lines changed

ingester_client.go

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -77,8 +77,7 @@ func (c *IngesterClient) Append(ctx context.Context, samples []*model.Sample) er
7777
req.Timeseries = append(req.Timeseries, ts)
7878
}
7979

80-
var resp remote.WriteResponse
81-
return c.doRequest(ctx, "/push", req, &resp, true)
80+
return c.doRequest(ctx, "/push", req, nil, true)
8281
}
8382

8483
// Query implements Querier.

server.go

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -126,22 +126,6 @@ func AppenderHandler(appender SampleAppender) http.Handler {
126126
http.Error(w, err.Error(), http.StatusInternalServerError)
127127
return
128128
}
129-
130-
respBuf, err := proto.Marshal(&remote.WriteResponse{})
131-
if err != nil {
132-
log.Errorf("marshall err: %v", err)
133-
http.Error(w, err.Error(), http.StatusInternalServerError)
134-
return
135-
}
136-
137-
if _, err := snappy.NewWriter(w).Write(respBuf); err != nil {
138-
log.Errorf("write err: %v", err)
139-
http.Error(w, err.Error(), http.StatusInternalServerError)
140-
return
141-
}
142-
143-
w.Header().Add("Content-Encoding", "snappy")
144-
w.WriteHeader(http.StatusOK)
145129
})
146130
}
147131

0 commit comments

Comments
 (0)