http

Documentation

Index

• type Body
  • func NewBody(reader BodyReader, decoder *decode.Decoder) *Body
  • func (b *Body) Callback(onBody onBodyCallback) error
  • func (b *Body) Init(req *Request)
  • func (b *Body) Raw() ([]byte, error)
  • func (b *Body) RawCallback(onBody onBodyCallback) error
  • func (b *Body) RawReader() io.Reader
  • func (b *Body) Read(buff []byte) (n int, err error)
  • func (b *Body) Reset() error
  • func (b *Body) Value() ([]byte, error)
• type BodyReader
• type Fragment
• type Params
• type Path
• type Request
  • func NewRequest(hdrs *headers.Headers, query query.Query, response Response, conn net.Conn, ...) *Request
  • func (r *Request) Body() *Body
  • func (r *Request) Clear() (err error)
  • func (r *Request) Hijack() (net.Conn, error)
  • func (r *Request) WasHijacked() bool
• type Response
  • func NewResponse() Response
  • func RespondTo(request *Request) Response
  • func (r Response) Attachment() types.Attachment
  • func (r Response) Clear() Response
  • func (r Response) DiscardHeaders() Response
  • func (r Response) Headers() []string
  • func (r Response) WithAttachment(reader io.Reader, size int) Response
  • func (r Response) WithBody(body string) Response
  • func (r Response) WithBodyByte(body []byte) Response
  • func (r Response) WithCode(code status.Code) Response
  • func (r Response) WithContentType(value string) Response
  • func (r Response) WithError(err error) Response
  • func (r Response) WithFile(path string) (Response, error)
  • func (r Response) WithHeader(key string, values ...string) Response
  • func (r Response) WithHeaders(headers map[string][]string) Response
  • func (r Response) WithStatus(status status.Status) Response
  • func (r Response) WithTransferEncoding(value string) Response
  • func (r Response) WithWriter(cb func(io.Writer) error) (Response, error)
• type ResponseWriter

Types

type Body

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

func NewBody

func NewBody(reader BodyReader, decoder *decode.Decoder) *Body

func (*Body) Callback

func (b *Body) Callback(onBody onBodyCallback) error

func (*Body) Init

func (b *Body) Init(req *Request)

func (*Body) Raw

func (b *Body) Raw() ([]byte, error)

func (*Body) RawCallback

func (b *Body) RawCallback(onBody onBodyCallback) error

func (*Body) RawReader

func (b *Body) RawReader() io.Reader

func (*Body) Read

func (b *Body) Read(buff []byte) (n int, err error)

func (*Body) Reset

func (b *Body) Reset() error

func (*Body) Value

func (b *Body) Value() ([]byte, error)

type BodyReader

type BodyReader interface {
	Init(*Request)
	Read() ([]byte, error)
}

type Fragment

type Fragment = string

type Params

type Params = map[string]string

type Path

type Path struct {
	String   string
	Params   Params
	Query    query.Query
	Fragment Fragment
}

type Request

type Request struct {
	Remote  net.Addr
	Ctx     context.Context
	Headers *headers.Headers

	Path             Path
	ContentLength    int
	TransferEncoding headers.TransferEncoding
	Method           method.Method
	Upgrade          proto.Proto
	Proto            proto.Proto
	// contains filtered or unexported fields
}

Request struct represents http request About headers manager see at http/headers/headers.go:Manager Headers attribute references at that one that lays in manager

func NewRequest

func NewRequest(
	hdrs *headers.Headers, query query.Query, response Response, conn net.Conn, body *Body,
	paramsMap Params, disableParamsMapClearing bool,
) *Request

NewRequest returns a new instance of request object and body gateway Must not be used externally, this function is for internal purposes only HTTP/1.1 as a protocol by default is set because if first request from user is invalid, we need to render a response using request method, but appears that default method is a null-value (proto.Unknown)

func (*Request) Body

func (r *Request) Body() *Body

Body returns an entity representing a request's body

func (*Request) Clear

func (r *Request) Clear() (err error)

Clear resets request headers and reads body into nowhere until completed. It is implemented to clear the request object between requests

