statiq 0.2.5

Zero-overhead, compile-time MSSQL service for Rust — stored procedures, async CRUD, connection pooling, static dispatch
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

pub mod noop;
pub mod redis;

use std::time::Duration;
use async_trait::async_trait;
use serde::{de::DeserializeOwned, Serialize};
use crate::error::SqlError;

pub use noop::NoCache;
pub use redis::RedisCache;

/// Strategy interface for caching — implemented by `RedisCache` and `NoCache`.
#[async_trait]
pub trait CacheLayer: Send + Sync + 'static {
    fn default_ttl(&self) -> Duration;
    fn count_ttl(&self) -> Duration;

    async fn get<T: DeserializeOwned + Send>(&self, key: &str) -> Result<Option<T>, SqlError>;
    async fn set<T: Serialize + Send + Sync>(&self, key: &str, value: &T, ttl: Duration) -> Result<(), SqlError>;

    async fn get_vec<T: DeserializeOwned + Send>(&self, key: &str) -> Result<Option<Vec<T>>, SqlError>;
    async fn set_vec<T: Serialize + Send + Sync>(&self, key: &str, values: &[T], ttl: Duration) -> Result<(), SqlError>;

    async fn get_scalar<T: DeserializeOwned + Send>(&self, key: &str) -> Result<Option<T>, SqlError>;
    async fn set_scalar<T: Serialize + Send + Sync>(&self, key: &str, value: T, ttl: Duration) -> Result<(), SqlError>;

    /// Delete a single entity entry (e.g. `GetById::42`).
    async fn invalidate_entry(&self, prefix: &str, id: &str) -> Result<(), SqlError>;

    /// Delete all keys under a table prefix (Count, GetAll, etc.).
    async fn invalidate_table(&self, prefix: &str) -> Result<(), SqlError>;
}