tracing and proxy configuration

Author: rescrv

rust/log-service/src/lib.rs

@@ -202,7 +202,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),
@@ -640,6 +639,7 @@ pub struct LogServer {
 }
 
 impl LogServer {
+    #[tracing::instrument(skip(self, proxy))]
     async fn effectuate_log_transfer(
         &self,
         collection_id: CollectionUuid,
@@ -730,6 +730,7 @@ impl LogServer {
         })
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_push_logs(
         &self,
         collection_id: CollectionUuid,
@@ -754,6 +755,7 @@ impl LogServer {
         }
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_scout_logs(
         &self,
         request: Request<ScoutLogsRequest>,
@@ -765,6 +767,7 @@ impl LogServer {
         }
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_pull_logs(
         &self,
         request: Request<PullLogsRequest>,
@@ -776,6 +779,7 @@ impl LogServer {
         }
     }
 
+    #[tracing::instrument(skip(self, request))]
     async fn forward_update_collection_log_offset(
         &self,
         request: Request<UpdateCollectionLogOffsetRequest>,
@@ -787,6 +791,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