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

Method dial

transport.go:184–189  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

182}
183
184func (t *Transport) dial() func(context.Context, string, string) (net.Conn, error) {
185 if t.Dial != nil {
186 return t.Dial
187 }
188 return defaultDialer.DialContext
189}
190
191func (t *Transport) dialTimeout() time.Duration {
192 if t.DialTimeout > 0 {

Callers 2

grabPoolMethod · 0.95
connectMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected