RoundTrip sends a request to a kafka broker and returns the response that was received, or a non-nil error. The context passed as first argument can be used to asynchronnously abort the call if needed.
(context.Context, net.Addr, Request)
| 43 | // The context passed as first argument can be used to asynchronnously abort |
| 44 | // the call if needed. |
| 45 | RoundTrip(context.Context, net.Addr, Request) (Response, error) |
| 46 | } |
| 47 | |
| 48 | // Transport is an implementation of the RoundTripper interface. |
no outgoing calls
no test coverage detected