Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/segmentio/kafka-go
/ idleTimeout
Method
idleTimeout
transport.go:198–203 ·
view source on GitHub ↗
()
Source
from the content-addressed store, hash-verified
196
}
197
198
func
(t *Transport) idleTimeout() time.Duration {
199
if
t.IdleTimeout > 0 {
200
return
t.IdleTimeout
201
}
202
return
30 * time.Second
203
}
204
205
func
(t *Transport) metadataTTL() time.Duration {
206
if
t.MetadataTTL > 0 {
Callers
1
grabPool
Method · 0.95
Calls
no outgoing calls
Tested by
no test coverage detected