nbhttp

Apr 10, 2024

retracted

Changes in this version

type BodyReader

+ func (br *BodyReader) Buffers() [][]byte

+ func (br *BodyReader) Engine() *Engine

+ func (br *BodyReader) Index() int

+ func (br *BodyReader) Left() int

+ func (br *BodyReader) RawBodyBuffers() [][]byte

type Client

+ Dial func(network, addr string) (net.Conn, error)

type ClientConn

+ Dial func(network, addr string) (net.Conn, error)

type Config

+ AsyncReadInPoller bool

+ IOExecute func(f func([]byte))

+ MaxHTTPBodySize int

type Engine

+ func (e *Engine) SetETAsyncRead()

+ func (e *Engine) SetLTSyncRead()

type Parser

+ ParserCloser ParserCloser

+ func (p *Parser) Parse(data []byte) error

+ type ParserCloser interface

+ CloseAndClean func(err error)

+ Parse func(data []byte) error

+ UnderlayerConn func() net.Conn

Feb 13, 2024

Changes in this version

type ClientProcessor

+ func (p *ClientProcessor) Clean(parser *Parser)

type EmptyProcessor

+ func (p *EmptyProcessor) Clean(parser *Parser)

type Parser

+ ReadCloser ReadCloser

+ func (p *Parser) CloseAndClean(err error)

+ func (p *Parser) UnderlayerConn() net.Conn

type Processor

+ Clean func(parser *Parser)

type ReadCloser

+ CloseAndClean func(err error)

+ UnderlayerConn func() net.Conn

type ServerProcessor

+ func (p *ServerProcessor) Clean(parser *Parser)

Nov 16, 2023

Changes in this version

+ type Conn struct

+ Parser *Parser

+ Trasfered bool

Oct 30, 2023

Changes in this version

type Engine

+ func (e *Engine) DialerOnline() int

May 22, 2023

Changes in this version

+ var ReadBufferPools = &sync.Map

+ func SyncExecutor(f func()) bool

type Config

+ EPOLLONESHOT uint32

+ EpollMod uint32

+ ReadBufferPool mempool.Allocator

May 14, 2023

Changes in this version

+ var ErrServiceOverload = errors.New("service overload")

type Config

+ WebsocketCompressor func() interface{ ... }

+ WebsocketDecompressor func() interface{ ... }

type Engine

+ func (engine *Engine) AddTransferredConn(nbc *nbio.Conn) error

Apr 12, 2023

Changes in this version

type ConfAddr

+ NListener int

type Config

+ WriteTimeout time.Duration

Dec 9, 2022

Changes in this version

type BodyReader

+ func (br *BodyReader) Reset() error

type Config

+ RetainHTTPBody bool

Nov 17, 2022

Changes in this version

type Config

+ Listen func(network, addr string) (net.Listener, error)

+ ListenUDP func(network string, laddr *net.UDPAddr) (*net.UDPConn, error)

Oct 30, 2022

Changes in this version

+ const DefaultBlockingReadBufferSize

+ const DefaultIOMod

+ const DefaultMaxBlockingOnline

+ const IOModBlocking

+ const IOModMixed

+ const IOModNonBlocking

type Config

+ BlockingReadBufferSize int

+ IOMod int

+ MaxBlockingOnline int

type Engine

+ func (engine *Engine) AddConnNonTLSBlocking(conn net.Conn, tlsConfig *tls.Config, decrease func())

+ func (engine *Engine) AddConnNonTLSNonBlocking(c net.Conn, tlsConfig *tls.Config, decrease func())

+ func (engine *Engine) AddConnTLSBlocking(conn net.Conn, tlsConfig *tls.Config, decrease func())

+ func (engine *Engine) AddConnTLSNonBlocking(conn net.Conn, tlsConfig *tls.Config, decrease func())

type Response

+ Parser *Parser

Sep 14, 2022

Changes in this version

type Config

+ TimerExecutor func(f func())

Sep 9, 2022

Changes in this version

type Parser

+ Reader ReadCloser

Mar 19, 2022

Changes in this version

type Config

+ MaxConnReadTimesPerEventLoop int

Oct 28, 2021

Changes in this version

+ type ConfAddr struct

+ Addr string

+ Network string

+ TLSConfig *tls.Config

type Config

+ AddrConfigs []ConfAddr

+ AddrConfigsTLS []ConfAddr

+ AddrsTLS []string

+ DisableSendfile bool

+ SupportServerOnly bool

