1# Initialize swarm
 2npx agentic-flow hooks swarm-init --topology mesh --max-agents 5
 3
 4# Spawn agents
 5npx agentic-flow hooks agent-spawn --type coder
 6npx agentic-flow hooks agent-spawn --type tester
 7npx agentic-flow hooks agent-spawn --type reviewer
 8
 9# Orchestrate task
10npx agentic-flow hooks task-orchestrate \
11  --task "Build REST API with tests" \
12  --mode parallel

1// Equal peers, distributed decision-making
2await swarm.init({
3  topology: 'mesh',
4  agents: ['coder', 'tester', 'reviewer'],
5  communication: 'broadcast'
6});

1// Centralized coordination, specialized workers
2await swarm.init({
3  topology: 'hierarchical',
4  queen: 'architect',
5  workers: ['backend-dev', 'frontend-dev', 'db-designer']
6});

1// Automatically switches topology based on task
2await swarm.init({
3  topology: 'adaptive',
4  optimization: 'task-complexity'
5});

 1// Execute tasks concurrently
 2const results = await swarm.execute({
 3  tasks: [
 4    { agent: 'coder', task: 'Implement API endpoints' },
 5    { agent: 'frontend', task: 'Build UI components' },
 6    { agent: 'tester', task: 'Write test suite' }
 7  ],
 8  mode: 'parallel',
 9  timeout: 300000 // 5 minutes
10});

1// Sequential pipeline with dependencies
2await swarm.pipeline([
3  { stage: 'design', agent: 'architect' },
4  { stage: 'implement', agent: 'coder', after: 'design' },
5  { stage: 'test', agent: 'tester', after: 'implement' },
6  { stage: 'review', agent: 'reviewer', after: 'test' }
7]);

1// Let swarm decide execution strategy
2await swarm.autoOrchestrate({
3  goal: 'Build production-ready API',
4  constraints: {
5    maxTime: 3600,
6    maxAgents: 8,
7    quality: 'high'
8  }
9});

1// Share state across swarm
2await swarm.memory.store('api-schema', {
3  endpoints: [...],
4  models: [...]
5});
6
7// Agents read shared memory
8const schema = await swarm.memory.retrieve('api-schema');

1// Automatic work distribution
2await swarm.enableLoadBalancing({
3  strategy: 'dynamic',
4  metrics: ['cpu', 'memory', 'task-queue']
5});

1// Handle agent failures
2await swarm.setResiliency({
3  retry: { maxAttempts: 3, backoff: 'exponential' },
4  fallback: 'reassign-task'
5});

1// Track swarm metrics
2const metrics = await swarm.getMetrics();
3// { throughput, latency, success_rate, agent_utilization }

1# Pre-task coordination
2npx agentic-flow hooks pre-task --description "Build API"
3
4# Post-task synchronization
5npx agentic-flow hooks post-task --task-id "task-123"
6
7# Session restore
8npx agentic-flow hooks session-restore --session-id "swarm-001"