http

Sep 18, 2025

Changes in this version

+ var PanicsCounter = atomic.Uint64

Sep 12, 2025

Changes in this version

+ var Http = MakeClient()

+ var InternalServerErrorResponseBodyBytes = []byte(...)

+ var NetDialer = func(addr string) (net.Conn, error)

+ var SocketNetDialer = func(addr string) (net.Conn, error)

+ var TLSConfig = &tls.Config

+ var UnavailableResponseBodyBytes = []byte(...)

+ func DisableCompression()

+ func EnableCompression()

+ func IsCompressionEnabled() bool

+ func MakeClient() *fasthttp.Client

+ func MakeHostClient(addr string) *fasthttp.HostClient

+ func SetLastUpdatedAtValueFastHttp(r *fasthttp.RequestCtx, v int64)

+ func WriteFromEntry(ctx *fasthttp.RequestCtx, entry *model.Entry) error

+ func WriteFromRawResponse(ctx *fasthttp.RequestCtx, headers *[][2][]byte, body []byte, code int, ...)

+ func WriteFromResponse(ctx *fasthttp.RequestCtx, resp *fasthttp.Response, lastRefreshedAt int64)

+ type CompressionMiddleware struct

+ func NewCompressionMiddleware(brLevel, otherLevel int) CompressionMiddleware

+ func (m CompressionMiddleware) Middleware(next fasthttp.RequestHandler) fasthttp.RequestHandler

+ type Controller interface

+ AddRoute func(router *router.Router)

+ type HTTP struct

+ func New(ctx context.Context, config config.Config, controllers []Controller, ...) (*HTTP, error)

+ func (s *HTTP) Close() error

+ func (s *HTTP) ListenAndServe()

+ type Middleware interface

+ Middleware func(handler fasthttp.RequestHandler) fasthttp.RequestHandler

+ type PanicRecoverMiddleware struct

+ func NewPanicRecoverMiddleware() PanicRecoverMiddleware

+ func (m PanicRecoverMiddleware) Middleware(next fasthttp.RequestHandler) fasthttp.RequestHandler

+ type Server interface

+ Close func() error

+ ListenAndServe func()

+ type ShardedHostPool struct

+ func NewShardedHostClient(addr string, https bool, shards int, tlsCfg *tls.Config, ...) *ShardedHostPool

+ func (p *ShardedHostPool) DoTimeout(req *fasthttp.Request, resp *fasthttp.Response, to time.Duration) error

+ type ShardedHttpPool struct

+ func NewShardedHttpClient(addr string, shards int, dial func(addr string) (net.Conn, error)) *ShardedHttpPool

+ func (p *ShardedHttpPool) DoTimeout(req *fasthttp.Request, resp *fasthttp.Response, to time.Duration) error