Skip to content

Commit dc74000

Browse files
committed
Fix Ingester Proto
Signed-off-by: Alan Protasio <[email protected]>
1 parent ab5144e commit dc74000

File tree

3 files changed

+85
-330
lines changed

3 files changed

+85
-330
lines changed

pkg/ingester/client/cortex_util.go

Lines changed: 0 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -12,14 +12,6 @@ func SendQueryStream(s Ingester_QueryStreamServer, m *QueryStreamResponse) error
1212
})
1313
}
1414

15-
// SendTimeSeriesChunk wraps the stream's Send() checking if the context is done
16-
// before calling Send().
17-
func SendTimeSeriesChunk(s Ingester_TransferChunksClient, m *TimeSeriesChunk) error {
18-
return sendWithContextErrChecking(s.Context(), func() error {
19-
return s.Send(m)
20-
})
21-
}
22-
2315
func SendMetricsForLabelMatchersStream(s Ingester_MetricsForLabelMatchersStreamServer, m *MetricsForLabelMatchersStreamResponse) error {
2416
return sendWithContextErrChecking(s.Context(), func() error {
2517
return s.Send(m)

0 commit comments

Comments
 (0)