tracing and proxy configuration

Author: rescrv

rust/log-service/src/lib.rs

@@ -205,7 +205,6 @@ async fn get_log_from_handle<'a>(
             _phantom: std::marker::PhantomData,
         });
     }
-    tracing::info!("Opening log at {}", prefix);
     let opened = LogWriter::open(
         options.clone(),
         Arc::clone(storage),
@@ -667,6 +666,7 @@ impl LogServer {
         Ok(())
     }
 
+    #[tracing::instrument(skip(self, proxy))]
     async fn effectuate_log_transfer(
         &self,
         collection_id: CollectionUuid,
@@ -757,6 +757,7 @@ impl LogServer {
         })
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_push_logs(
         &self,
         collection_id: CollectionUuid,
@@ -781,6 +782,7 @@ impl LogServer {
         }
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_scout_logs(
         &self,
         request: Request<ScoutLogsRequest>,
@@ -792,6 +794,7 @@ impl LogServer {
         }
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_pull_logs(
         &self,
         request: Request<PullLogsRequest>,
@@ -803,6 +806,7 @@ impl LogServer {
         }
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_update_collection_log_offset(
         &self,
         request: Request<UpdateCollectionLogOffsetRequest>,
@@ -814,6 +818,7 @@ impl LogServer {
         }
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_fork_logs(
         &self,
         request: Request<ForkLogsRequest>,

rust/worker/tilt_config.yaml

@@ -191,3 +191,10 @@ log_service:
             batch_size_bytes: 8388608 # 8MiB
             throughput: 3300
             headroom: 200
+    proxy_to:
+        host: "logservice.chroma"
+        port: 50051
+        connect_timeout_ms: 5000
+        request_timeout_ms: 60000 # 1 minute
+        alt_host: "rust-log-service.chroma"
+        use_alt_host_for_everything: true