From 9de1ebf23ef6b34263c5ed9704c8ee173d9d875c Mon Sep 17 00:00:00 2001 From: Florian Klink Date: Tue, 9 Jan 2024 14:59:26 +0200 Subject: feat(tvix/castore/grpc): instrument some more functions Change-Id: Icedb148c88c5f4a3b2242ed12df1dd8692af94fd Reviewed-on: https://cl.tvl.fyi/c/depot/+/10584 Autosubmit: flokli Tested-by: BuildkiteCI Reviewed-by: raitobezarius --- tvix/castore/src/blobservice/grpc.rs | 2 ++ 1 file changed, 2 insertions(+) (limited to 'tvix/castore/src/blobservice') diff --git a/tvix/castore/src/blobservice/grpc.rs b/tvix/castore/src/blobservice/grpc.rs index 691cf8529d34..183ebb76e10c 100644 --- a/tvix/castore/src/blobservice/grpc.rs +++ b/tvix/castore/src/blobservice/grpc.rs @@ -49,6 +49,7 @@ impl BlobService for GRPCBlobService { } } + #[instrument(skip(self, digest), fields(blob.digest=%digest), err)] async fn open_read(&self, digest: &B3Digest) -> io::Result>> { // Get a stream of [proto::BlobChunk], or return an error if the blob // doesn't exist. @@ -80,6 +81,7 @@ impl BlobService for GRPCBlobService { /// Returns a BlobWriter, that'll internally wrap each write in a /// [proto::BlobChunk], which is send to the gRPC server. + #[instrument(skip_all)] async fn open_write(&self) -> Box { // set up an mpsc channel passing around Bytes. let (tx, rx) = tokio::sync::mpsc::channel::(10); -- cgit 1.4.1