Invoke implements drpc.Conn's Invoke method with tracing information injected into the context.
(ctx context.Context, rpc string, enc drpc.Encoding, in drpc.Message, out drpc.Message)
| 37 | |
| 38 | // Invoke implements drpc.Conn's Invoke method with tracing information injected into the context. |
| 39 | func (c *DRPCConn) Invoke(ctx context.Context, rpc string, enc drpc.Encoding, in drpc.Message, out drpc.Message) (err error) { |
| 40 | return c.Conn.Invoke(c.addMetadata(ctx), rpc, enc, in, out) |
| 41 | } |
| 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) { |