router

Documentation

Index

• Constants
• Variables
• type RouteResult
• type Router
  • func NewRouter(toolRegistry ToolRegistry, serverReg registry.Registry, ...) Router
• type RouterError
  • func NewRouterError(code int, message string, err error) *RouterError
  • func (e *RouterError) Error() string
  • func (e *RouterError) Unwrap() error
• type ServerEntry
• type ToolEntry
• type ToolRegistry
  • func NewToolRegistry() ToolRegistry

Constants

const (
	ErrCodeMethodNotFound = -32601
	ErrCodeInvalidParams  = -32602
	ErrCodeInternalError  = -32603
)

Variables

var (
	ErrToolNotFound  = errors.New("tool not found in any registered server")
	ErrAmbiguousTool = errors.New("tool found in multiple servers")
	ErrServerOffline = errors.New("target server is offline")
	ErrRoutingFailed = errors.New("routing failed")
	ErrInvalidMethod = errors.New("invalid method name")
)

Types

type RouteResult

type RouteResult struct {
	Method   string
	ServerID string
	Server   *ServerEntry
	Error    error
}

type Router

type Router interface {
	Route(ctx context.Context, method string) (*ServerEntry, error)
	RouteBatch(ctx context.Context, methods []string) ([]*ServerEntry, []error)
	GetComplexityTier(ctx context.Context, method string) (string, error)
}

func NewRouter

func NewRouter(toolRegistry ToolRegistry, serverReg registry.Registry, logger interface{ Debug(msg string, args ...any) }) Router

type RouterError

type RouterError struct {
	Code    int
	Message string
	Err     error
}

func NewRouterError

func NewRouterError(code int, message string, err error) *RouterError

func (*RouterError) Error

func (e *RouterError) Error() string

func (*RouterError) Unwrap

func (e *RouterError) Unwrap() error

type ServerEntry

type ServerEntry = registry.ServerEntry

type ToolEntry

type ToolEntry struct {
	Name           string
	Namespace      string
	ServerID       string
	ComplexityTier string
}

type ToolRegistry

type ToolRegistry interface {
	RegisterTool(ctx context.Context, tool ToolEntry) error
	UnregisterTool(ctx context.Context, name string) error
	FindByNamespace(ctx context.Context, namespace string) ([]string, error)
	FindByToolName(ctx context.Context, toolName string) ([]string, error)
	FindServerForTool(ctx context.Context, toolName string) (string, error)
	ListTools(ctx context.Context) ([]ToolEntry, error)
}

func NewToolRegistry

func NewToolRegistry() ToolRegistry