http_context

package
v0.8.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 4, 2022 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	MultipartForm  = "multipart/form-data"
	FormData       = "application/x-www-form-urlencoded"
	TEXT           = "text/plain"
	JSON           = "application/json"
	JavaScript     = "application/javascript"
	AppLicationXML = "application/xml"
	TextXML        = "text/xml"
	Html           = "text/html"
)

Variables

View Source 
var (
	ErrorNotForm      = errors.New("contentType is not Form")
	ErrorNotMultipart = errors.New("contentType is not Multipart")
	ErrorNotAllowRaw  = errors.New("contentType is not allow Raw")
	ErrorNotSend      = errors.New("not send")
)

Functions

func NotFound 

func NotFound(ctx *Context)

Types

type BodyRequestHandler 

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

BodyRequestHandler body请求处理器

func NewBodyRequestHandler 

func NewBodyRequestHandler(request *fasthttp.Request) *BodyRequestHandler

func (*BodyRequestHandler) AddFile 

func (b *BodyRequestHandler) AddFile(key string, file *multipart.FileHeader) error

AddFile 新增文件参数

func (*BodyRequestHandler) AddForm 

func (b *BodyRequestHandler) AddForm(key, value string) error

AddForm 新增表单参数

func (*BodyRequestHandler) BodyForm 

func (b *BodyRequestHandler) BodyForm() (url.Values, error)

BodyForm 获取表单参数

func (*BodyRequestHandler) ContentType 

func (b *BodyRequestHandler) ContentType() string

ContentType 获取contentType

func (*BodyRequestHandler) Files 

func (b *BodyRequestHandler) Files() (map[string][]*multipart.FileHeader, error)

func (*BodyRequestHandler) GetFile 

func (b *BodyRequestHandler) GetFile(key string) ([]*multipart.FileHeader, bool)

func (*BodyRequestHandler) GetForm 

func (b *BodyRequestHandler) GetForm(key string) string

GetForm 获取表单参数

func (*BodyRequestHandler) MultipartForm added in v0.8.0 

func (b *BodyRequestHandler) MultipartForm() (*multipart.Form, error)

func (*BodyRequestHandler) RawBody 

func (b *BodyRequestHandler) RawBody() ([]byte, error)

RawBody 获取raw数据

func (*BodyRequestHandler) SetFile 

func (b *BodyRequestHandler) SetFile(files map[string][]*multipart.FileHeader) error

SetFile 设置文件参数

func (*BodyRequestHandler) SetForm 

func (b *BodyRequestHandler) SetForm(values url.Values) error

SetForm 设置表单参数

func (*BodyRequestHandler) SetRaw 

func (b *BodyRequestHandler) SetRaw(contentType string, body []byte)

SetRaw 设置raw数据

func (*BodyRequestHandler) SetToForm 

func (b *BodyRequestHandler) SetToForm(key, value string) error

type Context 

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

Context fasthttpRequestCtx

func NewContext 

func NewContext(ctx *fasthttp.RequestCtx, port int) *Context

NewContext 创建Context

func (*Context) Assert added in v0.8.0 

func (ctx *Context) Assert(i interface{}) error

func (*Context) Context 

func (ctx *Context) Context() context.Context

func (*Context) FastFinish added in v0.8.0 

func (ctx *Context) FastFinish()

Finish finish

func (*Context) GetApp added in v0.8.0 

func (ctx *Context) GetApp() eoscContext.EoApp

func (*Context) GetBalance added in v0.8.0 

func (ctx *Context) GetBalance() eoscContext.BalanceHandler

func (*Context) GetComplete added in v0.8.0 

func (ctx *Context) GetComplete() eoscContext.CompleteHandler

func (*Context) GetFinish added in v0.8.0 

func (ctx *Context) GetFinish() eoscContext.FinishHandler

func (*Context) GetLabel added in v0.7.1 

func (ctx *Context) GetLabel(name string) string

func (*Context) GetUpstreamHostHandler added in v0.8.0 

func (ctx *Context) GetUpstreamHostHandler() eoscContext.UpstreamHostHandler

