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

Method LookupBrokerIPAddr

resolver.go:27–27  ·  view source on GitHub ↗

Returns the IP addresses of the broker passed as argument.

(ctx context.Context, broker Broker)

Source from the content-addressed store, hash-verified

25type BrokerResolver interface {
26 // Returns the IP addresses of the broker passed as argument.
27 LookupBrokerIPAddr(ctx context.Context, broker Broker) ([]net.IPAddr, error)
28}
29
30// NewBrokerResolver constructs a Resolver from r.

Callers 1

grabConnOrConnectMethod · 0.65

Implementers 1

brokerResolverresolver.go

Calls

no outgoing calls

Tested by

no test coverage detected