type google.golang.org/grpc.Server
55 uses
google.golang.org/grpc (current package)
server.go#L100: type Server struct {
server.go#L462: func (s *Server) serverWorker(ch chan *serverWorkerData) {
server.go#L479: func (s *Server) initServerWorkers() {
server.go#L487: func (s *Server) stopServerWorkers() {
server.go#L495: func NewServer(opt ...ServerOption) *Server {
server.go#L500: s := &Server{
server.go#L529: func (s *Server) printf(format string, a ...interface{}) {
server.go#L537: func (s *Server) errorf(format string, a ...interface{}) {
server.go#L559: func (s *Server) RegisterService(sd *ServiceDesc, ss interface{}) {
server.go#L570: func (s *Server) register(sd *ServiceDesc, ss interface{}) {
server.go#L616: func (s *Server) GetServiceInfo() map[string]ServiceInfo {
server.go#L647: func (s *Server) useTransportAuthenticator(rawConn net.Conn) (net.Conn, credentials.AuthInfo, error) {
server.go#L680: func (s *Server) Serve(lis net.Listener) error {
server.go#L770: func (s *Server) handleRawConn(rawConn net.Conn) {
server.go#L809: func (s *Server) newHTTP2Transport(c net.Conn, authInfo credentials.AuthInfo) transport.ServerTransport {
server.go#L838: func (s *Server) serveStreams(st transport.ServerTransport) {
server.go#L872: var _ http.Handler = (*Server)(nil)
server.go#L898: func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request) {
server.go#L913: func (s *Server) traceInfo(st transport.ServerTransport, stream *transport.Stream) (trInfo *traceInfo) {
server.go#L935: func (s *Server) addConn(st transport.ServerTransport) bool {
server.go#L951: func (s *Server) removeConn(st transport.ServerTransport) {
server.go#L960: func (s *Server) channelzMetric() *channelz.ServerInternalMetric {
server.go#L969: func (s *Server) incrCallsStarted() {
server.go#L974: func (s *Server) incrCallsSucceeded() {
server.go#L978: func (s *Server) incrCallsFailed() {
server.go#L982: func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{}, cp Compressor, opts *transport.Options, comp encoding.Compressor) error {
server.go#L1006: func chainUnaryServerInterceptors(s *Server) {
server.go#L1039: func (s *Server) processUnaryRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
server.go#L1287: func chainStreamServerInterceptors(s *Server) {
server.go#L1320: func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
server.go#L1487: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.Stream, trInfo *traceInfo) {
server.go#L1593: func (s *Server) Stop() {
server.go#L1637: func (s *Server) GracefulStop() {
server.go#L1682: func (s *Server) getCodec(contentSubtype string) baseCodec {
server.go#L1750: s *Server
google.golang.org/grpc/balancer/grpclb/grpc_lb_v1
load_balancer.pb.go#L715: func RegisterLoadBalancerServer(s *grpc.Server, srv LoadBalancerServer) {
google.golang.org/grpc/credentials/alts/internal/proto/grpc_gcp
handshaker.pb.go#L1062: func RegisterHandshakerServiceServer(s *grpc.Server, srv HandshakerServiceServer) {
google.golang.org/genproto/googleapis/cloud/secretmanager/v1
service.pb.go#L1899: func RegisterSecretManagerServiceServer(s *grpc.Server, srv SecretManagerServiceServer) {
google.golang.org/genproto/googleapis/cloud/tasks/v2
cloudtasks.pb.go#L2228: func RegisterCloudTasksServer(s *grpc.Server, srv CloudTasksServer) {
google.golang.org/genproto/googleapis/container/v1
cluster_service.pb.go#L12131: func RegisterClusterManagerServer(s *grpc.Server, srv ClusterManagerServer) {
google.golang.org/genproto/googleapis/devtools/clouderrorreporting/v1beta1
error_group_service.pb.go#L387: func RegisterErrorGroupServiceServer(s *grpc.Server, srv ErrorGroupServiceServer) {
error_stats_service.pb.go#L1667: func RegisterErrorStatsServiceServer(s *grpc.Server, srv ErrorStatsServiceServer) {
report_errors_service.pb.go#L517: func RegisterReportErrorsServiceServer(s *grpc.Server, srv ReportErrorsServiceServer) {
google.golang.org/genproto/googleapis/devtools/cloudprofiler/v2
profiler.pb.go#L899: func RegisterProfilerServiceServer(s *grpc.Server, srv ProfilerServiceServer) {
google.golang.org/genproto/googleapis/devtools/cloudtrace/v2
tracing.pb.go#L321: func RegisterTraceServiceServer(s *grpc.Server, srv TraceServiceServer) {
google.golang.org/genproto/googleapis/iam/v1
iam_policy.pb.go#L575: func RegisterIAMPolicyServer(s *grpc.Server, srv IAMPolicyServer) {
google.golang.org/genproto/googleapis/logging/v2
logging.pb.go#L1375: func RegisterLoggingServiceV2Server(s *grpc.Server, srv LoggingServiceV2Server) {
logging_config.pb.go#L3519: func RegisterConfigServiceV2Server(s *grpc.Server, srv ConfigServiceV2Server) {
logging_metrics.pb.go#L1168: func RegisterMetricsServiceV2Server(s *grpc.Server, srv MetricsServiceV2Server) {
google.golang.org/genproto/googleapis/monitoring/v3
alert_service.pb.go#L888: func RegisterAlertPolicyServiceServer(s *grpc.Server, srv AlertPolicyServiceServer) {
group_service.pb.go#L1175: func RegisterGroupServiceServer(s *grpc.Server, srv GroupServiceServer) {
metric_service.pb.go#L2173: func RegisterMetricServiceServer(s *grpc.Server, srv MetricServiceServer) {
notification_service.pb.go#L1726: func RegisterNotificationChannelServiceServer(s *grpc.Server, srv NotificationChannelServiceServer) {
service_service.pb.go#L1562: func RegisterServiceMonitoringServiceServer(s *grpc.Server, srv ServiceMonitoringServiceServer) {
uptime_service.pb.go#L1072: func RegisterUptimeCheckServiceServer(s *grpc.Server, srv UptimeCheckServiceServer) {
 |
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. |