vial

Aug 30, 2026

Changes in this version

type Option

+ func WithHTTPProtocols(protocols *http.Protocols) Option

Aug 8, 2026

Changes in this version

+ var ErrAsyncQueueFull = errors.New("async executor queue is full")

+ var ErrAsyncUnavailable = errors.New("async executor is unavailable")

+ var ErrInvalidOperation = errors.New("invalid async operation")

+ var ErrInvalidPreference = errors.New("invalid Prefer header")

+ var ErrOperationFinished = errors.New("operation is already finished")

+ var ErrOperationNotFound = errors.New("operation not found")

+ var ErrRetriesUnsupported = errors.New("async executor does not support retries")

+ func PrefersRespondAsync(header string) bool

type App

+ func (app *App) Async(executor AsyncExecutor)

+ func (app *App) AsyncExecutor() AsyncExecutor

+ type AsyncExecutor interface

+ Cancel func(context.Context, string) error

+ Get func(context.Context, string) (*Operation, error)

+ Submit func(context.Context, SubmitRequest) (*Operation, error)

+ type AsyncHandler func(context.Context, AsyncJob) (any, error)

+ type AsyncJob interface

+ Decode func(any) error

+ ID func() string

+ Metadata func() map[string]string

+ Name func() string

+ Progress func(context.Context, int) error

+ type AsyncLifecycleExecutor interface

+ Done func() <-chan error

+ Shutdown func(context.Context) error

+ Start func(context.Context) error

+ type AsyncMetrics struct

+ CancelledTotal uint64

+ CompletedTotal uint64

+ DurationCount uint64

+ DurationSecondsTotal float64

+ FailedTotal uint64

+ QueueDepth int64

+ QueueWaitCount uint64

+ QueueWaitSecondsTotal float64

+ RetriedTotal uint64

+ Running int64

+ SubmittedTotal uint64

+ type AsyncMetricsProvider interface

+ Metrics func(context.Context) (AsyncMetrics, error)

+ type AsyncPreference struct

+ RespondAsync bool

+ Wait time.Duration

+ WaitSpecified bool

+ func ParsePrefer(header string) (AsyncPreference, error)

+ type AsyncWaiter interface

+ Wait func(context.Context, string) (*Operation, error)

type Context

+ func (contextValue *Context) Accepted(operation *Operation) error

+ func (contextValue *Context) AcceptedAt(operation *Operation, statusURL string) error

+ func (contextValue *Context) Async() AsyncExecutor

+ func (contextValue *Context) Await(operation *Operation, maximum time.Duration) (current *Operation, completed bool, err error)

type Handler

+ func AsyncMetricsHandler(provider AsyncMetricsProvider) Handler

+ func OperationCancelHandler(executor AsyncExecutor, authorize OperationAuthorizer) Handler

+ func OperationStatusHandler(executor AsyncExecutor, authorize OperationAuthorizer) Handler

+ type Operation struct

+ Attempt int

+ CreatedAt time.Time

+ Error *OperationError

+ FinishedAt *time.Time

+ ID string

+ MaxAttempts int

+ Metadata map[string]string

+ Name string

+ NextAttemptAt *time.Time

+ Progress int

+ Result any

+ StartedAt *time.Time

+ Status OperationStatus

+ type OperationAuthorizer func(*Context, *Operation) error

+ type OperationError struct

+ Code string

+ Message string

+ func (operationError *OperationError) Error() string

+ type OperationStatus string

+ const OperationCancelled

+ const OperationFailed

+ const OperationPending

+ const OperationRetrying

+ const OperationRunning

+ const OperationSucceeded

+ func (status OperationStatus) Terminal() bool

+ type RetryPolicy struct

+ InitialBackoff time.Duration

+ MaxAttempts int

+ MaxBackoff time.Duration

+ type SubmitRequest struct

+ IdempotencyKey string

+ IdempotencyScope string

+ Metadata map[string]string

+ Name string

+ Payload any

+ Retry RetryPolicy

Aug 3, 2026

Changes in this version

type App

+ func (app *App) Health(path string)

+ func (app *App) Readiness(path string, checks ...HealthCheck)

type Context

