use cached::proc_macro::io_cached;
use cached::RedisCache;
use once_cell::sync::Lazy;
use std::io;
use std::io::Write;
use std::time::Duration;
use thiserror::Error;
#[derive(Error, Debug, PartialEq, Clone)]
enum ExampleError {
#[error("error with redis cache `{0}`")]
RedisError(String),
}
#[io_cached(
redis = true,
time = 30,
cache_prefix_block = r##"{ "cache-redis-example-1" }"##,
map_error = r##"|e| ExampleError::RedisError(format!("{:?}", e))"##
)]
fn cached_sleep_secs(secs: u64) -> Result<(), ExampleError> {
std::thread::sleep(Duration::from_secs(secs));
Ok(())
}
#[io_cached(
redis = true,
time = 30,
map_error = r##"|e| ExampleError::RedisError(format!("{:?}", e))"##
)]
fn cached_sleep_secs_example_2(secs: u64) -> Result<(), ExampleError> {
std::thread::sleep(Duration::from_secs(secs));
Ok(())
}
struct Config {
conn_str: String,
}
impl Config {
fn load() -> Self {
Self {
conn_str: std::env::var("CACHED_REDIS_CONNECTION_STRING").unwrap(),
}
}
}
static CONFIG: Lazy<Config> = Lazy::new(Config::load);
#[io_cached(
map_error = r##"|e| ExampleError::RedisError(format!("{:?}", e))"##,
ty = "cached::RedisCache<u64, String>",
create = r##" {
RedisCache::new("cache_redis_example_cached_sleep_secs_config", 1)
.set_refresh(true)
.set_connection_string(&CONFIG.conn_str)
.build()
.expect("error building example redis cache")
} "##
)]
fn cached_sleep_secs_config(secs: u64) -> Result<String, ExampleError> {
std::thread::sleep(Duration::from_secs(secs));
Ok(secs.to_string())
}
#[tokio::main]
async fn main() {
print!("1. first sync call with a 2 seconds sleep...");
io::stdout().flush().unwrap();
cached_sleep_secs(2).unwrap();
println!("done");
print!("second sync call with a 2 seconds sleep (it should be fast)...");
io::stdout().flush().unwrap();
cached_sleep_secs(2).unwrap();
println!("done");
use cached::IOCached;
CACHED_SLEEP_SECS.cache_remove(&2).unwrap();
print!("third sync call with a 2 seconds sleep (slow, after cache-remove)...");
io::stdout().flush().unwrap();
cached_sleep_secs(2).unwrap();
println!("done");
print!("2. first sync call with a 2 seconds sleep...");
io::stdout().flush().unwrap();
cached_sleep_secs_example_2(2).unwrap();
println!("done");
print!("second sync call with a 2 seconds sleep (it should be fast)...");
io::stdout().flush().unwrap();
cached_sleep_secs_example_2(2).unwrap();
println!("done");
cached_sleep_secs_config_prime_cache(2).unwrap();
print!("3. first primed async call with a 2 seconds sleep (should be fast)...");
io::stdout().flush().unwrap();
cached_sleep_secs_config(2).unwrap();
println!("done");
print!("second async call with a 2 seconds sleep (it should be fast)...");
io::stdout().flush().unwrap();
cached_sleep_secs_config(2).unwrap();
println!("done");
}