mocra-core 0.4.1

The mocra crawler framework runtime: errors, cache, utilities, domain models, downloader, data-plane queue, coordination, scheduler and engine.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

//! Adapts the multi-level [`CacheService`] into `mocra-dag`'s distributed KV / atomic
//! [`DagStore`] backend.
//!
//! This impl lives here (not in the host) because both `CacheService` (this crate) and
//! `DagStore` (mocra-dag) are now defined outside the host — the orphan rule requires the
//! impl to sit in the crate that owns one of them.

use std::time::Duration;

use async_trait::async_trait;
use mocra_dag::DagStore;

use super::CacheService;

#[async_trait]
impl DagStore for CacheService {
    async fn get(&self, key: &str) -> Result<Option<Vec<u8>>, String> {
        CacheService::get(self, key)
            .await
            .map_err(|e| e.to_string())
    }
    async fn set(&self, key: &str, value: &[u8], ttl: Option<Duration>) -> Result<(), String> {
        CacheService::set(self, key, value, ttl)
            .await
            .map_err(|e| e.to_string())
    }
    async fn del(&self, key: &str) -> Result<(), String> {
        CacheService::del(self, key)
            .await
            .map_err(|e| e.to_string())
    }
    async fn incr(&self, key: &str, delta: i64) -> Result<i64, String> {
        CacheService::incr(self, key, delta)
            .await
            .map_err(|e| e.to_string())
    }
}