Versions in this module Expand all Collapse all v0 v0.2.1 Oct 9, 2026 v0.2.0 Oct 8, 2026 Changes in this version + const DefaultWebSocketRouteKey + const RouteConnect + const RouteDefault + const RouteDisconnect + const Version + var BadRequest = handler.BadRequest + var Conflict = handler.Conflict + var Forbidden = handler.Forbidden + var Gone = handler.Gone + var Invalid = handler.Invalid + var Issue = handler.Issue + var NotFound = handler.NotFound + var NotImplemented = handler.NotImplemented + var ServiceUnavailable = handler.ServiceUnavailable + var Status = handler.Status + var Statusf = handler.Statusf + var TooManyRequests = handler.TooManyRequests + var Unauthorized = handler.Unauthorized + var UnprocessableEntity = handler.UnprocessableEntity + var WrapWithStatus = handler.Wrap + func AddGuard(app *App, name string, g Guard) + func ConnectionID(ctx context.Context) string + func Consume(app *App, sourceID string, ...) + func CustomTag(handlerName string) string + func Delete[In, Out any](app *App, route string, h HandlerFunc[In, Out], opts ...RegisterOption) + func EventFrom(ctx context.Context) (*handler.Event, bool) + func Get[In, Out any](app *App, route string, h HandlerFunc[In, Out], opts ...RegisterOption) + func HTTP(app *App, method, route string, ...) + func HTTPTag(method, route string) string + func Handler[In, Out any](app *App, name string, h HandlerFunc[In, Out], opts ...RegisterOption) + func Invoke[In, Out any](app *App, name string, h HandlerFunc[In, Out], opts ...RegisterOption) + func NormaliseRoute(route string) string + func OnConnect[In, Out any](app *App, h HandlerFunc[In, Out], opts ...RegisterOption) + func OnDisconnect[In, Out any](app *App, h HandlerFunc[In, Out], opts ...RegisterOption) + func OnMessage[In, Out any](app *App, route string, h HandlerFunc[In, Out], opts ...RegisterOption) + func Patch[In, Out any](app *App, route string, h HandlerFunc[In, Out], opts ...RegisterOption) + func Post[In, Out any](app *App, route string, h HandlerFunc[In, Out], opts ...RegisterOption) + func Put[In, Out any](app *App, route string, h HandlerFunc[In, Out], opts ...RegisterOption) + func RequestID(ctx context.Context) string + func Run(app *App) + func RunContext(ctx context.Context, app *App) error + func Schedule(app *App, sourceID string, ...) + func SourceTag(sourceID, handlerName string) string + func WebSocketEventFrom(ctx context.Context) (*handler.WebSocketMessage, bool) + func WebSocketSenderFrom(ctx context.Context) (handler.WebSocketSender, bool) + func WebSocketTag(routeKey, route string) string + func WithEvent(ctx context.Context, ev *handler.Event) context.Context + type App struct + func New(opts ...Option) *App + func (a *App) Adapter() serverless.Adapter + func (a *App) Config() *config.Service + func (a *App) Err() error + func (a *App) Extracting() bool + func (a *App) HandlerLimits() map[string]int + func (a *App) Logger() telemetry.Logger + func (a *App) Manifest() *manifest.Manifest + func (a *App) Pipeline(reg *Registration) layer.Next + func (a *App) ReconcileTags(blueprint []BlueprintHandler) ([]string, error) + func (a *App) RecordResourceRef(kind resources.Kind, name string) + func (a *App) Registry() *Registry + func (a *App) Resolver() serverless.Resolver + func (a *App) ResourceError(err error) + func (a *App) ResourceProvider() resources.Provider + func (a *App) ResourceRefs() map[resources.Kind][]string + type BlueprintHandler struct + Name string + PublishedName string + Tag string + type Guard = guard.Guard + type HandlerFunc func(ctx context.Context, in In) (Out, error) + type Mode string + const ModeExtract + const ModeRuntime + const ModeServerless + func DetectMode() Mode + type Option func(*options) + func WithAdapter(a serverless.Adapter) Option + func WithConfig(svc *config.Service) Option + func WithLayers(layers ...layer.Layer) Option + func WithLogger(l telemetry.Logger) Option + func WithResourceProvider(p resources.Provider) Option + func WithValidator(v Validator) Option + func WithWebSocketRouteKey(key string) Option + type RegisterOption func(*registerOptions) + func MaxConcurrent(n int) RegisterOption + func Named(name string) RegisterOption + func ProtectedBy(guards ...string) RegisterOption + func Public() RegisterOption + func PublishedAs(name string) RegisterOption + func SkipValidation() RegisterOption + func Uses(resourceNames ...string) RegisterOption + func ValidateWith(v Validator) RegisterOption + func With(layers ...layer.Layer) RegisterOption + type Registration struct + FromBlueprint bool + FuncPath string + Guards []string + Handler handler.Func + Kind handler.Kind + Layers []layer.Layer + MaxConcurrent int + Method string + Name string + Public bool + PublishedName string + Route string + RouteKey string + SourceFile string + SourceID string + SourceLine int + Tag string + Uses []string + type Registry struct + func NewRegistry() *Registry + func (r *Registry) Add(reg *Registration) error + func (r *Registry) All() []*Registration + func (r *Registry) ByName(name string) (*Registration, bool) + func (r *Registry) Get(tag string) (*Registration, bool) + func (r *Registry) Len() int + func (r *Registry) OfKind(kind handler.Kind) []*Registration + func (r *Registry) Retag(from, to string) + func (r *Registry) Tags() []string + type SelfValidating interface + Validate func() error + type StatusCoder = handler.StatusCoder + type StatusError = handler.StatusError + type UnresolvedHandlerError struct + Declared []string + Names []string + func (e *UnresolvedHandlerError) Error() string + type ValidationError = handler.ValidationError + type ValidationIssue = handler.ValidationIssue + type Validator interface + Validate func(input any) error
Go to main page