Skip to main content

Cache

Struct Cache 

Source
pub struct Cache;
Expand description

Cache facade - main entry point for cache operations

Provides static methods for accessing the cache. The cache store is automatically initialized when the server starts.

§Example

use ferro_rs::Cache;
use std::time::Duration;

// Store with TTL
Cache::put("key", &value, Some(Duration::from_secs(3600))).await?;

// Store forever (no expiration)
Cache::forever("key", &value).await?;

// Retrieve
let value: Option<MyType> = Cache::get("key").await?;

// Get or compute (remember pattern)
let value = Cache::remember("key", Some(Duration::from_secs(3600)), || async {
    expensive_computation().await
}).await?;

Implementations§

Source§

impl Cache

Source

pub fn store() -> Result<Arc<dyn CacheStore>, FrameworkError>

Get the underlying cache store

Source

pub fn is_initialized() -> bool

Check if the cache is initialized

Source

pub async fn get<T: DeserializeOwned>( key: &str, ) -> Result<Option<T>, FrameworkError>

Retrieve an item from the cache

Returns None if the key doesn’t exist or has expired.

§Example
let user: Option<User> = Cache::get("user:1").await?;
Source

pub async fn put<T: Serialize>( key: &str, value: &T, ttl: Option<Duration>, ) -> Result<(), FrameworkError>

Store an item in the cache

If ttl is None, uses the default TTL from config (or no expiration if 0).

§Example
Cache::put("user:1", &user, Some(Duration::from_secs(3600))).await?;
Source

pub async fn forever<T: Serialize>( key: &str, value: &T, ) -> Result<(), FrameworkError>

Store an item forever (no expiration)

§Example
Cache::forever("config:settings", &settings).await?;
Source

pub async fn has(key: &str) -> Result<bool, FrameworkError>

Check if a key exists in the cache

§Example
if Cache::has("user:1").await? {
    println!("User is cached");
}
Source

pub async fn forget(key: &str) -> Result<bool, FrameworkError>

Remove an item from the cache

Returns true if the item existed and was removed.

§Example
Cache::forget("user:1").await?;
Source

pub async fn flush() -> Result<(), FrameworkError>

Remove all items from the cache

§Example
Cache::flush().await?;
Source

pub async fn increment(key: &str, amount: i64) -> Result<i64, FrameworkError>

Increment a numeric value

If the key doesn’t exist, it’s initialized to 0 before incrementing. Returns the new value.

§Example
let count = Cache::increment("visits", 1).await?;
Source

pub async fn decrement(key: &str, amount: i64) -> Result<i64, FrameworkError>

Decrement a numeric value

If the key doesn’t exist, it’s initialized to 0 before decrementing. Returns the new value.

§Example
let remaining = Cache::decrement("quota", 1).await?;
Source

pub async fn expire(key: &str, ttl: Duration) -> Result<bool, FrameworkError>

Set a TTL on an existing key

Returns true if the key existed and TTL was set, false if key not found.

§Example
Cache::expire("counter", Duration::from_secs(60)).await?;
Source

pub async fn remember<T, F, Fut>( key: &str, ttl: Option<Duration>, default: F, ) -> Result<T, FrameworkError>
where T: Serialize + DeserializeOwned, F: FnOnce() -> Fut, Fut: Future<Output = Result<T, FrameworkError>>,

Get an item or store a default value if it doesn’t exist

If the key exists, returns the cached value. If not, calls the closure to compute the value, stores it, and returns it.

§Example
let user = Cache::remember("user:1", Some(Duration::from_secs(3600)), || async {
    User::find(1).await
}).await?;
Source

pub async fn remember_forever<T, F, Fut>( key: &str, default: F, ) -> Result<T, FrameworkError>
where T: Serialize + DeserializeOwned, F: FnOnce() -> Fut, Fut: Future<Output = Result<T, FrameworkError>>,

Get an item or store a default value forever

Same as remember but with no expiration.

Auto Trait Implementations§

§

impl Freeze for Cache

§

impl RefUnwindSafe for Cache

§

impl Send for Cache

§

impl Sync for Cache

§

impl Unpin for Cache

§

impl UnsafeUnpin for Cache

§

impl UnwindSafe for Cache

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> Chain<T> for T

Source§

fn len(&self) -> usize

The number of items that this chain link consists of.
Source§

fn append_to(self, v: &mut Vec<T>)

Append the elements in this link to the chain.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> PolicyExt for T
where T: ?Sized,

Source§

fn and<P, B, E>(self, other: P) -> And<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow only if self and other return Action::Follow. Read more
Source§

fn or<P, B, E>(self, other: P) -> Or<T, P>
where T: Policy<B, E>, P: Policy<B, E>,

Create a new Policy that returns Action::Follow if either self or other returns Action::Follow. Read more
Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more