Versions in this module Expand all Collapse all v1 v1.0.2 Apr 11, 2021 v1.0.1 Apr 9, 2021 v1.0.0 Apr 9, 2021 Changes in this version + var ChunkedRoutesPool sync.Pool + func ReleaseChunkedRoutes(h *ChunkedRoutes) + func ReleaseHeader(h *Header) + func ReleaseRequest(h *Request) + func ReleaseResponse(h *Response) + func ReleaseTarget(h *Target) + func StatusCodeIsRedirect(statusCode int) bool + type BackupClient = fasthttp.Client + type ChunkedRoutes [][]*Route + func AcquireChunkedRoutes() *ChunkedRoutes + func ChunkRoutes(items []*Route, src *ChunkedRoutes, chunks int) *ChunkedRoutes + type Config struct + BlacklistRedirects []string + ExtraHeaders []Header + MaxRedirects int + ReadBody bool + ReadHeaders bool + Timeout time.Duration + func (c *Config) BackupClient() *BackupClient + func (c *Config) IsBlacklistedRedirect(host []byte) bool + func (c *Config) ResetBackupClient() + type Field struct + Key string + Type FieldType + func StringToFields(in string) (ret []Field) + func (f *Field) AppendBytes(dst []byte) []byte + func (f *Field) Bytes() []byte + type FieldType int + const Date + const Format + const Int + const String + const Timestamp + const UUID + type HTTPClient = fasthttp.HostClient + func NewHTTPClient(host string, tls bool) *HTTPClient + type Header struct + Key string + Value string + func AcquireHeader() *Header + func (h *Header) AppendBytes(b []byte) []byte + func (h *Header) String() string + func (h *Header) Write(buf io.Writer) (int, error) + func (h Header) MarshalZerologObject(e *zerolog.Event) + type HeaderField struct + Key Field + Value Field + type Headers []Header + func (rr Headers) MarshalZerologArray(a *zerolog.Array) + type Method []byte + var DELETE Method = []byte("DELETE") + var ErrUnsupportedMethod = fmt.Errorf("unsupported method") + var GET Method = []byte("GET") + var PATCH Method = []byte("PATCH") + var POST Method = []byte("POST") + var PUT Method = []byte("PUT") + var TRACE Method = []byte("TRACE") + func MethodFromString(m string) (Method, error) + type Range struct + Max int + Min int + func RangeFromString(in string) (ret Range, err error) + func (r Range) String() string + type Request struct + Route *Route + Target *Target + func AcquireRequest() *Request + func (r *Request) String() string + func (r *Request) WriteRequest(dst *fasthttp.Request, basepath []byte) + type Response struct + Body []byte + BodyLength int + Error error + HTTPVersion string + Headers []*Header + Lines int + Next *Response + OriginRequest Request + StatusCode int + URI []byte + Words int + func AcquireResponse() *Response + func DoClient(c *HTTPClient, req Request, config *Config) (Response, error) + func (r *Response) AddHeader(k, v []byte) + func (r *Response) AppendRedirectChain(b []byte) []byte + func (r *Response) Flatten() (ret Responses) + func (r *Response) Reset() + func (r *Response) String() string + func (r Response) MarshalZerologObject(e *zerolog.Event) + type Responses []*Response + func (rr Responses) MarshalZerologArray(a *zerolog.Array) + type Route struct + Body []byte + Headers []Header + Method Method + Path []byte + Query []byte + Source string + func FilterSource(routes []*Route, want map[string]interface{}) []*Route + func UniqueSource(routes []*Route) []*Route + func (r *Route) AppendPath(dst []byte) []byte + func (r *Route) AppendQuery(dst []byte) []byte + func (r Route) AppendBytes(b []byte) []byte + func (r Route) AppendShortBytes(b []byte) []byte + func (r Route) MarshalZerologObject(e *zerolog.Event) + func (r Route) String() string + type RouteMap map[string][]*Route + func GroupRouteDepth(routes []*Route, depth int64) RouteMap + func (r RouteMap) Flatten() []*Route + func (r RouteMap) FlattenCount() int + type Target struct + BasePath string + Headers []Header + HostHeader []byte + Hostname string + IP string + IsTLS bool + Port int + func AcquireTarget() *Target + func (t *Target) AppendBytes(b []byte) []byte + func (t *Target) AppendHost(buf []byte) []byte + func (t *Target) AppendHostHeader(buf []byte) []byte + func (t *Target) AppendIPOrHostname(buf []byte) []byte + func (t *Target) AppendScheme(buf []byte) []byte + func (t *Target) Bytes() []byte + func (t *Target) Cancel() + func (t *Target) Context() context.Context + func (t *Target) HTTPClient(maxConnections int, timeout time.Duration) *HTTPClient + func (t *Target) HitIncr() int64 + func (t *Target) HitReset() int64 + func (t *Target) Hits() int64 + func (t *Target) Host() string + func (t *Target) ParseHostHeader() []byte + func (t *Target) Quarantine() + func (t *Target) QuarantineIncr() int64 + func (t *Target) QuarantineReset() int64 + func (t *Target) Quarantined() bool + func (t *Target) SetContext(c context.Context) + func (t *Target) String() string + func (t *Target) Write(b io.Writer) (int, error)