Struct WorkflowServer 

pub struct WorkflowServer { /* private fields */ }

Built-in MCP server for executing OxiFY workflows

This server exposes workflows as MCP tools, allowing external clients like Claude Desktop to invoke workflow executions.

Features

• Auto-generates tool schemas from workflow metadata
• Supports custom input schemas per workflow
• Configurable tool naming prefix
• Thread-safe workflow registration

Example

use oxify_mcp::servers::WorkflowServer;
use oxify_model::Workflow;

let server = WorkflowServer::new();
server.register_workflow(my_workflow).await;

// Server can now be used via MCP protocol
let tools = server.list_tools().await?;

Implementations

impl WorkflowServer

pub fn new() -> Self

Create a new workflow server with default configuration

pub fn with_config(config: WorkflowServerConfig) -> Self

Create a new workflow server with custom configuration

pub fn with_executor(self, executor: WorkflowExecutor) -> Self

Set the workflow executor function

The executor is called when a workflow tool is invoked. It receives the workflow definition and input variables.

pub async fn register_workflow(&self, workflow: Workflow) -> Result<String>

Register a workflow as an MCP tool

pub async fn register_workflow_with_schema( &self, workflow: Workflow, input_schema: Value, description: Option<String>, ) -> Result<String>

Register a workflow with custom schema

pub async fn unregister_workflow(&self, tool_name: &str) -> Result<()>

Unregister a workflow

pub async fn list_registered_tools(&self) -> Vec<String>

Get list of registered tool names

pub async fn get_workflow(&self, tool_name: &str) -> Option<Workflow>

Get workflow by tool name

Trait Implementations

impl Default for WorkflowServer

fn default() -> Self

Returns the “default value” for a type.

impl McpServer for WorkflowServer

fn call_tool<'life0, 'life1, 'async_trait>( &'life0 self, name: &'life1 str, arguments: Value, ) -> Pin<Box<dyn Future<Output = Result<Value>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Call a tool provided by this server

fn list_tools<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<Value>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

List all tools provided by this server