type google.golang.org/grpc.ClientConn
68 uses
google.golang.org/grpc (current package)
balancer_wrapper.go#L66: cc *ClientConn
balancer_wrapper.go#L85: func newCCBalancerWrapper(cc *ClientConn) *ccBalancerWrapper {
call.go#L29: func (cc *ClientConn) Invoke(ctx context.Context, method string, args, reply any, opts ...CallOption) error {
call.go#L59: func Invoke(ctx context.Context, method string, args, reply any, cc *ClientConn, opts ...CallOption) error {
call.go#L65: func invoke(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error {
clientconn.go#L145: func NewClient(target string, opts ...DialOption) (conn *ClientConn, err error) {
clientconn.go#L146: cc := &ClientConn{
clientconn.go#L224: func Dial(target string, opts ...DialOption) (*ClientConn, error) {
clientconn.go#L239: func DialContext(ctx context.Context, target string, opts ...DialOption) (conn *ClientConn, err error) {
clientconn.go#L322: func (cc *ClientConn) addTraceEvent(msg string) {
clientconn.go#L336: type idler ClientConn
clientconn.go#L339: (*ClientConn)(i).enterIdleMode()
clientconn.go#L343: return (*ClientConn)(i).exitIdleMode()
clientconn.go#L349: func (cc *ClientConn) exitIdleMode() (err error) {
clientconn.go#L369: func (cc *ClientConn) initIdleStateLocked() {
clientconn.go#L382: func (cc *ClientConn) enterIdleMode() {
clientconn.go#L425: func (cc *ClientConn) validateTransportCredentials() error {
clientconn.go#L456: func (cc *ClientConn) channelzRegistration(target string) {
clientconn.go#L463: func chainUnaryClientInterceptors(cc *ClientConn) {
clientconn.go#L476: chainedInt = func(ctx context.Context, method string, req, reply any, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error {
clientconn.go#L488: return func(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error {
clientconn.go#L494: func chainStreamClientInterceptors(cc *ClientConn) {
clientconn.go#L507: chainedInt = func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error) {
clientconn.go#L519: return func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
clientconn.go#L598: var _ ClientConnInterface = (*ClientConn)(nil)
clientconn.go#L612: type ClientConn struct {
clientconn.go#L654: func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
clientconn.go#L668: func (cc *ClientConn) GetState() connectivity.State {
clientconn.go#L680: func (cc *ClientConn) Connect() {
clientconn.go#L703: func (cc *ClientConn) waitForResolvedAddrs(ctx context.Context) (bool, error) {
clientconn.go#L729: internal.SubscribeToConnectivityStateChanges = func(cc *ClientConn, s grpcsync.Subscriber) func() {
clientconn.go#L732: internal.EnterIdleModeForTesting = func(cc *ClientConn) {
clientconn.go#L735: internal.ExitIdleModeForTesting = func(cc *ClientConn) error {
clientconn.go#L740: func (cc *ClientConn) maybeApplyDefaultServiceConfig() {
clientconn.go#L752: func (cc *ClientConn) updateResolverStateAndUnlock(s resolver.State, err error) error {
clientconn.go#L824: func (cc *ClientConn) applyFailingLBLocked(sc *serviceconfig.ParseResult) {
clientconn.go#L847: func (cc *ClientConn) newAddrConnLocked(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L882: func (cc *ClientConn) removeAddrConn(ac *addrConn, err error) {
clientconn.go#L894: func (cc *ClientConn) Target() string {
clientconn.go#L905: func (cc *ClientConn) CanonicalTarget() string {
clientconn.go#L909: func (cc *ClientConn) incrCallsStarted() {
clientconn.go#L914: func (cc *ClientConn) incrCallsSucceeded() {
clientconn.go#L918: func (cc *ClientConn) incrCallsFailed() {
clientconn.go#L1031: func (cc *ClientConn) getServerName(addr resolver.Address) string {
clientconn.go#L1063: func (cc *ClientConn) GetMethodConfig(method string) MethodConfig {
clientconn.go#L1070: func (cc *ClientConn) healthCheckConfig() *healthCheckConfig {
clientconn.go#L1079: func (cc *ClientConn) applyServiceConfigAndBalancer(sc *ServiceConfig, configSelector iresolver.ConfigSelector) {
clientconn.go#L1102: func (cc *ClientConn) resolveNow(o resolver.ResolveNowOptions) {
clientconn.go#L1108: func (cc *ClientConn) resolveNowLocked(o resolver.ResolveNowOptions) {
clientconn.go#L1125: func (cc *ClientConn) ResetConnectBackoff() {
clientconn.go#L1135: func (cc *ClientConn) Close() error {
clientconn.go#L1190: cc *ClientConn
clientconn.go#L1651: func (cc *ClientConn) getResolver(scheme string) resolver.Builder {
clientconn.go#L1660: func (cc *ClientConn) updateConnectionError(err error) {
clientconn.go#L1666: func (cc *ClientConn) connectionError() error {
clientconn.go#L1679: func (cc *ClientConn) initParsedTargetAndResolverBuilder() error {
clientconn.go#L1798: func (cc *ClientConn) initAuthority() error {
interceptor.go#L26: type UnaryInvoker func(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error
interceptor.go#L43: type UnaryClientInterceptor func(ctx context.Context, method string, req, reply any, 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_wrapper.go#L39: cc *ClientConn
resolver_wrapper.go#L55: func newCCResolverWrapper(cc *ClientConn) *ccResolverWrapper {
stream.go#L164: func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L176: func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L180: func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L261: func newClientStreamWithParams(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, mc serviceconfig.MethodConfig, onCommit, doneFunc func(), nameResolutionDelayed bool, opts ...CallOption) (_ iresolver.ClientStream, err error) {
stream.go#L541: cc *ClientConn