| 2873 | } |
| 2874 | |
| 2875 | type ingesterPushStreamClient struct { |
| 2876 | grpc.ClientStream |
| 2877 | } |
| 2878 | |
| 2879 | func (x *ingesterPushStreamClient) Send(m *cortexpb.StreamWriteRequest) error { |
| 2880 | return x.ClientStream.SendMsg(m) |
nothing calls this directly
no outgoing calls
no test coverage detected