MCPcopy
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
198func (t *Transport) idleTimeout() time.Duration {
199 if t.IdleTimeout > 0 {
200 return t.IdleTimeout
201 }
202 return 30 * time.Second
203}
204
205func (t *Transport) metadataTTL() time.Duration {
206 if t.MetadataTTL > 0 {

Callers 1

grabPoolMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected