about summary refs log tree commit diff
path: root/tvix/store/src/dummy_blob_service.rs
diff options
context:
space:
mode:
authorFlorian Klink <flokli@flokli.de>2023-02-13T17·58+0100
committerflokli <flokli@flokli.de>2023-03-10T10·58+0000
commit7fe7e03df32977da2bea7531a5142b24af971cf8 (patch)
treed722c164bce492ef6986d5f86d7ee790903438b1 /tvix/store/src/dummy_blob_service.rs
parent6b91efa5cf6d09e65dc06dfc56376b678eafa033 (diff)
chore(tvix/store): remove old implementations r/5923
These were implementing against the (more complicated) gRPC interface,
for which we now have a wrapper.

Change-Id: I0a8284493718ab99618a1d21a76df4d173edb899
Reviewed-on: https://cl.tvl.fyi/c/depot/+/8100
Reviewed-by: raitobezarius <tvl@lahfa.xyz>
Tested-by: BuildkiteCI
Diffstat (limited to 'tvix/store/src/dummy_blob_service.rs')
-rw-r--r--tvix/store/src/dummy_blob_service.rs43
1 files changed, 0 insertions, 43 deletions
diff --git a/tvix/store/src/dummy_blob_service.rs b/tvix/store/src/dummy_blob_service.rs
deleted file mode 100644
index 690f6bde3869..000000000000
--- a/tvix/store/src/dummy_blob_service.rs
+++ /dev/null
@@ -1,43 +0,0 @@
-use tokio_stream::wrappers::ReceiverStream;
-
-use crate::proto::blob_service_server::BlobService;
-use crate::proto::BlobChunk;
-use crate::proto::BlobMeta;
-use crate::proto::PutBlobResponse;
-use crate::proto::ReadBlobRequest;
-use crate::proto::StatBlobRequest;
-use tonic::{Request, Response, Result, Status, Streaming};
-use tracing::{instrument, warn};
-
-const NOT_IMPLEMENTED_MSG: &str = "not implemented";
-
-pub struct DummyBlobService {}
-
-#[tonic::async_trait]
-impl BlobService for DummyBlobService {
-    type ReadStream = ReceiverStream<Result<BlobChunk>>;
-
-    #[instrument(skip(self))]
-    async fn stat(&self, _request: Request<StatBlobRequest>) -> Result<Response<BlobMeta>> {
-        warn!(NOT_IMPLEMENTED_MSG);
-        Err(Status::unimplemented(NOT_IMPLEMENTED_MSG))
-    }
-
-    #[instrument(skip(self))]
-    async fn read(
-        &self,
-        _request: Request<ReadBlobRequest>,
-    ) -> Result<Response<Self::ReadStream>, Status> {
-        warn!(NOT_IMPLEMENTED_MSG);
-        Err(Status::unimplemented(NOT_IMPLEMENTED_MSG))
-    }
-
-    #[instrument(skip(self, _request))]
-    async fn put(
-        &self,
-        _request: Request<Streaming<BlobChunk>>,
-    ) -> Result<Response<PutBlobResponse>> {
-        warn!(NOT_IMPLEMENTED_MSG);
-        Err(Status::unimplemented(NOT_IMPLEMENTED_MSG))
-    }
-}