Struct benjamin_arbitrage_bot::jupiter_api::JupiterClient

pub struct JupiterClient {
    client: Client,
    max_retries: u32,
    rate_limiter: Option<Arc<RateLimiter>>,
    solana_client: Option<Arc<SolanaClient>>,
    rate_limits: Arc<Mutex<HashMap<String, (Instant, u32)>>>,
    current_thread_id: Arc<Mutex<usize>>,
    api_key: Option<String>,
}

Fields

client: Client

max_retries: u32

rate_limiter: Option<Arc<RateLimiter>>

solana_client: Option<Arc<SolanaClient>>

rate_limits: Arc<Mutex<HashMap<String, (Instant, u32)>>>

current_thread_id: Arc<Mutex<usize>>

api_key: Option<String>

Implementations

impl JupiterClient

pub fn new(max_retries: u32) -> Self

pub fn with_solana_client(self, solana_client: Arc<SolanaClient>) -> Self

pub fn with_rate_limiter(self, rate_limiter: Arc<RateLimiter>) -> Self

pub fn with_api_key(self, api_key: String) -> Self

pub fn set_rate_limit(&self, api_level: u64)

pub fn set_thread_id(&self, thread_id: usize)

fn check_rate_limit(&self, endpoint: &str) -> Result<()>

async fn make_request<T: for<'de> Deserialize<'de>>( &self, url: &str, endpoint_name: &str, ) -> Result<T>

pub async fn get_quote( &self, input_mint: &str, output_mint: &str, amount: u64, slippage_bps: u64, ) -> Result<Quote>

pub async fn get_swap_transaction( &self, quote: &Quote, ) -> Result<SwapTransaction>

pub async fn fetch_trending_tokens(&self) -> Result<Vec<Token>>

pub fn get_usdc_token() -> Token

pub fn get_wsol_token() -> Token