runtime

package

Go to main page

Versions in this module

v0

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