Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
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
191
func
(t *Transport) dialTimeout() time.Duration {
192
if
t.DialTimeout > 0 {
193
return
t.DialTimeout
194
}
195
return
5 * time.Second
196
}
197
198
func
(t *Transport) idleTimeout() time.Duration {
199
if
t.IdleTimeout > 0 {
Callers
1
grabPool
Method · 0.95
Calls
no outgoing calls
Tested by
no test coverage detected