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