Struct svc_telemetry::cache::pool::RedisPool

pub struct RedisPool { /* private fields */ }

Represents a pool of connections to a Redis server.

The RedisPool struct provides a managed pool of connections to a Redis server. It allows clients to acquire and release connections from the pool and handles connection management, such as connection pooling and reusing connections.

Implementations

impl RedisPool

pub async fn new(config: Config, key_folder: &str) -> Result<Self, ()>

Create a new RedisPool The ‘key_folder’ argument is prepended to the key being stored. The complete key will take the format <folder>:<subset>:<subset>:<key>. This is used to differentiate keys inserted into Redis by different microservices. For example, an ADS-B key in svc-telemetry might be formatted telemetry:adsb:1234567890.

pub async fn increment(
    &mut self,
    key: &str,
    expiration_ms: u32
) -> Result<u32, CacheError>

If the key didn’t exist, inserts the key with an expiration time. If the key exists, increments the key and doesn’t extend the expiration time.

Returns the order in which this specific key was received (1 for first time).

pub async fn multiple_set(
    &mut self,
    keyvals: Vec<(String, String)>,
    expiration_ms: u32
) -> Result<(), CacheError>

Set the value of multiple keys

pub async fn multiple_get<T: FromStr>(
    &mut self,
    keys: Vec<String>
) -> Result<Vec<T>, CacheError>

Get the value of multiple keys

Trait Implementations

impl Clone for RedisPool

fn clone(&self) -> RedisPool

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RedisPool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.