selium-filesystem-store 1.0.0-alpha.6

Streaming compute fabric
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::sync::Arc;

use selium_kernel::drivers::module_store::{ModuleStoreError, ModuleStoreReadCapability};

use crate::FilesystemStore;

pub struct FilesystemStoreReadDriver {
    inner: FilesystemStore,
}

impl FilesystemStoreReadDriver {
    pub fn new(store: FilesystemStore) -> Arc<Self> {
        Arc::new(Self { inner: store })
    }
}

impl ModuleStoreReadCapability for FilesystemStoreReadDriver {
    fn read(&self, module_id: &str) -> Result<Vec<u8>, ModuleStoreError> {
        self.inner.fetch(module_id)
    }
}