Struct GrpcClient

pub struct GrpcClient {
    pub public_key: Option<Pubkey>,
    /* private fields */
}

Fields

public_key: Option<Pubkey>

Implementations

impl GrpcClient

pub async fn get_raydium_quotes( &mut self, request: &GetRaydiumQuotesRequest, ) -> Result<GetRaydiumQuotesResponse>

pub async fn get_raydium_cpmm_quotes( &mut self, request: &GetRaydiumCpmmQuotesRequest, ) -> Result<GetRaydiumCpmmQuotesResponse>

pub async fn get_raydium_clmm_quotes( &mut self, request: &GetRaydiumClmmQuotesRequest, ) -> Result<GetRaydiumClmmQuotesResponse>

pub async fn get_pump_fun_quotes( &mut self, request: &GetPumpFunQuotesRequest, ) -> Result<GetPumpFunQuotesResponse>

pub async fn get_jupiter_quotes( &mut self, request: &GetJupiterQuotesRequest, ) -> Result<GetJupiterQuotesResponse>

pub async fn get_quotes( &mut self, request: &GetQuotesRequest, ) -> Result<GetQuotesResponse>

pub async fn get_raydium_prices( &mut self, tokens: Vec<String>, ) -> Result<GetRaydiumPricesResponse>

pub async fn get_jupiter_prices( &mut self, tokens: Vec<String>, ) -> Result<GetJupiterPricesResponse>

impl GrpcClient

pub async fn get_prices_stream( &mut self, projects: Vec<Project>, tokens: Vec<String>, ) -> Result<Streaming<GetPricesStreamResponse>>

pub async fn get_block_stream( &mut self, ) -> Result<Streaming<GetBlockStreamResponse>>

pub async fn get_orderbook_stream( &mut self, markets: Vec<String>, limit: u32, project: Project, ) -> Result<Streaming<GetOrderbooksStreamResponse>>

pub async fn get_market_depths_stream( &mut self, markets: Vec<String>, limit: u32, project: Project, ) -> Result<Streaming<GetMarketDepthsStreamResponse>>

pub async fn get_ticker_stream( &mut self, markets: Vec<String>, project: Project, ) -> Result<Streaming<GetTickersStreamResponse>>

pub async fn get_trades_stream( &mut self, market: String, limit: u32, project: Project, ) -> Result<Streaming<GetTradesStreamResponse>>

pub async fn get_swaps_stream( &mut self, projects: Vec<Project>, pools: Vec<String>, include_failed: bool, ) -> Result<Streaming<GetSwapsStreamResponse>>

pub async fn get_new_raydium_pools_stream( &mut self, include_cpmm: bool, ) -> Result<Streaming<GetNewRaydiumPoolsResponse>>

pub async fn get_new_raydium_pools_by_transaction_stream( &mut self, ) -> Result<Streaming<GetNewRaydiumPoolsByTransactionResponse>>

pub async fn get_recent_block_hash_stream( &mut self, ) -> Result<Streaming<GetRecentBlockHashResponse>>

pub async fn get_pool_reserves_stream( &mut self, projects: Vec<Project>, pools: Vec<String>, ) -> Result<Streaming<GetPoolReservesStreamResponse>>

pub async fn get_priority_fee_stream( &mut self, project: Project, percentile: Option<f64>, ) -> Result<Streaming<GetPriorityFeeResponse>>

pub async fn get_bundle_tip_stream( &mut self, ) -> Result<Streaming<GetBundleTipResponse>>

pub async fn get_pump_fun_new_tokens_stream( &mut self, ) -> Result<Streaming<GetPumpFunNewTokensStreamResponse>>

pub async fn get_pump_fun_swaps_stream( &mut self, tokens: Vec<String>, ) -> Result<Streaming<GetPumpFunSwapsStreamResponse>>

pub async fn get_priority_fee_by_program_stream( &mut self, projects: Vec<String>, ) -> Result<Streaming<GetPriorityFeeByProgramResponse>>

impl GrpcClient

pub async fn post_raydium_swap( &mut self, request: &PostRaydiumSwapRequest, ) -> Result<PostRaydiumSwapResponse>

pub async fn post_raydium_route_swap( &mut self, request: &PostRaydiumRouteSwapRequest, ) -> Result<PostRaydiumRouteSwapResponse>

pub async fn post_raydium_swap_instructions( &mut self, request: &PostRaydiumSwapInstructionsRequest, ) -> Result<PostRaydiumSwapInstructionsResponse>

pub async fn submit_raydium_swap_instructions( &mut self, request: PostRaydiumSwapInstructionsRequest, submit_opts: SubmitParams, use_bundle: bool, ) -> Result<Vec<String>>

pub async fn post_raydium_cpmm_swap( &mut self, request: &PostRaydiumCpmmSwapRequest, ) -> Result<PostRaydiumCpmmSwapResponse>

pub async fn post_raydium_clmm_swap( &mut self, request: &PostRaydiumSwapRequest, ) -> Result<PostRaydiumSwapResponse>

pub async fn post_raydium_clmm_route_swap( &mut self, request: &PostRaydiumRouteSwapRequest, ) -> Result<PostRaydiumRouteSwapResponse>

pub async fn post_jupiter_swap( &mut self, request: &PostJupiterSwapRequest, ) -> Result<PostJupiterSwapResponse>

pub async fn post_jupiter_route_swap( &mut self, request: &PostJupiterRouteSwapRequest, ) -> Result<PostJupiterRouteSwapResponse>

pub async fn post_jupiter_swap_instructions( &mut self, request: &PostJupiterSwapInstructionsRequest, ) -> Result<PostJupiterSwapInstructionsResponse>

pub async fn submit_jupiter_swap_instructions( &mut self, request: PostJupiterSwapInstructionsRequest, submit_opts: SubmitParams, use_bundle: bool, ) -> Result<Vec<String>>

pub async fn post_pump_swap( &mut self, request: &PostPumpFunSwapRequest, ) -> Result<PostPumpFunSwapResponse>

pub async fn post_trade_swap( &mut self, request: &TradeSwapRequest, ) -> Result<TradeSwapResponse>

pub async fn post_route_trade_swap( &mut self, request: &RouteTradeSwapRequest, ) -> Result<TradeSwapResponse>

impl GrpcClient

pub fn get_keypair(&self) -> Result<&Keypair>

pub async fn new(endpoint: Option<String>) -> Result<Self>

pub async fn sign_and_submit<T: IntoTransactionMessage + Clone>( &mut self, txs: Vec<T>, submit_opts: SubmitParams, use_bundle: bool, ) -> Result<Vec<String>>

pub async fn sign_and_submit_snipe<T: IntoTransactionMessage + Clone>( &mut self, txs: Vec<T>, use_staked_rpcs: bool, ) -> Result<Vec<String>>

pub async fn sign_and_submit_paladin<T: IntoTransactionMessage + Clone>( &mut self, tx: T, ) -> Result<String>

pub async fn get_transaction( &mut self, request: &GetTransactionRequest, ) -> Result<GetTransactionResponse>

pub async fn get_recent_block_hash( &mut self, request: &GetRecentBlockHashRequest, ) -> Result<GetRecentBlockHashResponse>

pub async fn get_recent_block_hash_v2( &mut self, request: GetRecentBlockHashRequestV2, ) -> Result<GetRecentBlockHashResponseV2>

pub async fn get_rate_limit( &mut self, request: &GetRateLimitRequest, ) -> Result<GetRateLimitResponse>

pub async fn get_account_balance_v2( &mut self, request: &GetAccountBalanceRequest, ) -> Result<GetAccountBalanceResponse>

pub async fn get_priority_fee( &mut self, project: Project, percentile: Option<f64>, ) -> Result<GetPriorityFeeResponse>

pub async fn get_priority_fee_by_program( &mut self, programs: Vec<String>, ) -> Result<GetPriorityFeeByProgramResponse>

pub async fn get_token_accounts( &mut self, owner_address: String, ) -> Result<GetTokenAccountsResponse>

pub async fn get_account_balance( &mut self, owner_address: String, ) -> Result<GetAccountBalanceResponse>

pub async fn get_leader_schedule( &mut self, max_slots: u64, ) -> Result<GetLeaderScheduleResponse>

Trait Implementations

impl Debug for GrpcClient

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.