type google.golang.org/grpc/internal/transport.ServerStream
60 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L228: func (ht *serverHandlerTransport) writeStatus(s *ServerStream, st *status.Status) error {
handler_server.go#L292: func (ht *serverHandlerTransport) writePendingHeaders(s *ServerStream) {
handler_server.go#L299: func (ht *serverHandlerTransport) writeCommonHeaders(s *ServerStream) {
handler_server.go#L320: func (ht *serverHandlerTransport) writeCustomHeaders(s *ServerStream) {
handler_server.go#L336: func (ht *serverHandlerTransport) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
handler_server.go#L360: func (ht *serverHandlerTransport) writeHeader(s *ServerStream, md metadata.MD) error {
handler_server.go#L386: func (ht *serverHandlerTransport) adjustWindow(*ServerStream, uint32) {
handler_server.go#L389: func (ht *serverHandlerTransport) updateWindow(*ServerStream, uint32) {
handler_server.go#L392: func (ht *serverHandlerTransport) HandleStreams(ctx context.Context, startStream func(*ServerStream)) {
handler_server.go#L415: s := &ServerStream{
http2_server.go#L119: activeStreams map[uint32]*ServerStream
http2_server.go#L271: activeStreams: make(map[uint32]*ServerStream),
http2_server.go#L377: func (t *http2Server) operateHeaders(ctx context.Context, frame *http2.MetaHeadersFrame, handle func(*ServerStream)) error {
http2_server.go#L402: s := &ServerStream{
http2_server.go#L639: func (t *http2Server) HandleStreams(ctx context.Context, handle func(*ServerStream)) {
http2_server.go#L704: func (t *http2Server) getStream(f http2.Frame) (*ServerStream, bool) {
http2_server.go#L722: func (t *http2Server) adjustWindow(s *ServerStream, n uint32) {
http2_server.go#L732: func (t *http2Server) updateWindow(s *ServerStream, n uint32) {
http2_server.go#L1001: func (t *http2Server) streamContextErr(s *ServerStream) error {
http2_server.go#L1011: func (t *http2Server) writeHeader(s *ServerStream, md metadata.MD) error {
http2_server.go#L1040: func (t *http2Server) writeHeaderLocked(s *ServerStream) error {
http2_server.go#L1079: func (t *http2Server) writeStatus(s *ServerStream, st *status.Status) error {
http2_server.go#L1150: func (t *http2Server) write(s *ServerStream, hdr []byte, data mem.BufferSlice, _ *WriteOptions) error {
http2_server.go#L1307: func (t *http2Server) deleteStream(s *ServerStream, eosReceived bool) {
http2_server.go#L1328: func (t *http2Server) finishStream(s *ServerStream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
http2_server.go#L1352: func (t *http2Server) closeStream(s *ServerStream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
server_stream.go#L34: type ServerStream struct {
server_stream.go#L56: func (s *ServerStream) Read(n int) (mem.BufferSlice, error) {
server_stream.go#L65: func (s *ServerStream) SendHeader(md metadata.MD) error {
server_stream.go#L70: func (s *ServerStream) Write(hdr []byte, data mem.BufferSlice, opts *WriteOptions) error {
server_stream.go#L76: func (s *ServerStream) WriteStatus(st *status.Status) error {
server_stream.go#L81: func (s *ServerStream) isHeaderSent() bool {
server_stream.go#L87: func (s *ServerStream) updateHeaderSent() bool {
server_stream.go#L93: func (s *ServerStream) RecvCompress() string {
server_stream.go#L98: func (s *ServerStream) SendCompress() string {
server_stream.go#L107: func (s *ServerStream) ContentSubtype() string {
server_stream.go#L112: func (s *ServerStream) SetSendCompress(name string) error {
server_stream.go#L123: func (s *ServerStream) SetContext(ctx context.Context) {
server_stream.go#L129: func (s *ServerStream) ClientAdvertisedCompressors() []string {
server_stream.go#L140: func (s *ServerStream) Header() (metadata.MD, error) {
server_stream.go#L148: func (s *ServerStream) HeaderWireLength() int {
server_stream.go#L154: func (s *ServerStream) SetHeader(md metadata.MD) error {
server_stream.go#L170: func (s *ServerStream) SetTrailer(md metadata.MD) error {
server_stream.go#L183: func (s *ServerStream) requestRead(n int) {
server_stream.go#L187: func (s *ServerStream) updateWindow(n int) {
transport.go#L656: HandleStreams(context.Context, func(*ServerStream))
transport.go#L672: writeHeader(s *ServerStream, md metadata.MD) error
transport.go#L673: write(s *ServerStream, hdr []byte, data mem.BufferSlice, opts *WriteOptions) error
transport.go#L674: writeStatus(s *ServerStream, st *status.Status) error
transport.go#L676: adjustWindow(s *ServerStream, n uint32)
transport.go#L677: updateWindow(s *ServerStream, n uint32)
google.golang.org/grpc
server.go#L1072: st.HandleStreams(ctx, func(stream *transport.ServerStream) {
server.go#L1188: func (s *Server) sendResponse(ctx context.Context, stream *transport.ServerStream, msg any, cp Compressor, opts *transport.WriteOptions, comp encoding.Compressor) error {
server.go#L1260: func (s *Server) processUnaryRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, md *MethodDesc, trInfo *traceInfo) (err error) {
server.go#L1590: func (s *Server) processStreamingRPC(ctx context.Context, stream *transport.ServerStream, info *serviceInfo, sd *StreamDesc, trInfo *traceInfo) (err error) {
server.go#L1782: func (s *Server) handleMalformedMethodName(stream *transport.ServerStream, ti *traceInfo) {
server.go#L1800: func (s *Server) handleStream(t transport.ServerTransport, stream *transport.ServerStream) {
server.go#L2156: stream, ok := ServerTransportStreamFromContext(ctx).(*transport.ServerStream)
server.go#L2178: stream, ok := ServerTransportStreamFromContext(ctx).(*transport.ServerStream)
stream.go#L1634: s *transport.ServerStream