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

Struct brokerResolver

resolver.go:37–39  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

35}
36
37type brokerResolver struct {
38 *net.Resolver
39}
40
41func (r brokerResolver) LookupBrokerIPAddr(ctx context.Context, broker Broker) ([]net.IPAddr, error) {
42 ipAddrs, err := r.LookupIPAddr(ctx, broker.Host)

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected