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

Method metadataTTL

transport.go:205–210  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

203}
204
205func (t *Transport) metadataTTL() time.Duration {
206 if t.MetadataTTL > 0 {
207 return t.MetadataTTL
208 }
209 return 6 * time.Second
210}
211
212func (t *Transport) grabPool(addr net.Addr) *connPool {
213 k := networkAddress{

Callers 1

grabPoolMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected