diff options
author | Matthias Beyer <mail@beyermatthias.de> | 2020-11-04 15:23:11 +0100 |
---|---|---|
committer | Matthias Beyer <mail@beyermatthias.de> | 2020-11-04 16:43:42 +0100 |
commit | d35bf6ec74adb7f3b3752a723b055a55df334738 (patch) | |
tree | 54c656cbcea78832953f2c6fb89ef8cbcd4902ae | |
parent | 0269a32d3aaf1128e8146d22b48bab24d78f87fb (diff) |
Let the Orchestrator have a file log sink factory (optionally)
Signed-off-by: Matthias Beyer <mail@beyermatthias.de>
-rw-r--r-- | src/orchestrator/orchestrator.rs | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/src/orchestrator/orchestrator.rs b/src/orchestrator/orchestrator.rs index 5cbca08..b1e5fa4 100644 --- a/src/orchestrator/orchestrator.rs +++ b/src/orchestrator/orchestrator.rs @@ -13,6 +13,8 @@ use crate::job::RunnableJob; use crate::log::LogItem; use crate::filestore::StagingStore; use crate::filestore::ReleaseStore; +use crate::log::FileLogSinkFactory; +use crate::log::LogSink; pub struct Orchestrator { scheduler: EndpointScheduler, @@ -20,6 +22,7 @@ pub struct Orchestrator { release_store: Arc<RwLock<ReleaseStore>>, jobsets: Vec<JobSet>, database: PgConnection, + file_log_sink_factory: Option<FileLogSinkFactory>, } #[derive(TypedBuilder)] @@ -29,6 +32,7 @@ pub struct OrchestratorSetup { release_store: Arc<RwLock<ReleaseStore>>, jobsets: Vec<JobSet>, database: PgConnection, + file_log_sink_factory: Option<FileLogSinkFactory>, } impl OrchestratorSetup { @@ -36,11 +40,12 @@ impl OrchestratorSetup { let scheduler = EndpointScheduler::setup(self.ep_cfg, self.staging_store.clone()).await?; Ok(Orchestrator { - scheduler: scheduler, - staging_store: self.staging_store, - release_store: self.release_store, - jobsets: self.jobsets, - database: self.database, + scheduler: scheduler, + staging_store: self.staging_store, + release_store: self.release_store, + jobsets: self.jobsets, + database: self.database, + file_log_sink_factory: self.file_log_sink_factory, }) } } |