Struct SwarmExecutor 

pub struct SwarmExecutor { /* private fields */ }

The swarm executor runs subtasks in parallel

Implementations

impl SwarmExecutor

pub fn new(config: SwarmConfig) -> Self

Create a new executor

pub fn with_event_tx(self, tx: Sender<SwarmEvent>) -> Self

Set an event channel for real-time TUI updates

pub fn with_coordinator_agent(self, agent: Arc<Mutex<Agent>>) -> Self

Set a coordinator agent for swarm-level coordination

pub fn coordinator_agent(&self) -> Option<&Arc<Mutex<Agent>>>

Get the coordinator agent if set

pub async fn execute( &self, task: &str, strategy: DecompositionStrategy, ) -> Result<SwarmResult>

Execute a task using the swarm

pub async fn execute_single(&self, task: &str) -> Result<SwarmResult>

Execute a single task without decomposition (for simple cases)