Struct GeyserGrpcClient 

pub struct GeyserGrpcClient<F> {
    pub health: HealthClient<InterceptedService<Channel, F>>,
    pub geyser: GeyserClient<InterceptedService<Channel, F>>,
}

Fields

health: HealthClient<InterceptedService<Channel, F>>

geyser: GeyserClient<InterceptedService<Channel, F>>

Implementations

impl GeyserGrpcClient<()>

pub fn build_from_shared( endpoint: impl Into<Bytes>, ) -> GeyserGrpcBuilderResult<GeyserGrpcBuilder>

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

impl<F: Interceptor> GeyserGrpcClient<F>

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

pub async fn health_check( &mut self, ) -> GeyserGrpcClientResult<HealthCheckResponse>

pub async fn health_watch( &mut self, ) -> GeyserGrpcClientResult<impl Stream<Item = Result<HealthCheckResponse, Status>>>

pub async fn subscribe( &mut self, ) -> GeyserGrpcClientResult<(impl Sink<SubscribeRequest, Error = SendError>, impl Stream<Item = Result<SubscribeUpdate, Status>>)>

pub async fn subscribe_with_request( &mut self, request: Option<SubscribeRequest>, ) -> GeyserGrpcClientResult<(impl Sink<SubscribeRequest, Error = SendError>, impl Stream<Item = Result<SubscribeUpdate, Status>>)>

pub async fn subscribe_once( &mut self, request: SubscribeRequest, ) -> GeyserGrpcClientResult<impl Stream<Item = Result<SubscribeUpdate, Status>>>

pub async fn subscribe_preprocessed( &mut self, ) -> GeyserGrpcClientResult<(impl Sink<SubscribePreprocessedRequest, Error = SendError>, impl Stream<Item = Result<SubscribePreprocessedUpdate, Status>>)>

pub async fn subscribe_preprocessed_with_request( &mut self, request: Option<SubscribePreprocessedRequest>, ) -> GeyserGrpcClientResult<(impl Sink<SubscribePreprocessedRequest, Error = SendError>, impl Stream<Item = Result<SubscribePreprocessedUpdate, Status>>)>

pub async fn subscribe_preprocessed_once( &mut self, request: SubscribePreprocessedRequest, ) -> GeyserGrpcClientResult<impl Stream<Item = Result<SubscribePreprocessedUpdate, Status>>>

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

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

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

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

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

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

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