crc32block

type Decoder ¶

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

func NewDecoder(r io.ReaderAt, off int64, size int64) (dec *Decoder, err error)

func NewDecoderWithBlock(r io.ReaderAt, off int64, size int64, block []byte, bufferSize int64) (dec *Decoder, err error)

func (dec *Decoder) Reader(from, to int64) (r io.Reader, err error)

type Encoder ¶

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

func NewEncoder(block []byte) (enc *Encoder, err error)

func (enc *Encoder) Encode(from io.Reader, limitSize int64, to io.Writer) (n int64, err error)

type ReaderError ¶

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

type RequestBody ¶

type RequestBody interface {
	io.ReadCloser

	// CodeSize returns encoded whole body size for encoding,
	// or origin body size for decoding.
	CodeSize(int64) int64
}

RequestBody is implemented http request's body. always io.ReadCloser.

For client requests, The HTTP Client's Transport is responsible for calling the Close method. Necessarily call the Close method if the body's life-cycle control by yourself.

For server requests, the Server will close the request body. The ServeHTTP Handler does not need to.

The Body must allow Read to be called concurrently with Close. In particular, calling Close should unblock a Read waiting for input.

func NewBodyDecoder(rc io.ReadCloser) RequestBody

func NewBodyEncoder(rc io.ReadCloser) RequestBody

type WriterError ¶

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