google.golang.org/grpc.ClientConn.dopts (field)

90 uses

	google.golang.org/grpc (current package)
		call.go#L32: 	opts = combine(cc.dopts.callOptions, opts)
		call.go#L34: 	if cc.dopts.unaryInt != nil {
		call.go#L35: 		return cc.dopts.unaryInt(ctx, method, args, reply, cc, invoke, opts...)
		clientconn.go#L128: 		dopts:             defaultDialOptions(),
		clientconn.go#L137: 		opt.apply(&cc.dopts)
		clientconn.go#L150: 		if cc.dopts.channelzParentID != 0 {
		clientconn.go#L151: 			cc.channelzID = channelz.RegisterChannel(&channelzChannel{cc}, cc.dopts.channelzParentID, target)
		clientconn.go#L167: 	if !cc.dopts.insecure {
		clientconn.go#L168: 		if cc.dopts.copts.TransportCredentials == nil && cc.dopts.copts.CredsBundle == nil {
		clientconn.go#L171: 		if cc.dopts.copts.TransportCredentials != nil && cc.dopts.copts.CredsBundle != nil {
		clientconn.go#L175: 		if cc.dopts.copts.TransportCredentials != nil || cc.dopts.copts.CredsBundle != nil {
		clientconn.go#L178: 		for _, cd := range cc.dopts.copts.PerRPCCredentials {
		clientconn.go#L185: 	if cc.dopts.defaultServiceConfigRawJSON != nil {
		clientconn.go#L186: 		scpr := parseServiceConfig(*cc.dopts.defaultServiceConfigRawJSON)
		clientconn.go#L190: 		cc.dopts.defaultServiceConfig, _ = scpr.Config.(*ServiceConfig)
		clientconn.go#L192: 	cc.mkp = cc.dopts.copts.KeepaliveParams
		clientconn.go#L194: 	if cc.dopts.copts.Dialer == nil {
		clientconn.go#L195: 		cc.dopts.copts.Dialer = func(ctx context.Context, addr string) (net.Conn, error) {
		clientconn.go#L199: 		if cc.dopts.withProxy {
		clientconn.go#L200: 			cc.dopts.copts.Dialer = newProxyDialer(cc.dopts.copts.Dialer)
		clientconn.go#L204: 	if cc.dopts.copts.UserAgent != "" {
		clientconn.go#L205: 		cc.dopts.copts.UserAgent += " " + grpcUA
		clientconn.go#L207: 		cc.dopts.copts.UserAgent = grpcUA
		clientconn.go#L210: 	if cc.dopts.timeout > 0 {
		clientconn.go#L212: 		ctx, cancel = context.WithTimeout(ctx, cc.dopts.timeout)
		clientconn.go#L221: 			case err == nil || !cc.dopts.returnLastError:
		clientconn.go#L231: 	if cc.dopts.scChan != nil {
		clientconn.go#L234: 		case sc, ok := <-cc.dopts.scChan:
		clientconn.go#L242: 	if cc.dopts.bs == nil {
		clientconn.go#L243: 		cc.dopts.bs = backoff.DefaultExponential
		clientconn.go#L266: 	creds := cc.dopts.copts.TransportCredentials
		clientconn.go#L269: 	} else if cc.dopts.insecure && cc.dopts.authority != "" {
		clientconn.go#L270: 		cc.authority = cc.dopts.authority
		clientconn.go#L279: 	if cc.dopts.scChan != nil && !scSet {
		clientconn.go#L282: 		case sc, ok := <-cc.dopts.scChan:
		clientconn.go#L290: 	if cc.dopts.scChan != nil {
		clientconn.go#L295: 	if creds := cc.dopts.copts.TransportCredentials; creds != nil {
		clientconn.go#L300: 		CredsBundle:      cc.dopts.copts.CredsBundle,
		clientconn.go#L301: 		Dialer:           cc.dopts.copts.Dialer,
		clientconn.go#L316: 	if cc.dopts.block {
		clientconn.go#L321: 			} else if cc.dopts.copts.FailOnNonTempDialError && s == connectivity.TransientFailure {
		clientconn.go#L333: 				if err = cc.connectionError(); err != nil && cc.dopts.returnLastError {
		clientconn.go#L346: 	interceptors := cc.dopts.chainUnaryInts
		clientconn.go#L349: 	if cc.dopts.unaryInt != nil {
		clientconn.go#L350: 		interceptors = append([]UnaryClientInterceptor{cc.dopts.unaryInt}, interceptors...)
		clientconn.go#L362: 	cc.dopts.unaryInt = chainedInt
		clientconn.go#L377: 	interceptors := cc.dopts.chainStreamInts
		clientconn.go#L380: 	if cc.dopts.streamInt != nil {
		clientconn.go#L381: 		interceptors = append([]StreamClientInterceptor{cc.dopts.streamInt}, interceptors...)
		clientconn.go#L393: 	cc.dopts.streamInt = chainedInt
		clientconn.go#L484: 	dopts        dialOptions
		clientconn.go#L534: 		case sc, ok := <-cc.dopts.scChan:
		clientconn.go#L583: 	if cc.dopts.defaultServiceConfig != nil {
		clientconn.go#L584: 		cc.applyServiceConfigAndBalancer(cc.dopts.defaultServiceConfig, addrs)
		clientconn.go#L617: 	if cc.dopts.disableServiceConfig || s.ServiceConfig == nil {
		clientconn.go#L642: 	if cc.dopts.balancerBuilder == nil && cc.sc != nil && cc.sc.lbConfig != nil {
		clientconn.go#L682: 	if cc.dopts.balancerBuilder != nil {
		clientconn.go#L724: 		dopts:        cc.dopts,
		clientconn.go#L927: 	if cc.dopts.balancerBuilder == nil {
		clientconn.go#L953: 		cc.curBalancerName = cc.dopts.balancerBuilder.Name()
		clientconn.go#L954: 		cc.balancerWrapper = newCCBalancerWrapper(cc, cc.dopts.balancerBuilder, cc.balancerBuildOpts)
		clientconn.go#L1023: 		if cc.dopts.channelzParentID != 0 {
		clientconn.go#L1325: 	if ac.cc.dopts.disableHealthCheck {
		clientconn.go#L1335: 	healthCheckFunc := ac.cc.dopts.healthCheckFunc
		clientconn.go#L1367: 		err := ac.cc.dopts.healthCheckFunc(ctx, newStream, setConnectivityState, healthCheckConfig.ServiceName)
		clientconn.go#L1538: 	for _, rb := range cc.dopts.resolvers {
		resolver_conn_wrapper.go#L57: 	if creds := cc.dopts.copts.TransportCredentials; creds != nil {
		resolver_conn_wrapper.go#L61: 		DisableServiceConfig: cc.dopts.disableServiceConfig,
		resolver_conn_wrapper.go#L63: 		CredsBundle:          cc.dopts.copts.CredsBundle,
		resolver_conn_wrapper.go#L64: 		Dialer:               cc.dopts.copts.Dialer,
		resolver_conn_wrapper.go#L118: 			t := time.NewTimer(ccr.cc.dopts.resolveNowBackoff(i))
		resolver_conn_wrapper.go#L179: 	if ccr.cc.dopts.disableServiceConfig {
		stream.go#L145: 	opts = combine(cc.dopts.callOptions, opts)
		stream.go#L147: 	if cc.dopts.streamInt != nil {
		stream.go#L148: 		return cc.dopts.streamInt(ctx, desc, cc, method, newClientStream, opts...)
		stream.go#L226: 	} else if cc.dopts.cp != nil {
		stream.go#L227: 		callHdr.SendCompress = cc.dopts.cp.Type()
		stream.go#L228: 		cp = cc.dopts.cp
		stream.go#L248: 	sh := cc.dopts.copts.StatsHandler
		stream.go#L276: 	if !cc.dopts.disableRetry {
		stream.go#L334: 		dc:           cs.cc.dopts.dc,
		stream.go#L506: 	if cs.cc.dopts.disableRetry {
		stream.go#L1070: 	} else if ac.cc.dopts.cp != nil {
		stream.go#L1071: 		callHdr.SendCompress = ac.cc.dopts.cp.Type()
		stream.go#L1072: 		cp = ac.cc.dopts.cp