+ func ContextFromRequest(request *http.Request) (*Context, bool)

+ func (context *Context) ClientIP() (netip.Addr, error)

+ func (context *Context) Flush() error

+ func (context *Context) ResponseController() *http.ResponseController

+ func (context *Context) SetWriteDeadline(deadline time.Time) error

type Group

+ func (group *Group) HandleHTTP(pattern string, handler http.Handler, options ...RouteOption)

+ type HealthCheck func(context.Context) error

type Option

+ func WithBaseContext(baseContext func(net.Listener) context.Context) Option

+ func WithConnContext(connContext func(context.Context, net.Conn) context.Context) Option

+ func WithHealthCheckTimeout(timeout time.Duration) Option

+ func WithMaxHeaderBytes(bytes int) Option

+ func WithServerErrorLog(logger *log.Logger) Option

+ func WithTrustedProxies(values ...string) Option

type Registrar

+ func (registrar *Registrar) Go(name string, task Task, options ...TaskOption)

+ func (registrar *Registrar) Health(path string)

+ func (registrar *Registrar) OnStart(hooks ...LifecycleHook)

+ func (registrar *Registrar) OnStop(hooks ...LifecycleHook)

+ func (registrar *Registrar) Readiness(path string, checks ...HealthCheck)

type Route

+ MiddlewareCount int

+ Parameters []string

type RouteOption

+ func RouteMiddleware(middleware ...Middleware) RouteOption

+ type ValueKey struct

+ func NewValueKey[T any](name string) *ValueKey[T]

+ func (key *ValueKey[T]) FromRequest(request *http.Request) (T, bool)

+ func (key *ValueKey[T]) Get(context *Context) (T, bool)

+ func (key *ValueKey[T]) Name() string

+ func (key *ValueKey[T]) Set(context *Context, value T)

Aug 1, 2026

Changes in this version

type Context

+ func (context *Context) FormValue(name string) (string, error)

+ type Validator interface

+ Validate func() error

Aug 1, 2026

Changes in this version

type App

+ func (app *App) Go(name string, task Task, options ...TaskOption)

+ type Task func(context.Context) error

+ type TaskOption struct

+ func NonCritical() TaskOption

Aug 1, 2026

Changes in this version

type App

+ func (app *App) OnStart(hooks ...LifecycleHook)

+ func (app *App) OnStop(hooks ...LifecycleHook)

+ func (app *App) Register(modules ...Module) error

+ type BindingError struct

+ Cause error

+ Field string

+ Source string

+ func (err *BindingError) Error() string

+ func (err *BindingError) Unwrap() error

type Context

+ func (context *Context) Bind(destination any) error

+ func (context *Context) BindCookie(destination any) error

+ func (context *Context) BindHeader(destination any) error

+ func (context *Context) BindPath(destination any) error

+ type LifecycleHook func(context.Context) error

+ type Module interface

+ Name func() string

+ Register func(*Registrar) error

+ type Registrar struct

+ func (registrar *Registrar) Group(prefix string) *Group

+ func (registrar *Registrar) Handle(method, path string, handler Handler, options ...RouteOption)

+ func (registrar *Registrar) HandleHTTP(pattern string, handler http.Handler, options ...RouteOption)

+ func (registrar *Registrar) Use(middleware ...Middleware)

type Route

+ Module string

+ Name string

+ type RouteOption struct

+ func RouteName(name string) RouteOption

Aug 1, 2026

Changes in this version

type Context

+ func (context *Context) BindForm(destination any) error

+ func (context *Context) BindQuery(destination any) error

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

type HTTPError

+ func MethodNotAllowed(code, message string) *HTTPError

Aug 1, 2026

Changes in this version

type App

+ func (app *App) Routes() ([]Route, error)

Aug 1, 2026

Changes in this version

+ func StatusCode(err error) int

+ type App struct

+ func New(options ...Option) *App

+ func (app *App) Build() error

+ func (app *App) Delete(path string, handler Handler)

+ func (app *App) Get(path string, handler Handler)

+ func (app *App) Group(prefix string) *Group

+ func (app *App) Handle(method, path string, handler Handler)

+ func (app *App) HandleHTTP(pattern string, handler http.Handler)

