type google.golang.org/grpc.ClientConn
69 uses
google.golang.org/grpc (current package)
balancer_wrapper.go#L65: cc *ClientConn
balancer_wrapper.go#L84: 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#L185: func NewClient(target string, opts ...DialOption) (conn *ClientConn, err error) {
clientconn.go#L186: cc := &ClientConn{
clientconn.go#L265: func Dial(target string, opts ...DialOption) (*ClientConn, error) {
clientconn.go#L280: func DialContext(ctx context.Context, target string, opts ...DialOption) (conn *ClientConn, err error) {
clientconn.go#L364: func (cc *ClientConn) addTraceEvent(msg string) {
clientconn.go#L378: type idler ClientConn
clientconn.go#L381: (*ClientConn)(i).enterIdleMode()
clientconn.go#L388: (*ClientConn)(i).exitIdleMode()
clientconn.go#L394: func (cc *ClientConn) exitIdleMode() error {
clientconn.go#L426: func (cc *ClientConn) initIdleStateLocked() {
clientconn.go#L439: func (cc *ClientConn) enterIdleMode() {
clientconn.go#L482: func (cc *ClientConn) validateTransportCredentials() error {
clientconn.go#L513: func (cc *ClientConn) channelzRegistration(target string) {
clientconn.go#L520: func chainUnaryClientInterceptors(cc *ClientConn) {
clientconn.go#L533: chainedInt = func(ctx context.Context, method string, req, reply any, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error {
clientconn.go#L545: return func(ctx context.Context, method string, req, reply any, cc *ClientConn, opts ...CallOption) error {
clientconn.go#L551: func chainStreamClientInterceptors(cc *ClientConn) {
clientconn.go#L564: chainedInt = func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error) {
clientconn.go#L576: return func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
clientconn.go#L655: var _ ClientConnInterface = (*ClientConn)(nil)
clientconn.go#L669: type ClientConn struct {
clientconn.go#L712: func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
clientconn.go#L726: func (cc *ClientConn) GetState() connectivity.State {
clientconn.go#L738: func (cc *ClientConn) Connect() {
clientconn.go#L759: func (cc *ClientConn) waitForResolvedAddrs(ctx context.Context) (bool, error) {
clientconn.go#L785: internal.SubscribeToConnectivityStateChanges = func(cc *ClientConn, s grpcsync.Subscriber) func() {
clientconn.go#L788: internal.EnterIdleModeForTesting = func(cc *ClientConn) {
clientconn.go#L791: internal.ExitIdleModeForTesting = func(cc *ClientConn) {
clientconn.go#L796: func (cc *ClientConn) maybeApplyDefaultServiceConfig() {
clientconn.go#L808: func (cc *ClientConn) updateResolverStateAndUnlock(s resolver.State, err error) error {
clientconn.go#L880: func (cc *ClientConn) applyFailingLBLocked(sc *serviceconfig.ParseResult) {
clientconn.go#L903: func (cc *ClientConn) newAddrConnLocked(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L939: func (cc *ClientConn) removeAddrConn(ac *addrConn, err error) {
clientconn.go#L951: func (cc *ClientConn) Target() string {
clientconn.go#L962: func (cc *ClientConn) CanonicalTarget() string {
clientconn.go#L966: func (cc *ClientConn) incrCallsStarted() {
clientconn.go#L971: func (cc *ClientConn) incrCallsSucceeded() {
clientconn.go#L975: func (cc *ClientConn) incrCallsFailed() {
clientconn.go#L1087: func (cc *ClientConn) getServerName(addr resolver.Address) string {
clientconn.go#L1119: func (cc *ClientConn) GetMethodConfig(method string) MethodConfig {
clientconn.go#L1126: func (cc *ClientConn) healthCheckConfig() *healthCheckConfig {
clientconn.go#L1135: func (cc *ClientConn) applyServiceConfigAndBalancer(sc *ServiceConfig, configSelector iresolver.ConfigSelector) {
clientconn.go#L1158: func (cc *ClientConn) resolveNow(o resolver.ResolveNowOptions) {
clientconn.go#L1164: func (cc *ClientConn) resolveNowLocked(o resolver.ResolveNowOptions) {
clientconn.go#L1181: func (cc *ClientConn) ResetConnectBackoff() {
clientconn.go#L1191: func (cc *ClientConn) Close() error {
clientconn.go#L1246: cc *ClientConn
clientconn.go#L1808: func (cc *ClientConn) getResolver(scheme string) resolver.Builder {
clientconn.go#L1817: func (cc *ClientConn) updateConnectionError(err error) {
clientconn.go#L1823: func (cc *ClientConn) connectionError() error {
clientconn.go#L1836: func (cc *ClientConn) initParsedTargetAndResolverBuilder() error {
clientconn.go#L1955: 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#L167: func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L179: func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L188: func endOfClientStream(cc *ClientConn, err error, opts ...CallOption) {
stream.go#L204: func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L286: 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#L578: cc *ClientConn