Struct ServiceConfigCache 

pub struct ServiceConfigCache { /* private fields */ }

Thread-safe cache for service configurations

Caches aggregation configs, operator weights, and operator lists with TTL-based expiration.

Implementations

impl ServiceConfigCache

pub fn new(ttl: Duration) -> Self

Create a new cache with the specified TTL

pub fn with_default_ttl() -> Self

Create a new cache with default TTL (5 minutes)

pub fn ttl(&self) -> Duration

Get the current TTL

pub fn set_ttl(&mut self, ttl: Duration)

Set a new TTL (does not affect already cached entries)

pub async fn get_aggregation_config( &self, client: &TangleClient, service_id: u64, job_index: u8, ) -> Result<AggregationConfig, CacheError>

Get aggregation config, using cache if available and not expired

pub fn set_aggregation_config( &self, service_id: u64, job_index: u8, config: AggregationConfig, ) -> Result<(), CacheError>

Pre-populate aggregation config cache

pub async fn get_operator_weights( &self, client: &TangleClient, service_id: u64, ) -> Result<OperatorWeights, CacheError>

Get operator weights for a service, using cache if available

pub fn set_operator_weights( &self, service_id: u64, weights: OperatorWeights, ) -> Result<(), CacheError>

Pre-populate operator weights cache

pub async fn get_service_operators( &self, client: &TangleClient, service_id: u64, ) -> Result<ServiceOperators, CacheError>

Get service operators list, using cache if available

pub async fn get_operator_metadata( &self, client: &TangleClient, blueprint_id: u64, operator: Address, ) -> Result<OperatorMetadata, CacheError>

Get metadata for a specific operator (cached by blueprint + operator)

pub async fn get_service_operator_metadata( &self, client: &TangleClient, blueprint_id: u64, service_id: u64, ) -> Result<HashMap<Address, OperatorMetadata>, CacheError>

Get metadata for all operators in a service.

pub fn invalidate_service(&self, service_id: u64)

Invalidate all cached data for a specific service

pub fn invalidate_aggregation_config(&self, service_id: u64, job_index: u8)

Invalidate a specific aggregation config

pub fn clear(&self)

Clear all cached data

pub fn cleanup_expired(&self)

Remove expired entries from all caches

pub fn stats(&self) -> CacheStats

Get cache statistics

impl ServiceConfigCache

pub fn handle_event(&self, event: &CacheInvalidationEvent)

Handle a cache invalidation event

Call this when you receive relevant on-chain events to keep the cache in sync. Logs clearly when invalidation occurs.

Trait Implementations

impl Default for ServiceConfigCache

fn default() -> Self

Returns the “default value” for a type.