Struct GrpcClient 

pub struct GrpcClient<F> {
    pub geyser: GeyserClient<InterceptedService<Channel, F>>,
}

Fields

geyser: GeyserClient<InterceptedService<Channel, F>>

Implementations

impl GrpcClient<()>

pub fn build_from_shared( endpoint: impl Into<Bytes>, ) -> Result<GrpcClientBuilder, Error>

pub fn build_from_static(endpoint: &'static str) -> GrpcClientBuilder

impl<F: Interceptor> GrpcClient<F>

pub const fn new(geyser: GeyserClient<InterceptedService<Channel, F>>) -> Self

pub async fn subscribe_dragons_mouth( &mut self, ) -> Result<(impl Sink<SubscribeRequest, Error = SendError>, GrpcClientStream), Status>

pub async fn subscribe_dragons_mouth_once( &mut self, request: SubscribeRequest, ) -> Result<GrpcClientStream, Status>

pub async fn subscribe_accounts( &mut self, ) -> Result<(UnboundedSender<SubscribeAccountsRequest>, GrpcClientStream), Status>

pub async fn subscribe_richat( &mut self, request: GrpcSubscribeRequest, ) -> Result<GrpcClientStream, Status>

pub async fn subscribe_replay_info( &mut self, ) -> Result<SubscribeReplayInfoResponse, Status>

pub async fn ping(&mut self, count: i32) -> Result<PongResponse, Status>

pub async fn get_latest_blockhash( &mut self, commitment: Option<CommitmentLevel>, ) -> Result<GetLatestBlockhashResponse, Status>

pub async fn get_block_height( &mut self, commitment: Option<CommitmentLevel>, ) -> Result<GetBlockHeightResponse, Status>

pub async fn get_slot( &mut self, commitment: Option<CommitmentLevel>, ) -> Result<GetSlotResponse, Status>

pub async fn is_blockhash_valid( &mut self, blockhash: String, commitment: Option<CommitmentLevel>, ) -> Result<IsBlockhashValidResponse, Status>

pub async fn get_version(&mut self) -> Result<GetVersionResponse, Status>

Trait Implementations

impl<F: Debug> Debug for GrpcClient<F>

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

Formats the value using the given formatter.