Struct L2Cache 

pub struct L2Cache { /* private fields */ }

L2 Cache using Redis

Implementations

impl L2Cache

pub async fn new() -> Result<Self>

Create new L2 cache

pub async fn get(&self, key: &str) -> Option<Value>

Get value from L2 cache

pub async fn set_with_ttl( &self, key: &str, value: Value, ttl: Duration, ) -> Result<()>

Set value with custom TTL

pub async fn remove(&self, key: &str) -> Result<()>

Remove value from cache

pub async fn health_check(&self) -> bool

Health check

pub async fn stream_add( &self, stream_key: &str, fields: Vec<(String, String)>, maxlen: Option<usize>, ) -> Result<String>

Publish data to Redis Stream using XADD

Arguments

• stream_key - Name of the Redis Stream (e.g., “events_stream”)
• fields - Vec of field-value pairs to add to the stream
• maxlen - Optional maximum length for stream trimming (uses MAXLEN ~ for approximate trimming)

Returns

The stream entry ID generated by Redis (e.g., “1234567890123-0”)

pub async fn stream_read_latest( &self, stream_key: &str, count: usize, ) -> Result<Vec<(String, Vec<(String, String)>)>>

Read latest entries from Redis Stream using XREVRANGE

Arguments

• stream_key - Name of the Redis Stream
• count - Number of latest entries to retrieve

Returns

Vector of (entry_id, fields) tuples, ordered from newest to oldest

pub async fn stream_read( &self, stream_key: &str, last_id: &str, count: usize, block_ms: Option<usize>, ) -> Result<Vec<(String, Vec<(String, String)>)>>

Read entries from Redis Stream using XREAD (blocking or non-blocking)

Arguments

• stream_key - Name of the Redis Stream
• last_id - Last entry ID seen (use “0” to read from beginning, “$” for only new entries)
• count - Maximum number of entries to retrieve
• block_ms - Optional blocking timeout in milliseconds (None for non-blocking)

Returns

Vector of (entry_id, fields) tuples