type Engine

+ func (e *Engine) Start() error

+ func (e *Engine) Stop()

+ func (engine *Engine) AddConnNonTLS(c net.Conn)

+ func (engine *Engine) AddConnTLS(conn net.Conn, tlsConfig *tls.Config)

type Parser

+ ConnState ReadCloser

+ type ReadCloser interface

+ Close func(p *Parser, err error)

+ Read func(p *Parser, data []byte) error

Oct 9, 2021

Changes in this version

type Config

+ BodyAllocator mempool.Allocator

+ TLSAllocator tls.Allocator

type Engine

+ BodyAllocator mempool.Allocator

Sep 28, 2021

Changes in this version

+ const MaxInt

+ const MaxUint

+ var ErrClientClosed = errors.New("http client closed")

+ var ErrClientTimeout = errors.New("timeout")

+ var ErrClientUnsupportedSchema = errors.New("unsupported schema")

+ type Client struct

+ CheckRedirect func(req *http.Request, via []*http.Request) error

+ Engine *Engine

+ IdleConnTimeout time.Duration

+ Jar http.CookieJar

+ MaxConnsPerHost int32

+ Proxy func(*http.Request) (*url.URL, error)

+ TLSClientConfig *tls.Config

+ Timeout time.Duration

+ func (c *Client) Close()

+ func (c *Client) CloseWithError(err error)

+ func (c *Client) Do(req *http.Request, handler func(res *http.Response, conn net.Conn, err error))

+ type ClientConn struct

+ CheckRedirect func(req *http.Request, via []*http.Request) error

+ Engine *Engine

+ IdleConnTimeout time.Duration

+ Jar http.CookieJar

+ Proxy func(*http.Request) (*url.URL, error)

+ TLSClientConfig *tls.Config

+ Timeout time.Duration

+ func (c *ClientConn) Close()

+ func (c *ClientConn) CloseWithError(err error)

+ func (c *ClientConn) Do(req *http.Request, handler func(res *http.Response, conn net.Conn, err error))

+ func (c *ClientConn) OnClose(h func())

+ func (c *ClientConn) Reset()

type Config

+ Cancel func()

+ ClientExecutor func(f func())

+ Context context.Context

+ Handler http.Handler

+ ServerExecutor func(f func())

+ SupportClient bool

+ TLSConfig *tls.Config

+ type Engine struct

+ BaseCtx context.Context

+ Cancel func()

+ CheckUtf8 func(data []byte) bool

+ ExecuteClient func(f func())

+ MaxLoad int

+ MaxWebsocketFramePayloadSize int

+ ReleaseWebsocketPayload bool

+ func NewEngine(conf Config, v ...interface{}) *Engine

+ func NewEngineTLS(conf Config, v ...interface{}) *Engine

+ func (e *Engine) DataHandler(c *nbio.Conn, data []byte)

+ func (e *Engine) InitTLSBuffers()

+ func (e *Engine) OnClose(h func(c *nbio.Conn, err error))

+ func (e *Engine) OnOpen(h func(c *nbio.Conn))

+ func (e *Engine) OnStop(h func())

+ func (e *Engine) Online() int

+ func (e *Engine) SetTLSConfig(tlsConfig *tls.Config)

+ func (e *Engine) Shutdown(ctx context.Context) error

+ func (e *Engine) TLSBuffer(c *nbio.Conn) []byte

+ func (e *Engine) TLSConfig() *tls.Config

+ func (e *Engine) TLSDataHandler(c *nbio.Conn, data []byte)

type Parser

+ Engine *Engine

+ func (p *Parser) OnClose(h func(p *Parser, err error))

Sep 11, 2021

Changes in this version

type Server

+ func (s *Server) SetTLSConfig(config *tls.Config)

Aug 11, 2021

Changes in this version

type Parser

+ func (p *Parser) Execute(f func())

type Response

+ func (res *Response) WriteString(s string) (int, error)

Jul 19, 2021

Changes in this version

type ClientProcessor

+ func (p *ClientProcessor) Close()

type EmptyProcessor

+ func (p *EmptyProcessor) Close()

type Parser

+ Conn net.Conn

+ func (p *Parser) Close(err error)

type Processor

+ Close func()

type ServerProcessor

+ func (p *ServerProcessor) Close()

Jul 16, 2021

Changes in this version

+ var DefaultMaxWebsocketFramePayloadSize = 1024 * 32

type Config

+ MaxReadTimesPerEventLoop int

