diff options
author | Florian Klink <flokli@flokli.de> | 2023-02-12T11·00+0100 |
---|---|---|
committer | flokli <flokli@flokli.de> | 2023-03-06T15·32+0000 |
commit | 119aa43171c2e2c654d513ea2f2ee740f962a398 (patch) | |
tree | 11afb3f3fb1c13898ac5943daee15728935032ca /tvix/store/src/chunkservice/mod.rs | |
parent | 3f27fe34843357e8782ae3357ab1f7ed272ccfca (diff) |
feat(tvix/store): add chunkservice r/5893
This adds the simpler ChunkService trait, and an implementation for it using sled, and one using a HashMap. Change-Id: Icb0fdc41b37b44e9e9e4f548d0f4acae1d83b71e Reviewed-on: https://cl.tvl.fyi/c/depot/+/8086 Reviewed-by: raitobezarius <tvl@lahfa.xyz> Tested-by: BuildkiteCI
Diffstat (limited to 'tvix/store/src/chunkservice/mod.rs')
-rw-r--r-- | tvix/store/src/chunkservice/mod.rs | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/tvix/store/src/chunkservice/mod.rs b/tvix/store/src/chunkservice/mod.rs new file mode 100644 index 000000000000..83c91fd96ea3 --- /dev/null +++ b/tvix/store/src/chunkservice/mod.rs @@ -0,0 +1,23 @@ +pub mod memory; +pub mod sled; + +use crate::Error; + +pub use self::memory::MemoryChunkService; +pub use self::sled::SledChunkService; + +/// The base trait all ChunkService services need to implement. +/// It allows checking for the existence, download and upload of chunks. +/// It's usually used after consulting a [crate::blobservice::BlobService] for +/// chunking information. +pub trait ChunkService { + /// check if the service has a chunk, given by its digest. + fn has(&self, digest: &[u8]) -> Result<bool, Error>; + + /// retrieve a chunk by its digest. Implementations MUST validate the digest + /// matches. + fn get(&self, digest: &[u8]) -> Result<Option<Vec<u8>>, Error>; + + /// insert a chunk. returns the digest of the chunk, or an error. + fn put(&self, data: Vec<u8>) -> Result<Vec<u8>, Error>; +} |