type google.golang.org/grpc/resolver.Address
52 uses
google.golang.org/grpc/resolver (current package)
resolver.go#L97: type Address struct {
resolver.go#L159: Addresses []Address
resolver.go#L190: NewAddress(addresses []Address)
google.golang.org/grpc
balancer_conn_wrappers.go#L131: func (ccb *ccBalancerWrapper) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
balancer_conn_wrappers.go#L196: func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) {
clientconn.go#L578: func (cc *ClientConn) maybeApplyDefaultServiceConfig(addrs []resolver.Address) {
clientconn.go#L718: func (cc *ClientConn) newAddrConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L832: func (ac *addrConn) tryUpdateAddrs(addrs []resolver.Address) bool {
clientconn.go#L908: func (cc *ClientConn) applyServiceConfigAndBalancer(sc *ServiceConfig, addrs []resolver.Address) {
clientconn.go#L1054: curAddr resolver.Address // The current address.
clientconn.go#L1055: addrs []resolver.Address // All addresses that the resolver resolved to.
clientconn.go#L1191: func (ac *addrConn) tryAllAddrs(addrs []resolver.Address, connectDeadline time.Time) (transport.ClientTransport, resolver.Address, *grpcsync.Event, error) {
clientconn.go#L1197: return nil, resolver.Address{}, nil, errConnClosing
clientconn.go#L1223: return nil, resolver.Address{}, nil, firstConnErr
clientconn.go#L1229: func (ac *addrConn) createTransport(addr resolver.Address, copts transport.ConnectOptions, connectDeadline time.Time) (transport.ClientTransport, *grpcsync.Event, error) {
clientconn.go#L1425: ac.curAddr = resolver.Address{}
resolver_conn_wrapper.go#L160: func (ccr *ccResolverWrapper) NewAddress(addrs []resolver.Address) {
google.golang.org/grpc/balancer
balancer.go#L104: UpdateAddresses([]resolver.Address)
balancer.go#L142: NewSubConn([]resolver.Address, NewSubConnOptions) (SubConn, error)
google.golang.org/grpc/balancer/base
balancer.go#L44: subConns: make(map[resolver.Address]balancer.SubConn),
balancer.go#L67: subConns map[resolver.Address]balancer.SubConn
balancer.go#L102: addrsSet := make(map[resolver.Address]struct{})
balancer.go#L107: 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
grpclb.go#L143: subConns: make(map[resolver.Address]balancer.SubConn),
grpclb.go#L204: backendAddrs []resolver.Address
grpclb.go#L209: backendAddrsWithoutMetadata []resolver.Address
grpclb.go#L212: subConns map[resolver.Address]balancer.SubConn // Used to new/remove SubConn.
grpclb.go#L223: resolvedBackendAddrs []resolver.Address
grpclb.go#L417: var remoteBalancerAddrs, backendAddrs []resolver.Address
grpclb_remote_balancer.go#L65: var backendAddrs []resolver.Address
grpclb_remote_balancer.go#L79: addr := resolver.Address{
grpclb_remote_balancer.go#L99: func (lb *lbBalancer) refreshSubConns(backendAddrs []resolver.Address, fallback bool, pickFirst bool) {
grpclb_remote_balancer.go#L163: addrsSet := make(map[resolver.Address]struct{})
grpclb_remote_balancer.go#L173: sc, err := lb.cc.NewSubConn([]resolver.Address{addr}, opts)
grpclb_util.go#L103: subConnCache map[resolver.Address]*subConnCacheEntry
grpclb_util.go#L104: subConnToAddr map[balancer.SubConn]resolver.Address
grpclb_util.go#L118: subConnCache: make(map[resolver.Address]*subConnCacheEntry),
grpclb_util.go#L119: subConnToAddr: make(map[balancer.SubConn]resolver.Address),
grpclb_util.go#L123: func (ccc *lbCacheClientConn) NewSubConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (balancer.SubConn, error) {
google.golang.org/grpc/balancer/grpclb/state
state.go#L36: BalancerAddresses []resolver.Address
google.golang.org/grpc/internal/resolver/dns
dns_resolver.go#L118: addr := []resolver.Address{{Addr: ipAddr + ":" + port}}
dns_resolver.go#L230: func (d *dnsResolver) lookupSRV() ([]resolver.Address, error) {
dns_resolver.go#L234: var newAddrs []resolver.Address
dns_resolver.go#L257: newAddrs = append(newAddrs, resolver.Address{Addr: addr, ServerName: s.Target})
dns_resolver.go#L308: func (d *dnsResolver) lookupHost() ([]resolver.Address, error) {
dns_resolver.go#L309: var newAddrs []resolver.Address
dns_resolver.go#L321: newAddrs = append(newAddrs, resolver.Address{Addr: addr})
google.golang.org/grpc/internal/resolver/passthrough
passthrough.go#L48: r.cc.UpdateState(resolver.State{Addresses: []resolver.Address{{Addr: r.target.Endpoint}}})
google.golang.org/grpc/internal/transport
http2_client.go#L166: func newHTTP2Client(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onPrefaceReceipt func(), onGoAway func(GoAwayReason), onClose func()) (_ *http2Client, err error) {
transport.go#L576: func NewClientTransport(connectCtx, ctx context.Context, addr resolver.Address, opts ConnectOptions, onPrefaceReceipt func(), onGoAway func(GoAwayReason), onClose func()) (ClientTransport, error) {
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |