engine

package

v0.1.2 Latest Latest Go to latest Published: Sep 4, 2026 License: MIT Imports: 23 Imported by: 0

Details

Package engine provides route binding, HTTP multiplexing, and pipeline initialization.

This section is empty.

This section is empty.

This section is empty.

type Engine struct {
	// contains filtered or unexported fields
}

Engine is the central HTTP coordinator.

func New(options manifest.Options) (*Engine, error)

New initializes an Engine by parsing manifests, statically compiling services, and registering routes.

func (e *Engine) Close() error

Close gracefully closes all active database and cache connection pools.

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

Handler returns the underlying http.Handler multiplexer.

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

RegisterStep registers a named custom Go function for the pipeline runtime.

func (e *Engine) Server() manifest.Server

Server returns the server configuration with defaults applied.

type PipelineExecutor struct {
	// contains filtered or unexported fields
}

PipelineExecutor coordinates sequential pipeline step dispatching.

func NewPipelineExecutor(
	steps []parser.ParsedStep,
	goSteps map[string]runtime.StepHandler,
	sqlManager *connsql.Manager,
) *PipelineExecutor

NewPipelineExecutor creates a new instance of the pipeline runner.

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

Execute walks through configured steps sequentially, updating context state.