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

Method transport

client.go:118–123  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

116}
117
118func (c *Client) transport() RoundTripper {
119 if c.Transport != nil {
120 return c.Transport
121 }
122 return DefaultTransport
123}
124
125func (c *Client) timeout(ctx context.Context, defaultTimeout time.Duration) time.Duration {
126 timeout := c.Timeout

Callers 2

roundTripMethod · 0.95
partitionsMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected