triple

package
v0.0.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2021 License: BSD-3-Clause Imports: 4 Imported by: 2

Documentation

Index

Constants

View Source
const (
	DataMsgType              = MsgType(1)
	ServerStreamCloseMsgType = MsgType(2)
)

Variables

This section is empty.

Functions

This section is empty.

Types

type BufferMsg

type BufferMsg struct {
	Buffer  *bytes.Buffer
	MsgType MsgType
}

BufferMsg is the basic transfer unit in one stream

type MsgType

type MsgType uint8

type ProtocolHeader

type ProtocolHeader interface {
	GetPath() string
	FieldToCtx() context.Context
}

ProtocolHeader

type ProtocolHeaderHandler

type ProtocolHeaderHandler interface {
	// ReadFromTripleReqHeader read http header field from http request to ProtocolHeader
	ReadFromTripleReqHeader(header *http.Request) ProtocolHeader

	// WriteTripleReqHeaderField write protocol header fields to http Header
	WriteTripleReqHeaderField(header http.Header) http.Header

	// WriteTripleFinalRspHeaderField write protocol trailer fields to http2 trailer header
	WriteTripleFinalRspHeaderField(w http.ResponseWriter, grpcStatusCode int, grpcMessage string, traceProtoBin int)
}

ProtocolHeaderHandler

type ResponseBody

type ResponseBody struct {
	// contains filtered or unexported fields
}

func (*ResponseBody) Close

func (rsp *ResponseBody) Close() error

func (*ResponseBody) GetTrailer

func (rsp *ResponseBody) GetTrailer() http.Header

func (*ResponseBody) GetTrailerChan

func (rsp *ResponseBody) GetTrailerChan() chan http.Header

func (*ResponseBody) Read

func (rsp *ResponseBody) Read(p []byte) (n int, err error)

func (*ResponseBody) SetRawHttp2ResponseBody

func (rsp *ResponseBody) SetRawHttp2ResponseBody(readCloser io.ReadCloser)

func (*ResponseBody) SetTrailerChan

func (rsp *ResponseBody) SetTrailerChan(trailerChan chan http.Header)

type StreamingRequest

type StreamingRequest struct {
	SendChan chan BufferMsg
	Handler  ProtocolHeaderHandler
}

func (*StreamingRequest) Close

func (sr *StreamingRequest) Close() error

func (*StreamingRequest) Read

func (sr *StreamingRequest) Read(p []byte) (n int, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
JackTT - Gopher 🇻🇳