api

Documentation

Index

• func BuildMCPHandler(version, commit, buildTime string) (*mcp.Handler, context.Context)
• func RunMCPStdio(version, commit, buildTime string)
• type Middleware
• type Server
  • func NewServer() *Server
  • func (s *Server) JobsSvc() *manager.Service
  • func (s *Server) Run(ctx context.Context, port int) error

Functions

func BuildMCPHandler

func BuildMCPHandler(version, commit, buildTime string) (*mcp.Handler, context.Context)

BuildMCPHandler initialises the connector layer (DB + connectors bootstrap) and returns a ready-to-serve MCP handler + admin context. Callers must either call ServeStdioOS (for the production stdio path) or ServeStdio with a custom reader/writer (for exec/test paths).

func RunMCPStdio

func RunMCPStdio(version, commit, buildTime string)

RunMCPStdio initialises the connector layer and serves MCP JSON-RPC over stdin/stdout. Intended for local clients (Claude Desktop, Cursor).

Types

type Middleware

type Middleware func(http.Handler) http.Handler

type Server

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

func NewServer

func NewServer() *Server

func (*Server) JobsSvc

func (s *Server) JobsSvc() *manager.Service

JobsSvc returns the manager.Service the API server owns. Exposed so the single-node `lab all` entrypoint can hand it to worker.RunScheduler — both the HTTP handlers and the cron loop then share one Service, avoiding the double-fire race two independent Services would have.

func (*Server) Run

func (s *Server) Run(ctx context.Context, port int) error

Run starts the HTTP server. Cancel ctx to trigger a graceful shutdown; returns nil on clean stop or the error from ListenAndServe / Shutdown otherwise. CLI callers wrap with signal.NotifyContext; in-process callers (system tray) cancel from the UI.