type google.golang.org/grpc/resolver.Address
107 uses
google.golang.org/grpc/resolver (current package)
map.go#L28: addr Address
map.go#L56: m map[Address]addressMapEntryList[T]
map.go#L59: func toMapKey(addr *Address) Address {
map.go#L60: return Address{Addr: addr.Addr, ServerName: addr.ServerName}
map.go#L74: return &AddressMapV2[T]{m: make(map[Address]addressMapEntryList[T])}
map.go#L79: func (l addressMapEntryList[T]) find(addr Address) int {
map.go#L91: func (a *AddressMapV2[T]) Get(addr Address) (value T, ok bool) {
map.go#L101: func (a *AddressMapV2[T]) Set(addr Address, value T) {
map.go#L112: func (a *AddressMapV2[T]) Delete(addr Address) {
map.go#L138: func (a *AddressMapV2[T]) Keys() []Address {
map.go#L139: ret := make([]Address, 0, a.Len())
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#L187: Addresses []Address
resolver.go#L205: Addresses []Address
resolver.go#L252: NewAddress(addresses []Address)
google.golang.org/grpc
balancer_wrapper.go#L39: setConnectedAddress = internal.SetConnectedAddress.(func(*balancer.SubConnState, resolver.Address))
balancer_wrapper.go#L181: func (ccb *ccBalancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
balancer_wrapper.go#L216: func (ccb *ccBalancerWrapper) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address) {
balancer_wrapper.go#L308: func (acbw *acBalancerWrapper) updateState(s connectivity.State, curAddr resolver.Address, err error) {
balancer_wrapper.go#L349: func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) {
clientconn.go#L838: func copyAddresses(in []resolver.Address) []resolver.Address {
clientconn.go#L839: out := make([]resolver.Address, len(in))
clientconn.go#L847: func (cc *ClientConn) newAddrConnLocked(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L950: func equalAddressIgnoringBalAttributes(a, b *resolver.Address) bool {
clientconn.go#L956: func equalAddressesIgnoringBalAttributes(a, b []resolver.Address) bool {
clientconn.go#L957: return slices.EqualFunc(a, b, func(a, b resolver.Address) bool { return equalAddressIgnoringBalAttributes(&a, &b) })
clientconn.go#L962: func (ac *addrConn) updateAddrs(addrs []resolver.Address) {
clientconn.go#L1031: func (cc *ClientConn) getServerName(addr resolver.Address) string {
clientconn.go#L1206: curAddr resolver.Address // The current address.
clientconn.go#L1207: addrs []resolver.Address // All addresses that the resolver resolved to.
clientconn.go#L1326: func (ac *addrConn) tryAllAddrs(ctx context.Context, addrs []resolver.Address, connectDeadline time.Time) error {
clientconn.go#L1364: func (ac *addrConn) createTransport(ctx context.Context, addr resolver.Address, copts transport.ConnectOptions, connectDeadline time.Time) error {
clientconn.go#L1551: ac.curAddr = resolver.Address{}
resolver_wrapper.go#L162: func (ccr *ccResolverWrapper) NewAddress(addrs []resolver.Address) {
resolver_wrapper.go#L213: func addressesToEndpoints(addrs []resolver.Address) []resolver.Endpoint {
resolver_wrapper.go#L216: 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)
subconn.go#L116: connectedAddress resolver.Address
subconn.go#L121: func connectedAddress(scs SubConnState) resolver.Address {
subconn.go#L126: func setConnectedAddress(scs *SubConnState, addr 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#L144: var addrs []resolver.Address
pickfirst.go#L171: addrs = append([]resolver.Address{}, addrs...)
google.golang.org/grpc/balancer/pickfirst/pickfirstleaf
pickfirstleaf.go#L158: addr resolver.Address
pickfirstleaf.go#L168: func (b *pickfirstBalancer) newSCData(addr resolver.Address) (*scData, error) {
pickfirstleaf.go#L174: sc, err := b.cc.NewSubConn([]resolver.Address{addr}, balancer.NewSubConnOptions{
pickfirstleaf.go#L261: var newAddrs []resolver.Address
pickfirstleaf.go#L285: newAddrs = append([]resolver.Address{}, newAddrs...)
pickfirstleaf.go#L376: func deDupAddresses(addrs []resolver.Address) []resolver.Address {
pickfirstleaf.go#L378: retAddrs := []resolver.Address{}
pickfirstleaf.go#L400: func interleaveAddresses(addrs []resolver.Address) []resolver.Address {
pickfirstleaf.go#L401: familyAddrsMap := map[ipAddrFamily][]resolver.Address{}
pickfirstleaf.go#L411: interleavedAddrs := make([]resolver.Address, 0, len(addrs))
pickfirstleaf.go#L462: func (b *pickfirstBalancer) reconcileSubConnsLocked(newAddrs []resolver.Address) {
pickfirstleaf.go#L836: addresses []resolver.Address
pickfirstleaf.go#L860: func (al *addressList) currentAddress() resolver.Address {
pickfirstleaf.go#L862: return resolver.Address{}
pickfirstleaf.go#L871: func (al *addressList) updateAddrs(addrs []resolver.Address) {
pickfirstleaf.go#L878: func (al *addressList) seekTo(needle resolver.Address) bool {
pickfirstleaf.go#L903: func equalAddressIgnoringBalAttributes(a, b *resolver.Address) bool {
google.golang.org/grpc/internal/balancer/gracefulswitch
gracefulswitch.go#L360: func (bw *balancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
gracefulswitch.go#L401: 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#L58: proxyAddrs []resolver.Address // resolved proxy addresses; empty if no proxy is configured
delegatingresolver.go#L135: Addresses: []resolver.Address{{Addr: target.Endpoint()}},
delegatingresolver.go#L136: Endpoints: []resolver.Endpoint{{Addresses: []resolver.Address{{Addr: target.Endpoint()}}}},
delegatingresolver.go#L205: func skipProxy(address resolver.Address) bool {
delegatingresolver.go#L250: var proxyAddr resolver.Address
delegatingresolver.go#L254: proxyAddr = resolver.Address{Addr: r.proxyURL.Host}
delegatingresolver.go#L256: var addresses []resolver.Address
delegatingresolver.go#L273: var addrs []resolver.Address
delegatingresolver.go#L314: r.proxyAddrs = make([]resolver.Address, 0, len(state.Endpoints))
delegatingresolver.go#L321: r.proxyAddrs = []resolver.Address{} // ensure proxyAddrs is non-nil to indicate an update has been received
delegatingresolver.go#L419: 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#L240: func (d *dnsResolver) lookupSRV(ctx context.Context) ([]resolver.Address, error) {
dns_resolver.go#L246: var newAddrs []resolver.Address
dns_resolver.go#L269: newAddrs = append(newAddrs, resolver.Address{Addr: addr, ServerName: s.Target})
dns_resolver.go#L318: func (d *dnsResolver) lookupHost(ctx context.Context) ([]resolver.Address, error) {
dns_resolver.go#L324: newAddrs := make([]resolver.Address, 0, len(addrs))
dns_resolver.go#L331: newAddrs = append(newAddrs, resolver.Address{Addr: 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#L78: address resolver.Address
http2_client.go#L157: func dial(ctx context.Context, fn func(context.Context, string) (net.Conn, error), addr resolver.Address, grpcUA string) (net.Conn, error) {
http2_client.go#L206: func NewHTTP2Client(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onClose func(GoAwayReason)) (_ 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) {