celeris

Apr 14, 2026

Changes in this version

+ var ErrDetached = errors.New("celeris: cannot write standard response on detached context")

+ var ErrServiceUnavailable = NewHTTPError(503, "Service Unavailable")

+ var ErrUnauthorized = NewHTTPError(401, "Unauthorized")

type Context

+ func (c *Context) SetWSDetachClose(fn func())

+ func (c *Context) SetWSErrorHandler(fn func(error))

+ func (c *Context) SetWSIdleDeadline(ns int64)

+ func (c *Context) StreamReader(code int, contentType string, r io.Reader) error

+ func (c *Context) UpgradeWebSocket(delivery func(data []byte)) bool

+ func (c *Context) WSRawWriteFn() func([]byte)

+ func (c *Context) WSReadPauser() (pause, resume func())

Apr 5, 2026

Changes in this version

+ func SetTestScheme(c *Context, scheme string)

Apr 5, 2026

Changes in this version

+ func AddTestParam(c *Context, key, value string)

+ func ReleaseTestContext(c *Context)

+ func SetTestFullPath(c *Context, path string)

+ func SetTestHandlers(c *Context, handlers []HandlerFunc)

+ func SetTestStartTime(c *Context, t time.Time)

+ func SetTestTrustedNets(c *Context, nets []*net.IPNet)

+ func TestStream(c *Context) *stream.Stream

type Context

+ func AcquireTestContext(s *stream.Stream) *Context

+ func (c *Context) FileFromFS(name string, fsys fs.FS) error

+ func (c *Context) SetMethod(m string)

+ func (c *Context) SetResponseHeaders(headers [][2]string)

+ func (c *Context) StatusBlob(contentType string, data []byte) error

+ func (c *Context) StatusJSON(v any) error

+ func (c *Context) StatusString(s string) error

+ func (c *Context) StatusXML(v any) error

type Server

+ func (s *Server) Pre(middleware ...HandlerFunc) *Server

+ type SkipHelper struct

+ func (s *SkipHelper) Init(paths []string, fn func(*Context) bool)

+ func (s *SkipHelper) ShouldSkip(c *Context) bool

Apr 4, 2026

Changes in this version

+ const RequestIDKey

+ func EscapeQuotedString(s string) string

type Config

+ TrustedProxies []string

type Server

+ func (s *Server) OnShutdown(fn func(ctx context.Context)) *Server

type StreamWriter

+ func (sw *StreamWriter) BytesWritten() int64

Apr 4, 2026

Changes in this version

type Context

+ func (c *Context) DiscardBufferedResponse()

+ func (c *Context) OnRelease(fn func())

+ func (c *Context) Protocol() string

+ func (c *Context) StartTime() time.Time

type Server

+ func (s *Server) OnError(handler func(c *Context, err error)) *Server

Apr 1, 2026

Changes in this version

type Context

+ func (c *Context) FormValueOK(name string) (string, bool)

+ func (c *Context) ParamDefault(key, defaultValue string) string

+ func (c *Context) QueryBool(key string, defaultValue bool) bool

+ func (c *Context) QueryInt64(key string, defaultValue int64) int64

Mar 31, 2026

Changes in this version

+ var ErrAcceptControlNotSupported = errors.New("celeris: engine does not support accept control")

type Config

+ MaxRequestBodySize int64

+ OnExpectContinue func(method, path string, headers [][2]string) bool

type Context

+ func (c *Context) ContentLength() int64

+ func (c *Context) DeleteCookie(name, path string)

+ func (c *Context) ResponseHeaders() [][2]string

+ func (c *Context) SetClientIP(ip string)

+ func (c *Context) SetHost(host string)

+ func (c *Context) SetRawQuery(q string)

+ func (c *Context) SetScheme(scheme string)

type Server

+ func (s *Server) PauseAccept() error

+ func (s *Server) ResumeAccept() error

Mar 30, 2026

Changes in this version

+ var ErrHijackNotSupported = stream.ErrHijackNotSupported

+ var ErrInvalidRedirectCode = errors.New("celeris: redirect status code must be 3xx")

+ func InheritListener(envVar string) (net.Listener, error)

+ func ToHandler(h HandlerFunc) http.Handler

type Config

+ BufferSize int

+ DisableKeepAlive bool

+ InitialWindowSize uint32

+ MaxConcurrentStreams uint32

+ MaxConns int

+ MaxFrameSize uint32

+ MaxHeaderBytes int

+ OnConnect func(addr string)

+ OnDisconnect func(addr string)

+ SocketRecvBuf int

+ SocketSendBuf int

type Context

+ func (c *Context) AcceptsEncodings(offers ...string) string

