engine

Sep 18, 2026

Changes in this version

+ func ValidateIngress(ctx *Context, rules *manifest.Request, schemas map[string]manifest.Schema) *problem.Problem

type Context

+ func (c *Context) Body() any

+ func (c *Context) BodyMalformed() bool

+ func (c *Context) GoHandler(name string) (manifest.GoHandler, error)

+ func (c *Context) HTTPClient() *http.Client

+ func (c *Context) OpenAPISpec(format string) ([]byte, string, error)

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

+ func (c *Context) ResponseWriter() http.ResponseWriter

+ func (c *Context) SQL(name string) (*sql.DB, error)

+ func (c *Context) Schemas() map[string]manifest.Schema

+ func (c *Context) Scope() manifest.Scope

+ func (c *Context) SetBody(body any)

+ func (c *Context) SetPathParam(name string, val any)

+ func (c *Context) SetQueryParam(name string, val any)

+ func (c *Context) Telemetry() *telemetry.Telemetry

+ func (c *Context) Valkey(name string) (valkey.Client, error)

+ type Dependencies struct

+ HTTPClient *http.Client

+ Handlers map[string]manifest.GoHandler

+ SQL map[string]*sql.DB

+ Schemas map[string]manifest.Schema

+ Spec *openapi.Spec

+ Telemetry *telemetry.Telemetry

+ Valkey map[string]valkey.Client

type Engine

+ func (e *Engine) Telemetry() *telemetry.Telemetry

type Option

+ func WithGoHandler(name string, h manifest.GoHandler) Option

+ func WithHTTPClient(client *http.Client) Option

+ func WithTelemetry(t *telemetry.Telemetry) Option

Sep 17, 2026

Changes in this version

+ type Args map[string]any

+ func (a Args) Bind(dst any) error

+ func (a Args) GetOr[T any](key string, fallback T) T

+ func (a Args) Get[T any](key string) (T, bool)

+ func (a Args) Has(key string) bool

+ func (a Args) Slice[T any](key string) []T

+ type Context struct

+ func NewContext(r *http.Request, routePattern string, maxBytes int64) (*Context, error)

+ func (c *Context) EvalAny(expr hcl.Expression) (any, error)

+ func (c *Context) EvalBool(expr hcl.Expression) (bool, error)

+ func (c *Context) EvalContext() *hcl.EvalContext

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

+ func (c *Context) SetStepResult(name string, res any)

type Engine

+ func (e *Engine) SQL(name string) (*sql.DB, bool)

+ func (e *Engine) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ func (e *Engine) Valkey(name string) (valkey.Client, bool)

+ type Option func(*Engine)

+ func WithLogger(logger *slog.Logger) Option

+ func WithStep(name string, h StepHandler) Option

+ func WithValkey(name string, client valkey.Client) Option

type Step

+ Args Args

+ Name string

+ Request *http.Request

+ type StepHandler func(ctx context.Context, step *Step) (any, error)

Sep 7, 2026

retracted

Changes in this version

type Engine

+ func (e *Engine) Service() *service.Definition

+ type ErrorResponder struct

+ func NewErrorResponder(p service.Problem, h problem.Handler, logger *slog.Logger) *ErrorResponder

+ func (r *ErrorResponder) Respond(w http.ResponseWriter, req *http.Request, err error)

+ type GoStep struct

+ Args hcl.Expression

+ Name string

+ Registry *StepRegistry

+ Use string

+ func (s *GoStep) Run(execCtx *runtime.ExecutionContext, w http.ResponseWriter) (StepResult, error)

+ type Options struct

+ ConfigPath string

+ Logger *slog.Logger

+ ProblemHandler problem.Handler

+ StrictTyping bool

+ type Pipeline struct

+ func NewPipeline(steps ...Step) *Pipeline

+ func (p *Pipeline) Execute(execCtx *runtime.ExecutionContext, w http.ResponseWriter) error

+ type RespondStep struct

+ Body hcl.Expression

+ Condition hcl.Expression

+ Headers hcl.Expression

+ Status hcl.Expression

+ func (s *RespondStep) Run(execCtx *runtime.ExecutionContext, w http.ResponseWriter) (StepResult, error)

+ type SQLStep struct

+ Args hcl.Expression

+ Catches []service.SQLCatch

+ Name string

+ Pool *sqldb.Pool

+ Query string

+ func (s *SQLStep) Run(execCtx *runtime.ExecutionContext, w http.ResponseWriter) (StepResult, error)

+ type StarlarkStep struct

+ Name string

+ Source string

+ func (s *StarlarkStep) Run(execCtx *runtime.ExecutionContext, w http.ResponseWriter) (StepResult, error)

+ type Step interface

+ Run func(execCtx *runtime.ExecutionContext, w http.ResponseWriter) (StepResult, error)

+ type StepRegistry struct

+ func NewStepRegistry() *StepRegistry

+ func (r *StepRegistry) Get(name string) (runtime.StepHandler, bool)

+ func (r *StepRegistry) Register(name string, handler runtime.StepHandler) error

+ type StepResult struct

+ Terminated bool

Sep 2, 2026

retracted

Changes in this version

+ type Engine struct

+ func New(options core.Options) (*Engine, error)

+ func (e *Engine) Close() error

+ func (e *Engine) Handler() http.Handler

+ func (e *Engine) RegisterStep(name string, handler core.StepHandler) error

+ func (e *Engine) Server() core.Server

+ type PipelineExecutor struct

+ func NewPipelineExecutor(steps []parser.ParsedStep, goSteps map[string]core.StepHandler, ...) *PipelineExecutor

+ func (p *PipelineExecutor) Execute(w http.ResponseWriter, ctx *core.Context) error