Method QueryStream

integration/grpc_server_test.go:34–39

(req *ingester_client.QueryRequest, streamServer ingester_client.Ingester_QueryStreamServer)

}

func (m mockGprcServer) QueryStream(req *ingester_client.QueryRequest, streamServer ingester_client.Ingester_QueryStreamServer) error {
	md, _ := metadata.FromIncomingContext(streamServer.Context())
	i, _ := strconv.Atoi(md["i"][0])
	defer req.Free()
	return streamServer.Send(createStreamResponse(i))
}

func (m mockGprcServer) PushStream(srv ingester_client.Ingester_PushStreamServer) error {
	for {