Function
SendLabelNamesStream
(s Ingester_LabelNamesStreamServer, l *LabelNamesStreamResponse)
Source from the content-addressed store, hash-verified
| 25 | } |
| 26 | |
| 27 | func SendLabelNamesStream(s Ingester_LabelNamesStreamServer, l *LabelNamesStreamResponse) error { |
| 28 | return sendWithContextErrChecking(s.Context(), func() error { |
| 29 | return s.Send(l) |
| 30 | }) |
| 31 | } |
| 32 | |
| 33 | func SendAsBatchToStream(totalItems int, streamBatchSize int, fn func(start, end int) error) error { |
| 34 | for i := 0; i < totalItems; i += streamBatchSize { |