type google.golang.org/grpc/resolver.Address
64 uses
google.golang.org/grpc/resolver (current package)
map.go#L22: addr Address
map.go#L44: m map[Address]addressMapEntryList
map.go#L47: func toMapKey(addr *Address) Address {
map.go#L48: return Address{Addr: addr.Addr, ServerName: addr.ServerName}
map.go#L55: return &AddressMap{m: make(map[Address]addressMapEntryList)}
map.go#L60: func (l addressMapEntryList) find(addr Address) int {
map.go#L72: func (a *AddressMap) Get(addr Address) (value interface{}, ok bool) {
map.go#L82: func (a *AddressMap) Set(addr Address, value interface{}) {
map.go#L93: func (a *AddressMap) Delete(addr Address) {
map.go#L119: func (a *AddressMap) Keys() []Address {
map.go#L120: ret := make([]Address, 0, a.Len())
resolver.go#L104: type Address struct {
resolver.go#L144: func (a Address) Equal(o Address) bool {
resolver.go#L152: func (a Address) String() string {
resolver.go#L185: Addresses []Address
resolver.go#L216: NewAddress(addresses []Address)
google.golang.org/grpc
balancer_conn_wrappers.go#L183: var addrs []resolver.Address
balancer_conn_wrappers.go#L302: func (ccb *ccBalancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
balancer_conn_wrappers.go#L336: func (ccb *ccBalancerWrapper) UpdateAddresses(sc balancer.SubConn, addrs []resolver.Address) {
balancer_conn_wrappers.go#L370: func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) {
clientconn.go#L593: func (cc *ClientConn) maybeApplyDefaultServiceConfig(addrs []resolver.Address) {
clientconn.go#L702: func (cc *ClientConn) newAddrConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L813: func equalAddresses(a, b []resolver.Address) bool {
clientconn.go#L843: func (ac *addrConn) tryUpdateAddrs(addrs []resolver.Address) bool {
clientconn.go#L889: func (cc *ClientConn) getServerName(addr resolver.Address) string {
clientconn.go#L944: func (cc *ClientConn) applyServiceConfigAndBalancer(sc *ServiceConfig, configSelector iresolver.ConfigSelector, addrs []resolver.Address) {
clientconn.go#L1087: curAddr resolver.Address // The current address.
clientconn.go#L1088: addrs []resolver.Address // All addresses that the resolver resolved to.
clientconn.go#L1198: func (ac *addrConn) tryAllAddrs(addrs []resolver.Address, connectDeadline time.Time) error {
clientconn.go#L1236: func (ac *addrConn) createTransport(addr resolver.Address, copts transport.ConnectOptions, connectDeadline time.Time) error {
clientconn.go#L1419: ac.curAddr = resolver.Address{}
resolver_conn_wrapper.go#L119: func (ccr *ccResolverWrapper) NewAddress(addrs []resolver.Address) {
google.golang.org/grpc/balancer
balancer.go#L110: UpdateAddresses([]resolver.Address)
balancer.go#L153: NewSubConn([]resolver.Address, NewSubConnOptions) (SubConn, error)
balancer.go#L163: UpdateAddresses(SubConn, []resolver.Address)
google.golang.org/grpc/balancer/base
balancer.go#L108: sc, err := b.cc.NewSubConn([]resolver.Address{a}, balancer.NewSubConnOptions{HealthCheckEnabled: b.config.HealthCheck})
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/internal
xds_handshake_cluster.go#L30: func SetXDSHandshakeClusterName(addr resolver.Address, clusterName string) resolver.Address {
google.golang.org/grpc/internal/balancer/gracefulswitch
gracefulswitch.go#L330: func (bw *balancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
gracefulswitch.go#L372: 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/resolver/dns
dns_resolver.go#L126: addr := []resolver.Address{{Addr: ipAddr + ":" + port}}
dns_resolver.go#L247: func (d *dnsResolver) lookupSRV() ([]resolver.Address, error) {
dns_resolver.go#L251: var newAddrs []resolver.Address
dns_resolver.go#L274: newAddrs = append(newAddrs, resolver.Address{Addr: addr, ServerName: s.Target})
dns_resolver.go#L320: func (d *dnsResolver) lookupHost() ([]resolver.Address, error) {
dns_resolver.go#L326: newAddrs := make([]resolver.Address, 0, len(addrs))
dns_resolver.go#L333: 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#L70: address resolver.Address
http2_client.go#L150: func dial(ctx context.Context, fn func(context.Context, string) (net.Conn, error), addr resolver.Address, useProxy bool, grpcUA string) (net.Conn, error) {
http2_client.go#L199: func newHTTP2Client(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onClose func(GoAwayReason)) (_ *http2Client, err error) {
transport.go#L586: func NewClientTransport(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onClose func(GoAwayReason)) (ClientTransport, 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) {