RoundTripper is an interface implemented by types which support interacting with kafka brokers.
| 37 | // RoundTripper is an interface implemented by types which support interacting |
| 38 | // with kafka brokers. |
| 39 | type RoundTripper interface { |
| 40 | // RoundTrip sends a request to a kafka broker and returns the response that |
| 41 | // was received, or a non-nil error. |
| 42 | // |
| 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. |
| 49 | // |
no outgoing calls
no test coverage detected