mcp

type CapabilityConfig ¶ added in v1.6.0

type CapabilityConfig struct {
	Tools       bool
	Resources   bool
	Prompts     bool
	Completions bool
	Tasks       bool
}

CapabilityConfig controls which implemented MCP server surfaces may be advertised during initialize.

The config is intentionally limited to surfaces that AppTheory currently implements. Unsupported MCP sub-capabilities such as listChanged and tasks are omitted until their concrete hooks exist. Resource subscription and logging are also omitted until AppTheory has a first-class outbound notification contract for notifications/resources/updated and notifications/message. Completion and task support are advertised only when their explicit hooks or stores are configured. That keeps capability negotiation fail-closed instead of allowing callers to overclaim unsupported behavior.

func DefaultCapabilityConfig() CapabilityConfig

type Completion ¶ added in v1.6.0

type Completion struct {
	Values  []string `json:"values"`
	Total   *int     `json:"total,omitempty"`
	HasMore *bool    `json:"hasMore,omitempty"`
}

Completion contains completion values returned to the client.

type CompletionArgument ¶ added in v1.6.0

type CompletionArgument struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

CompletionArgument identifies the argument currently being completed.

type CompletionContext ¶ added in v1.6.0

type CompletionContext struct {
	Arguments map[string]string `json:"arguments,omitempty"`
}

CompletionContext carries optional previously-resolved arguments.

type CompletionHook ¶ added in v1.6.0

type CompletionHook func(ctx context.Context, req CompletionRequest) (*CompletionResult, error)

CompletionHook handles a prompt or resource completion request.

type CompletionRef ¶ added in v1.6.0

type CompletionRef struct {
	Type string `json:"type"`
	Name string `json:"name,omitempty"`
	URI  string `json:"uri,omitempty"`
}

CompletionRef identifies the prompt or resource template being completed.

type CompletionRequest ¶ added in v1.6.0

type CompletionRequest struct {
	SessionID string             `json:"sessionId"`
	Ref       CompletionRef      `json:"ref"`
	Argument  CompletionArgument `json:"argument"`
	Context   CompletionContext  `json:"context,omitempty"`
}

CompletionRequest is passed to completion hooks.

type CompletionResult ¶ added in v1.6.0

type CompletionResult struct {
	Completion Completion `json:"completion"`
}

CompletionResult is the MCP completion/complete result.

type ContentBlock ¶

type ContentBlock struct {
	Type string `json:"type"` // "text", "image", "audio", "resource_link", "resource"

	// Text content (type = "text").
	Text string `json:"text,omitempty"`

	// Image/audio content (type = "image" or "audio").
	Data     string `json:"data,omitempty"`     // base64-encoded
	MimeType string `json:"mimeType,omitempty"` // e.g. "image/png"

	// Resource link content (type = "resource_link").
	URI         string `json:"uri,omitempty"`
	Name        string `json:"name,omitempty"`
	Title       string `json:"title,omitempty"`
	Description string `json:"description,omitempty"`
	Size        int64  `json:"size,omitempty"`

	// Embedded resource content (type = "resource").
	Resource *ResourceContent `json:"resource,omitempty"`
}

type CreateTaskResult ¶ added in v1.6.0

type CreateTaskResult struct {
	Meta map[string]any `json:"_meta,omitempty"`
	Task Task           `json:"task"`
}

CreateTaskResult is returned when AppTheory accepts a task-augmented request.

type DynamoSessionStore ¶

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

DynamoSessionStore implements SessionStore using DynamoDB via TableTheory.

func (d *DynamoSessionStore) Delete(ctx context.Context, id string) error

func (d *DynamoSessionStore) Get(ctx context.Context, id string) (*Session, error)

func (d *DynamoSessionStore) Put(ctx context.Context, session *Session) error

type DynamoStreamStore ¶ added in v0.20.0

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

DynamoStreamStore implements StreamStore using DynamoDB via TableTheory.

Subscribe uses strongly consistent reads plus short polling so separate server instances can replay and continue an active stream from shared state. Replay is bounded by each event record's ExpiresAt value at runtime; DynamoDB TTL and S3 lifecycle cleanup are backstops, not access checks. The strongest DeleteSession/Append race protection is enabled when the provided TableTheory DB implements TransactWrite, which is the production TableTheory path.

