MCPcopy
hub / github.com/segmentio/kafka-go / RoundTrip

Method RoundTrip

transport.go:45–45  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

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.

Callers 5

roundTripMethod · 0.65
saslHandshakeRoundTripFunction · 0.65
roundTripMethod · 0.65
partitionsMethod · 0.65

Implementers 3

Transporttransport.go
mockRoundTripperdescribegroups_test.go
Connprotocol/conn.go

Calls

no outgoing calls

Tested by

no test coverage detected