NewStream implements drpc.Conn's NewStream method with tracing information injected into the context.
(ctx context.Context, rpc string, enc drpc.Encoding)
| 42 | |
| 43 | // NewStream implements drpc.Conn's NewStream method with tracing information injected into the context. |
| 44 | func (c *DRPCConn) NewStream(ctx context.Context, rpc string, enc drpc.Encoding) (_ drpc.Stream, err error) { |
| 45 | return c.Conn.NewStream(c.addMetadata(ctx), rpc, enc) |
| 46 | } |
| 47 | |
| 48 | // addMetadata propagates the headers into a map that we inject into drpc metadata so they are |
| 49 | // sent across the wire for the server to get. |