func (*Context) Labels added in v0.7.1 

func (ctx *Context) Labels() map[string]string

func (*Context) LocalAddr added in v0.8.0 

func (ctx *Context) LocalAddr() net.Addr

func (*Context) LocalIP added in v0.8.0 

func (ctx *Context) LocalIP() net.IP

func (*Context) LocalPort added in v0.8.0 

func (ctx *Context) LocalPort() int

func (*Context) Proxies 

func (ctx *Context) Proxies() []http_service.IRequest

func (*Context) Proxy 

func (ctx *Context) Proxy() http_service.IRequest

func (*Context) Request 

func (ctx *Context) Request() http_service.IRequestReader

func (*Context) RequestId 

func (ctx *Context) RequestId() string

RequestId 请求ID

func (*Context) Response 

func (ctx *Context) Response() http_service.IResponse

func (*Context) Scheme added in v0.8.0 

func (ctx *Context) Scheme() string

func (*Context) SendTo 

func (ctx *Context) SendTo(address string, timeout time.Duration) error

func (*Context) SetApp added in v0.8.0 

func (ctx *Context) SetApp(app eoscContext.EoApp)

func (*Context) SetBalance added in v0.8.0 

func (ctx *Context) SetBalance(handler eoscContext.BalanceHandler)

func (*Context) SetCompleteHandler added in v0.8.0 

func (ctx *Context) SetCompleteHandler(handler eoscContext.CompleteHandler)

func (*Context) SetFinish added in v0.8.0 

func (ctx *Context) SetFinish(handler eoscContext.FinishHandler)

func (*Context) SetLabel added in v0.7.1 

func (ctx *Context) SetLabel(name, value string)

func (*Context) SetUpstreamHostHandler added in v0.8.0 

func (ctx *Context) SetUpstreamHostHandler(handler eoscContext.UpstreamHostHandler)

func (*Context) Value 

func (ctx *Context) Value(key interface{}) interface{}

func (*Context) WithValue 

func (ctx *Context) WithValue(key, val interface{})

type ProxyRequest 

type ProxyRequest struct {
	*RequestReader
}

func NewProxyRequest 

func NewProxyRequest(request *fasthttp.Request, remoteAddr string) *ProxyRequest

func (*ProxyRequest) Body 

func (r *ProxyRequest) Body() http_service.IBodyDataWriter

func (*ProxyRequest) Finish 

func (r *ProxyRequest) Finish() error

func (*ProxyRequest) Header 

func (r *ProxyRequest) Header() http_service.IHeaderWriter

func (*ProxyRequest) SetMethod 

func (r *ProxyRequest) SetMethod(s string)

func (*ProxyRequest) SetPath 

func (r *ProxyRequest) SetPath(s string)

func (*ProxyRequest) URI 

func (r *ProxyRequest) URI() http_service.IURIWriter

type RequestHeader 

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

func NewRequestHeader 

func NewRequestHeader(header *fasthttp.RequestHeader) *RequestHeader

func (*RequestHeader) AddHeader 

func (h *RequestHeader) AddHeader(key, value string)

func (*RequestHeader) DelHeader 

func (h *RequestHeader) DelHeader(key string)

func (*RequestHeader) GetCookie 

func (h *RequestHeader) GetCookie(key string) string

func (*RequestHeader) GetHeader 

func (h *RequestHeader) GetHeader(name string) string

func (*RequestHeader) Headers 

func (h *RequestHeader) Headers() http.Header

func (*RequestHeader) Host 

func (h *RequestHeader) Host() string

func (*RequestHeader) RawHeader 

func (h *RequestHeader) RawHeader() string

func (*RequestHeader) SetHeader 

func (h *RequestHeader) SetHeader(key, value string)

func (*RequestHeader) SetHost 

func (h *RequestHeader) SetHost(host string)

type RequestReader 

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

func NewRequestReader 

func NewRequestReader(req *fasthttp.Request, remoteAddr string) *RequestReader

func (*RequestReader) Body 

func (r *RequestReader) Body() http_service.IBodyDataReader

