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

Function DialContext

dialer.go:394–396  ·  view source on GitHub ↗

DialContext is a convenience wrapper for DefaultDialer.DialContext.

(ctx context.Context, network string, address string)

Source from the content-addressed store, hash-verified

392
393// DialContext is a convenience wrapper for DefaultDialer.DialContext.
394func DialContext(ctx context.Context, network string, address string) (*Conn, error) {
395 return DefaultDialer.DialContext(ctx, network, address)
396}
397
398// DialLeader is a convenience wrapper for DefaultDialer.DialLeader.
399func DialLeader(ctx context.Context, network string, address string, topic string, partition int) (*Conn, error) {

Callers 1

TestConnCreateTopicsFunction · 0.85

Calls 1

DialContextMethod · 0.80

Tested by 1

TestConnCreateTopicsFunction · 0.68