Add CLI execution profiling

Author: troyjr4103

Cargo.lock

@@ -33,6 +33,11 @@ fn is_transient_lock_error(message: &str) -> bool {
 pub fn open_kindb_snapshot(
     layout: &kin_core::KinLayout,
 ) -> std::result::Result<kin_db::SnapshotManager, kin_db::KinDbError> {
+    let _span = tracing::info_span!(
+        "kindb.open_snapshot",
+        path = %kindb_snapshot_path(layout).display()
+    )
+    .entered();
     let path = kindb_snapshot_path(layout);
     let mut attempts = 0usize;
     let mut delay = Duration::from_millis(SNAPSHOT_OPEN_INITIAL_DELAY_MS);
@@ -72,6 +77,11 @@ pub fn vector_index_path(layout: &kin_core::KinLayout) -> PathBuf {
 pub async fn open_snapshot_daemon_first(
     layout: &kin_core::KinLayout,
 ) -> std::result::Result<kin_db::SnapshotManager, kin_db::KinDbError> {
+    let _span = tracing::info_span!(
+        "kin.backend.open_snapshot_daemon_first",
+        snapshot = %kindb_snapshot_path(layout).display()
+    )
+    .entered();
     // Respect explicit offline mode
     if std::env::var("KIN_OFFLINE").is_ok() {
         return open_kindb_snapshot(layout);
@@ -93,6 +103,11 @@ pub async fn open_snapshot_daemon_first(
 /// Non-fatal: if the file doesn't exist or fails to load, semantic search
 /// gracefully returns empty results.
 fn load_vector_index_if_exists(snap: &kin_db::SnapshotManager, layout: &kin_core::KinLayout) {
+    let _span = tracing::info_span!(
+        "kindb.load_vector_index_if_exists",
+        path = %vector_index_path(layout).display()
+    )
+    .entered();
     let path = vector_index_path(layout);
     if path.exists() {
         let graph = snap.graph();
@@ -112,6 +127,7 @@ fn load_vector_index_if_exists(snap: &kin_db::SnapshotManager, layout: &kin_core
 /// Fetch the graph from the daemon's `/graph/bootstrap` endpoint.
 /// Returns `None` if the daemon is unreachable or returns an error.
 async fn fetch_daemon_graph() -> Option<kin_db::InMemoryGraph> {
+    let _span = tracing::info_span!("kin.backend.fetch_daemon_graph").entered();
     let base_url =
         std::env::var("KIN_DAEMON_URL").unwrap_or_else(|_| "http://127.0.0.1:4219".to_string());
 

crates/kin-cli/src/backend.rs

@@ -17,6 +17,11 @@ pub(crate) fn drain_pending_embeddings(
     graph: &kin_db::InMemoryGraph,
     batch_size: usize,
 ) -> Result<usize> {
+    let _span = tracing::info_span!(
+        "kin.embed.drain_pending_embeddings",
+        batch_size = batch_size
+    )
+    .entered();
     Ok(graph.process_all_pending_embeddings(batch_size)?)
 }
 
@@ -36,6 +41,7 @@ fn should_queue_full_embedding_pass(status: &kin_db::engine::EmbeddingStatus) ->
 /// Opens the graph snapshot, queues all entities for embedding, processes
 /// the queue in batches, and persists the HNSW vector index to disk.
 pub async fn run(batch_size: usize, json: bool) -> Result<()> {
+    let _span = tracing::info_span!("kin.embed", batch_size = batch_size, json = json).entered();
     let layout = kin_core::KinLayout::discover(&std::env::current_dir()?)
         .ok_or_else(|| anyhow::anyhow!("not a Kin repository (no .kin/ found)"))?;
 

crates/kin-cli/src/commands/embed.rs

@@ -3,4 +3,5 @@
 
 pub mod backend;
 pub mod commands;
+pub mod profile;
 pub mod provenance;