Struct CachingMiddleware 

pub struct CachingMiddleware { /* private fields */ }

Caching middleware

Implementations

impl CachingMiddleware

pub fn new(config: CacheConfig) -> Self

Create new caching middleware

pub fn get(&mut self, key: &str) -> Option<Array2<Float>>

Get cached data

pub fn put(&mut self, key: String, data: Array2<Float>)

Put data in cache

Trait Implementations

impl PipelineMiddleware for CachingMiddleware

fn name(&self) -> &'static str

Middleware name

fn before_process( &self, context: &mut MiddlewareContext, input: &Array2<Float>, ) -> SklResult<()>

Execute before pipeline processing

fn after_process( &self, context: &mut MiddlewareContext, output: &Array2<Float>, ) -> SklResult<()>

Execute after pipeline processing

fn on_error( &self, _context: &mut MiddlewareContext, _error: &SklearsError, ) -> SklResult<ErrorAction>

Handle errors during pipeline execution

fn priority(&self) -> i32

Middleware priority (lower numbers execute first)

fn should_execute(&self, context: &MiddlewareContext) -> bool

Whether middleware should be executed