+ MaxWebsocketFramePayloadSize int

+ ReleaseWebsocketPayload bool

type Server

+ MaxWebsocketFramePayloadSize int

+ ReleaseWebsocketPayload bool

Jun 28, 2021

Changes in this version

type Server

+ CheckUtf8 func(data []byte) bool

Jun 8, 2021

Changes in this version

+ const H2HeaderLen

+ var DefaultHTTPReadLimit = 1024 * 1024 * 64

+ var DefaultHTTPWriteBufferSize = 1024 * 2

+ var DefaultKeepaliveTime = time.Second * 120

+ var DefaultMaxLoad = 1024 * 500

+ var DefaultMessageHandlerTaskIdleTime = time.Second * 60

+ var DefaultMinBufferSize = 1024 * 2

+ var DefaultTLSHandshakeTimeout = time.Second * 10

+ var ErrCRExpected = errors.New("CR character expected")

+ var ErrClosed = errors.New("closed")

+ var ErrInvalidCRLF = errors.New("invalid cr/lf at the end of line")

+ var ErrInvalidCharInHeader = errors.New("invalid character in header")

+ var ErrInvalidChunkSize = errors.New("invalid chunk size")

+ var ErrInvalidContentLength = errors.New("invalid ContentLength")

+ var ErrInvalidFragment = errors.New("invalid fragment")

+ var ErrInvalidH2HeaderR = errors.New("invalid http2 SM characters")

+ var ErrInvalidH2SM = errors.New("invalid http2 SM characters")

+ var ErrInvalidHTTPStatus = errors.New("invalid HTTP status")

+ var ErrInvalidHTTPStatusCode = errors.New("invalid HTTP status code")

+ var ErrInvalidHTTPVersion = errors.New("invalid HTTP version")

+ var ErrInvalidHost = errors.New("invalid host")

+ var ErrInvalidMethod = errors.New("invalid HTTP method")

+ var ErrInvalidPath = errors.New("invalid path")

+ var ErrInvalidPort = errors.New("invalid port")

+ var ErrInvalidQueryString = errors.New("invalid query string")

+ var ErrInvalidRequestURI = errors.New("invalid URL")

+ var ErrLFExpected = errors.New("LF character expected")

+ var ErrNilConn = errors.New("nil Conn")

+ var ErrTooLong = errors.New("invalid http message: too long")

+ var ErrTrailerExpected = errors.New("trailer expected")

+ var ErrUnexpectedContentLength = errors.New("unexpected content-length header")

+ type BodyReader struct

+ func NewBodyReader(buffer []byte) *BodyReader

+ func (br *BodyReader) Append(b []byte)

+ func (br *BodyReader) Close() error

+ func (br *BodyReader) RawBody() []byte

+ func (br *BodyReader) Read(p []byte) (int, error)

+ func (br *BodyReader) TakeOver() []byte

+ type ClientProcessor struct

+ func (p *ClientProcessor) Clear()

+ func (p *ClientProcessor) Conn() net.Conn

+ func (p *ClientProcessor) HandleExecute(executor func(index int, f func()))

+ func (p *ClientProcessor) HandleMessage(handler func(*http.Response))

+ func (p *ClientProcessor) OnBody(data []byte, needRelease bool)

+ func (p *ClientProcessor) OnComplete(parser *Parser)

+ func (p *ClientProcessor) OnContentLength(contentLength int)

+ func (p *ClientProcessor) OnHeader(key, value string)

+ func (p *ClientProcessor) OnMethod(method string)

+ func (p *ClientProcessor) OnProto(proto string) error

+ func (p *ClientProcessor) OnStatus(code int, status string)

+ func (p *ClientProcessor) OnTrailerHeader(key, value string)

+ func (p *ClientProcessor) OnURL(uri string) error

+ type Config struct

+ Addrs []string

+ EnableSendfile bool

+ KeepaliveTime time.Duration

+ LockListener bool

+ LockPoller bool

+ MaxLoad int

+ MaxWriteBufferSize int

+ MessageHandlerPoolSize int

+ MessageHandlerTaskIdleTime time.Duration

+ MinBufferSize int

+ NListener int

+ NParser int

+ NPoller int

+ Name string

+ Network string

+ ReadBufferSize int

+ ReadLimit int

+ type EmptyProcessor struct

+ func (p *EmptyProcessor) Clear()

+ func (p *EmptyProcessor) Conn() net.Conn

+ func (p *EmptyProcessor) HandleExecute(executor func(index int, f func()))

