Struct RateLimiter 

pub struct RateLimiter { /* private fields */ }

Wraps rate limit database operations with a clean API.

Implementations

impl RateLimiter

pub fn new(pool: DbPool) -> Self

Create a new rate limiter backed by the given database pool.

pub async fn can_reply(&self) -> Result<bool, StorageError>

Check if a reply action is allowed under the current rate limit.

pub async fn can_tweet(&self) -> Result<bool, StorageError>

Check if a tweet action is allowed under the current rate limit.

pub async fn can_thread(&self) -> Result<bool, StorageError>

Check if a thread action is allowed under the current rate limit.

pub async fn can_search(&self) -> Result<bool, StorageError>

Check if a search action is allowed under the current rate limit.

pub async fn record_reply(&self) -> Result<(), StorageError>

Record a successful reply action (increments counter).

pub async fn record_tweet(&self) -> Result<(), StorageError>

Record a successful tweet action (increments counter).

pub async fn record_thread(&self) -> Result<(), StorageError>

Record a successful thread action (increments counter).

pub async fn record_search(&self) -> Result<(), StorageError>

Record a successful search action (increments counter).

pub async fn acquire_posting_permit( &self, action_type: &str, ) -> Result<bool, StorageError>

Atomically check and claim a rate limit slot.

Returns Ok(true) if permitted (counter incremented), Ok(false) if the rate limit is reached. Preferred over separate check + record for posting actions.