http

Documentation

Index

• Constants
• Variables
• func DelRequestHeader(request *fasthttp.Request)
• func DelResponseHeader(response *fasthttp.Response)
• func Error(ctx *fasthttp.RequestCtx, msg string, statusCode int)
• func GetHeader(ctx *fasthttp.RequestCtx, key, defaultV string) string
• func GetParams(ctx *fasthttp.RequestCtx, key, defaultV string) string
• func GetToken(ctx *fasthttp.RequestCtx) string
• func Header(ctx *fasthttp.RequestCtx, key, defaultV string) (string, bool)
• func HijackClientRequest(websocketConn *websocket.Conn, httpConn *httputil.ClientConn, ...) error
• func InitClientDial(endpoint string) (net.Conn, error)
• func JsonBody2Object(ctx *fasthttp.RequestCtx, obj any) error
• func JsonBodyUnmarshalObject[T fastjson.Unmarshalable](ctx *fasthttp.RequestCtx, obj T) error
• func NewFastHTTPHandler(h http.Handler) fasthttp.RequestHandler
• func Param(ctx *fasthttp.RequestCtx, key string) (string, bool)
• func Params(ctx *fasthttp.RequestCtx) map[string]any
• func Proxy(host string, schema string, uri string, query string, ctx *fasthttp.RequestCtx, ...) error
• func UnixSocketProxy(unixPath string, host string, schema string, uri string, query string, ...) error
• func WithHttpReverseProxy(host string, schema string, uri string, query string, ctx *fasthttp.RequestCtx) (rtn error)
• func WithHttpReverseUnixSocketProxy(unixPath string, uri string, query string, ctx *fasthttp.RequestCtx) (rtn error)
• type EchoWSRequestHandler
  • func (h *EchoWSRequestHandler) Handle(ctx *fasthttp.RequestCtx) error
• type RequestChainHandler
• type RequestHandlerChain
  • func (c *RequestHandlerChain) Add(handler RequestChainHandler) *RequestHandlerChain
  • func (c *RequestHandlerChain) Then(handler fasthttp.RequestHandler) fasthttp.RequestHandler
• type Upgrader

Constants

const (
	SUCCESS = 0
	FAIL    = 1
)

Variables

var DEFAULT_CONTENTTYPE = []byte("application/json;charset=utf-8")

var Logger = log4go.LoggerManager.GetLogger("gohutool.util4go.http.proxy")

var PageResultData = pageResultData{}

var PageResultDataBuilder = pageResultDataBuilder{}

var Result = result{}

Functions

func DelRequestHeader

func DelRequestHeader(request *fasthttp.Request)

func DelResponseHeader

func DelResponseHeader(response *fasthttp.Response)

func Error

func Error(ctx *fasthttp.RequestCtx, msg string, statusCode int)

func GetHeader

func GetHeader(ctx *fasthttp.RequestCtx, key, defaultV string) string

func GetParams

func GetParams(ctx *fasthttp.RequestCtx, key, defaultV string) string

func GetToken

func GetToken(ctx *fasthttp.RequestCtx) string

func Header

func Header(ctx *fasthttp.RequestCtx, key, defaultV string) (string, bool)

func HijackClientRequest

func HijackClientRequest(websocketConn *websocket.Conn, httpConn *httputil.ClientConn, request *http.Request) error

func InitClientDial

func InitClientDial(endpoint string) (net.Conn, error)

InitClientDial /var/run/docker.sock

func JsonBody2Object

func JsonBody2Object(ctx *fasthttp.RequestCtx, obj any) error

func JsonBodyUnmarshalObject

func JsonBodyUnmarshalObject[T fastjson.Unmarshalable](ctx *fasthttp.RequestCtx, obj T) error

func NewFastHTTPHandler

func NewFastHTTPHandler(h http.Handler) fasthttp.RequestHandler

func Param

func Param(ctx *fasthttp.RequestCtx, key string) (string, bool)

func Params

func Params(ctx *fasthttp.RequestCtx) map[string]any

func Proxy

func Proxy(host string, schema string, uri string, query string, ctx *fasthttp.RequestCtx, timeout int) error

func UnixSocketProxy

func UnixSocketProxy(unixPath string, host string, schema string, uri string, query string, ctx *fasthttp.RequestCtx, timeout int) error

func WithHttpReverseProxy

func WithHttpReverseProxy(host string, schema string, uri string, query string, ctx *fasthttp.RequestCtx) (rtn error)

func WithHttpReverseUnixSocketProxy

func WithHttpReverseUnixSocketProxy(unixPath string, uri string, query string, ctx *fasthttp.RequestCtx) (rtn error)

Types

type EchoWSRequestHandler

type EchoWSRequestHandler struct {
	Upgrader Upgrader
}

func (*EchoWSRequestHandler) Handle

func (h *EchoWSRequestHandler) Handle(ctx *fasthttp.RequestCtx) error

type RequestChainHandler

type RequestChainHandler func(next fasthttp.RequestHandler) fasthttp.RequestHandler

type RequestHandlerChain

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

func (*RequestHandlerChain) Add

func (c *RequestHandlerChain) Add(handler RequestChainHandler) *RequestHandlerChain

func (*RequestHandlerChain) Then

func (c *RequestHandlerChain) Then(handler fasthttp.RequestHandler) fasthttp.RequestHandler

type Upgrader

type Upgrader = websocket.FastHTTPUpgrader