+ func (c *Context) AcceptsLanguages(offers ...string) string

+ func (c *Context) Attachment(filename string)

+ func (c *Context) BodyCopy() []byte

+ func (c *Context) BodyReader() io.Reader

+ func (c *Context) BufferResponse()

+ func (c *Context) BytesWritten() int

+ func (c *Context) CaptureResponse()

+ func (c *Context) Detach() (done func())

+ func (c *Context) FlushResponse() error

+ func (c *Context) Hijack() (net.Conn, error)

+ func (c *Context) Host() string

+ func (c *Context) Inline(filename string)

+ func (c *Context) IsTLS() bool

+ func (c *Context) IsWebSocket() bool

+ func (c *Context) IsWritten() bool

+ func (c *Context) Negotiate(offers ...string) string

+ func (c *Context) RawQuery() string

+ func (c *Context) RemoteAddr() string

+ func (c *Context) RequestHeaders() [][2]string

+ func (c *Context) Respond(code int, v any) error

+ func (c *Context) ResponseBody() []byte

+ func (c *Context) ResponseContentType() string

+ func (c *Context) ResponseStatus() int

+ func (c *Context) SetPath(p string)

+ func (c *Context) SetResponseBody(body []byte)

+ func (c *Context) StreamWriter() *StreamWriter

type Cookie

+ Expires time.Time

type Route

+ func (r *Route) Use(middleware ...HandlerFunc) *Route

type RouteGroup

+ func (g *RouteGroup) Static(prefix, root string) *Route

type Server

+ func (s *Server) StartWithListener(ln net.Listener) error

+ func (s *Server) StartWithListenerAndContext(ctx context.Context, ln net.Listener) error

+ func (s *Server) Static(prefix, root string) *Route

+ type StreamWriter struct

+ func (sw *StreamWriter) Close() error

+ func (sw *StreamWriter) Flush() error

+ func (sw *StreamWriter) Write(data []byte) (int, error)

+ func (sw *StreamWriter) WriteHeader(status int, headers [][2]string) error

Mar 12, 2026

Changes in this version

+ const DefaultMaxFormSize

+ const Version

+ var ErrAlreadyStarted = errors.New("celeris: server already started")

+ var ErrDuplicateRouteName = errors.New("celeris: duplicate route name")

+ var ErrEmptyBody = errors.New("celeris: empty request body")

+ var ErrNoCookie = errors.New("celeris: named cookie not present")

+ var ErrResponseWritten = errors.New("celeris: response already written")

+ var ErrRouteNotFound = errors.New("celeris: named route not found")

+ type Config struct

+ Addr string

+ DisableMetrics bool

+ Engine EngineType

+ IdleTimeout time.Duration

+ Logger *slog.Logger

+ MaxFormSize int64

+ Objective Objective

+ Protocol Protocol

+ ReadTimeout time.Duration

+ ShutdownTimeout time.Duration

+ Workers int

+ WriteTimeout time.Duration

+ type Context struct

+ func (c *Context) Abort()

+ func (c *Context) AbortWithStatus(code int) error

+ func (c *Context) AddHeader(key, value string)

+ func (c *Context) BasicAuth() (username, password string, ok bool)

+ func (c *Context) Bind(v any) error

+ func (c *Context) BindJSON(v any) error

+ func (c *Context) BindXML(v any) error

+ func (c *Context) Blob(code int, contentType string, data []byte) error

+ func (c *Context) Body() []byte

+ func (c *Context) ClientIP() string

+ func (c *Context) Context() context.Context

+ func (c *Context) Cookie(name string) (string, error)

+ func (c *Context) File(filePath string) error

+ func (c *Context) FileFromDir(baseDir, userPath string) error

+ func (c *Context) FormFile(name string) (multipart.File, *multipart.FileHeader, error)

+ func (c *Context) FormValue(name string) string

+ func (c *Context) FormValueOk(name string) (string, bool)

+ func (c *Context) FormValues(name string) []string

+ func (c *Context) FullPath() string

+ func (c *Context) Get(key string) (any, bool)

+ func (c *Context) HTML(code int, html string) error

+ func (c *Context) Header(key string) string

+ func (c *Context) IsAborted() bool

+ func (c *Context) JSON(code int, v any) error

+ func (c *Context) Keys() map[string]any

+ func (c *Context) Method() string

+ func (c *Context) MultipartForm() (*multipart.Form, error)

+ func (c *Context) Next() error

+ func (c *Context) NoContent(code int) error

+ func (c *Context) Param(key string) string

+ func (c *Context) ParamInt(key string) (int, error)

+ func (c *Context) ParamInt64(key string) (int64, error)

+ func (c *Context) Path() string

+ func (c *Context) Query(key string) string