+ func (app *App) Options(path string, handler Handler)

+ func (app *App) Patch(path string, handler Handler)

+ func (app *App) Post(path string, handler Handler)

+ func (app *App) Put(path string, handler Handler)

+ func (app *App) Run(contextValue context.Context, address string) error

+ func (app *App) Serve(contextValue context.Context, listener net.Listener) error

+ func (app *App) ServeHTTP(writer http.ResponseWriter, request *http.Request)

+ func (app *App) SetErrorHandler(handler ErrorHandler)

+ func (app *App) Use(middleware ...Middleware)

+ type Context struct

+ func (context *Context) App() *App

+ func (context *Context) BindJSON(destination any) error

+ func (context *Context) BytesWritten() int64

+ func (context *Context) Committed() bool

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

+ func (context *Context) Header(name string) string

+ func (context *Context) JSON(status int, value any) error

+ func (context *Context) Logger() *slog.Logger

+ func (context *Context) NoContent(status int) error

+ func (context *Context) Param(name string) string

+ func (context *Context) Query(name string) string

+ func (context *Context) Redirect(status int, location string) error

+ func (context *Context) Request() *http.Request

+ func (context *Context) Response() http.ResponseWriter

+ func (context *Context) Route() *Route

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

+ func (context *Context) SetLogger(logger *slog.Logger)

+ func (context *Context) Status() int

+ func (context *Context) Text(status int, value string) error

+ type ErrorHandler func(*Context, error)

+ type Group struct

+ func (group *Group) Delete(path string, handler Handler)

+ func (group *Group) Get(path string, handler Handler)

+ func (group *Group) Group(prefix string) *Group

+ func (group *Group) Handle(method, path string, handler Handler)

+ func (group *Group) Options(path string, handler Handler)

+ func (group *Group) Patch(path string, handler Handler)

+ func (group *Group) Post(path string, handler Handler)

+ func (group *Group) Put(path string, handler Handler)

+ func (group *Group) Use(middleware ...Middleware)

+ type HTTPError struct

+ Cause error

+ Code string

+ Headers http.Header

+ Message string

+ Status int

+ func BadRequest(code, message string) *HTTPError

+ func Conflict(code, message string) *HTTPError

+ func Forbidden(code, message string) *HTTPError

+ func InternalServerError(cause error) *HTTPError

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

+ func NotFound(code, message string) *HTTPError

+ func RequestEntityTooLarge(code, message string) *HTTPError

+ func Unauthorized(code, message string) *HTTPError

+ func UnsupportedMediaType(code, message string) *HTTPError

+ func WrapHTTPError(status int, code, message string, cause error) *HTTPError

+ func (err *HTTPError) Error() string

+ func (err *HTTPError) Unwrap() error

+ type Handler func(*Context) error

+ type Middleware func(Handler) Handler

+ type Option func(*config)

+ func WithDisallowUnknownJSONFields(enabled bool) Option

+ func WithIdleTimeout(timeout time.Duration) Option

+ func WithLogger(logger *slog.Logger) Option

+ func WithMaxBodySize(bytes int64) Option

+ func WithReadHeaderTimeout(timeout time.Duration) Option

+ func WithReadTimeout(timeout time.Duration) Option

+ func WithShutdownTimeout(timeout time.Duration) Option

+ func WithWriteTimeout(timeout time.Duration) Option

+ type ResponseWriter struct

+ func (writer *ResponseWriter) BytesWritten() int64

+ func (writer *ResponseWriter) Committed() bool

+ func (writer *ResponseWriter) Flush()

+ func (writer *ResponseWriter) Hijack() (net.Conn, *bufio.ReadWriter, error)

+ func (writer *ResponseWriter) Push(target string, options *http.PushOptions) error

+ func (writer *ResponseWriter) ReadFrom(reader io.Reader) (int64, error)

+ func (writer *ResponseWriter) Status() int

+ func (writer *ResponseWriter) Unwrap() http.ResponseWriter

+ func (writer *ResponseWriter) Write(data []byte) (int, error)

+ func (writer *ResponseWriter) WriteHeader(status int)

+ type Route struct

+ Method string

+ Path string

+ Pattern string