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

Interface RoundTripper

transport.go:39–46  ·  transport.go::RoundTripper

RoundTripper is an interface implemented by types which support interacting with kafka brokers.

Source from the content-addressed store, hash-verified

37// RoundTripper is an interface implemented by types which support interacting
38// with kafka brokers.
39type 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//

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