Function runBackendServer

examples/server/proxy/main.go:52–69

Backend Server: Echoes received headers to verify propagation.

()

// Backend Server: Echoes received headers to verify propagation.
func runBackendServer() {
	server := mcp.NewServer(&mcp.Implementation{Name: "backend-server", Version: "1.0.0"}, nil)

	mcp.AddTool(server, &mcp.Tool{
		Name:        "echo_headers",
		Description: "Returns the headers received by the server",
	}, func(ctx context.Context, req *mcp.CallToolRequest, args struct{}) (*mcp.CallToolResult, any, error) {
		return nil, req.Extra.Header, nil
	})

	// Start the backend server on port 8082.
	log.Println("Starting Backend Server on :8082")
	if err := http.ListenAndServe(":8082", mcp.NewStreamableHTTPHandler(func(r *http.Request) *mcp.Server {
		return server
	}, nil)); err != nil {
		log.Fatal(err)
	}
}

// Proxy Server: Forwards requests to the backend with headers.
func runProxyServer(ctx context.Context) {