beam_worker/lib.rs
1mod adapter;
2mod adapters;
3mod backend;
4mod worker_runtime;
5
6use std::path::Path;
7
8use anyhow::Result;
9use beam_core::InitConfig;
10
11pub use worker_runtime::run;
12
13#[cfg(test)]
14#[path = "worker_runtime/tests.rs"]
15mod tests;
16
17pub async fn run_from_init_path(path: &Path) -> Result<()> {
18 let payload = tokio::fs::read_to_string(path).await?;
19 let init = serde_json::from_str::<InitConfig>(&payload)?;
20 run(init).await
21}