mirror of
https://github.com/goauthentik/authentik.git
synced 2026-06-17 19:09:11 +03:00
run -> start
Signed-off-by: Marc 'risson' Schmitt <marc.schmitt@risson.space>
This commit is contained in:
@@ -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
@@ -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
@@ -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
@@ -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()?);
|
||||
|
||||
Reference in New Issue
Block a user