ext

package

v0.7.2 Latest Latest Go to latest Published: Nov 15, 2023 License: Apache-2.0 Imports: 15 Imported by: 4

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/cloudwego/hertz

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func AcquireBodyStream(b *bytebufferpool.ByteBuffer, r network.Reader, t *protocol.Trailer, ...) io.Reader
func BufferSnippet(b []byte) string
func HasHeaderValue(s, value []byte) bool
func HeaderError(typ string, err, errParse error, b []byte) error
func LimitedReaderSize(r io.Reader) int64
func MustDiscard(r network.Reader, n int)
func MustPeekBuffered(r network.Reader) []byte
func ReadBody(r network.Reader, contentLength, maxBodySize int, dst []byte) ([]byte, error)
func ReadBodyWithStreaming(zr network.Reader, contentLength, maxBodySize int, dst []byte) (b []byte, err error)
func ReadRawHeaders(dst, buf []byte) ([]byte, int, error)
func ReadTrailer(t *protocol.Trailer, r network.Reader) error
func ReleaseBodyStream(requestReader io.Reader) (err error)
func SkipTrailer(r network.Reader) error
func WriteBodyChunked(w network.Writer, r io.Reader) error
func WriteBodyFixedSize(w network.Writer, r io.Reader, size int64) error
func WriteChunk(w network.Writer, b []byte, withFlush bool) (err error)
func WriteTrailer(t *protocol.Trailer, w network.Writer) error
type HeaderScanner
- func (s *HeaderScanner) Next() bool
type HeaderValueScanner

Constants ¶

This section is empty.

Variables ¶

View Source

var NoBody = protocol.NoBody

Deprecated: Use github.com/cloudwego/hertz/pkg/protocol.NoBody instead.

Functions ¶

func AcquireBodyStream ¶

func AcquireBodyStream(b *bytebufferpool.ByteBuffer, r network.Reader, t *protocol.Trailer, contentLength int) io.Reader

func BufferSnippet ¶

func BufferSnippet(b []byte) string

func HasHeaderValue ¶

func HasHeaderValue(s, value []byte) bool

func HeaderError ¶

func HeaderError(typ string, err, errParse error, b []byte) error

func LimitedReaderSize ¶

func LimitedReaderSize(r io.Reader) int64

func MustDiscard ¶

func MustDiscard(r network.Reader, n int)

func MustPeekBuffered ¶

func MustPeekBuffered(r network.Reader) []byte

func ReadBody ¶

func ReadBody(r network.Reader, contentLength, maxBodySize int, dst []byte) ([]byte, error)

func ReadBodyWithStreaming ¶

func ReadBodyWithStreaming(zr network.Reader, contentLength, maxBodySize int, dst []byte) (b []byte, err error)

func ReadRawHeaders ¶

func ReadRawHeaders(dst, buf []byte) ([]byte, int, error)

func ReadTrailer ¶ added in v0.6.0

func ReadTrailer(t *protocol.Trailer, r network.Reader) error

func ReleaseBodyStream ¶

func ReleaseBodyStream(requestReader io.Reader) (err error)

ReleaseBodyStream releases the body stream. Error of skipRest may be returned if there is one.

NOTE: Be careful to use this method unless you know what it's for.

func SkipTrailer ¶ added in v0.6.0

func SkipTrailer(r network.Reader) error

func WriteBodyChunked ¶

func WriteBodyChunked(w network.Writer, r io.Reader) error

func WriteBodyFixedSize ¶

func WriteBodyFixedSize(w network.Writer, r io.Reader, size int64) error

func WriteChunk ¶ added in v0.6.0

func WriteChunk(w network.Writer, b []byte, withFlush bool) (err error)

func WriteTrailer ¶ added in v0.6.0

func WriteTrailer(t *protocol.Trailer, w network.Writer) error

writeTrailer writes response trailer to w

Types ¶

type HeaderScanner ¶

type HeaderScanner struct {
	B     []byte
	Key   []byte
	Value []byte
	Err   error

	// HLen stores header subslice len
	HLen int

	DisableNormalizing bool
	// contains filtered or unexported fields
}

func (*HeaderScanner) Next ¶

func (s *HeaderScanner) Next() bool

type HeaderValueScanner ¶

type HeaderValueScanner struct {
	B     []byte
	Value []byte
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL