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

Function Dial

dialer.go:389–391  ·  view source on GitHub ↗

Dial is a convenience wrapper for DefaultDialer.Dial.

(network string, address string)

Source from the content-addressed store, hash-verified

387
388// Dial is a convenience wrapper for DefaultDialer.Dial.
389func Dial(network string, address string) (*Conn, error) {
390 return DefaultDialer.Dial(network, address)
391}
392
393// DialContext is a convenience wrapper for DefaultDialer.DialContext.
394func DialContext(ctx context.Context, network string, address string) (*Conn, error) {

Callers 6

createTopicFunction · 0.85
deleteTopicFunction · 0.85
TestCloseLeavesGroupFunction · 0.85
TestConnCreateTopicsFunction · 0.85

Calls 1

DialMethod · 0.45

Tested by 6

createTopicFunction · 0.68
deleteTopicFunction · 0.68
TestCloseLeavesGroupFunction · 0.68
TestConnCreateTopicsFunction · 0.68