README
¶
Documentation
¶
Index ¶
- Constants
- Variables
- func WithAddr(addr string) config
- func WithBalancingRand() config
- func WithManagerNum(num int) config
- func WithMaxWorkerNum(num int) config
- func WithReadLimit(num int) config
- func WithTcpBuff(num int) config
- func WithWsConfig(cfg websocket.Config) config
- type BodyReader
- type Engine
- func (e *Engine) Get(uri string, handler func(ctx *kernel.Context, request *Request))
- func (e *Engine) GetGroup(uriGroup string) *GetGroup
- func (e *Engine) GetWebsocket(uri string, handler *kernel.Actor, args ...interface{})
- func (e *Engine) Post(uri string, handler func(ctx *kernel.Context, request *Request))
- func (e *Engine) PostGroup(uriGroup string) *PostGroup
- func (e *Engine) Run() error
- type GetGroup
- type Group
- type Parser
- type PostGroup
- type Request
- func (r *Request) AddBody(body []byte)
- func (r *Request) AddCookie(name, value string)
- func (r *Request) AddCookieExpire(name, value string, Second int)
- func (r *Request) AddHead(name, value string)
- func (r *Request) AddJsonBody(rs interface{})
- func (r *Request) CacheTime(time int)
- func (r *Request) FormValue(key string) (value string)
- func (r *Request) FormValues(key string) (values []string)
- func (r *Request) Json() ejson.Json
- func (r *Request) Lookup(key string) (value string)
- func (r *Request) RemoteIP() string
- func (r *Request) Reply(statusCode int, body []byte) error
- func (r *Request) Reply304(ETag string)
- func (r *Request) ResponseWriter() http.ResponseWriter
- func (r *Request) SetCookie(name, value string)
- func (r *Request) SetCookieExpire(name, value string, Second int)
- func (r *Request) SetHead(name, value string)
Constants ¶
View Source
const ( // MaxUint . MaxUint = ^uint(0) // MaxInt . MaxInt = int64(int(MaxUint >> 1)) )
Variables ¶
View Source
var ( // ErrClosed . ErrClosed = errors.New("closed") // ErrInvalidCRLF . ErrInvalidCRLF = errors.New("invalid cr/lf at the end of line") // ErrInvalidHTTPVersion . ErrInvalidHTTPVersion = errors.New("invalid HTTP version") // ErrInvalidHTTPStatusCode . ErrInvalidHTTPStatusCode = errors.New("invalid HTTP status code") // ErrInvalidHTTPStatus . ErrInvalidHTTPStatus = errors.New("invalid HTTP status") // ErrInvalidMethod . ErrInvalidMethod = errors.New("invalid HTTP method") // ErrInvalidRequestURI . ErrInvalidRequestURI = errors.New("invalid URL") // ErrInvalidHost . ErrInvalidHost = errors.New("invalid host") // ErrInvalidPort . ErrInvalidPort = errors.New("invalid port") // ErrInvalidPath . ErrInvalidPath = errors.New("invalid path") // ErrInvalidQueryString . ErrInvalidQueryString = errors.New("invalid query string") // ErrInvalidFragment . ErrInvalidFragment = errors.New("invalid fragment") // ErrCRExpected . ErrCRExpected = errors.New("CR character expected") // ErrLFExpected . ErrLFExpected = errors.New("LF character expected") // ErrInvalidCharInHeader . ErrInvalidCharInHeader = errors.New("invalid character in header") // ErrUnexpectedContentLength . ErrUnexpectedContentLength = errors.New("unexpected content-length header") // ErrInvalidContentLength . ErrInvalidContentLength = errors.New("invalid ContentLength") // ErrInvalidChunkSize . ErrInvalidChunkSize = errors.New("invalid chunk size") // ErrTrailerExpected . ErrTrailerExpected = errors.New("trailer expected") // ErrTooLong . ErrTooLong = errors.New("invalid http message: too long") )
View Source
var ( // ErrInvalidH2SM . ErrInvalidH2SM = errors.New("invalid http2 SM characters") // ErrInvalidH2HeaderR . ErrInvalidH2HeaderR = errors.New("invalid http2 SM characters") )
View Source
var ( // ErrClientUnsupportedSchema . ErrClientUnsupportedSchema = errors.New("unsupported schema") // ErrClientTimeout . ErrClientTimeout = errors.New("timeout") // ErrClientClosed . ErrClientClosed = errors.New("http client closed") )
View Source
var (
DefaultHTTPReadLimit = 20 * 1024 * 1024
)
View Source
var ( // ErrNilConn . ErrNilConn = errors.New("nil Conn") )
Functions ¶
func WithAddr ¶
func WithAddr(addr string) config
如果你仅仅想监听内网ip，或者多个端口，使用这个 WithAddr("127.0.0.1:8080") WithAddr(":8081")
func WithManagerNum ¶
func WithManagerNum(num int) config
func WithMaxWorkerNum ¶
func WithMaxWorkerNum(num int) config
func WithReadLimit ¶
func WithReadLimit(num int) config
func WithTcpBuff ¶
func WithTcpBuff(num int) config
func WithWsConfig ¶
Types ¶
type BodyReader ¶
type BodyReader struct {
// contains filtered or unexported fields
}
BodyReader .
func NewBodyReader ¶
func NewBodyReader(buffer *bpool.Buff) *BodyReader
NewBodyReader creates a BodyReader.
func (*BodyReader) RawBody ¶
func (br *BodyReader) RawBody() []byte
func (*BodyReader) Read ¶
func (br *BodyReader) Read(p []byte) (int, error)
Read implements io.Reader.
func (*BodyReader) TakeOver ¶
func (br *BodyReader) TakeOver() *bpool.Buff
type Engine ¶
type Engine struct {
// contains filtered or unexported fields
}
func (*Engine) GetGroup ¶
GetGroup 返回一个url组 用法 e := New("web",8080) g := e.Group("/v1") // 组为根目录 host/v1
{
g.Get("/login",handler) // 响应url： host/v1/login
}
func (*Engine) GetWebsocket ¶
type Parser ¶
Parser .
type Request ¶
func (*Request) AddCookieExpire ¶
func (*Request) AddJsonBody ¶
func (r *Request) AddJsonBody(rs interface{})
func (*Request) FormValues ¶
返回表单多个values
func (*Request) ResponseWriter ¶
func (r *Request) ResponseWriter() http.ResponseWriter
func (*Request) SetCookieExpire ¶
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.