func (d *DynamoStreamStore) Append(ctx context.Context, sessionID, streamID string, data json.RawMessage) (string, error)

func (d *DynamoStreamStore) Close(ctx context.Context, sessionID, streamID string) error

func (d *DynamoStreamStore) Create(ctx context.Context, sessionID string) (string, error)

func (d *DynamoStreamStore) DeleteSession(ctx context.Context, sessionID string) error

func (d *DynamoStreamStore) StreamForEvent(ctx context.Context, sessionID, eventID string) (string, error)

func (d *DynamoStreamStore) Subscribe(ctx context.Context, sessionID, streamID, afterEventID string) (<-chan StreamEvent, error)

type DynamoTaskStore ¶ added in v1.6.0

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

DynamoTaskStore implements TaskStore using DynamoDB via TableTheory.

func (d *DynamoTaskStore) Cancel(ctx context.Context, lookup TaskLookup) (*TaskRecord, error)

func (d *DynamoTaskStore) Create(ctx context.Context, task TaskRecord) (*TaskRecord, error)

func (d *DynamoTaskStore) DeleteSession(ctx context.Context, sessionID string) error

func (d *DynamoTaskStore) Get(ctx context.Context, lookup TaskLookup) (*TaskRecord, error)

func (d *DynamoTaskStore) List(ctx context.Context, req TaskListRequest) (*TaskListResult, error)

func (d *DynamoTaskStore) Update(ctx context.Context, task TaskRecord) (*TaskRecord, error)

type Icon ¶ added in v0.14.1

type Icon struct {
	Src      string   `json:"src"`
	MimeType string   `json:"mimeType,omitempty"`
	Sizes    []string `json:"sizes,omitempty"`
	Theme    string   `json:"theme,omitempty"` // "light" or "dark"
}

type InitialSessionListenerBudgetOptions ¶ added in v0.25.0

type InitialSessionListenerBudgetOptions struct {
	SafetyBuffer time.Duration
	MaxDuration  time.Duration
}

InitialSessionListenerBudgetOptions configures how the initial GET /mcp session listener is capped against the Lambda remaining-time budget.

The option is explicit opt-in and applies only when GET /mcp is used without Last-Event-ID (the keepalive listener path). Resume/replay GET requests keep their existing behavior.

Zero values use the framework defaults:

• SafetyBuffer: 5s
• MaxDuration: 25s

type LoggingLevel ¶ added in v1.6.0

type LoggingLevel string

LoggingLevel is an MCP logging level.

const (
	LoggingLevelDebug     LoggingLevel = "debug"
	LoggingLevelInfo      LoggingLevel = "info"
	LoggingLevelNotice    LoggingLevel = "notice"
	LoggingLevelWarning   LoggingLevel = "warning"
	LoggingLevelError     LoggingLevel = "error"
	LoggingLevelCritical  LoggingLevel = "critical"
	LoggingLevelAlert     LoggingLevel = "alert"
	LoggingLevelEmergency LoggingLevel = "emergency"
)

type LoggingLevelHook ¶ added in v1.6.0

type LoggingLevelHook func(ctx context.Context, req LoggingLevelRequest) error

LoggingLevelHook handles a logging/setLevel request.

type LoggingLevelRequest ¶ added in v1.6.0

type LoggingLevelRequest struct {
	SessionID string       `json:"sessionId"`
	Level     LoggingLevel `json:"level"`
}

LoggingLevelRequest identifies a logging/setLevel request for a session.

type MemorySessionStore ¶

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

MemorySessionStore is an in-memory SessionStore for testing and local development.

func NewMemorySessionStore(opts ...MemorySessionStoreOption) *MemorySessionStore

func (m *MemorySessionStore) Delete(_ context.Context, id string) error

func (m *MemorySessionStore) Get(_ context.Context, id string) (*Session, error)

func (m *MemorySessionStore) Put(_ context.Context, session *Session) error

type MemorySessionStoreOption ¶

type MemorySessionStoreOption func(*MemorySessionStore)

MemorySessionStoreOption configures a MemorySessionStore.

func WithClock(c apptheory.Clock) MemorySessionStoreOption

type MemoryStreamStore ¶ added in v0.11.1

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

MemoryStreamStore is an in-memory StreamStore for testing and local development.

