run -> start

Signed-off-by: Marc 'risson' Schmitt <marc.schmitt@risson.space>
This commit is contained in:
Marc 'risson' Schmitt
2026-04-16 13:40:07 +02:00
parent 8657d74dc9
commit 1fec16b8e0
4 changed files with 7 additions and 7 deletions
+2 -2
View File
@@ -263,7 +263,7 @@ async fn watch_config(arbiter: Arbiter) -> Result<()> {
/// Start the configuration watcher.
///
/// [`init`] must be called before this is used.
pub fn run(tasks: &mut Tasks) -> Result<()> {
pub fn start(tasks: &mut Tasks) -> Result<()> {
info!("starting config file watcher");
let arbiter = tasks.arbiter();
tasks
@@ -400,7 +400,7 @@ mod tests {
let arbiter = tasks.arbiter();
let mut events_rx = arbiter.events_subscribe();
super::run(&mut tasks).expect("failed to start watcher");
super::start(&mut tasks).expect("failed to start watcher");
assert_eq!(super::get().secret_key, "my_secret_key");
assert_eq!(super::get().postgresql.password, "my_postgres_pass");
+3 -3
View File
@@ -66,9 +66,9 @@ fn main() -> Result<()> {
.block_on(async {
let mut tasks = Tasks::new()?;
config::run(&mut tasks)?;
config::start(&mut tasks)?;
let metrics = metrics::run(&mut tasks)?;
let metrics = metrics::start(&mut tasks)?;
#[cfg(feature = "core")]
if Mode::get() == Mode::AllInOne || Mode::get() == Mode::Worker {
@@ -78,7 +78,7 @@ fn main() -> Result<()> {
match cli.command {
#[cfg(feature = "core")]
Command::Worker(args) => {
let workers = worker::run(args, &mut tasks)?;
let workers = worker::start(args, &mut tasks)?;
metrics.workers.store(Some(workers));
}
}
+1 -1
View File
@@ -67,7 +67,7 @@ fn build_router(state: Arc<Metrics>) -> Router {
)
}
pub(crate) fn run(tasks: &mut Tasks) -> Result<Arc<Metrics>> {
pub(crate) fn start(tasks: &mut Tasks) -> Result<Arc<Metrics>> {
let arbiter = tasks.arbiter();
let metrics = Arc::new(Metrics::new()?);
let router = build_router(Arc::clone(&metrics));
+1 -1
View File
@@ -295,7 +295,7 @@ async fn watch_workers(arbiter: Arbiter, workers: Arc<Workers>) -> Result<()> {
}
}
pub(crate) fn run(_cli: Cli, tasks: &mut Tasks) -> Result<Arc<Workers>> {
pub(crate) fn start(_cli: Cli, tasks: &mut Tasks) -> Result<Arc<Workers>> {
let arbiter = tasks.arbiter();
let workers = Arc::new(Workers::new()?);