Skip to content

Commit

Permalink
fix(reload): move imports
Browse files Browse the repository at this point in the history
  • Loading branch information
KH-Moogsoft committed Jul 18, 2023
1 parent 4381796 commit 163c820
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions src/topology/controller.rs
Original file line number Diff line number Diff line change
@@ -1,10 +1,8 @@
use std::sync::Arc;

use crate::internal_events::ApiStarted;
#[cfg(feature = "enterprise")]
use futures_util::future::BoxFuture;
use futures_util::FutureExt as _;
use tokio::runtime::Handle;

use tokio::sync::{Mutex, MutexGuard};

Expand All @@ -18,7 +16,6 @@ use crate::internal_events::{
VectorConfigLoadError, VectorRecoveryError, VectorReloadError, VectorReloaded,
};

use crate::topology::ReloadOutcome::FatalError;
use crate::{config, topology::RunningTopology};

#[derive(Clone, Debug)]
Expand Down Expand Up @@ -106,8 +103,13 @@ impl TopologyController {
drop(server)
}
} else if self.api_server.is_none() {
use crate::internal_events::ApiStarted;
use crate::topology::ReloadOutcome::FatalError;
use std::sync::atomic::AtomicBool;
use tokio::runtime::Handle;

debug!("Starting api server.");

self.api_server = match api::Server::start(
self.topology.config(),
self.topology.watch(),
Expand Down

0 comments on commit 163c820

Please sign in to comment.