func (*RequestReader) Finish 

func (r *RequestReader) Finish() error

func (*RequestReader) ForwardIP 

func (r *RequestReader) ForwardIP() string

func (*RequestReader) Header 

func (r *RequestReader) Header() http_service.IHeaderReader

func (*RequestReader) Method 

func (r *RequestReader) Method() string

func (*RequestReader) ReadIP 

func (r *RequestReader) ReadIP() string

func (*RequestReader) RemoteAddr 

func (r *RequestReader) RemoteAddr() string

func (*RequestReader) RemotePort 

func (r *RequestReader) RemotePort() string

func (*RequestReader) Request 

func (r *RequestReader) Request() *fasthttp.Request

func (*RequestReader) String 

func (r *RequestReader) String() string

func (*RequestReader) URI 

func (r *RequestReader) URI() http_service.IURIReader

type Response 

type Response struct {
	*ResponseHeader
	*fasthttp.Response
	// contains filtered or unexported fields
}

func NewResponse 

func NewResponse(ctx *fasthttp.RequestCtx) *Response

func (*Response) BodyLen 

func (r *Response) BodyLen() int

func (*Response) ClearError 

func (r *Response) ClearError()

func (*Response) GetBody 

func (r *Response) GetBody() []byte

func (*Response) HeadersString 

func (r *Response) HeadersString() string

func (*Response) ProxyStatus 

func (r *Response) ProxyStatus() string

func (*Response) ProxyStatusCode 

func (r *Response) ProxyStatusCode() int

原始的响应状态码

func (*Response) ResponseError 

func (r *Response) ResponseError() error

func (*Response) SetBody 

func (r *Response) SetBody(bytes []byte)

func (*Response) SetProxyStatus 

func (r *Response) SetProxyStatus(code int, status string)

func (*Response) SetStatus 

func (r *Response) SetStatus(code int, status string)

func (*Response) Status 

func (r *Response) Status() string

func (*Response) StatusCode 

func (r *Response) StatusCode() int

type ResponseHeader 

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

func NewResponseHeader 

func NewResponseHeader(header *fasthttp.ResponseHeader) *ResponseHeader

func (*ResponseHeader) AddHeader 

func (r *ResponseHeader) AddHeader(key, value string)

func (*ResponseHeader) DelHeader 

func (r *ResponseHeader) DelHeader(key string)

func (*ResponseHeader) GetHeader 

func (r *ResponseHeader) GetHeader(name string) string

func (*ResponseHeader) Headers 

func (r *ResponseHeader) Headers() http.Header

func (*ResponseHeader) SetHeader 

func (r *ResponseHeader) SetHeader(key, value string)

type URIRequest 

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

func NewURIRequest 

func NewURIRequest(uri *fasthttp.URI) *URIRequest

func (*URIRequest) AddQuery 

func (ur *URIRequest) AddQuery(key, value string)

func (*URIRequest) DelQuery 

func (ur *URIRequest) DelQuery(key string)

func (*URIRequest) GetQuery 

func (ur *URIRequest) GetQuery(key string) string

func (*URIRequest) Host 

func (ur *URIRequest) Host() string

func (*URIRequest) Path 

func (ur *URIRequest) Path() string

func (*URIRequest) RawQuery 

func (ur *URIRequest) RawQuery() string

func (*URIRequest) RawURL 

func (ur *URIRequest) RawURL() string

func (*URIRequest) RequestURI 

func (ur *URIRequest) RequestURI() string

func (*URIRequest) Scheme 

func (ur *URIRequest) Scheme() string

func (*URIRequest) SetHost 

func (ur *URIRequest) SetHost(host string)

func (*URIRequest) SetPath 

func (ur *URIRequest) SetPath(s string)

func (*URIRequest) SetQuery 

func (ur *URIRequest) SetQuery(key, value string)

func (*URIRequest) SetRawQuery 

func (ur *URIRequest) SetRawQuery(raw string)

func (*URIRequest) SetScheme 

func (ur *URIRequest) SetScheme(scheme string)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.