| 28 | ) |
| 29 | |
| 30 | type mockGprcServer struct { |
| 31 | ingester_client.IngesterServer |
| 32 | } |
| 33 | |
| 34 | func (m mockGprcServer) QueryStream(req *ingester_client.QueryRequest, streamServer ingester_client.Ingester_QueryStreamServer) error { |
| 35 | md, _ := metadata.FromIncomingContext(streamServer.Context()) |
nothing calls this directly
no outgoing calls
no test coverage detected