Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentSummary ¶
type InvokeAgentInput ¶
type InvokeAgentOutput ¶
type ListAgentsOutput ¶
type ListAgentsOutput struct {
Agents []AgentSummary `json:"agents"`
}
type MCPHandler ¶
type MCPHandler struct {
// contains filtered or unexported fields
}
MCPHandler handles MCP requests and bridges them to A2A endpoints
func NewMCPHandler ¶
func NewMCPHandler(kubeClient client.Client, agentClients *a2a.AgentClientRegistry, authenticator auth.AuthProvider) (*MCPHandler, error)
NewMCPHandler creates a new MCP handler that bridges MCP tool calls directly to agent A2A clients, bypassing the controller's own HTTP A2A listener.
func (*MCPHandler) NotifyAgentsChanged ¶
func (h *MCPHandler) NotifyAgentsChanged(ctx context.Context)
NotifyAgentsChanged sends a resources/updated notification for kagent://agents to all subscribed clients. Called by A2ARegistrar when agents are added, updated, or removed.
func (*MCPHandler) ServeHTTP ¶
func (h *MCPHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
ServeHTTP implements http.Handler interface
Click to show internal directories.
Click to hide internal directories.