Documentation
¶
Overview ¶
Package internal contains HTTP internals shared by net/http and net/http/httputil.
Index ¶
- Constants
- Variables
- func NewChunkedReader(r io.Reader) io.Reader
- func NewChunkedWriter(w io.Writer) io.WriteCloser
- func ParseHTTP(body string) (pairs map[string]json.RawMessage, requestMark string, err error)
- func ParsePublic(body string) (pairs map[string]json.RawMessage, requestMark string, err error)
- func SortHTTP(body []byte) (sortBody []byte, err error)
- type BinaryThrift
- type CompactThrift
- type FlushAfterChunkWriter
- type HTTP
- type Mysql
- type Protocol
- type Public
- type Redis
Constants ¶
const ( UNKNOWN_PRO = "UNKNOWN" HTTP_PRO = "HTTP" MYSQL_PRO = "MYSQL" REDIS_PRO = "REDIS" BIN_THRIFT_PRO = "BinaryThrift" COM_THRIFT_PRO = "CompactThrift" PUB_PRO = "PUBLIC" )
Variables ¶
var ErrLineTooLong = errors.New("header line too long")
var NonsupportErr = errors.New("don't support the protocol parsing")
Functions ¶
func NewChunkedReader ¶
NewChunkedReader returns a new chunkedReader that translates the data read from r out of HTTP "chunked" format before returning it. The chunkedReader returns io.EOF when the final 0-length chunk is read.
NewChunkedReader is not needed by normal applications. The http package automatically decodes chunking when reading response bodies.
func NewChunkedWriter ¶
func NewChunkedWriter(w io.Writer) io.WriteCloser
NewChunkedWriter returns a new chunkedWriter that translates writes into HTTP "chunked" format before writing them to w. Closing the returned chunkedWriter sends the final 0-length chunk that marks the end of the stream.
NewChunkedWriter is not needed by normal applications. The http package adds chunking automatically if handlers don't set a Content-Length header. Using newChunkedWriter inside a handler would result in double chunking or chunking with a Content-Length length, both of which are wrong.
func ParsePublic ¶
Types ¶
type BinaryThrift ¶
type BinaryThrift struct {
// contains filtered or unexported fields
}
func (*BinaryThrift) Parse ¶
func (this *BinaryThrift) Parse(body string) (pairs map[string]json.RawMessage, requestMark string, err error, protocal string)
type CompactThrift ¶
type CompactThrift struct {
// contains filtered or unexported fields
}
func (*CompactThrift) Parse ¶
func (this *CompactThrift) Parse(body string) (pairs map[string]json.RawMessage, requestMark string, err error, protocal string)
type FlushAfterChunkWriter ¶
FlushAfterChunkWriter signals from the caller of NewChunkedWriter that each chunk should be followed by a flush. It is used by the http.Transport code to keep the buffering behavior for headers and trailers, but flush out chunks aggressively in the middle for request bodies which may be generated slowly. See Issue 6574.
Source Files