Struct benjamin_arbitrage_bot::token_rotation::TokenRotator

pub struct TokenRotator {
    pub jupiter_client: Arc<JupiterClient>,
    pub token_list: Arc<Mutex<Vec<Token>>>,
    pub last_rotation: Arc<Mutex<Instant>>,
    pub rotation_interval: Duration,
    pub thread_token_indices: Arc<Mutex<Vec<usize>>>,
    pub machine_index: u64,
    pub machine_count: u64,
}

Fields

jupiter_client: Arc<JupiterClient>

token_list: Arc<Mutex<Vec<Token>>>

last_rotation: Arc<Mutex<Instant>>

rotation_interval: Duration

thread_token_indices: Arc<Mutex<Vec<usize>>>

machine_index: u64

machine_count: u64

Implementations

impl TokenRotator

pub fn new( jupiter_client: Arc<JupiterClient>, rotation_interval_minutes: u64, machine_index: u64, machine_count: u64, ) -> Self

pub async fn initialize(&self) -> Result<()>

pub fn initialize_thread_tokens(&self, thread_count: usize) -> Result<()>

pub fn get_token_for_thread(&self, thread_id: usize) -> Result<Token>

pub fn rotate_token_for_thread(&self, thread_id: usize) -> Result<Token>