Struct SwarmCoordinator 

pub struct SwarmCoordinator {
    pub engine: Arc<InferenceEngine>,
    pub scratch_dir: PathBuf,
    pub worker_model: Option<String>,
    pub gpu_state: Arc<GpuState>,
    pub professional: bool,
}

The Core parallel orchestrator locking background models to strict 12GB KV cache boundaries.

Fields

engine: Arc<InferenceEngine>

scratch_dir: PathBuf

worker_model: Option<String>

gpu_state: Arc<GpuState>

professional: bool

Implementations

impl SwarmCoordinator

pub fn new( engine: Arc<InferenceEngine>, gpu_state: Arc<GpuState>, worker_model: Option<String>, professional: bool, ) -> Self

pub async fn dispatch_swarm( &self, tasks: Vec<WorkerTask>, progression_tx: Sender<SwarmMessage>, max_workers: usize, ) -> Result<(), String>

Spawns parallel execution green-threads while respecting the hardware-aware limit.

pub async fn apply_patches_descending( &self, file_path: &Path, hunks: Vec<Hunk>, progression_tx: Sender<SwarmMessage>, ) -> Result<(), Box<dyn Error + Send + Sync>>

Evaluates compiled scratchpad chunks backwards utilizing Reverse sorting organically slicing VRAM limits natively!

Trait Implementations

impl Drop for SwarmCoordinator

fn drop(&mut self)

Executes the destructor for this type.