runtime

package

Go to main page

Versions in this module

v0

v0.5.0

Sep 1, 2026

Changes in this version

+ const MetaDeniedBy

+ const MetaDenyReason

+ func HTTPHeaders(next http.Handler) http.Handler

+ func HeadersFromContext(ctx context.Context) http.Header

+ func NewOwnedID() string

+ func OwnerRoutedParam(toolName string) (paramName string, ok bool)

+ func OwnerRoutedPathRegistered(prefix string) bool

+ func PeerAllowed(hostPort string) bool

+ func PublicBaseURL() string

+ func RegisterOwnerRoutedPath(prefix string, fn PathOwnerExtractor)

+ func RegisterTool(t ToolInfo)

+ func ResetOwnerRoutedForTest()

+ func ResetOwnerRoutedPathsForTest()

+ func ResetToolsForTest()

+ func SelfHostPort() string

+ func SetPeerProvider(fn func() []string)

+ func SetPeers(hosts []string)

+ func SetPublicBaseURL(base string)

+ func ToolText(text string) *mcp.CallToolResult

+ func WithHeaders(ctx context.Context, h http.Header) context.Context

+ func WithPathOwnerRouting(next http.Handler) http.Handler

+ func WithSubject(ctx context.Context, s *Subject) context.Context

+ type Call struct

+ Args json.RawMessage

+ Headers http.Header

+ Labels map[string]string

+ LogID string

+ Meta map[string]any

+ Method string

+ Subject *Subject

+ Tool string

+ Tools func() []ToolInfo

+ func (c *Call) SetMeta(key string, val any)

type Config

+ Match string

+ Peers []string

+ RequiredPlugins []string

+ type Handler func(ctx context.Context, c *Call) (*Result, error)

+ func Chain(mws []Middleware, final Handler) Handler

+ type Middleware func(next Handler) Handler

+ type PathOwnerExtractor func(r *http.Request) string

type RegisterOptions

+ Match string

+ func (o RegisterOptions) Compile() (RegisterOptions, error)

+ func (o RegisterOptions) Counts() (registered, filtered int)

+ type Registry struct

+ func New(cfg Config, registrar Registrar) *Registry

+ func NewRegistry(cfg Config) *Registry

+ func (r *Registry) Config(dst any) error

+ func (r *Registry) Handlers() (mcpHandler http.Handler, routes map[string]http.Handler, err error)

+ func (r *Registry) Middlewares() []Middleware

+ func (r *Registry) Named(name string)

+ func (r *Registry) OnBuild(fn func() error)

+ func (r *Registry) OnStop(fn func())

+ func (r *Registry) PluginNames() []string

+ func (r *Registry) RegisterCounts() (registered, filtered int)

+ func (r *Registry) Route(pattern string, h http.Handler)

+ func (r *Registry) RoutePublic(pattern string, h http.Handler)

+ func (r *Registry) Routes() map[string]http.Handler

+ func (r *Registry) RunStop(ctx context.Context)

+ func (r *Registry) Server() *mcp.Server

+ func (r *Registry) Start(ctx context.Context) error

+ func (r *Registry) Tool(add func(s *mcp.Server))

+ func (r *Registry) Use(mw Middleware)

+ type Result struct

+ List *mcp.ListToolsResult

+ Tool *mcp.CallToolResult

+ func DenyResult(c *Call, by, reason string) *Result

+ func ListResult(l *mcp.ListToolsResult) *Result

+ func TextResult(text string) *Result

+ type Subject struct

+ ID string

+ Labels map[string]string

+ Token string

+ func SubjectFromContext(ctx context.Context) *Subject

+ type TokenAuthz struct

+ func NewTokenAuthz(cfg TokenAuthzConfig) (*TokenAuthz, error)

+ func (a *TokenAuthz) HTTPMiddleware(next http.Handler) http.Handler

+ func (a *TokenAuthz) IdentityHeaders() []string

+ func (a *TokenAuthz) Middleware() Middleware

+ func (a *TokenAuthz) ResolveIdentity(get func(name string) string) string

+ func (a *TokenAuthz) SubjectOf(token string, get func(name string) string) (*Subject, bool)

+ func (a *TokenAuthz) TokenName(token string) (name string, ok bool)

+ type TokenAuthzConfig struct

+ IdentityHeaders []string

+ Tokens []TokenConfig

+ TrustIdentityHeader bool

+ type TokenConfig struct

+ Allow []string

+ Applicant string

+ Deny []string

+ Identity string

+ Name string

+ Token string

+ type ToolInfo struct

+ Labels map[string]string

+ Name string

+ Pkg string

+ func LookupTool(name string) (ToolInfo, bool)

+ func Tools() []ToolInfo

+ func (t ToolInfo) AllLabels() map[string]string

v0.4.0

Aug 20, 2026

Changes in this version

+ func NewOwnedSpillID() string

+ func OwnerOf(id string) (hostPort string, ok bool)

+ func RegisterOwnerRouted(toolName, paramName string)

+ func SpillDir() string

+ func WithOwnerRouting(next http.Handler) http.Handler

v0.3.1

Aug 13, 2026

v0.3.0

Aug 13, 2026

v0.2.0

Aug 12, 2026

Changes in this version

+ var LocalSpillExplore func(id, op string, lineOffset, limit int, pattern, jqExpr string, ...) (map[string]any, error)

+ func NewSpillIDForOwnerTest(hostPort string) string

