reportErrorToPipeline sends errors back up the query frontend http pipeline
(err error)
| 102 | |
| 103 | // reportErrorToPipeline sends errors back up the query frontend http pipeline |
| 104 | func (b *requestBatch) reportErrorToPipeline(err error) { |
| 105 | for _, r := range b.pipelineRequests { |
| 106 | r.err <- err |
| 107 | } |
| 108 | } |
| 109 | |
| 110 | // reportResultsToPipeline sends errors back up the query frontend http pipeline |
| 111 | func (b *requestBatch) reportResultsToPipeline(responses []*httpgrpc.HTTPResponse) error { |
no outgoing calls