type google.golang.org/grpc/resolver.Address
104 uses
google.golang.org/grpc/resolver (current package)
map.go#L29: addr Address
map.go#L57: m map[Address]addressMapEntryList[T]
map.go#L60: func toMapKey(addr *Address) Address {
map.go#L61: return Address{Addr: addr.Addr, ServerName: addr.ServerName}
map.go#L75: return &AddressMapV2[T]{m: make(map[Address]addressMapEntryList[T])}
map.go#L80: func (l addressMapEntryList[T]) find(addr Address) int {
map.go#L92: func (a *AddressMapV2[T]) Get(addr Address) (value T, ok bool) {
map.go#L102: func (a *AddressMapV2[T]) Set(addr Address, value T) {
map.go#L113: func (a *AddressMapV2[T]) Delete(addr Address) {
map.go#L140: func (a *AddressMapV2[T]) Keys() []Address {
map.go#L141: ret := make([]Address, 0, a.Len())
map.go#L163: func (a *AddressMapV2[T]) All() iter.Seq2[Address, T] {
map.go#L164: return func(yield func(Address, T) bool) {
resolver.go#L91: type Address struct {
resolver.go#L130: func (a Address) Equal(o Address) bool {
resolver.go#L138: func (a Address) String() string {
resolver.go#L188: Addresses []Address
resolver.go#L206: Addresses []Address
resolver.go#L253: NewAddress(addresses []Address)
google.golang.org/grpc
balancer_wrapper.go#L180: func (ccb *ccBalancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
balancer_wrapper.go#L215: func (ccb *ccBalancerWrapper) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address) {
balancer_wrapper.go#L345: func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) {
clientconn.go#L894: func copyAddresses(in []resolver.Address) []resolver.Address {
clientconn.go#L895: out := make([]resolver.Address, len(in))
clientconn.go#L903: func (cc *ClientConn) newAddrConnLocked(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L1006: func equalAddressIgnoringBalAttributes(a, b *resolver.Address) bool {
clientconn.go#L1012: func equalAddressesIgnoringBalAttributes(a, b []resolver.Address) bool {
clientconn.go#L1013: return slices.EqualFunc(a, b, func(a, b resolver.Address) bool { return equalAddressIgnoringBalAttributes(&a, &b) })
clientconn.go#L1018: func (ac *addrConn) updateAddrs(addrs []resolver.Address) {
clientconn.go#L1087: func (cc *ClientConn) getServerName(addr resolver.Address) string {
clientconn.go#L1262: curAddr resolver.Address // The current address.
clientconn.go#L1263: addrs []resolver.Address // All addresses that the resolver resolved to.
clientconn.go#L1414: labelsFunc, ok := internal.AddressToTelemetryLabels.(func(resolver.Address) map[string]string)
clientconn.go#L1452: func (ac *addrConn) tryAllAddrs(ctx context.Context, addrs []resolver.Address, connectDeadline time.Time) error {
clientconn.go#L1490: func (ac *addrConn) createTransport(ctx context.Context, addr resolver.Address, copts transport.ConnectOptions, connectDeadline time.Time) error {
clientconn.go#L1708: ac.curAddr = resolver.Address{}
resolver_wrapper.go#L163: func (ccr *ccResolverWrapper) NewAddress(addrs []resolver.Address) {
resolver_wrapper.go#L214: func addressesToEndpoints(addrs []resolver.Address) []resolver.Endpoint {
resolver_wrapper.go#L217: ep := resolver.Endpoint{Addresses: []resolver.Address{a}, Attributes: a.BalancerAttributes}
google.golang.org/grpc/balancer
balancer.go#L146: NewSubConn([]resolver.Address, NewSubConnOptions) (SubConn, error)
balancer.go#L161: UpdateAddresses(SubConn, []resolver.Address)
subconn.go#L62: UpdateAddresses([]resolver.Address)
google.golang.org/grpc/balancer/base
balancer.go#L113: sc, err := b.cc.NewSubConn([]resolver.Address{a}, opts)
base.go#L55: Address resolver.Address // the address used to create this SubConn
google.golang.org/grpc/balancer/grpclb/state
state.go#L36: BalancerAddresses []resolver.Address
google.golang.org/grpc/balancer/pickfirst
pickfirst.go#L157: addr resolver.Address
pickfirst.go#L167: func (b *pickfirstBalancer) newSCData(addr resolver.Address) (*scData, error) {
pickfirst.go#L173: sc, err := b.cc.NewSubConn([]resolver.Address{addr}, balancer.NewSubConnOptions{
pickfirst.go#L260: var newAddrs []resolver.Address
pickfirst.go#L318: newAddrs = append([]resolver.Address{}, newAddrs...)
pickfirst.go#L416: func deDupAddresses(addrs []resolver.Address) []resolver.Address {
pickfirst.go#L418: retAddrs := []resolver.Address{}
pickfirst.go#L441: func interleaveAddresses(addrs []resolver.Address) []resolver.Address {
pickfirst.go#L442: familyAddrsMap := map[ipAddrFamily][]resolver.Address{}
pickfirst.go#L452: interleavedAddrs := make([]resolver.Address, 0, len(addrs))
pickfirst.go#L503: func (b *pickfirstBalancer) reconcileSubConnsLocked(newAddrs []resolver.Address) {
pickfirst.go#L877: addresses []resolver.Address
pickfirst.go#L901: func (al *addressList) currentAddress() resolver.Address {
pickfirst.go#L903: return resolver.Address{}
pickfirst.go#L912: func (al *addressList) updateAddrs(addrs []resolver.Address) {
pickfirst.go#L919: func (al *addressList) seekTo(needle resolver.Address) bool {
pickfirst.go#L944: func equalAddressIgnoringBalAttributes(a, b *resolver.Address) bool {
google.golang.org/grpc/internal/balancer/gracefulswitch
gracefulswitch.go#L372: func (bw *balancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
gracefulswitch.go#L413: func (bw *balancerWrapper) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address) {
google.golang.org/grpc/internal/metadata
metadata.go#L61: func Get(addr resolver.Address) metadata.MD {
metadata.go#L74: func Set(addr resolver.Address, md metadata.MD) resolver.Address {
google.golang.org/grpc/internal/proxyattributes
proxyattributes.go#L41: func Set(addr resolver.Address, opts Options) resolver.Address {
proxyattributes.go#L49: func Get(addr resolver.Address) (Options, bool) {
google.golang.org/grpc/internal/resolver/delegatingresolver
delegatingresolver.go#L62: proxyAddrs []resolver.Address // resolved proxy addresses; empty if no proxy is configured
delegatingresolver.go#L147: Addresses: []resolver.Address{{Addr: addr}},
delegatingresolver.go#L148: Endpoints: []resolver.Endpoint{{Addresses: []resolver.Address{{Addr: addr}}}},
delegatingresolver.go#L255: func skipProxy(address resolver.Address) bool {
delegatingresolver.go#L300: var proxyAddr resolver.Address
delegatingresolver.go#L304: proxyAddr = resolver.Address{Addr: r.proxyURL.Host}
delegatingresolver.go#L306: var addresses []resolver.Address
delegatingresolver.go#L323: var addrs []resolver.Address
delegatingresolver.go#L364: r.proxyAddrs = make([]resolver.Address, 0, len(state.Endpoints))
delegatingresolver.go#L371: r.proxyAddrs = []resolver.Address{} // ensure proxyAddrs is non-nil to indicate an update has been received
delegatingresolver.go#L469: func (wcc *wrappingClientConn) NewAddress(addrs []resolver.Address) {
google.golang.org/grpc/internal/resolver/dns
dns_resolver.go#L127: addr := []resolver.Address{{Addr: ipAddr + ":" + port}}
dns_resolver.go#L243: func (d *dnsResolver) lookupSRV(ctx context.Context) ([]resolver.Address, error) {
dns_resolver.go#L249: var newAddrs []resolver.Address
dns_resolver.go#L272: newAddrs = append(newAddrs, resolver.Address{Addr: addr, ServerName: s.Target})
dns_resolver.go#L321: func (d *dnsResolver) lookupHost(ctx context.Context) ([]resolver.Address, error) {
dns_resolver.go#L327: newAddrs := make([]resolver.Address, 0, len(addrs))
dns_resolver.go#L334: newAddrs = append(newAddrs, resolver.Address{Addr: addr})
dns_resolver.go#L350: eps = append(eps, resolver.Endpoint{Addresses: []resolver.Address{addr}})
google.golang.org/grpc/internal/resolver/passthrough
passthrough.go#L55: r.cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: r.target.Endpoint()}}})
google.golang.org/grpc/internal/resolver/unix
unix.go#L50: addr := resolver.Address{Addr: endpoint}
unix.go#L56: cc.UpdateState(resolver.State{Addresses: []resolver.Address{networktype.Set(addr, "unix")}})
google.golang.org/grpc/internal/transport
http2_client.go#L80: address resolver.Address
http2_client.go#L161: func dial(ctx context.Context, fn func(context.Context, string) (net.Conn, error), addr resolver.Address, grpcUA string) (net.Conn, error) {
http2_client.go#L210: func NewHTTP2Client(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onClose OnCloseFunc) (_ ClientTransport, err error) {
proxy.go#L102: func proxyDial(ctx context.Context, addr resolver.Address, grpcUA string, opts proxyattributes.Options) (net.Conn, error) {
google.golang.org/grpc/internal/transport/networktype
networktype.go#L33: func Set(address resolver.Address, networkType string) resolver.Address {
networktype.go#L40: func Get(address resolver.Address) (string, bool) {