type google.golang.org/grpc.ClientConn

57 uses

	google.golang.org/grpc (current package)
		balancer_conn_wrappers.go#L52: 	cc *ClientConn
		balancer_conn_wrappers.go#L68: func newCCBalancerWrapper(cc *ClientConn, bopts balancer.BuildOptions) *ccBalancerWrapper {
		call.go#L29: func (cc *ClientConn) Invoke(ctx context.Context, method string, args, reply interface{}, opts ...CallOption) error {
		call.go#L59: func Invoke(ctx context.Context, method string, args, reply interface{}, cc *ClientConn, opts ...CallOption) error {
		call.go#L65: func invoke(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error {
		clientconn.go#L104: func Dial(target string, opts ...DialOption) (*ClientConn, error) {
		clientconn.go#L135: func DialContext(ctx context.Context, target string, opts ...DialOption) (conn *ClientConn, err error) {
		clientconn.go#L136: 	cc := &ClientConn{
		clientconn.go#L335: func chainUnaryClientInterceptors(cc *ClientConn) {
		clientconn.go#L348: 		chainedInt = func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error {
		clientconn.go#L360: 	return func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error {
		clientconn.go#L366: func chainStreamClientInterceptors(cc *ClientConn) {
		clientconn.go#L379: 		chainedInt = func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error) {
		clientconn.go#L391: 	return func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
		clientconn.go#L453: var _ ClientConnInterface = (*ClientConn)(nil)
		clientconn.go#L467: type ClientConn struct {
		clientconn.go#L510: func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
		clientconn.go#L529: func (cc *ClientConn) GetState() connectivity.State {
		clientconn.go#L541: func (cc *ClientConn) Connect() {
		clientconn.go#L545: func (cc *ClientConn) scWatcher() {
		clientconn.go#L567: func (cc *ClientConn) waitForResolvedAddrs(ctx context.Context) error {
		clientconn.go#L593: func (cc *ClientConn) maybeApplyDefaultServiceConfig(addrs []resolver.Address) {
		clientconn.go#L605: func (cc *ClientConn) updateResolverState(s resolver.State, err error) error {
		clientconn.go#L683: func (cc *ClientConn) applyFailingLB(sc *serviceconfig.ParseResult) {
		clientconn.go#L695: func (cc *ClientConn) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State, err error) {
		clientconn.go#L702: func (cc *ClientConn) newAddrConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
		clientconn.go#L740: func (cc *ClientConn) removeAddrConn(ac *addrConn, err error) {
		clientconn.go#L751: func (cc *ClientConn) channelzMetric() *channelz.ChannelInternalMetric {
		clientconn.go#L768: func (cc *ClientConn) Target() string {
		clientconn.go#L772: func (cc *ClientConn) incrCallsStarted() {
		clientconn.go#L777: func (cc *ClientConn) incrCallsSucceeded() {
		clientconn.go#L781: func (cc *ClientConn) incrCallsFailed() {
		clientconn.go#L889: func (cc *ClientConn) getServerName(addr resolver.Address) string {
		clientconn.go#L921: func (cc *ClientConn) GetMethodConfig(method string) MethodConfig {
		clientconn.go#L928: func (cc *ClientConn) healthCheckConfig() *healthCheckConfig {
		clientconn.go#L937: func (cc *ClientConn) getTransport(ctx context.Context, failfast bool, method string) (transport.ClientTransport, balancer.PickResult, error) {
		clientconn.go#L944: func (cc *ClientConn) applyServiceConfigAndBalancer(sc *ServiceConfig, configSelector iresolver.ConfigSelector, addrs []resolver.Address) {
		clientconn.go#L988: func (cc *ClientConn) resolveNow(o resolver.ResolveNowOptions) {
		clientconn.go#L1011: func (cc *ClientConn) ResetConnectBackoff() {
		clientconn.go#L1021: func (cc *ClientConn) Close() error {
		clientconn.go#L1075: 	cc     *ClientConn
		clientconn.go#L1516: 	cc *ClientConn
		clientconn.go#L1530: func (cc *ClientConn) getResolver(scheme string) resolver.Builder {
		clientconn.go#L1539: func (cc *ClientConn) updateConnectionError(err error) {
		clientconn.go#L1545: func (cc *ClientConn) connectionError() error {
		clientconn.go#L1551: func (cc *ClientConn) parseTargetAndFindResolver() (resolver.Builder, error) {
		interceptor.go#L26: type UnaryInvoker func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error
		interceptor.go#L43: type UnaryClientInterceptor func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error
		interceptor.go#L46: type Streamer func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error)
		interceptor.go#L63: type StreamClientInterceptor func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error)
		resolver_conn_wrapper.go#L37: 	cc         *ClientConn
		resolver_conn_wrapper.go#L48: func newCCResolverWrapper(cc *ClientConn, rb resolver.Builder) (*ccResolverWrapper, error) {
		stream.go#L154: func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
		stream.go#L166: func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
		stream.go#L170: func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
		stream.go#L231: func newClientStreamWithParams(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, mc serviceconfig.MethodConfig, onCommit, doneFunc func(), opts ...CallOption) (_ iresolver.ClientStream, err error) {
		stream.go#L502: 	cc       *ClientConn