+ func (p *EmptyProcessor) HandleMessage(handler http.Handler)

+ func (p *EmptyProcessor) OnBody(data []byte, needRelease bool)

+ func (p *EmptyProcessor) OnComplete(parser *Parser)

+ func (p *EmptyProcessor) OnContentLength(contentLength int)

+ func (p *EmptyProcessor) OnHeader(key, value string)

+ func (p *EmptyProcessor) OnMethod(method string)

+ func (p *EmptyProcessor) OnProto(proto string) error

+ func (p *EmptyProcessor) OnStatus(code int, status string)

+ func (p *EmptyProcessor) OnTrailerHeader(key, value string)

+ func (p *EmptyProcessor) OnURL(uri string) error

+ type Hijacker interface

+ Hijack func() (net.Conn, error)

+ type Http2Upgrader struct

+ CheckOrigin func(r *http.Request) bool

+ HandshakeTimeout time.Duration

+ ReadLimit int64

+ Subprotocols []string

+ func (u *Http2Upgrader) Close(p *Parser, err error)

+ func (u *Http2Upgrader) Read(p *Parser, data []byte) error

+ func (u *Http2Upgrader) Upgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (net.Conn, error)

+ type Parser struct

+ Processor Processor

+ Server *Server

+ TLSBuffer []byte

+ Upgrader Upgrader

+ func NewParser(processor Processor, isClient bool, readLimit int, minBufferSize int) *Parser

+ func (p *Parser) Read(data []byte) error

+ type Processor interface

+ Clear func()

+ Conn func() net.Conn

+ HandleExecute func(executor func(index int, f func()))

+ OnBody func(data []byte, needRelease bool)

+ OnComplete func(parser *Parser)

+ OnContentLength func(contentLength int)

+ OnHeader func(key, value string)

+ OnMethod func(method string)

+ OnProto func(proto string) error

+ OnStatus func(code int, status string)

+ OnTrailerHeader func(key, value string)

+ OnURL func(uri string) error

+ func NewClientProcessor(conn net.Conn, handler func(*http.Response)) Processor

+ func NewEmptyProcessor() Processor

+ func NewServerProcessor(conn net.Conn, handler http.Handler, executor func(index int, f func()), ...) Processor

+ type Response struct

+ func NewResponse(parser *Parser, request *http.Request, enableSendfile bool) *Response

+ func (res *Response) Header() http.Header

+ func (res *Response) Hijack() (net.Conn, error)

+ func (res *Response) ReadFrom(r io.Reader) (n int64, err error)

+ func (res *Response) Write(data []byte) (int, error)

+ func (res *Response) WriteHeader(statusCode int)

+ type Server struct

+ Free func(buf []byte) error

+ Malloc func(size int) []byte

+ MaxLoad int

+ MessageHandlerExecutor func(index int, f func())

+ ParserExecutor func(index int, f func())

+ Realloc func(buf []byte, size int) []byte

+ func NewServer(conf Config, handler http.Handler, ...) *Server

+ func NewServerTLS(conf Config, handler http.Handler, ...) *Server

+ func (s *Server) OnClose(h func(c *nbio.Conn, err error))

+ func (s *Server) OnOpen(h func(c *nbio.Conn))

+ func (s *Server) OnStop(h func())

+ func (s *Server) Online() int

+ func (s *Server) Shutdown(ctx context.Context) error

+ type ServerProcessor struct

+ func (p *ServerProcessor) Clear()

+ func (p *ServerProcessor) Conn() net.Conn

+ func (p *ServerProcessor) HandleExecute(executor func(index int, f func()))

+ func (p *ServerProcessor) HandleMessage(handler http.Handler)

+ func (p *ServerProcessor) OnBody(data []byte, needRelease bool)

+ func (p *ServerProcessor) OnComplete(parser *Parser)

+ func (p *ServerProcessor) OnContentLength(contentLength int)

+ func (p *ServerProcessor) OnHeader(key, value string)

+ func (p *ServerProcessor) OnMethod(method string)

+ func (p *ServerProcessor) OnProto(proto string) error

+ func (p *ServerProcessor) OnStatus(code int, status string)

+ func (p *ServerProcessor) OnTrailerHeader(key, value string)

+ func (p *ServerProcessor) OnURL(uri string) error

+ type Upgrader interface

+ Close func(p *Parser, err error)

+ Read func(p *Parser, data []byte) error

+ Upgrade func(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (net.Conn, error)