type google.golang.org/grpc/internal/transport.ServerTransport
18 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L52: func NewServerHandlerTransport(w http.ResponseWriter, r *http.Request, stats []stats.Handler) (ServerTransport, error) {
http2_server.go#L141: func NewServerTransport(conn net.Conn, config *ServerConfig) (_ ServerTransport, err error) {
transport.go#L245: st ServerTransport // nil for client side Stream
transport.go#L685: type ServerTransport interface {
google.golang.org/grpc
server.go#L119: st transport.ServerTransport
server.go#L133: conns map[string]map[transport.ServerTransport]bool
server.go#L612: conns: make(map[string]map[transport.ServerTransport]bool),
server.go#L907: func (s *Server) newHTTP2Transport(c net.Conn) transport.ServerTransport {
server.go#L944: func (s *Server) serveStreams(st transport.ServerTransport) {
server.go#L1024: func (s *Server) traceInfo(st transport.ServerTransport, stream *transport.Stream) (trInfo *traceInfo) {
server.go#L1046: func (s *Server) addConn(addr string, st transport.ServerTransport) bool {
server.go#L1061: s.conns[addr] = make(map[transport.ServerTransport]bool)
server.go#L1067: func (s *Server) removeConn(addr string, st transport.ServerTransport) {
server.go#L1106: func (s *Server) sendResponse(t transport.ServerTransport, stream *transport.Stream, msg interface{}, cp Compressor, opts *transport.Options, comp encoding.Compressor) error {
server.go#L1167: func (s *Server) processUnaryRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
server.go#L1482: func (s *Server) processStreamingRPC(t transport.ServerTransport, stream *transport.Stream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
server.go#L1674: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.Stream, trInfo *traceInfo) {
stream.go#L1504: t transport.ServerTransport