http_context

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2022 License: Apache-2.0 Imports: 18 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 *http_service.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) BodyInterface 

func (b *BodyRequestHandler) BodyInterface() (interface{}, error)

BodyInterface 获取请求体对象

func (*BodyRequestHandler) ContentType 

func (b *BodyRequestHandler) ContentType() string

ContentType 获取contentType

func (*BodyRequestHandler) Files 

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

Files 获取文件参数

func (*BodyRequestHandler) GetFile 

func (b *BodyRequestHandler) GetFile(key string) (file *http_service.FileHeader, has bool)

func (*BodyRequestHandler) GetForm 

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

GetForm 获取表单参数

func (*BodyRequestHandler) RawBody 

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

RawBody 获取raw数据

func (*BodyRequestHandler) SetFile 

func (b *BodyRequestHandler) SetFile(files map[string]*http_service.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

SetToForm 设置表单参数

type Context 

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

Context fasthttpRequestCtx

func NewContext 

func NewContext(ctx *fasthttp.RequestCtx) *Context

NewContext 创建Context

func (*Context) Context 

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

func (*Context) Finish 

func (ctx *Context) Finish()

Finish finish

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) SendTo 

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

func (*Context) Value 

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

func (*Context) WithValue 

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

type Finish 

type Finish interface {
	Finish() error
}

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.