func (*Request) Hijack

func (r *Request) Hijack() (net.Conn, error)

Hijack the connection. Request body will be implicitly read (so if you need it you should read it before) all the body left. After handler exits, the connection will be closed, so the connection can be hijacked only once

func (*Request) WasHijacked

func (r *Request) WasHijacked() bool

WasHijacked returns true or false, depending on whether was a connection hijacked

type Response

type Response struct {
	Status           status.Status
	ContentType      string
	TransferEncoding string

	Body []byte
	Code status.Code
	// contains filtered or unexported fields
}

func NewResponse

func NewResponse() Response

func RespondTo

func RespondTo(request *Request) Response

RespondTo returns a response object of request

func (Response) Attachment

func (r Response) Attachment() types.Attachment

Attachment returns response's attachment.

WARNING: do NEVER use this method in your code. It serves internal purposes ONLY

func (Response) Clear

func (r Response) Clear() Response

Clear discards everything was done with response object before

func (Response) DiscardHeaders

func (r Response) DiscardHeaders() Response

DiscardHeaders returns response object with no any headers set.

Warning: this action is not pure. Appending new headers will cause overriding old ones

func (Response) Headers

func (r Response) Headers() []string

Headers returns an underlying response headers

func (Response) WithAttachment

func (r Response) WithAttachment(reader io.Reader, size int) Response

WithAttachment sets a response's attachment. In this case response body will be ignored. If size <= 0, then Transfer-Encoding: chunked will be used

func (Response) WithBody

func (r Response) WithBody(body string) Response

WithBody sets a string as a response body. This will override already-existing body if it was set

func (Response) WithBodyByte

func (r Response) WithBodyByte(body []byte) Response

WithBodyByte does all the same as Body does, but for byte slices

func (Response) WithCode

func (r Response) WithCode(code status.Code) Response

WithCode sets a response code and a corresponding status. In case of unknown code, "Unknown Status Code" will be set as a status code. In this case you should call Status explicitly

func (Response) WithContentType

func (r Response) WithContentType(value string) Response

WithContentType sets a custom Content-Type header value.

func (Response) WithError

func (r Response) WithError(err error) Response

WithError checks, whether the passed error is a HTTPError instance. In this case, setting response code and body to HTTPError.Code and HTTPError.Message respectively. If the check failed, simply setting the code to status.InternalServerError. Error message won't be included in the response, as this possibly can spoil project internals, creating security breaches

func (Response) WithFile

func (r Response) WithFile(path string) (Response, error)

WithFile opens a file for reading, and returns a new response with attachment corresponding to the file FD. In case not found or any other error, it'll be directly returned. In case error occurred while opening the file, response builder won't be affected and stay clean

func (Response) WithHeader

func (r Response) WithHeader(key string, values ...string) Response

WithHeader sets header values to a key. In case it already exists the value will be appended.

func (Response) WithHeaders

func (r Response) WithHeaders(headers map[string][]string) Response

WithHeaders simply merges passed headers into response. Also, it is the only way to specify a quality marker of value. In case headers were not initialized before, response headers will be set to a passed map, so editing this map will affect response

func (Response) WithStatus

func (r Response) WithStatus(status status.Status) Response

WithStatus sets a custom status text. This text does not matter at all, and usually totally ignored by client, so there is actually no reasons to use this except some rare cases when you need to represent a response status text somewhere

func (Response) WithTransferEncoding

func (r Response) WithTransferEncoding(value string) Response

WithTransferEncoding sets a custom Transfer-Encoding header value.

func (Response) WithWriter

func (r Response) WithWriter(cb func(io.Writer) error) (Response, error)

WithWriter takes a function that takes an io.Writer, which allows us to stream data directly into the response body. Note: this method causes an allocation

TODO: This is not the best design solution. I would like to make this method just like

all others, so returning only Response object itself. The problem is that it is
impossible because io.Writer is a procedure-style thing that does not work with
our builder that pretends to be clear. Hope in future this issue will be solved

type ResponseWriter

type ResponseWriter func(b []byte) error