filter_trait.rs

use async_trait::async_trait;

use redis_command_gen::CmdType;
use redis_proxy_common::ReqPkt;

use crate::session::Session;

#[allow(unused_variables)]
#[async_trait]
pub trait Filter {
    async fn on_request(&self, session: &mut Session, req_pkt: &ReqPkt) -> anyhow::Result<bool> {
        Ok(false)
    }

    async fn on_request_done(&self, session: &mut Session, cmd_type: CmdType, e: Option<&anyhow::Error>) {}
}