Searched refs:insertDataRequest (Results 1 – 3 of 3) sorted by relevance
173 close(value.(chan *insertDataRequest))208 …p.getMetricBatcher(metricName) <- &insertDataRequest{metric: metricName, data: data, finished: wor…271 func (p *pgxDispatcher) getMetricBatcher(metric string) chan<- *insertDataRequest {279 c := make(chan *insertDataRequest, MetricBatcherChannelCap)286 ch := batcher.(chan *insertDataRequest)291 type insertDataRequest struct { struct298 func (idr *insertDataRequest) reportResult(err error) { argument
127 input chan *insertDataRequest, argument136 firstReq *insertDataRequest141 addReq := func(req *insertDataRequest, buf *pendingBuffer) {
81 func (p *pendingBuffer) addReq(req *insertDataRequest) {