Skip to main content

somatize_worker/
lib.rs

1//! Remote worker for distributed pipeline execution.
2//!
3//! Receives execution plans from a coordinator, runs them locally,
4//! and reports results. Each worker manages isolated Python environments
5//! ([`EnvManager`]) and communicates via WebSocket ([`protocol`]).
6
7pub mod coordinator;
8pub mod coordinator_server;
9pub mod detect;
10pub mod env_manager;
11pub mod protocol;
12pub mod server;
13pub mod worker;
14
15pub use coordinator::{WorkerRegistry, WorkerStatus};
16pub use coordinator_server::{coordinator_router, serve_coordinator};
17pub use detect::ResourceLimits;
18pub use env_manager::EnvManager;
19pub use protocol::*;
20pub use server::{
21    serve_worker, serve_worker_authenticated, worker_router, worker_router_authenticated,
22};
23pub use worker::Worker;