It assigns monotonically increasing numeric event IDs per session (as strings).

func NewMemoryStreamStore(opts ...MemoryStreamStoreOption) *MemoryStreamStore

func (m *MemoryStreamStore) Append(_ context.Context, sessionID, streamID string, data json.RawMessage) (string, error)

func (m *MemoryStreamStore) Close(_ context.Context, sessionID, streamID string) error

func (m *MemoryStreamStore) Create(_ context.Context, sessionID string) (string, error)

func (m *MemoryStreamStore) DeleteSession(_ context.Context, sessionID string) error

func (m *MemoryStreamStore) StreamForEvent(_ context.Context, sessionID, eventID string) (string, error)

func (m *MemoryStreamStore) Subscribe(ctx context.Context, sessionID, streamID, afterEventID string) (<-chan StreamEvent, error)

type MemoryStreamStoreOption ¶ added in v0.11.1

type MemoryStreamStoreOption func(*MemoryStreamStore)

func WithStreamIDGenerator(gen apptheory.IDGenerator) MemoryStreamStoreOption

type MemoryTaskStore ¶ added in v1.6.0

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

MemoryTaskStore is an in-memory TaskStore for testing and local development.

func NewMemoryTaskStore() *MemoryTaskStore

func (m *MemoryTaskStore) Cancel(_ context.Context, lookup TaskLookup) (*TaskRecord, error)

func (m *MemoryTaskStore) Create(_ context.Context, task TaskRecord) (*TaskRecord, error)

func (m *MemoryTaskStore) DeleteSession(_ context.Context, sessionID string) error

func (m *MemoryTaskStore) Get(_ context.Context, lookup TaskLookup) (*TaskRecord, error)

func (m *MemoryTaskStore) List(_ context.Context, req TaskListRequest) (*TaskListResult, error)

func (m *MemoryTaskStore) Update(_ context.Context, task TaskRecord) (*TaskRecord, error)

type OriginValidator ¶ added in v0.11.1

type OriginValidator func(origin string) bool

OriginValidator validates an HTTP Origin header value.

If a request includes an Origin header and the validator returns false, the server should reject the request (fail closed).

func AllowOrigins(origins ...string) OriginValidator

type PromptArgument ¶ added in v0.11.0

type PromptArgument struct {
	Name        string `json:"name"`
	Title       string `json:"title,omitempty"`
	Description string `json:"description,omitempty"`
	Required    bool   `json:"required,omitempty"`
}

PromptArgument defines an argument a prompt can accept.

type PromptDef ¶ added in v0.11.0

type PromptDef struct {
	Name        string           `json:"name"`
	Title       string           `json:"title,omitempty"`
	Description string           `json:"description,omitempty"`
	Arguments   []PromptArgument `json:"arguments,omitempty"`
}

PromptDef defines an MCP prompt's metadata.

type PromptHandler ¶ added in v0.11.0

type PromptHandler func(ctx context.Context, args json.RawMessage) (*PromptResult, error)

PromptHandler renders a prompt given optional arguments.

type PromptMessage ¶ added in v0.11.0

type PromptMessage struct {
	Role    string       `json:"role"`
	Content ContentBlock `json:"content"`
}

PromptMessage is a single message returned from prompts/get.

type PromptRegistry ¶ added in v0.11.0

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

PromptRegistry manages registered MCP prompts.

func NewPromptRegistry() *PromptRegistry

func (r *PromptRegistry) Get(ctx context.Context, name string, args json.RawMessage) (*PromptResult, error)

func (r *PromptRegistry) Len() int

func (r *PromptRegistry) List() []PromptDef

func (r *PromptRegistry) RegisterPrompt(def PromptDef, handler PromptHandler) error

type PromptResult ¶ added in v0.11.0

type PromptResult struct {
	Description string          `json:"description,omitempty"`
	Messages    []PromptMessage `json:"messages"`
}

PromptResult is the result payload returned from prompts/get.

type RPCError ¶

type RPCError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
	Data    any    `json:"data,omitempty"`
}

RPCError is a JSON-RPC 2.0 error object.

type RelatedTaskMetadata ¶ added in v1.6.0

type RelatedTaskMetadata struct {
	TaskID string `json:"taskId"`
}

RelatedTaskMetadata is the MCP _meta entry that associates messages with a task.

type Request ¶

type Request struct {
	JSONRPC string          `json:"jsonrpc"`
	ID      any             `json:"id,omitempty"`
	Method  string          `json:"method"`
	Params  json.RawMessage `json:"params,omitempty"`
}

Request is a JSON-RPC 2.0 request message.

func ParseBatchRequest(data []byte) ([]*Request, error)

func ParseRequest(data []byte) (*Request, error)

type ResourceContent ¶ added in v0.11.0

type ResourceContent struct {
	URI      string `json:"uri"`
	MimeType string `json:"mimeType,omitempty"`
	Text     string `json:"text,omitempty"`
	Blob     string `json:"blob,omitempty"`
}

ResourceContent is a single content item returned from resources/read.

Exactly one of Text or Blob should be set. Blob is expected to be a base64-encoded payload (client-decoded).

type ResourceDef ¶ added in v0.11.0

type ResourceDef struct {
	URI         string `json:"uri"`
	Name        string `json:"name"`
	Title       string `json:"title,omitempty"`
	Description string `json:"description,omitempty"`
	MimeType    string `json:"mimeType,omitempty"`
	Size        int64  `json:"size,omitempty"`
}

ResourceDef defines an MCP resource's metadata.

type ResourceHandler ¶ added in v0.11.0

type ResourceHandler func(ctx context.Context) ([]ResourceContent, error)

ResourceHandler resolves and returns the content for a resource.

type ResourceRegistry ¶ added in v0.11.0

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

ResourceRegistry manages registered MCP resources.

func NewResourceRegistry() *ResourceRegistry

func (r *ResourceRegistry) Len() int

func (r *ResourceRegistry) List() []ResourceDef

func (r *ResourceRegistry) Read(ctx context.Context, uri string) ([]ResourceContent, error)

func (r *ResourceRegistry) RegisterResource(def ResourceDef, handler ResourceHandler) error

type ResourceSubscription ¶ added in v1.6.0

type ResourceSubscription struct {
	SessionID string `json:"sessionId"`
	URI       string `json:"uri"`
}

ResourceSubscription identifies a resource subscription request for a session.

type ResourceSubscriptionHook ¶ added in v1.6.0

type ResourceSubscriptionHook func(ctx context.Context, sub ResourceSubscription) error

ResourceSubscriptionHook handles a resources/subscribe or resources/unsubscribe request.

type Response ¶

type Response struct {
	JSONRPC string    `json:"jsonrpc"`
	ID      any       `json:"id"`
	Result  any       `json:"result,omitempty"`
	Error   *RPCError `json:"error,omitempty"`
}

Response is a JSON-RPC 2.0 response message.

func NewErrorResponse(id any, code int, message string) *Response

func NewResultResponse(id any, result any) *Response

func ParseResponse(data []byte) (*Response, error)

type SSEEvent ¶

type SSEEvent struct {
	Data any
}

SSEEvent is a progress event emitted by a streaming tool handler.

type Server ¶

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

Server is the MCP protocol handler. It dispatches JSON-RPC 2.0 messages to the appropriate MCP method handlers (initialize, tools/list, tools/call).

func NewServer(name, version string, opts ...ServerOption) *Server

func (s *Server) Handler() apptheory.Handler

func (s *Server) Prompts() *PromptRegistry

func (s *Server) Registry() *ToolRegistry

func (s *Server) Resources() *ResourceRegistry

type ServerOption ¶

type ServerOption func(*Server)

ServerOption configures a Server.

func WithCapabilityConfig(config CapabilityConfig) ServerOption

func WithCompletionHooks(promptHook, resourceHook CompletionHook) ServerOption

func WithInitialSessionListenerBudget(opts InitialSessionListenerBudgetOptions) ServerOption

func WithLogger(logger *slog.Logger) ServerOption

func WithLoggingLevelHook(hook LoggingLevelHook) ServerOption

func WithOriginValidator(v OriginValidator) ServerOption

func WithResourceSubscriptionHooks(subscribe, unsubscribe ResourceSubscriptionHook) ServerOption

func WithServerIDGenerator(gen apptheory.IDGenerator) ServerOption

func WithSessionStore(store SessionStore) ServerOption

func WithStreamStore(store StreamStore) ServerOption

func WithTaskRuntime(opts TaskRuntimeOptions) ServerOption

type Session ¶

type Session struct {
	ID        string            `json:"id"`
	CreatedAt time.Time         `json:"createdAt"`
	ExpiresAt time.Time         `json:"expiresAt"`
	Data      map[string]string `json:"data,omitempty"`
}

Session holds per-session state for an MCP connection.

type SessionStore ¶

type SessionStore interface {
	Get(ctx context.Context, id string) (*Session, error)
	Put(ctx context.Context, session *Session) error
	Delete(ctx context.Context, id string) error
}

SessionStore is the interface for session persistence backends.

func NewDynamoSessionStore(db tablecore.DB) SessionStore

type StreamEvent ¶ added in v0.11.1

type StreamEvent struct {
	ID   string
	Data json.RawMessage
}

StreamEvent is a single server->client JSON-RPC message framed as an SSE event.

ID is the SSE event id (used for resumability via Last-Event-ID). Data is the raw JSON payload (a single JSON-RPC message).

type StreamStore ¶ added in v0.11.1

type StreamStore interface {
	Create(ctx context.Context, sessionID string) (streamID string, err error)
	Append(ctx context.Context, sessionID, streamID string, data json.RawMessage) (eventID string, err error)
	Close(ctx context.Context, sessionID, streamID string) error

	// Subscribe streams events after afterEventID. If afterEventID is empty,
	// it streams from the beginning. If afterEventID is present, it must belong
	// to the requested stream.
	Subscribe(ctx context.Context, sessionID, streamID, afterEventID string) (<-chan StreamEvent, error)

	// StreamForEvent returns the stream id that the given event id belongs to.
	StreamForEvent(ctx context.Context, sessionID, eventID string) (streamID string, err error)

	// DeleteSession removes all stream state for a session.
	DeleteSession(ctx context.Context, sessionID string) error
}

StreamStore persists stream events so a disconnected client can replay them via GET + Last-Event-ID.

func NewDynamoStreamStore(db tablecore.DB) StreamStore

type StreamingToolHandler ¶

type StreamingToolHandler func(ctx context.Context, args json.RawMessage, emit func(SSEEvent)) (*ToolResult, error)

StreamingToolHandler is a tool handler that can emit progress events via SSE.

type Task ¶ added in v1.6.0

type Task struct {
	TaskID        string     `json:"taskId"`
	Status        TaskStatus `json:"status"`
	StatusMessage string     `json:"statusMessage,omitempty"`
	CreatedAt     time.Time  `json:"createdAt"`
	LastUpdatedAt time.Time  `json:"lastUpdatedAt"`
	TTL           *int64     `json:"ttl"`
	PollInterval  *int64     `json:"pollInterval,omitempty"`
}

Task is the MCP task state returned by task operations.

type TaskListRequest ¶ added in v1.6.0

type TaskListRequest struct {
	SessionID string `json:"sessionId"`
	Cursor    string `json:"cursor,omitempty"`
	Limit     int    `json:"limit,omitempty"`
}

TaskListRequest scopes a task listing to the active MCP session.

type TaskListResult ¶ added in v1.6.0

type TaskListResult struct {
	Tasks      []Task `json:"tasks"`
	NextCursor string `json:"nextCursor,omitempty"`
}

TaskListResult is the MCP tasks/list result.

type TaskLookup ¶ added in v1.6.0

type TaskLookup struct {
	SessionID string `json:"sessionId"`
	TaskID    string `json:"taskId"`
}

TaskLookup scopes a task lookup to the active MCP session.

type TaskMetadata ¶ added in v1.6.0

type TaskMetadata struct {
	TTL *int64 `json:"ttl,omitempty"`
}

TaskMetadata is the MCP request parameter used to request task-augmented execution.

type TaskRecord ¶ added in v1.6.0

type TaskRecord struct {
	SessionID string          `json:"sessionId"`
	Method    string          `json:"method"`
	ToolName  string          `json:"toolName,omitempty"`
	Task      Task            `json:"task"`
	Result    json.RawMessage `json:"result,omitempty"`
	Error     *RPCError       `json:"error,omitempty"`
}

TaskRecord is the durable representation stored by TaskStore implementations.

type TaskRuntimeOptions ¶ added in v1.6.0

