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

Method dialTimeout

transport.go:191–196  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

189}
190
191func (t *Transport) dialTimeout() time.Duration {
192 if t.DialTimeout > 0 {
193 return t.DialTimeout
194 }
195 return 5 * time.Second
196}
197
198func (t *Transport) idleTimeout() time.Duration {
199 if t.IdleTimeout > 0 {

Callers 1

grabPoolMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected