type google.golang.org/grpc.ClientConn
91 uses
google.golang.org/grpc (current package)
balancer_conn_wrappers.go#L43: cc *ClientConn
balancer_conn_wrappers.go#L53: func newCCBalancerWrapper(cc *ClientConn, b balancer.Builder, 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#L103: func Dial(target string, opts ...DialOption) (*ClientConn, error) {
clientconn.go#L123: func DialContext(ctx context.Context, target string, opts ...DialOption) (conn *ClientConn, err error) {
clientconn.go#L124: cc := &ClientConn{
clientconn.go#L345: func chainUnaryClientInterceptors(cc *ClientConn) {
clientconn.go#L358: chainedInt = func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error {
clientconn.go#L370: return func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error {
clientconn.go#L376: func chainStreamClientInterceptors(cc *ClientConn) {
clientconn.go#L389: chainedInt = func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error) {
clientconn.go#L401: return func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
clientconn.go#L463: var _ ClientConnInterface = (*ClientConn)(nil)
clientconn.go#L477: type ClientConn struct {
clientconn.go#L512: func (cc *ClientConn) WaitForStateChange(ctx context.Context, sourceState connectivity.State) bool {
clientconn.go#L527: func (cc *ClientConn) GetState() connectivity.State {
clientconn.go#L531: func (cc *ClientConn) scWatcher() {
clientconn.go#L552: func (cc *ClientConn) waitForResolvedAddrs(ctx context.Context) error {
clientconn.go#L578: func (cc *ClientConn) maybeApplyDefaultServiceConfig(addrs []resolver.Address) {
clientconn.go#L590: func (cc *ClientConn) updateResolverState(s resolver.State, err error) error {
clientconn.go#L676: func (cc *ClientConn) switchBalancer(name string) {
clientconn.go#L703: func (cc *ClientConn) handleSubConnStateChange(sc balancer.SubConn, s connectivity.State, err error) {
clientconn.go#L718: func (cc *ClientConn) newAddrConn(addrs []resolver.Address, opts balancer.NewSubConnOptions) (*addrConn, error) {
clientconn.go#L753: func (cc *ClientConn) removeAddrConn(ac *addrConn, err error) {
clientconn.go#L764: func (cc *ClientConn) channelzMetric() *channelz.ChannelInternalMetric {
clientconn.go#L777: func (cc *ClientConn) Target() string {
clientconn.go#L781: func (cc *ClientConn) incrCallsStarted() {
clientconn.go#L786: func (cc *ClientConn) incrCallsSucceeded() {
clientconn.go#L790: func (cc *ClientConn) incrCallsFailed() {
clientconn.go#L871: func (cc *ClientConn) GetMethodConfig(method string) MethodConfig {
clientconn.go#L888: func (cc *ClientConn) healthCheckConfig() *healthCheckConfig {
clientconn.go#L897: func (cc *ClientConn) getTransport(ctx context.Context, failfast bool, method string) (transport.ClientTransport, func(balancer.DoneInfo), error) {
clientconn.go#L908: func (cc *ClientConn) applyServiceConfigAndBalancer(sc *ServiceConfig, addrs []resolver.Address) {
clientconn.go#L958: func (cc *ClientConn) resolveNow(o resolver.ResolveNowOptions) {
clientconn.go#L978: func (cc *ClientConn) ResetConnectBackoff() {
clientconn.go#L988: func (cc *ClientConn) Close() error {
clientconn.go#L1042: cc *ClientConn
clientconn.go#L1523: cc *ClientConn
clientconn.go#L1537: func (cc *ClientConn) getResolver(scheme string) resolver.Builder {
clientconn.go#L1546: func (cc *ClientConn) updateConnectionError(err error) {
clientconn.go#L1552: func (cc *ClientConn) connectionError() error {
interceptor.go#L26: type UnaryInvoker func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, opts ...CallOption) error
interceptor.go#L31: type UnaryClientInterceptor func(ctx context.Context, method string, req, reply interface{}, cc *ClientConn, invoker UnaryInvoker, opts ...CallOption) error
interceptor.go#L34: type Streamer func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error)
interceptor.go#L39: type StreamClientInterceptor func(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, streamer Streamer, opts ...CallOption) (ClientStream, error)
resolver_conn_wrapper.go#L38: cc *ClientConn
resolver_conn_wrapper.go#L50: func newCCResolverWrapper(cc *ClientConn, rb resolver.Builder) (*ccResolverWrapper, error) {
stream.go#L142: func (cc *ClientConn) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L154: func NewClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (ClientStream, error) {
stream.go#L158: func newClientStream(ctx context.Context, desc *StreamDesc, cc *ClientConn, method string, opts ...CallOption) (_ ClientStream, err error) {
stream.go#L394: cc *ClientConn
google.golang.org/grpc/balancer/grpclb
grpclb.go#L66: cc *grpc.ClientConn
grpclb_remote_balancer.go#L206: cc *grpc.ClientConn
google.golang.org/grpc/credentials/alts/internal/handshaker
handshaker.go#L160: func NewClientHandshaker(ctx context.Context, conn *grpc.ClientConn, c net.Conn, opts *ClientHandshakerOptions) (core.Handshaker, error) {
handshaker.go#L176: func NewServerHandshaker(ctx context.Context, conn *grpc.ClientConn, c net.Conn, opts *ServerHandshakerOptions) (core.Handshaker, error) {
google.golang.org/grpc/credentials/alts/internal/handshaker/service
service.go#L35: hsConnMap = make(map[string]*grpc.ClientConn)
service.go#L43: func Dial(hsAddress string) (*grpc.ClientConn, error) {
google.golang.org/api/internal
conn_pool.go#L16: Conn() *grpc.ClientConn
settings.go#L35: GRPCConn *grpc.ClientConn
google.golang.org/api/option
option.go#L123: func WithGRPCConn(conn *grpc.ClientConn) ClientOption {
option.go#L127: type withGRPCConn struct{ conn *grpc.ClientConn }
google.golang.org/api/transport
dial.go#L27: func DialGRPC(ctx context.Context, opts ...option.ClientOption) (*grpc.ClientConn, error) {
dial.go#L34: func DialGRPCInsecure(ctx context.Context, opts ...option.ClientOption) (*grpc.ClientConn, error) {
google.golang.org/api/transport/grpc
dial.go#L38: func Dial(ctx context.Context, opts ...option.ClientOption) (*grpc.ClientConn, error) {
dial.go#L56: func DialInsecure(ctx context.Context, opts ...option.ClientOption) (*grpc.ClientConn, error) {
dial.go#L108: func dial(ctx context.Context, insecure bool, o *internal.DialSettings) (*grpc.ClientConn, error) {
pool.go#L24: *grpc.ClientConn
pool.go#L27: func (p *singleConnPool) Conn() *grpc.ClientConn { return p.ClientConn }
pool.go#L31: conns []*grpc.ClientConn
pool.go#L40: func (p *roundRobinConnPool) Conn() *grpc.ClientConn {
cloud.google.com/go/cloudtasks/apiv2
cloud_tasks_client.go#L238: func (c *Client) Connection() *grpc.ClientConn {
cloud.google.com/go/container/apiv1
cluster_manager_client.go#L277: func (c *ClusterManagerClient) Connection() *grpc.ClientConn {
cloud.google.com/go/errorreporting/apiv1beta1
error_group_client.go#L140: func (c *ErrorGroupClient) Connection() *grpc.ClientConn {
error_stats_client.go#L156: func (c *ErrorStatsClient) Connection() *grpc.ClientConn {
report_errors_client.go#L115: func (c *ReportErrorsClient) Connection() *grpc.ClientConn {
cloud.google.com/go/logging/apiv2
config_client.go#L93: conn *grpc.ClientConn
config_client.go#L125: func (c *ConfigClient) Connection() *grpc.ClientConn {
logging_client.go#L84: conn *grpc.ClientConn
logging_client.go#L115: func (c *Client) Connection() *grpc.ClientConn {
metrics_client.go#L83: conn *grpc.ClientConn
metrics_client.go#L114: func (c *MetricsClient) Connection() *grpc.ClientConn {
cloud.google.com/go/monitoring/apiv3
alert_policy_client.go#L158: func (c *AlertPolicyClient) Connection() *grpc.ClientConn {
group_client.go#L186: func (c *GroupClient) Connection() *grpc.ClientConn {
metric_client.go#L192: func (c *MetricClient) Connection() *grpc.ClientConn {
notification_channel_client.go#L205: func (c *NotificationChannelClient) Connection() *grpc.ClientConn {
service_monitoring_client.go#L196: func (c *ServiceMonitoringClient) Connection() *grpc.ClientConn {
uptime_check_client.go#L170: func (c *UptimeCheckClient) Connection() *grpc.ClientConn {
cloud.google.com/go/secretmanager/apiv1
secret_manager_client.go#L165: func (c *Client) Connection() *grpc.ClientConn {
cloud.google.com/go/trace/apiv2
trace_client.go#L133: func (c *Client) Connection() *grpc.ClientConn {
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |