Queue the Next-phase agent streaming item and the a2a multi-skill gap that
block a real consumer from retiring its bespoke planner / A2A handler. The
architecture-review pass re-ranks from here.
* gateway/mcp: configurable initialize + named not-found
NewHandler takes HandlerOptions: WithServerInfo(name, version) and WithProtocolVersion set the initialize response so a product can brand the endpoint instead of advertising go-micro-mcp/2024-11-05. ManualResolver's not-found error now includes the tool name.
* gateway/mcp: configurable initialize + named not-found
NewHandler takes HandlerOptions: WithServerInfo(name, version) and WithProtocolVersion set the initialize response so a product can brand the endpoint instead of advertising go-micro-mcp/2024-11-05. ManualResolver's not-found error now includes the tool name.
* gateway/mcp: richer resolver Call + spec-correct HTTP handler
Resolver.Call now returns (*CallResult, error): a tool that ran but failed sets CallResult.IsError (returned as a tools/call result with isError:true, per the MCP spec), while a protocol/pre-check failure returns an error -- an *RPCError carries a specific JSON-RPC code. The HTTP handler also answers notifications/* (and id-less requests) with 204 and no body.
* gateway/mcp: richer resolver Call + spec-correct HTTP handler
Resolver.Call now returns (*CallResult, error): a tool that ran but failed sets CallResult.IsError (returned as a tools/call result with isError:true, per the MCP spec), while a protocol/pre-check failure returns an error -- an *RPCError carries a specific JSON-RPC code. The HTTP handler also answers notifications/* (and id-less requests) with 204 and no body.
* gateway/mcp: richer resolver Call + spec-correct HTTP handler
Resolver.Call now returns (*CallResult, error): a tool that ran but failed sets CallResult.IsError (returned as a tools/call result with isError:true, per the MCP spec), while a protocol/pre-check failure returns an error -- an *RPCError carries a specific JSON-RPC code. The HTTP handler also answers notifications/* (and id-less requests) with 204 and no body.
* gateway/mcp: swappable Resolver + mountable JSON-RPC HTTP handler
Adds a Resolver interface (Manual/Registry) so the tool source is
pluggable, and NewHandler(resolver) serving standard MCP JSON-RPC over
HTTP as an http.Handler you can mount on your own server. Neither
resolver exposes the internal store/broker tools. Additive — the
existing Serve() path is unchanged.
* gateway/mcp: swappable Resolver + mountable JSON-RPC HTTP handler
Adds a Resolver interface (Manual/Registry) so the tool source is
pluggable, and NewHandler(resolver) serving standard MCP JSON-RPC over
HTTP as an http.Handler you can mount on your own server. Neither
resolver exposes the internal store/broker tools. Additive — the
existing Serve() path is unchanged.
* gateway/mcp: swappable Resolver + mountable JSON-RPC HTTP handler
Adds a Resolver interface (Manual/Registry) so the tool source is
pluggable, and NewHandler(resolver) serving standard MCP JSON-RPC over
HTTP as an http.Handler you can mount on your own server. Neither
resolver exposes the internal store/broker tools. Additive — the
existing Serve() path is unchanged.
Streaming is implemented now (v6.3.3); the old test expected
ErrStreamingUnsupported and failed. Replace it with a real SSE streaming
test (httptest) that also asserts stream_options.include_usage and the
final usage chunk.
* ai/atlascloud: surface token usage on streams
Request stream_options.include_usage and return the final usage chunk
as a Response with Usage set, so streaming callers can record usage.
* ai/openai: surface token usage on streams
Request stream_options.include_usage and return the final usage chunk
as a Response with Usage set, so streaming callers can record usage.
* Initial plan
* fix: remove extra blank line in ai/anthropic/anthropic.go (gofmt)
---------
Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
* ai: add WithMaxTokens option
Let callers cap response length; providers send max_tokens when set
(anthropic keeps its 8192 default otherwise).
* ai: add WithMaxTokens option
Let callers cap response length; providers send max_tokens when set
(anthropic keeps its 8192 default otherwise).
* ai: add WithMaxTokens option
Let callers cap response length; providers send max_tokens when set
(anthropic keeps its 8192 default otherwise).
* ai: add WithMaxTokens option
Let callers cap response length; providers send max_tokens when set
(anthropic keeps its 8192 default otherwise).
* ai/atlascloud: thread Request.Messages into the request
Fold conversation history (req.Messages) between the system prompt and
the final user prompt so multi-turn context reaches the model.
Refs #3292
* ai/openai: thread Request.Messages into the request
Fold conversation history (req.Messages) between the system prompt and
the final user prompt so multi-turn context reaches the model.
Refs #3292
* ai/anthropic: thread Request.Messages into the request
Fold conversation history (req.Messages) between the system prompt and
the final user prompt so multi-turn context reaches the model.
Refs #3292
Asim Aslam