+ func (c *Context) QueryDefault(key, defaultValue string) string

+ func (c *Context) QueryInt(key string, defaultValue int) int

+ func (c *Context) QueryParams() url.Values

+ func (c *Context) QueryValues(key string) []string

+ func (c *Context) Redirect(code int, url string) error

+ func (c *Context) Scheme() string

+ func (c *Context) Set(key string, value any)

+ func (c *Context) SetContext(ctx context.Context)

+ func (c *Context) SetCookie(cookie *Cookie)

+ func (c *Context) SetHeader(key, value string)

+ func (c *Context) Status(code int) *Context

+ func (c *Context) StatusCode() int

+ func (c *Context) Stream(code int, contentType string, r io.Reader) error

+ func (c *Context) String(code int, format string, args ...any) error

+ func (c *Context) XML(code int, v any) error

+ type Cookie struct

+ Domain string

+ HTTPOnly bool

+ MaxAge int

+ Name string

+ Path string

+ SameSite SameSite

+ Secure bool

+ Value string

+ type EngineInfo struct

+ Metrics EngineMetrics

+ Type EngineType

+ type EngineMetrics = engine.EngineMetrics

+ type EngineType engine.EngineType

+ const Adaptive

+ const Epoll

+ const IOUring

+ const Std

+ func (t EngineType) String() string

+ type HTTPError struct

+ Code int

+ Err error

+ Message string

+ func NewHTTPError(code int, message string) *HTTPError

+ func (e *HTTPError) Error() string

+ func (e *HTTPError) Unwrap() error

+ func (e *HTTPError) WithError(err error) *HTTPError

+ type HandlerFunc func(*Context) error

+ func Adapt(h http.Handler) HandlerFunc

+ func AdaptFunc(h http.HandlerFunc) HandlerFunc

+ type Objective resource.ObjectiveProfile

+ const Balanced

+ const Latency

+ const Throughput

+ func (o Objective) String() string

+ type Param struct

+ Key string

+ Value string

+ type Params []Param

+ func (ps Params) Get(key string) (string, bool)

+ type Protocol engine.Protocol

+ const Auto

+ const H2C

+ const HTTP1

+ func (p Protocol) String() string

+ type Route struct

+ func (r *Route) Name(name string) *Route

+ func (r *Route) TryName(name string) error

+ type RouteGroup struct

+ func (g *RouteGroup) Any(path string, handlers ...HandlerFunc) *RouteGroup

+ func (g *RouteGroup) DELETE(path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) GET(path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) Group(prefix string, middleware ...HandlerFunc) *RouteGroup

+ func (g *RouteGroup) HEAD(path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) Handle(method, path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) OPTIONS(path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) PATCH(path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) POST(path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) PUT(path string, handlers ...HandlerFunc) *Route

+ func (g *RouteGroup) Use(middleware ...HandlerFunc) *RouteGroup

+ type RouteInfo struct

+ HandlerCount int

+ Method string

+ Path string

+ type SameSite int

+ const SameSiteDefaultMode

+ const SameSiteLaxMode

+ const SameSiteNoneMode

+ const SameSiteStrictMode

+ func (s SameSite) String() string

+ type Server struct

+ func New(cfg Config) *Server

+ func (s *Server) Addr() net.Addr

+ func (s *Server) Any(path string, handlers ...HandlerFunc) *Server

+ func (s *Server) Collector() *observe.Collector

+ func (s *Server) DELETE(path string, handlers ...HandlerFunc) *Route

+ func (s *Server) EngineInfo() *EngineInfo

+ func (s *Server) GET(path string, handlers ...HandlerFunc) *Route

+ func (s *Server) Group(prefix string, middleware ...HandlerFunc) *RouteGroup

+ func (s *Server) HEAD(path string, handlers ...HandlerFunc) *Route

+ func (s *Server) Handle(method, path string, handlers ...HandlerFunc) *Route

+ func (s *Server) MethodNotAllowed(handler HandlerFunc) *Server

+ func (s *Server) NotFound(handler HandlerFunc) *Server

+ func (s *Server) OPTIONS(path string, handlers ...HandlerFunc) *Route

+ func (s *Server) PATCH(path string, handlers ...HandlerFunc) *Route

+ func (s *Server) POST(path string, handlers ...HandlerFunc) *Route

+ func (s *Server) PUT(path string, handlers ...HandlerFunc) *Route

+ func (s *Server) Routes() []RouteInfo

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

+ func (s *Server) Start() error

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

+ func (s *Server) URL(name string, params ...string) (string, error)

+ func (s *Server) URLMap(name string, params map[string]string) (string, error)

+ func (s *Server) Use(middleware ...HandlerFunc) *Server