Lines Matching defs:ClientConn

678 type ClientConn struct {  struct
679 	ctx    context.Context
680 	cancel context.CancelFunc
682 	target       string
683 	parsedTarget resolver.Target
684 	authority    string
685 	dopts        dialOptions
686 	csMgr        *connectivityStateManager
688 	balancerBuildOpts balancer.BuildOptions
689 	resolverWrapper   *ccResolverWrapper
690 	blockingpicker    *pickerWrapper
692 	mu    sync.RWMutex
693 	sc    ServiceConfig
694 	scRaw string
695 	conns map[*addrConn]struct{}
697 	mkp             keepalive.ClientParameters
698 	curBalancerName string
699 	preBalancerName string // previous balancer name.
700 	curAddresses    []resolver.Address
701 	balancerWrapper *ccBalancerWrapper
703 	channelzID          int64 // channelz unique identification number
704 	czmu                sync.RWMutex
705 	callsStarted        int64
706 	callsSucceeded      int64
707 	callsFailed         int64
708 	lastCallStartedTime time.Time
714 func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
729 func (cc *ClientConn) GetState() connectivity.State {
733 func (cc *ClientConn) scWatcher() {
752 func (cc *ClientConn) handleResolvedAddrs(addrs []resolver.Address, err error) {
814 func (cc *ClientConn) switchBalancer(name string) {
846 func (cc *ClientConn) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
861 func (cc *ClientConn) newAddrConn(addrs []resolver.Address) (*addrConn, error) {
884 func (cc *ClientConn) removeAddrConn(ac *addrConn, err error) {
897 func (cc *ClientConn) ChannelzMetric() *channelz.ChannelInternalMetric {
911 func (cc *ClientConn) incrCallsStarted() {
919 func (cc *ClientConn) incrCallsSucceeded() {
925 func (cc *ClientConn) incrCallsFailed() {
1003 func (cc *ClientConn) GetMethodConfig(method string) MethodConfig {
1015 …t(ctx context.Context, failfast bool) (transport.ClientTransport, func(balancer.DoneInfo), error) {
1025 func (cc *ClientConn) handleServiceConfig(js string) error {
1065 func (cc *ClientConn) resolveNow(o resolver.ResolveNowOption) {
1076 func (cc *ClientConn) Close() error {