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;
12#[cfg(feature = "embedded-python")]
13pub mod py_filter;
14pub mod remote_executor;
15pub mod server;
16pub mod worker;
17
18pub use coordinator::{WorkerRegistry, WorkerStatus};
19pub use coordinator_server::{coordinator_router, serve_coordinator};
20pub use detect::ResourceLimits;
21pub use env_manager::EnvManager;
22pub use protocol::*;
23#[cfg(feature = "embedded-python")]
24pub use py_filter::EmbeddedPyFilter;
25pub use remote_executor::WsRemoteExecutor;
26pub use server::{
27    serve_worker, serve_worker_authenticated, worker_router, worker_router_authenticated,
28};
29pub use worker::Worker;