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

Function DialPartition

dialer.go:404–406  ·  view source on GitHub ↗

DialPartition is a convenience wrapper for DefaultDialer.DialPartition.

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

Source from the content-addressed store, hash-verified

402
403// DialPartition is a convenience wrapper for DefaultDialer.DialPartition.
404func DialPartition(ctx context.Context, network string, address string, partition Partition) (*Conn, error) {
405 return DefaultDialer.DialPartition(ctx, network, address, partition)
406}
407
408// LookupPartition is a convenience wrapper for DefaultDialer.LookupPartition.
409func LookupPartition(ctx context.Context, network string, address string, topic string, partition int) (Partition, error) {

Callers

nothing calls this directly

Calls 1

DialPartitionMethod · 0.80

Tested by

no test coverage detected