+ func SetSpillPeer(token string, timeoutMS int)

+ func SetSpillPeerProvider(fn func() []string)

+ func SetSpillPeers(hosts []string)

+ func SpillDirForTest() string

+ func SpillExploreEndpoint() http.Handler

+ func SpillOwner(id string) (hostPort string, ok bool)

+ func SpillPeerAllowed(hostPort string) bool

+ func SpillPeerTimeout() time.Duration

+ func SpillPeerToken() string

+ func SpillSelfHostPort() string

type SpillConfig

+ PeerHosts []string

+ PeerTimeoutMS int

+ PeerToken string

v0.1.0

Aug 6, 2026

Changes in this version

+ var ShutdownHooks []func()

+ var StartupHooks []func(context.Context)

+ func AnyInputSchema[T any]() *jsonschema.Schema

+ func AuthzMiddleware(authz *Authz) mcp.Middleware

+ func BuildServer(cfg Config, registrar Registrar) *mcp.Server

+ func HTTPAuditHeaders(next http.Handler) http.Handler

+ func HTTPAuthContext(next http.Handler, authz *Authz) http.Handler

+ func HTTPLogID(next http.Handler) http.Handler

+ func InitAuditConfig(path string)

+ func InitLogConfig(path string)

+ func InitSpillConfig(path string)

+ func InitSpillStore(ctx context.Context, dir string, ttl spillTTLConfig)

+ func LogIDFromContext(ctx context.Context) string

+ func LoggingMiddleware() mcp.Middleware

+ func MCPHandler(cfg Config, s *mcp.Server) (http.Handler, error)

+ func MaybeSpill(toolName string, raw any, structured any) (*mcp.CallToolResult, any, error)

+ func NewAuthzHandler(s *mcp.Server, authz *Authz) http.Handler

+ func NewSpillID() string

+ func RegisterMeta(m ToolMeta)

+ func RegisterSpillResource(s *mcp.Server)

+ func ResolveSpillPath(id string) (string, bool)

+ func Run(ctx context.Context, cfg Config, registrar Registrar) error

+ func RunShutdownHooks()

+ func SetAuditHeaders(names []string)

+ func SetAuditLogger(l Logger)

+ func SetLogIDHeader(name string)

+ func SetSpillBaseURL(base string)

+ func SetSpillThreshold(tokens int)

+ func SpillDownloadHandler() http.Handler

+ func SpillDownloadURLFor(id string) string

+ func SpillHandler() http.Handler

+ func SpillResult(toolName string, out any) (*mcp.CallToolResult, error)

+ func ToolError(err error) *mcp.CallToolResult

+ func WithAuthContext(ctx context.Context, ac AuthContext) context.Context

+ func WithLogID(ctx context.Context, id string) context.Context

+ type AuditConfig struct

+ Headers []string

+ func LoadAuditConfig(path string) (AuditConfig, error)

+ type AuthContext struct

+ Caps TokenCaps

+ Identity string

+ TokenName string

+ func AuthFromContext(ctx context.Context) (AuthContext, bool)

+ type Authz struct

+ func NewAuthz(cfg AuthzConfig) *Authz

+ func (a *Authz) CapsOf(token string) (TokenCaps, bool)

+ func (a *Authz) IdentityHeaders() []string

+ func (a *Authz) ResolveIdentity(get func(name string) string) string

+ type AuthzConfig struct

+ IdentityHeaders []string

+ RiskAllowlist map[string][]string

+ Tokens []TokenEntry

+ func LoadAuthzConfig(path string) (AuthzConfig, error)

+ func (c AuthzConfig) Validate() error

+ type Capability int

+ const ReadOnly

+ const ReadWrite

+ type Config struct

+ Addr string

+ AuthzEnabled bool

+ ConfigPath string

+ Enable []string

+ PublicBaseURL string

+ SpillDir string

+ Tags []string

+ Transport string

+ type Field struct

+ Key string

+ Value string

+ func String(key, val string) Field

+ type LogConfig struct

+ LogIDHeader string

+ func LoadLogConfig(path string) (LogConfig, error)

+ type Logger interface

+ Notice func(msg string, fields ...Field)

+ Warning func(msg string, fields ...Field)

+ type RegisterOptions struct

+ Enable []string

+ Tags []string

+ func (o RegisterOptions) Allow(pkg string, tags []string) bool

+ type Registrar func(s *mcp.Server, opts RegisterOptions)

+ type RiskAuthorizer interface

+ CanRun func(identity string, level RiskLevel) bool

+ type RiskLevel int

+ const RiskHigh

+ const RiskLow

+ const RiskMedium

+ const RiskNone

+ func ParseRisk(s string) (RiskLevel, bool)

+ func (r RiskLevel) String() string

+ type SpillConfig struct

+ MaxResultTokens int

+ func LoadSpillConfig(path string) (SpillConfig, error)

+ type SpillFormat string

+ const FormatJSON

+ const FormatJSONL

+ const FormatText

+ type TokenCaps struct

+ Name string

+ Read RiskLevel

+ ReadOK bool

+ Write RiskLevel

+ WriteOK bool

+ type TokenEntry struct

+ Applicant string

+ Name string

+ Read string

+ Token string

+ Write string

+ type ToolMeta struct

+ Capability Capability

+ Name string

+ Risk RiskLevel

+ func LookupMeta(name string) (ToolMeta, bool)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL