diff --git a/quickwit/quickwit-control-plane/src/control_plane.rs b/quickwit/quickwit-control-plane/src/control_plane.rs index fbbde457f1b..9b94137f356 100644 --- a/quickwit/quickwit-control-plane/src/control_plane.rs +++ b/quickwit/quickwit-control-plane/src/control_plane.rs @@ -513,6 +513,7 @@ impl Handler for ControlPlane { ctx: &ActorContext, ) -> Result { let index_uid: IndexUid = request.index_uid().clone(); + info!(index=%index_uid, "delete index"); if let Err(metastore_error) = self.metastore.delete_index(request).await { return convert_metastore_error(metastore_error); @@ -557,6 +558,8 @@ impl Handler for ControlPlane { return Ok(Err(ControlPlaneError::from(error))); } }; + info!(index=%index_uid, source_config=?source_config, "add source"); + if let Err(error) = self.metastore.add_source(request).await { return Ok(Err(ControlPlaneError::from(error))); }; @@ -589,6 +592,8 @@ impl Handler for ControlPlane { let source_id = request.source_id.clone(); let enable = request.enable; + info!(index=%index_uid, source_id=%source_id, enable=enable, "toggle source"); + if let Err(error) = self.metastore.toggle_source(request).await { return Ok(Err(ControlPlaneError::from(error))); };