diff --git a/crates/orchestrator/src/network/node.rs b/crates/orchestrator/src/network/node.rs index 19acb8bf20f1baf2498871ec8133540c7f72b67c..bc3bee8b9509ed7c71a699dbd39e236ca091177b 100644 --- a/crates/orchestrator/src/network/node.rs +++ b/crates/orchestrator/src/network/node.rs @@ -174,6 +174,12 @@ impl NetworkNode { } } + /// Get the logs of the node + /// TODO: do we need the `since` param, maybe we could be handy later for loop filtering + pub async fn logs(&self) -> Result<String, anyhow::Error> { + Ok(self.inner.logs().await?) + } + async fn fetch_metrics(&self) -> Result<(), anyhow::Error> { let response = reqwest::get(&self.prometheus_uri).await?; let metrics = prom_metrics_parser::parse(&response.text().await?)?; diff --git a/crates/provider/src/kubernetes/node.rs b/crates/provider/src/kubernetes/node.rs index 8a158d83ef0fdca8a7b184674c9f715f494f5a05..4dcc16a1cea111392fed148f7e19efc59641768e 100644 --- a/crates/provider/src/kubernetes/node.rs +++ b/crates/provider/src/kubernetes/node.rs @@ -435,6 +435,7 @@ where PathBuf::from(file) } + // TODO: handle log rotation as we do in v1 async fn logs(&self) -> Result<String, ProviderError> { self.k8s_client .pod_logs(&self.namespace_name(), &self.name)