Struct ParamManager 

pub struct ParamManager { /* private fields */ }

Manager for optimized parameters with caching and updates

Implementations

impl ParamManager

pub fn new(instance_id: impl Into<String>) -> Self

Create a new param manager

pub fn redis_key(&self, suffix: &str) -> String

Get the Redis key prefix

pub fn updates_channel(&self) -> String

Get the param updates channel name

pub fn params_hash_key(&self) -> String

Get the params hash key

pub fn subscribe(&self) -> Receiver<ParamNotification>

Subscribe to param update notifications

pub async fn get(&self, asset: &str) -> Option<OptimizedParams>

Get params for an asset (from cache)

pub async fn get_all(&self) -> HashMap<String, OptimizedParams>

Get all cached params

pub async fn update(&self, params: OptimizedParams)

Update params for an asset

pub async fn load_from_redis( &self, client: &Client, ) -> Result<usize, ParamError>

Load all params from Redis

pub async fn process_notification(&self, json: &str) -> Result<(), ParamError>

Process a notification from Redis pub/sub