type google.golang.org/grpc/internal/transport.Stream
80 uses
google.golang.org/grpc/internal/transport (current package)
handler_server.go#L199: func (ht *serverHandlerTransport) WriteStatus(s *Stream, st *status.Status) error {
handler_server.go#L260: func (ht *serverHandlerTransport) writePendingHeaders(s *Stream) {
handler_server.go#L267: func (ht *serverHandlerTransport) writeCommonHeaders(s *Stream) {
handler_server.go#L288: func (ht *serverHandlerTransport) writeCustomHeaders(s *Stream) {
handler_server.go#L304: func (ht *serverHandlerTransport) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
handler_server.go#L316: func (ht *serverHandlerTransport) WriteHeader(s *Stream, md metadata.MD) error {
handler_server.go#L344: func (ht *serverHandlerTransport) HandleStreams(startStream func(*Stream), traceCtx func(context.Context, string) context.Context) {
handler_server.go#L369: s := &Stream{
http2_client.go#L119: activeStreams map[uint32]*Stream
http2_client.go#L334: activeStreams: make(map[uint32]*Stream),
http2_client.go#L461: func (t *http2Client) newStream(ctx context.Context, callHdr *CallHdr) *Stream {
http2_client.go#L463: s := &Stream{
http2_client.go#L707: func (t *http2Client) NewStream(ctx context.Context, callHdr *CallHdr) (*Stream, error) {
http2_client.go#L879: func (t *http2Client) CloseStream(s *Stream, err error) {
http2_client.go#L891: func (t *http2Client) closeStream(s *Stream, err error, rst bool, rstCode http2.ErrCode, st *status.Status, mdata map[string][]string, eosReceived bool) {
http2_client.go#L1035: func (t *http2Client) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
http2_client.go#L1058: func (t *http2Client) getStream(f http2.Frame) *Stream {
http2_client.go#L1068: func (t *http2Client) adjustWindow(s *Stream, n uint32) {
http2_client.go#L1077: func (t *http2Client) updateWindow(s *Stream, n uint32) {
http2_client.go#L1322: streamsToClose := make([]*Stream, 0)
http2_server.go#L114: activeStreams map[uint32]*Stream
http2_server.go#L261: activeStreams: make(map[uint32]*Stream),
http2_server.go#L350: func (t *http2Server) operateHeaders(frame *http2.MetaHeadersFrame, handle func(*Stream), traceCtx func(context.Context, string) context.Context) error {
http2_server.go#L376: s := &Stream{
http2_server.go#L627: func (t *http2Server) HandleStreams(handle func(*Stream), traceCtx func(context.Context, string) context.Context) {
http2_server.go#L686: func (t *http2Server) getStream(f http2.Frame) (*Stream, bool) {
http2_server.go#L704: func (t *http2Server) adjustWindow(s *Stream, n uint32) {
http2_server.go#L714: func (t *http2Server) updateWindow(s *Stream, n uint32) {
http2_server.go#L948: func (t *http2Server) streamContextErr(s *Stream) error {
http2_server.go#L958: func (t *http2Server) WriteHeader(s *Stream, md metadata.MD) error {
http2_server.go#L986: func (t *http2Server) writeHeaderLocked(s *Stream) error {
http2_server.go#L1025: func (t *http2Server) WriteStatus(s *Stream, st *status.Status) error {
http2_server.go#L1091: func (t *http2Server) Write(s *Stream, hdr []byte, data []byte, opts *Options) error {
http2_server.go#L1244: func (t *http2Server) deleteStream(s *Stream, eosReceived bool) {
http2_server.go#L1265: func (t *http2Server) finishStream(s *Stream, rst bool, rstCode http2.ErrCode, hdr *headerFrame, eosReceived bool) {
http2_server.go#L1289: func (t *http2Server) closeStream(s *Stream, rst bool, rstCode http2.ErrCode, eosReceived bool) {
transport.go#L243: type Stream struct {
transport.go#L300: func (s *Stream) isHeaderSent() bool {
transport.go#L306: func (s *Stream) updateHeaderSent() bool {
transport.go#L310: func (s *Stream) swapState(st streamState) streamState {
transport.go#L314: func (s *Stream) compareAndSwapState(oldState, newState streamState) bool {
transport.go#L318: func (s *Stream) getState() streamState {
transport.go#L322: func (s *Stream) waitOnHeader() {
transport.go#L342: func (s *Stream) RecvCompress() string {
transport.go#L348: func (s *Stream) SetSendCompress(str string) {
transport.go#L354: func (s *Stream) Done() <-chan struct{} {
transport.go#L366: func (s *Stream) Header() (metadata.MD, error) {
transport.go#L388: func (s *Stream) TrailersOnly() bool {
transport.go#L398: func (s *Stream) Trailer() metadata.MD {
transport.go#L408: func (s *Stream) ContentSubtype() string {
transport.go#L413: func (s *Stream) Context() context.Context {
transport.go#L418: func (s *Stream) Method() string {
transport.go#L425: func (s *Stream) Status() *status.Status {
transport.go#L432: func (s *Stream) SetHeader(md metadata.MD) error {
transport.go#L448: func (s *Stream) SendHeader(md metadata.MD) error {
transport.go#L455: func (s *Stream) SetTrailer(md metadata.MD) error {
transport.go#L468: func (s *Stream) write(m recvMsg) {
transport.go#L473: func (s *Stream) Read(p []byte) (n int, err error) {
transport.go#L505: func (s *Stream) BytesReceived() bool {
transport.go#L511: func (s *Stream) Unprocessed() bool {
transport.go#L517: func (s *Stream) GoString() string {
transport.go#L643: Write(s *Stream, hdr []byte, data []byte, opts *Options) error
transport.go#L646: NewStream(ctx context.Context, callHdr *CallHdr) (*Stream, error)
transport.go#L652: CloseStream(stream *Stream, err error)
transport.go#L687: HandleStreams(func(*Stream), func(context.Context, string) context.Context)
transport.go#L691: WriteHeader(s *Stream, md metadata.MD) error
transport.go#L695: Write(s *Stream, hdr []byte, data []byte, opts *Options) error
transport.go#L699: WriteStatus(s *Stream, st *status.Status) error
google.golang.org/grpc
rpc_util.go#L691: func recvAndDecompress(p *parser, s *transport.Stream, dc Decompressor, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) ([]byte, error) {
rpc_util.go#L757: func recv(p *parser, c baseCodec, s *transport.Stream, dc Decompressor, m interface{}, maxReceiveMessageSize int, payInfo *payloadInfo, compressor encoding.Compressor) error {
server.go#L121: stream *transport.Stream
server.go#L949: st.HandleStreams(func(stream *transport.Stream) {
server.go#L1024: func (s *Server) traceInfo(st transport.ServerTransport, stream *transport.Stream) (trInfo *traceInfo) {
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#L554: s *transport.Stream
stream.go#L1273: s *transport.Stream
stream.go#L1505: s *transport.Stream