SyncPulse provides a comprehensive API for orchestrating multi-agent workflows, managing agent coordination, and executing complex business processes.
- Orchestrator — Main orchestration engine for workflow execution
- Workflow — Workflow definition and execution manager
- Agent — Agent interface and coordination tools
- StateManager — Manages workflow and agent state
- WorkflowExecutor — Executes workflow steps sequentially or in parallel
registerSyncPulseTools()— Registers MCP tools for Claude integrationcreateWorkflow(definition)— Create a new workflow instanceexecuteWorkflow(workflow, context)— Execute a workflow with given context
WorkflowDefinition— Workflow structure and configurationWorkflowStep— Individual step in a workflowAgentState— Agent status and state informationExecutionContext— Context passed through workflow execution
- SyncPulseHub — Central hub for orchestration management
- OrchestrationEngine — Multi-agent orchestration engine
- PackageRegistry — Registry of available packages and skills
- DeploymentValidator — Validates deployment readiness
- UpdateChecker — Checks for package updates
initializeHub()— Initialize the SyncPulse hubgetOrchestratorStatus()— Get current orchestrator status
getTemplate(templateId)— Retrieve email template by IDrenderTemplate(template, variables)— Render template with variablesrenderSubject(template, variables)— Render email subjectgetWorkflowPattern(patternId)— Get predefined workflow patterncreateWorkflow(id, name, description, steps, options)— Create custom workflow
emailTemplates— All available email templatesworkflowPatterns— Common workflow patterns
import { Orchestrator } from '@h4shed/skill-syncpulse';
const orchestrator = new Orchestrator();
const workflow = {
name: 'simple-workflow',
steps: [
{ type: 'agent', agent: 'processor', action: 'process' },
{ type: 'email', template: 'task-completed' }
]
};
await orchestrator.executeWorkflow(workflow, { taskId: '123' });import { Agent } from '@h4shed/skill-syncpulse';
const agent = new Agent('task-processor');
agent.onMessage((message) => {
console.log(`Received: ${message.type}`);
});
await agent.send({ type: 'process', data: { /* ... */ } });import { getTemplate, renderTemplate } from '@h4shed/skill-syncpulse-workflows';
const template = getTemplate('agent-summary');
const rendered = renderTemplate(template, {
agentName: 'processor-1',
taskCount: '42',
successRate: '95'
});
console.log(rendered);import { getWorkflowPattern } from '@h4shed/skill-syncpulse-workflows';
// Get a predefined pattern
const pattern = getWorkflowPattern('parallel-analysis');
// Use it as base for custom workflow
const workflow = {
...pattern,
id: 'custom-analysis'
};SyncPulse automatically registers tools with the MCP ecosystem:
import { registerSyncPulseTools } from '@h4shed/skill-syncpulse';
// In your MCP server initialization:
registerSyncPulseTools();
// Tools now available to Claude:
// - syncpulse_create_workflow
// - syncpulse_execute_workflow
// - syncpulse_get_status
// - syncpulse_list_workflowsAll async operations throw errors that can be caught:
try {
await orchestrator.executeWorkflow(workflow, context);
} catch (error) {
console.error('Workflow failed:', error.message);
// Handle error based on workflow retry policy
}See packages/core/src/types.ts for complete type definitions.
For integration patterns, see INTEGRATION.md For architecture details, see ARCHITECTURE.md