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

Function LookupPartition

dialer.go:409–411  ·  view source on GitHub ↗

LookupPartition is a convenience wrapper for DefaultDialer.LookupPartition.

(ctx context.Context, network string, address string, topic string, partition int)

Source from the content-addressed store, hash-verified

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) {
410 return DefaultDialer.LookupPartition(ctx, network, address, topic, partition)
411}
412
413// LookupPartitions is a convenience wrapper for DefaultDialer.LookupPartitions.
414func LookupPartitions(ctx context.Context, network string, address string, topic string) ([]Partition, error) {

Callers

nothing calls this directly

Calls 1

LookupPartitionMethod · 0.80

Tested by

no test coverage detected