Struct benjamin_arbitrage_bot::rate_limiter::RateLimiter

pub struct RateLimiter {

    pub request_count: Arc<Mutex<u32>>,
    pub last_reset_time: Arc<Mutex<Instant>>,
    pub is_rate_limited: Arc<Mutex<bool>>,
    pub current_delay: Arc<Mutex<u64>>,
    pub max_requests_per_minute: u32,
    pub min_interval_ms: u64,
    pub thread_call_counts: Arc<Mutex<HashMap<usize, u32>>>,
    pub last_log_time: Arc<Mutex<Instant>>,
    pub endpoint_counts: Arc<Mutex<HashMap<String, u32>>>,
    pub thread_rate_limited: Arc<Mutex<HashSet<usize>>>,
    pub backoff_threads: Arc<Mutex<HashMap<usize, Instant>>>,
    pub backoff_duration: Arc<Mutex<u64>>,
    pub api_level: Arc<Mutex<u64>>,
}

Fields

request_count: Arc<Mutex<u32>>

last_reset_time: Arc<Mutex<Instant>>

is_rate_limited: Arc<Mutex<bool>>

current_delay: Arc<Mutex<u64>>

max_requests_per_minute: u32

min_interval_ms: u64

thread_call_counts: Arc<Mutex<HashMap<usize, u32>>>

last_log_time: Arc<Mutex<Instant>>

endpoint_counts: Arc<Mutex<HashMap<String, u32>>>

thread_rate_limited: Arc<Mutex<HashSet<usize>>>

backoff_threads: Arc<Mutex<HashMap<usize, Instant>>>

backoff_duration: Arc<Mutex<u64>>

api_level: Arc<Mutex<u64>>

Implementations

impl RateLimiter

pub fn new(min_interval_ms: u64, max_requests_per_minute: u32) -> Self

pub fn is_in_backoff(&self, thread_id: usize) -> bool

pub fn get_backoff_delay(&self) -> u64

pub fn handle_rate_limit_error(&self, thread_id: usize)

pub fn set_api_level(&self, level: u64)

pub fn increment_request_count_for_thread( &self, thread_id: usize, endpoint: Option<&str>, ) -> bool

pub fn get_current_delay_for_main_loop(&self) -> u64

pub fn get_current_delay(&self) -> u64

pub fn is_limited(&self) -> bool

pub fn reset(&self)

pub fn get_thread_stats(&self) -> Vec<(usize, u32)>

Trait Implementations

impl Clone for RateLimiter

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.