Versions in this module Expand all Collapse all v0 v0.2.1 Mar 18, 2026 v0.2.0 Mar 17, 2026 Changes in this version + const MaxDrainSize + var CtxKeyConnectionState = struct{} + type ConnectionState struct + CancelFunc context.CancelFunc + Processing atomic.Bool + ReadHandler appcontext.ReadHandler + ReadTimeout time.Duration + Reader *bufio.Reader + RemoteAddr string + Writer *bufio.Writer + func NewConnectionState(readTimeout time.Duration) *ConnectionState + func (s *ConnectionState) Cancel() + func (s *ConnectionState) Deadline() (deadline time.Time, ok bool) + func (s *ConnectionState) Done() <-chan struct{} + func (s *ConnectionState) Err() error + func (s *ConnectionState) Reset() + func (s *ConnectionState) Value(key any) any + type Engine struct + Handler http.Handler + func NewEngine(handler http.Handler, opts ...Option) *Engine + func (e *Engine) AcquireConnectionState(s *ConnectionState) + func (e *Engine) ReleaseConnectionState(s *ConnectionState) + func (e *Engine) ServeConn(ctx context.Context, conn netpoll.Connection) error + type Option func(*Engine) + func WithBufferSize(size int) Option + func WithMaxDrainSize(size int64) Option + func WithRequestTimeout(d time.Duration) Option
Go to main page