type TaskRuntimeOptions struct {
	Store                  TaskStore
	DefaultTTL             time.Duration
	MaxTTL                 time.Duration
	PollInterval           time.Duration
	ListLimit              int
	ModelImmediateResponse string
}

TaskRuntimeOptions configures task-augmented MCP execution.

type TaskStatus ¶ added in v1.6.0

type TaskStatus string

TaskStatus is an MCP task lifecycle state.

const (
	TaskStatusWorking       TaskStatus = "working"
	TaskStatusInputRequired TaskStatus = "input_required"
	TaskStatusCompleted     TaskStatus = "completed"
	TaskStatusFailed        TaskStatus = "failed"
	TaskStatusCanceled      TaskStatus = "cancel" + "led"
)

type TaskStore ¶ added in v1.6.0

type TaskStore interface {
	Create(ctx context.Context, task TaskRecord) (*TaskRecord, error)
	Get(ctx context.Context, lookup TaskLookup) (*TaskRecord, error)
	Update(ctx context.Context, task TaskRecord) (*TaskRecord, error)
	List(ctx context.Context, req TaskListRequest) (*TaskListResult, error)
	Cancel(ctx context.Context, lookup TaskLookup) (*TaskRecord, error)
	DeleteSession(ctx context.Context, sessionID string) error
}

TaskStore persists MCP task state. Implementations must bind every operation to the supplied SessionID and fail closed if a task belongs to a different authorization context.

func NewDynamoTaskStore(db tablecore.DB) TaskStore

type TaskSupport ¶ added in v1.6.0

type TaskSupport string

TaskSupport declares whether a tool can be invoked through MCP task augmentation.

const (
	TaskSupportForbidden TaskSupport = "forbidden"
	TaskSupportOptional  TaskSupport = "optional"
	TaskSupportRequired  TaskSupport = "required"
)

type ToolAnnotations ¶ added in v0.14.1

type ToolAnnotations struct {
	Title           string `json:"title,omitempty"`
	ReadOnlyHint    *bool  `json:"readOnlyHint,omitempty"`
	DestructiveHint *bool  `json:"destructiveHint,omitempty"`
	IdempotentHint  *bool  `json:"idempotentHint,omitempty"`
	OpenWorldHint   *bool  `json:"openWorldHint,omitempty"`
}

type ToolDef ¶

type ToolDef struct {
	Name        string           `json:"name"`
	Title       string           `json:"title,omitempty"`
	Description string           `json:"description,omitempty"`
	Annotations *ToolAnnotations `json:"annotations,omitempty"`

	Icons        []Icon          `json:"icons,omitempty"`
	Execution    *ToolExecution  `json:"execution,omitempty"`
	InputSchema  json.RawMessage `json:"inputSchema"`
	OutputSchema json.RawMessage `json:"outputSchema,omitempty"`
}

ToolDef defines an MCP tool's metadata and input schema.

type ToolExecution ¶ added in v0.14.1

type ToolExecution struct {
	// TaskSupport indicates if the tool supports task-augmented execution.
	// Values: "forbidden", "optional", "required".
	TaskSupport TaskSupport `json:"taskSupport,omitempty"`
}

type ToolHandler ¶

type ToolHandler func(ctx context.Context, args json.RawMessage) (*ToolResult, error)

ToolHandler is the function signature for tool implementations.

type ToolRegistry ¶

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

ToolRegistry manages registered MCP tools.

func NewToolRegistry() *ToolRegistry

func (r *ToolRegistry) Call(ctx context.Context, name string, args json.RawMessage) (*ToolResult, error)

func (r *ToolRegistry) CallStreaming(ctx context.Context, name string, args json.RawMessage, emit func(SSEEvent)) (*ToolResult, error)

func (r *ToolRegistry) Len() int

func (r *ToolRegistry) List() []ToolDef

func (r *ToolRegistry) RegisterStreamingTool(def ToolDef, handler StreamingToolHandler) error

func (r *ToolRegistry) RegisterTool(def ToolDef, handler ToolHandler) error

type ToolResult ¶

type ToolResult struct {
	Content           []ContentBlock `json:"content"`
	IsError           bool           `json:"isError,omitempty"`
	StructuredContent map[string]any `json:"structuredContent,omitempty"`
}

ToolResult is the result of a tool invocation.